0005375: Fixed how handleError() load filter method is handled for Po…

…stgres
JumpMind · Aug 3, 2022 · 094d67a · 094d67a
1 parent 453cd53
commit 094d67a
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/AbstractDatabaseWriter.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/AbstractDatabaseWriter.java
@@ -222,8 +222,12 @@ public void write(CsvData data) {
                             throw ex;
                         } else {
                             uncommittedCount++;
-                            statistics.get(batch).increment(DataWriterStatisticConstants.IGNORECOUNT);
+                            statistics.get(batch).increment(DataWriterStatisticConstants.IGNOREROWCOUNT);
                             checkForEarlyCommit();
+                            if (Boolean.TRUE.equals(context.get(AbstractDatabaseWriter.TRANSACTION_ABORTED))) {
+                                context.put(CONFLICT_IGNORE, true);
+                                throw ex;
+                            }
                         }
                     }
                 }