0004048: Table reload request- routing service can break up table reload

requests into multiple load requests
JumpMind · Jul 17, 2019 · 4bdab41 · 4bdab41
1 parent 5474504
commit 4bdab41
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/IDataService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/IDataService.java
@@ -49,7 +49,7 @@
  */
 public interface IDataService {
 
-    public void insertTableReloadRequest(TableReloadRequest request);
+    public void insertTableReloadRequest(ISqlTransaction transaction, TableReloadRequest request);
 
     public TableReloadRequest getTableReloadRequest(TableReloadRequestKey key);
 

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
@@ -237,15 +237,15 @@ protected void deleteTableReloadRequest(ISqlTransaction sqlTransaction,
                         Types.VARCHAR, Types.VARCHAR, Types.VARCHAR });
     }
 
-    public void insertTableReloadRequest(TableReloadRequest request) {
+    public void insertTableReloadRequest(ISqlTransaction transaction, TableReloadRequest request) {
         Date time = new Date();
         request.setLastUpdateTime(time);
         if (request.getCreateTime() == null) {
             request.setCreateTime(time);
         }
         request.setCreateTime(new Date((request.getCreateTime().getTime() / 1000) * 1000));
 
-        sqlTemplate.update(
+        transaction.prepareAndExecute(
                 getSql("insertTableReloadRequest"),
                 new Object[] { request.getReloadSelect(), request.getBeforeCustomSql(),
                         request.getCreateTime(), request.getLastUpdateBy(),