replication: add uuid.

Author: FateTHarlaown

go.mod

@@ -1,5 +1,7 @@
 module github.com/siddontang/go-mysql
 
+go 1.14
+
 require (
 	github.com/BurntSushi/toml v0.3.1
 	github.com/go-sql-driver/mysql v1.4.1
@@ -15,3 +17,5 @@ require (
 	github.com/sirupsen/logrus v1.4.1 // indirect
 	golang.org/x/text v0.3.2 // indirect
 )
+
+replace github.com/coreos/bbolt => go.etcd.io/bbolt v1.3.4

replication/binlogsyncer.go

@@ -44,6 +44,9 @@ type BinlogSyncerConfig struct {
 	// Charset is for MySQL client character set
 	Charset string
 
+	// the uuid of slave
+	Uuid string
+
 	// SemiSyncEnabled enables semi-sync or not.
 	SemiSyncEnabled bool
 
@@ -271,6 +274,11 @@ func (b *BinlogSyncer) registerSlave() error {
 		}
 	}
 
+	slaveuuid := b.uuid()
+	if _, err := b.c.Execute(fmt.Sprintf("SET @slave_uuid='%s'", slaveuuid)); err != nil {
+		return errors.Errorf("failed to set SET @slave_uuid='%s': %v", slaveuuid, err)
+	}
+
 	if b.cfg.Flavor == MariaDBFlavor {
 		// Refer https://github.com/alibaba/canal/wiki/BinlogChange(MariaDB5&10)
 		// Tell the server that we understand GTIDs by setting our slave capability
@@ -501,6 +509,13 @@ func (b *BinlogSyncer) localHostname() string {
 	return b.cfg.Localhost
 }
 
+func (b *BinlogSyncer) uuid() string {
+	if len(b.cfg.Uuid) == 0 {
+		return uuid.NewV1().String()
+	}
+	return b.cfg.Uuid
+}
+
 func (b *BinlogSyncer) writeRegisterSlaveCommand() error {
 	b.c.ResetSequence()