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
index bbba132e9d..8fea8a1f3c 100644
--- 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
@@ -1534,6 +1534,10 @@ public void reloadMissingForeignKeyRows(String nodeId, long dataId) {
             DmlStatement st = platform.createDmlStatement(DmlType.WHERE, foreignTable, null);
             Column[] foreignColumns = foreignColumnList.toArray(new Column[foreignColumnList.size()]);
             String sql = st.buildDynamicSql(symmetricDialect.getBinaryEncoding(), foreignRow, false, true, foreignColumns).substring(6);
+            String delimiter = platform.getDatabaseInfo().getSqlCommandDelimiter();
+            if (delimiter != null && delimiter.length() > 0) {
+                sql = sql.substring(0, sql.length() - delimiter.length());
+            }
 
             String catalog = foreignTable.getCatalog();
             String schema = foreignTable.getSchema();