remove trigger router grouplets by trigger router id

JumpMind · Jan 31, 2013 · 33050e5 · 33050e5
1 parent 211d086
commit 33050e5
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 0 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/IGroupletService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/IGroupletService.java
@@ -52,5 +52,7 @@ public interface IGroupletService {
     public void saveTriggerRouterGrouplet(Grouplet grouplet, TriggerRouterGrouplet triggerRouterGrouplet);
 
     public void deleteTriggerRouterGrouplet(Grouplet grouplet, TriggerRouterGrouplet triggerRouterGrouplet);
+
+    public void deleteTriggerRouterGroupletsFor(TriggerRouter triggerRouter);
 
 }
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/GroupletService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/GroupletService.java
@@ -310,6 +310,17 @@ public void saveTriggerRouterGrouplet(Grouplet grouplet,
 
         }
     }
+
+    public void deleteTriggerRouterGroupletsFor(TriggerRouter triggerRouter) {
+        ISqlTemplate sqlTemplate = platform.getSqlTemplate();
+        sqlTemplate
+                .update(getSql("deleteTriggerRouterGroupletForSql"),
+                        new Object[] { 
+                                triggerRouter.getTrigger().getTriggerId(),
+                                triggerRouter.getRouter().getRouterId() }, new int[] { Types.VARCHAR,
+                                Types.VARCHAR });
+
+    }
 
     public void deleteTriggerRouterGrouplet(Grouplet grouplet,
             TriggerRouterGrouplet triggerRouterGrouplet) {

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/GroupletServiceSqlMap.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/GroupletServiceSqlMap.java
@@ -43,6 +43,7 @@ public GroupletServiceSqlMap(IDatabasePlatform platform, Map<String, String> rep
         putSql("updateTriggerRouterGroupletSql", "update $(trigger_router_grouplet) set create_time=?, last_update_by=?, last_update_time=? where grouplet_id=? and applies_when=? and trigger_id=? and router_id=?");
         putSql("insertTriggerRouterGroupletSql", "insert into $(trigger_router_grouplet) (create_time, last_update_by, last_update_time, grouplet_id, applies_when, trigger_id, router_id) values(?,?,?,?,?,?,?)");
         putSql("deleteTriggerRouterGroupletSql", "delete from $(trigger_router_grouplet) where grouplet_id=? and applies_when=? and trigger_id=? and router_id=?");
+        putSql("deleteTriggerRouterGroupletForSql", "delete from $(trigger_router_grouplet) where trigger_id=? and router_id=?");
 
     }