0003052: Default handle key updates in for Table Triggers to on when

configuring via SymmetricDS Pro
JumpMind · Apr 18, 2017 · 209cee0 · 209cee0
1 parent a304641
commit 209cee0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 12 deletions.
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
@@ -125,9 +125,6 @@ public interface ITriggerRouterService {
 
     public void createTriggersOnChannelForTables(String channelId, String catalogName, String schemaName, List<String> tables, String lastUpdateBy);
 
-    public List<Trigger> createTriggersOnChannelForTablesWithReturn(String channelId, String catalogName,
-            String schemaName, List<String> tables, String lastUpdateBy);
-
     public boolean isTriggerBeingUsed(String triggerId);
 
     public boolean doesTriggerExist(String triggerId);

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
@@ -231,13 +231,7 @@ protected void deleteTriggerHistory(TriggerHistory history) {
     }
 
     public void createTriggersOnChannelForTables(String channelId, String catalogName,
-            String schemaName, List<String> tables, String lastUpdateBy) {
-        createTriggersOnChannelForTablesWithReturn(channelId, catalogName, schemaName, tables, lastUpdateBy);
-    }
-
-    public List<Trigger> createTriggersOnChannelForTablesWithReturn(String channelId, String catalogName,
-            String schemaName, List<String> tables, String lastUpdateBy) {
-
+            String schemaName, List<String> tables, String lastUpdateBy) {       
         List<Trigger> createdTriggers = new ArrayList<Trigger>();
 
         List<Trigger> existingTriggers = getTriggers();
@@ -282,8 +276,6 @@ public List<Trigger> createTriggersOnChannelForTablesWithReturn(String channelId
             saveTrigger(trigger);
             createdTriggers.add(trigger);
         }
-        return createdTriggers;
-
     }
 
     public Collection<Trigger> findMatchingTriggers(List<Trigger> triggers, String catalog, String schema,
@@ -485,6 +477,7 @@ protected Trigger buildTriggerForSymmetricTable(String tableName) {
                 || tableName.equals(TableConstants.getTableName(tablePrefix,
                         TableConstants.SYM_TABLE_RELOAD_REQUEST)));
         Trigger trigger = new Trigger();
+        trigger.setUseHandleKeyUpdates(false);
         trigger.setTriggerId(tableName);
         trigger.setSyncOnDelete(syncChanges);
         trigger.setSyncOnInsert(syncChanges);