0006507: Fixed values getting matched with the wrong columns during e…

…xtraction when using the targetExternalId variable and table definitions differ
JumpMind · Jun 20, 2024 · 1d735ad · 1d735ad
1 parent 8063557
commit 1d735ad
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/...c-core/src/main/java/org/jumpmind/symmetric/extract/ColumnsAccordingToTriggerHistory.java b/...c-core/src/main/java/org/jumpmind/symmetric/extract/ColumnsAccordingToTriggerHistory.java
@@ -190,13 +190,12 @@ protected Table lookupTableExpanded(IDatabasePlatform platform, String catalogNa
             if (table == null) {
                 table = lookupTable(platform, catalogName, schemaName, tableName, triggerHistory, addMissingColumns);
                 sourceTableMap.put(baseTableName, table);
+            } else {
+                table = table.copyAndFilterColumns(triggerHistory.getParsedColumnNames(),
+                        triggerHistory.getParsedPkColumnNames(), true, addMissingColumns);
             }
             if (table != null) {
-                try {
-                    table = (Table) table.clone();
-                    table.setName(tableName);
-                } catch (CloneNotSupportedException e) {
-                }
+                table.setName(tableName);
             }
         }
         return table;