@@ -14,7 +14,7 @@ type DiffType string
14
14
15
15
const (
16
16
// ActionAdd is used for inserted rows and created objects
17
- ActionAdd DiffType = "add"
17
+ ActionAdd DiffType = "add"
18
18
19
19
// ActionDelete is used for deleted rows and dropped objects
20
20
ActionDelete DiffType = "delete"
@@ -406,7 +406,7 @@ func dataDiffForModifiedTableRows(sdb *sqlite.Conn, tableName string, merge Merg
406
406
query += "B." + c + ","
407
407
}
408
408
query += "'" + string (ActionModify ) + "'" // Updated row
409
- for _ , c := range otherEscaped { // Other columns last
409
+ for _ , c := range otherEscaped { // Other columns last
410
410
query += ",A." + c + " IS NOT B." + c + ",B." + c
411
411
}
412
412
@@ -430,7 +430,7 @@ func dataDiffForModifiedTableRows(sdb *sqlite.Conn, tableName string, merge Merg
430
430
for _ , c := range pkEscaped { // Primary key columns first. This needs to be from the first table for deleted rows
431
431
query += "A." + c + ","
432
432
}
433
- query += "'" + string (ActionDelete ) + "'" // Deleted row
433
+ query += "'" + string (ActionDelete ) + "'" // Deleted row
434
434
query += strings .Repeat (",NULL" , len (otherEscaped )* 2 ) // Just NULL for all the other columns. They don't matter for deleted rows
435
435
436
436
query += " FROM main." + EscapeId (tableName ) + " A WHERE "
@@ -447,7 +447,7 @@ func dataDiffForModifiedTableRows(sdb *sqlite.Conn, tableName string, merge Merg
447
447
query += "B." + c + ","
448
448
}
449
449
query += "'" + string (ActionAdd ) + "'" // Inserted row
450
- for _ , c := range otherEscaped { // Other columns last. Always set the modified flag for inserted rows
450
+ for _ , c := range otherEscaped { // Other columns last. Always set the modified flag for inserted rows
451
451
query += ",1,B." + c
452
452
}
453
453
0 commit comments