From 12120805dc009e38e69244ce63126f155cdd0361 Mon Sep 17 00:00:00 2001
From: Eric Long <elong@jumpmind.com>
Date: Tue, 20 Sep 2022 14:31:29 -0400
Subject: [PATCH] 0005463: fix blank and null case

---
 .../org/jumpmind/symmetric/extract/SelectFromTableSource.java  | 3 ++-
 1 file changed, 2 insertions(+), 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
index 3f1d0402b7..e559df3c94 100644
--- 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();