0004212: Resolve foreign key violation can pick up table from wrong

catalog or schema
JumpMind · Dec 18, 2019 · 8429d37 · 8429d37
1 parent ea9929d
commit 8429d37
Showing 1 changed file with 3 additions and 3 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
@@ -2402,9 +2402,9 @@ public void reloadMissingForeignKeyRowsReverse(String sourceNodeId, Table table,
                     String schema = foreignTable.getSchema();
                     if (StringUtils.equals(platform.getDefaultCatalog(), catalog)) {
                         catalog = null;
-                    }
-                    if (StringUtils.equals(platform.getDefaultSchema(), schema)) {
-                        schema = null;
+                        if (StringUtils.equals(platform.getDefaultSchema(), schema)) {
+                            schema = null;
+                        }
                     }
 
                     log.info(