Skip to content

Commit ac6f966

Browse files
committed
Call ApplyIterationMoveTableCopyQueries in migrator
1 parent 927e8cb commit ac6f966

1 file changed

Lines changed: 6 additions & 1 deletion

File tree

go/logic/migrator.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1700,7 +1700,12 @@ func (mgtr *Migrator) iterateChunks() error {
17001700
// _ghost_ table, which no longer exists. So, bothering error messages and all, but no damage.
17011701
return nil
17021702
}
1703-
_, rowsAffected, _, err := mgtr.applier.ApplyIterationInsertQuery()
1703+
var rowsAffected int64
1704+
if mgtr.migrationContext.IsMoveTablesMode() {
1705+
_, rowsAffected, _, err = mgtr.applier.ApplyIterationMoveTableCopyQueries()
1706+
} else {
1707+
_, rowsAffected, _, err = mgtr.applier.ApplyIterationInsertQuery()
1708+
}
17041709
if err != nil {
17051710
return err // wrapping call will retry
17061711
}

0 commit comments

Comments
 (0)