0002253: When editing Table Routing entries switch the trigger or the…

… router causes a new entry to be created
JumpMind · Apr 3, 2015 · 6d1009b · 6d1009b
1 parent 1820f0a
commit 6d1009b
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/ITriggerRouterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/ITriggerRouterService.java
@@ -153,7 +153,9 @@ public TriggerHistory getNewestTriggerHistoryForTrigger(String triggerId, String
 
     public Map<Long, TriggerHistory> getHistoryRecords();
 
-    public void deleteTriggerRouter(TriggerRouter triggerRouter);
+    public void deleteTriggerRouter(TriggerRouter triggerRouter);
+
+    public void deleteTriggerRouter(String triggerId, String routerId);
 
     public void saveTriggerRouter(TriggerRouter triggerRouter, boolean updateTriggerRouterTableOnly);
 

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java
@@ -910,6 +910,12 @@ public void insert(TriggerHistory newHistRecord) {
                         Types.VARCHAR, Types.VARCHAR, Types.VARCHAR, Types.BIGINT, Types.BIGINT,
                         Types.VARCHAR });
     }
+
+    @Override
+    public void deleteTriggerRouter(String triggerId, String routerId) {
+        sqlTemplate.update(getSql("deleteTriggerRouterSql"), triggerId, routerId);
+        clearCache();
+    }
 
     public void deleteTriggerRouter(TriggerRouter triggerRouter) {
         sqlTemplate.update(getSql("deleteTriggerRouterSql"), (Object) triggerRouter.getTrigger()