Merge branch 'release-5.0' into release-5.0-cc8eadf2f70e

pingcap · Apr 16, 2021 · 36d4910 · 36d4910
2 parents 9b676b7 + 62bea27
commit 36d4910
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cdc/sink/simple_mysql_tester.go b/cdc/sink/simple_mysql_tester.go
@@ -131,10 +131,10 @@ func (s *simpleMySQLSink) executeRowChangedEvents(ctx context.Context, rows ...*
 						return errors.Trace(err)
 					}
 				}
-				sql, args = prepareUpdate(row.Table.QuoteString(), row.PreColumns, row.Columns, true)
+				sql, args = prepareReplace(row.Table.QuoteString(), row.Columns, true, false /* translateToInsert */)
 			} else if len(row.PreColumns) == 0 {
 				// insert
-				sql, args = prepareReplace(row.Table.QuoteString(), row.Columns, true, true)
+				sql, args = prepareReplace(row.Table.QuoteString(), row.Columns, true, false /* translateToInsert */)
 			} else if len(row.Columns) == 0 {
 				// delete
 				if s.enableCheckOldValue {