Make MySQL SetVersion compatible with sql_safe_update

golang-migrate · Apr 10, 2024 · 869888f · 869888f
1 parent 87ba13c
commit 869888f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/database/mysql/mysql.go b/database/mysql/mysql.go
@@ -361,7 +361,7 @@ func (m *Mysql) SetVersion(version int, dirty bool) error {
 		return &database.Error{OrigErr: err, Err: "transaction start failed"}
 	}
 
-	query := "DELETE FROM `" + m.config.MigrationsTable + "`"
+	query := "DELETE FROM `" + m.config.MigrationsTable + "` LIMIT 1"
 	if _, err := tx.ExecContext(context.Background(), query); err != nil {
 		if errRollback := tx.Rollback(); errRollback != nil {
 			err = multierror.Append(err, errRollback)