diff --git a/pkg/sqlmodel/multirow.go b/pkg/sqlmodel/multirow.go index e2fa618eb26..5e6ca54da48 100644 --- a/pkg/sqlmodel/multirow.go +++ b/pkg/sqlmodel/multirow.go @@ -178,10 +178,11 @@ func GenUpdateSQL(changes ...*RowChange) (string, []any) { var skipColIdx []int for i, col := range first.sourceTableInfo.Columns { if _, ok := targetGeneratedColSet[col.Name.L]; ok { - // non cdc visible column's value won't be in `RowChange` - if model.IsColCDCVisible(col) { - skipColIdx = append(skipColIdx, i) - } + skipColIdx = append(skipColIdx, i) + //// non cdc visible column's value won't be in `RowChange` + //if model.IsColCDCVisible(col) { + // skipColIdx = append(skipColIdx, i) + //} continue } assignValueColumnCount++ @@ -254,10 +255,11 @@ func GenInsertSQL(tp DMLType, changes ...*RowChange) (string, []interface{}) { generatedColumns := generatedColumnsNameSet(first.targetTableInfo.Columns) for i, col := range first.sourceTableInfo.Columns { if _, ok := generatedColumns[col.Name.L]; ok { - // non cdc visible column's value won't be in `RowChange` - if model.IsColCDCVisible(col) { - skipColIdx = append(skipColIdx, i) - } + skipColIdx = append(skipColIdx, i) + //// non cdc visible column's value won't be in `RowChange` + //if model.IsColCDCVisible(col) { + // skipColIdx = append(skipColIdx, i) + //} continue }