@@ -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()),`