0005463: fix blank and null case

JumpMind · Sep 20, 2022 · 1212080 · 1212080
1 parent 0971629
commit 1212080
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
@@ -167,7 +167,8 @@ 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) && overrideSelectSql.equals(Constants.ALWAYS_TRUE_CONDITION)) {
+                if (parameterService.is(ParameterConstants.INITIAL_LOAD_RECURSION_SELF_FK) && (StringUtils.isBlank(overrideSelectSql) ||
+                        Constants.ALWAYS_TRUE_CONDITION.equals(overrideSelectSql))) {
                     ForeignKey fk = sourceTable.getSelfReferencingForeignKey();
                     if (fk != null) {
                         Reference[] refs = fk.getReferences();