escape table name in ReadLastCheckpoint (#1610)

meiji163 · web-flow · commit 215dee4e52d5 · 2025-11-24T07:04:01.000-08:00
diff --git a/go/logic/applier.go b/go/logic/applier.go
@@ -637,7 +637,7 @@ func (this *Applier) WriteCheckpoint(chk *Checkpoint) (int64, error) {
 }
 
 func (this *Applier) ReadLastCheckpoint() (*Checkpoint, error) {
-	row := this.db.QueryRow(fmt.Sprintf(`select /* gh-ost */ * from %s.%s order by gh_ost_chk_id desc limit 1`, this.migrationContext.DatabaseName, this.migrationContext.GetCheckpointTableName()))
+	row := this.db.QueryRow(fmt.Sprintf(`select /* gh-ost */ * from %s.%s order by gh_ost_chk_id desc limit 1`, sql.EscapeName(this.migrationContext.DatabaseName), sql.EscapeName(this.migrationContext.GetCheckpointTableName())))
 	chk := &Checkpoint{
 		IterationRangeMin: sql.NewColumnValues(this.migrationContext.UniqueKey.Columns.Len()),
 		IterationRangeMax: sql.NewColumnValues(this.migrationContext.UniqueKey.Columns.Len()),

Original file line number	Diff line number	Diff line change
`@@ -637,7 +637,7 @@ func (this Applier) WriteCheckpoint(chk Checkpoint) (int64, error) {`
`637`	`637`	`}`
`638`	`638`
`639`	`639`	`func (this Applier) ReadLastCheckpoint() (Checkpoint, error) {`
`640`		- row := this.db.QueryRow(fmt.Sprintf(`select /* gh-ost / from %s.%s order by gh_ost_chk_id desc limit 1`, this.migrationContext.DatabaseName, this.migrationContext.GetCheckpointTableName()))
	`640`	+ row := this.db.QueryRow(fmt.Sprintf(`select /* gh-ost / from %s.%s order by gh_ost_chk_id desc limit 1`, sql.EscapeName(this.migrationContext.DatabaseName), sql.EscapeName(this.migrationContext.GetCheckpointTableName())))
`641`	`641`	`chk := &Checkpoint{`
`642`	`642`	`IterationRangeMin: sql.NewColumnValues(this.migrationContext.UniqueKey.Columns.Len()),`
`643`	`643`	`IterationRangeMax: sql.NewColumnValues(this.migrationContext.UniqueKey.Columns.Len()),`