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 ad7cbb1f3b..a1de268ce8 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 @@ -1777,10 +1777,16 @@ public List 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)); } }