0005095: Initial load before custom sql to support table replacement

with delimiters
JumpMind · Oct 5, 2021 · 849f8ec · 849f8ec
1 parent 8d5aaf1
commit 849f8ec
Showing 1 changed file with 6 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
@@ -1777,10 +1777,16 @@ public List<String> resolveTargetTables(String sql, TriggerRouter triggerRouter,
                     tableNames.add(transform.getFullyQualifiedTargetTableName());
                 }
             } else {
+
                 tableNames.add(sourceTableName);
             }
 
             for (String tableName : tableNames) {
+            	if (parameterService.is(ParameterConstants.DB_DELIMITED_IDENTIFIER_MODE)) {
+            		String delimiter = engine.getTargetDialect().getTargetPlatform().getDatabaseInfo().getDelimiterToken();
+            		tableName = tableName.replaceAll("\\.", delimiter + "." + delimiter);
+            		tableName = delimiter + tableName + delimiter;
+            	}
                 sqlStatements.add(String.format(sql, tableName));
             }
         }