Merge pull request go-mysql-org#788 from dveeden/default_connattrs

Set library specific connection attributes

Author: lance6716

client/conn.go

@@ -6,6 +6,7 @@ import (
 "crypto/tls"
 "fmt"
 "net"
+"runtime"
 "strings"
 "time"
 
@@ -78,6 +79,14 @@ type Dialer func(ctx context.Context, network, address string) (net.Conn, error)
 func ConnectWithDialer(ctx context.Context, network string, addr string, user string, password string, dbName string, dialer Dialer, options ...func(*Conn)) (*Conn, error) {
 c := new(Conn)
 
+c.attributes = map[string]string{
+"_client_name": "go-mysql",
+// "_client_version": "0.1",
+"_os": runtime.GOOS,
+"_platform": runtime.GOARCH,
+"_runtime_version": runtime.Version(),
+}
+
 if network == "" {
 network = getNetProto(addr)
 }
@@ -317,7 +326,9 @@ func (c *Conn) Rollback() error {
 }
 
 func (c *Conn) SetAttributes(attributes map[string]string) {
-c.attributes = attributes
+for k, v := range attributes {
+c.attributes[k] = v
+}
 }
 
 func (c *Conn) SetCharset(charset string) error {

replication/binlogsyncer.go

@@ -891,6 +891,7 @@ func (b *BinlogSyncer) newConnection(ctx context.Context) (*client.Conn, error)
 return client.ConnectWithDialer(timeoutCtx, "", addr, b.cfg.User, b.cfg.Password,
 "", b.cfg.Dialer, func(c *client.Conn) {
 c.SetTLSConfig(b.cfg.TLSConfig)
+c.SetAttributes(map[string]string{"_client_role": "binary_log_listener"})
 })
 }