Add GTID-based replication to example program

Author: lance6716

cmd/go-mysqlbinlog/main.go

@@ -24,6 +24,7 @@ var flavor = flag.String("flavor", "mysql", "Flavor: mysql or mariadb")
 
 var file = flag.String("file", "", "Binlog filename")
 var pos = flag.Int("pos", 4, "Binlog position")
+var gtid = flag.String("gtid", "", "Binlog GTID set that this slave has executed")
 
 var semiSync = flag.Bool("semisync", false, "Support semi sync")
 var backupPath = flag.String("backup_path", "", "backup path to store binlog files")
@@ -57,10 +58,27 @@ func main() {
 			return
 		}
 	} else {
-		s, err := b.StartSync(pos)
-		if err != nil {
-			fmt.Printf("Start sync error: %v\n", errors.ErrorStack(err))
-			return
+		var (
+			s   *replication.BinlogStreamer
+			err error
+		)
+		if len(*gtid) > 0 {
+			gset, err := mysql.ParseGTIDSet(*flavor, *gtid)
+			if err != nil {
+				fmt.Printf("Failed to parse gtid %s with flavor %s, error: %v\n",
+					*gtid, *flavor, errors.ErrorStack(err))
+			}
+			s, err = b.StartSyncGTID(gset)
+			if err != nil {
+				fmt.Printf("Start sync by GTID error: %v\n", errors.ErrorStack(err))
+				return
+			}
+		} else {
+			s, err = b.StartSync(pos)
+			if err != nil {
+				fmt.Printf("Start sync error: %v\n", errors.ErrorStack(err))
+				return
+			}
 		}
 
 		for {