Update PreparedStatementExecutor.java: fix updates

closes Altinity#899
salisbury-espinosa · Nov 4, 2024 · 053cc33 · 053cc33
1 parent 9103ab6
commit 053cc33
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/.../main/java/com/altinity/clickhouse/sink/connector/db/batch/PreparedStatementExecutor.java b/.../main/java/com/altinity/clickhouse/sink/connector/db/batch/PreparedStatementExecutor.java
@@ -330,8 +330,10 @@ public void insertPreparedStatement(Map<String, Integer> columnNameToIndexMap, P
                             } else {
                                 ps.setLong(columnNameToIndexMap.get(versionColumn), record.getGtid());
                             }
-                        } else {
+                        } else if (record.getSequenceNumber() != -1) {
                             ps.setLong(columnNameToIndexMap.get(versionColumn),  record.getSequenceNumber());
+                        } else {
+                            ps.setLong(columnNameToIndexMap.get(versionColumn),  record.getLsn());
                         }
                     }