0004459: Too many rows sent in reload for table when self-referencing

foreign key
JumpMind · Jun 29, 2020 · 74f5c67 · 74f5c67
1 parent 9d725c6
commit 74f5c67
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
@@ -2984,7 +2984,7 @@ protected void startNewCursor(final TriggerHistory triggerHistory,
                 }
 
                 if (selfRefLevel == 0) {
-                    selectSql += selfRefParentColumnName + " is null or " + selfRefParentColumnName + " = " + selfRefChildColumnName + " ";
+                    selectSql += "(" + selfRefParentColumnName + " is null or " + selfRefParentColumnName + " = " + selfRefChildColumnName + ") ";
                 } else {
                     DatabaseInfo info = getSymmetricDialect().getPlatform().getDatabaseInfo();
                     String tableName = Table.getFullyQualifiedTableName(sourceTable.getCatalog(), sourceTable.getSchema(),