0001797: sym_table_reload_request should be cleaned up when a node is…

… deleted
JumpMind · Jul 8, 2014 · d8ab2fb · d8ab2fb
1 parent 50e9709
commit d8ab2fb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeService.java
@@ -250,6 +250,7 @@ public void deleteNode(String nodeId, boolean syncChange) {
                 transaction.prepareAndExecute(getSql("deleteIncomingErrorSql"), new Object[] { nodeId });
                 transaction.prepareAndExecute(getSql("deleteExtractRequestSql"), new Object[] { nodeId });
                 transaction.prepareAndExecute(getSql("deleteNodeCommunicationSql"), new Object[] { nodeId });
+                transaction.prepareAndExecute(getSql("deleteTableReloadRequestSql"), new Object[] { nodeId, nodeId });
                 transaction.prepareAndExecute(getSql("setOutgoingBatchOkSql"), new Object[] { nodeId });
                 transaction.prepareAndExecute(getSql("setIncomingBatchOkSql"), new Object[] { nodeId });
             }

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeServiceSqlMap.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeServiceSqlMap.java
@@ -110,6 +110,8 @@ public NodeServiceSqlMap(IDatabasePlatform platform, Map<String, String> replace
 
         putSql("deleteIncomingErrorSql", "delete from $(incoming_error) where node_id = ?");
 
+        putSql("deleteTableReloadRequestSql", "delete from $(table_reload_request) where source_node_id = ? or target_node_id=?");
+
         putSql("deleteExtractRequestSql", "delete from $(extract_request) where node_id = ?");
 
         putSql("deleteNodeCommunicationSql", "delete from $(node_communication) where node_id = ?");