0005463: Initial load of a table with a self referencing FK will not

load if out of order
JumpMind · Sep 20, 2022 · 59cacda · 59cacda
1 parent 65607f3
commit 59cacda
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromTableSource.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromTableSource.java
@@ -37,6 +37,7 @@
 import org.jumpmind.db.sql.Row;
 import org.jumpmind.symmetric.ISymmetricEngine;
 import org.jumpmind.symmetric.SymmetricException;
+import org.jumpmind.symmetric.common.Constants;
 import org.jumpmind.symmetric.common.ParameterConstants;
 import org.jumpmind.symmetric.db.ISymmetricDialect;
 import org.jumpmind.symmetric.io.data.Batch;
@@ -166,7 +167,7 @@ protected CsvData selectNext() {
                 if (overrideSelectSql != null && overrideSelectSql.trim().toUpperCase().startsWith("WHERE")) {
                     overrideSelectSql = overrideSelectSql.trim().substring(5);
                 }
-                if (parameterService.is(ParameterConstants.INITIAL_LOAD_RECURSION_SELF_FK) && StringUtils.isBlank(overrideSelectSql)) {
+                if (parameterService.is(ParameterConstants.INITIAL_LOAD_RECURSION_SELF_FK) && overrideSelectSql.equals(Constants.ALWAYS_TRUE_CONDITION)) {
                     ForeignKey fk = sourceTable.getSelfReferencingForeignKey();
                     if (fk != null) {
                         Reference[] refs = fk.getReferences();