diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/load/TableTemplate.java b/symmetric/src/main/java/org/jumpmind/symmetric/load/TableTemplate.java index df16ada7f2..8c48a4d645 100644 --- a/symmetric/src/main/java/org/jumpmind/symmetric/load/TableTemplate.java +++ b/symmetric/src/main/java/org/jumpmind/symmetric/load/TableTemplate.java @@ -164,7 +164,16 @@ private StatementBuilder getStatementBuilder(IDataLoaderContext ctx, DmlType typ columnKeyMetaData = (Column[]) ArrayUtils.addAll(columnMetaData, keyMetaData); } - st = new StatementBuilder(type, table.getName(), keyMetaData, + String tableName = table.getName(); + if (table.getSchema() != null && dbDialect.getDefaultSchema() != null + && !table.getSchema().equals(dbDialect.getDefaultSchema())) { + tableName = table.getSchema() + "." + tableName; + } + if (table.getCatalog() != null && dbDialect.getDefaultCatalog() != null + && !table.getCatalog().equals(dbDialect.getDefaultCatalog())) { + tableName = table.getCatalog() + "." + tableName; + } + st = new StatementBuilder(type, tableName, keyMetaData, getColumnMetaData(filteredColumnNames), dbDialect.isBlobOverrideToBinary()); statementMap.put(type, st); }