0002845: Upgrade warning on node communication table

JumpMind · Oct 4, 2016 · 3cd43c2 · 3cd43c2
1 parent 350a540
commit 3cd43c2
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/db/DatabaseUpgradeListener.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/db/DatabaseUpgradeListener.java
@@ -68,6 +68,11 @@ public String beforeUpgrade(ISymmetricDialect symmetricDialect, String tablePref
             if (currentModel.findTable(dataGapTableName) != null) { 
                 engine.getSqlTemplate().update("delete from " + dataGapTableName);
             }
+
+            String nodeCommunicationTable = tablePrefix + "_" + TableConstants.SYM_NODE_COMMUNICATION;
+            if (currentModel.findTable(nodeCommunicationTable) != null) {
+                engine.getSqlTemplate().update("delete from " + tablePrefix + "_" + TableConstants.SYM_NODE_COMMUNICATION);
+            }
         }
 
         if (engine.getDatabasePlatform().getName().equals(DatabaseNamesConstants.FIREBIRD) ||