reduce the number of interactions between MySQL incremental synchronization and consul

LordofAvernus · ffffwh · commit df2cd65e22ae · 2022-04-18T14:10:27.000+08:00
diff --git a/drivers/mysql/mysql/applier.go b/drivers/mysql/mysql/applier.go
@@ -288,12 +288,13 @@ func (a *Applier) Run() {
 		return
 	}
 	a.ai.EntryExecutedHook = func(entry *common.BinlogEntry) {
-		err = a.storeManager.SaveOracleSCNPos(a.subject, entry.Coordinates.LogPos, entry.Coordinates.LastCommitted)
-		if err != nil {
-			a.onError(common.TaskStateDead, errors.Wrap(err, "SaveOracleSCNPos"))
-			return
+		if entry.Coordinates.SID == [16]byte{0} {
+			err = a.storeManager.SaveOracleSCNPos(a.subject, entry.Coordinates.LogPos, entry.Coordinates.LastCommitted)
+			if err != nil {
+				a.onError(common.TaskStateDead, errors.Wrap(err, "SaveOracleSCNPos"))
+				return
+			}
 		}
-
 		if entry.Final {
 			a.gtidCh <- &entry.Coordinates
 		}

Original file line number	Diff line number	Diff line change
`@@ -288,12 +288,13 @@ func (a *Applier) Run() {`
`288`	`288`	`return`
`289`	`289`	`}`
`290`	`290`	`a.ai.EntryExecutedHook = func(entry *common.BinlogEntry) {`
`291`		`- err = a.storeManager.SaveOracleSCNPos(a.subject, entry.Coordinates.LogPos, entry.Coordinates.LastCommitted)`
`292`		`- if err != nil {`
`293`		`- a.onError(common.TaskStateDead, errors.Wrap(err, "SaveOracleSCNPos"))`
`294`		`- return`
	`291`	`+ if entry.Coordinates.SID == [16]byte{0} {`
	`292`	`+ err = a.storeManager.SaveOracleSCNPos(a.subject, entry.Coordinates.LogPos, entry.Coordinates.LastCommitted)`
	`293`	`+ if err != nil {`
	`294`	`+ a.onError(common.TaskStateDead, errors.Wrap(err, "SaveOracleSCNPos"))`
	`295`	`+ return`
	`296`	`+ }`
`295`	`297`	`}`
`296`		`-`
`297`	`298`	`if entry.Final {`
`298`	`299`	`a.gtidCh <- &entry.Coordinates`
`299`	`300`	`}`