修复获取重置最大最小位点问题

daiguadaidai · daiguadaidai · commit 517cbf7af722 · 2019-10-30T18:09:01.000+08:00
diff --git a/go.mod b/go.mod
@@ -9,6 +9,7 @@ require (
 	github.com/daiguadaidai/tidb v0.0.0-20190707132446-e5f2e4b8edc0
 	github.com/go-sql-driver/mysql v1.4.1
 	github.com/jinzhu/gorm v1.9.11
+	github.com/openzipkin/zipkin-go v0.1.6 // indirect
 	github.com/siddontang/go-mysql v0.0.0-20191019025932-fba9c9655f7c
 	github.com/spf13/cobra v0.0.5
 )
diff --git a/services/create/helper.go b/services/create/helper.go
@@ -375,6 +375,9 @@ func resetConfigStartPosInfo(cc *config.CreateConfig, mTable *visitor.MatchTable
 				cc.StartTime = mTable.StartRollBackTime
 			}
 		}
+	} else if mTable.HaveStartPosInfo() {
+		cc.StartLogFile = mTable.StartLogFile
+		cc.StartLogPos = mTable.StartLogPos
 	} else if mTable.HaveStartTime() {
 		cc.StartTime = mTable.StartRollBackTime
 	}
@@ -396,6 +399,9 @@ func resetConfigEndPosInfo(cc *config.CreateConfig, mTable *visitor.MatchTable)
 				cc.EndTime = mTable.EndRollBackTime
 			}
 		}
+	} else if mTable.HaveEndPosInfo() {
+		cc.EndLogFile = mTable.EndLogFile
+		cc.EndLogPos = mTable.EndLogPos
 	} else if mTable.HaveEndTime() {
 		cc.EndTime = mTable.EndRollBackTime
 	}

Original file line number	Diff line number	Diff line change
`@@ -9,6 +9,7 @@ require (`
`9`	`9`	`github.com/daiguadaidai/tidb v0.0.0-20190707132446-e5f2e4b8edc0`
`10`	`10`	`github.com/go-sql-driver/mysql v1.4.1`
`11`	`11`	`github.com/jinzhu/gorm v1.9.11`
	`12`	`+ github.com/openzipkin/zipkin-go v0.1.6 // indirect`
`12`	`13`	`github.com/siddontang/go-mysql v0.0.0-20191019025932-fba9c9655f7c`
`13`	`14`	`github.com/spf13/cobra v0.0.5`
`14`	`15`	`)`
Original file line number	Diff line number	Diff line change
`@@ -375,6 +375,9 @@ func resetConfigStartPosInfo(cc config.CreateConfig, mTable visitor.MatchTable`
`375`	`375`	`cc.StartTime = mTable.StartRollBackTime`
`376`	`376`	`}`
`377`	`377`	`}`
	`378`	`+ } else if mTable.HaveStartPosInfo() {`
	`379`	`+ cc.StartLogFile = mTable.StartLogFile`
	`380`	`+ cc.StartLogPos = mTable.StartLogPos`
`378`	`381`	`} else if mTable.HaveStartTime() {`
`379`	`382`	`cc.StartTime = mTable.StartRollBackTime`
`380`	`383`	`}`
`@@ -396,6 +399,9 @@ func resetConfigEndPosInfo(cc config.CreateConfig, mTable visitor.MatchTable)`
`396`	`399`	`cc.EndTime = mTable.EndRollBackTime`
`397`	`400`	`}`
`398`	`401`	`}`
	`402`	`+ } else if mTable.HaveEndPosInfo() {`
	`403`	`+ cc.EndLogFile = mTable.EndLogFile`
	`404`	`+ cc.EndLogPos = mTable.EndLogPos`
`399`	`405`	`} else if mTable.HaveEndTime() {`
`400`	`406`	`cc.EndTime = mTable.EndRollBackTime`
`401`	`407`	`}`