drop table fk check enable

commit_hash:dc75315c19af88432f6f97b8b4eaf7fb28b53731
doublecloud · Nov 28, 2024 · 1ae7ed6 · 1ae7ed6
1 parent 30f7a68
commit 1ae7ed6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/providers/mysql/sink.go b/pkg/providers/mysql/sink.go
@@ -201,7 +201,7 @@ func (s *sinker) prepareInputPerTables(input []abstract.ChangeItem) (map[abstrac
 				s.logger.Infof("Skipped dropping table '%v.%v' due cleanup policy", db, row.Table)
 				continue
 			}
-			ddlQ := DisableFKQuery
+			ddlQ := EnableFKQuery
 			ddlQ += fmt.Sprintf("DROP TABLE IF EXISTS `%v`.`%v`", db, row.Table)
 			if _, err := s.db.Exec(ddlQ); err != nil {
 				s.logger.Warn("Unable to exec DDL:\n"+util.Sample(ddlQ, maxSampleLen), log.Error(err))