Merge pull request #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"})
 		})
 }