0005491: Table reload request with "where" keyword gets error

JumpMind · Oct 3, 2022 · ff8806b · ff8806b
1 parent 622f85a
commit ff8806b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
@@ -1462,6 +1462,9 @@ protected long getDataCountForReload(Table table, Node targetNode, String select
             String quote = dbInfo.getDelimiterToken();
             String catalogSeparator = dbInfo.getCatalogSeparator();
             String schemaSeparator = dbInfo.getSchemaSeparator();
+            if (selectSql != null && selectSql.trim().toUpperCase().startsWith("WHERE")) {
+                selectSql = selectSql.trim().substring(5);
+            }
             String sql = String.format("select count(*) from %s t where %s", table
                     .getQualifiedTableName(quote, catalogSeparator, schemaSeparator), selectSql);
             sql = FormatUtils.replace("groupId", targetNode.getNodeGroupId(), sql);