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

requests into multiple load requests
JumpMind · Jul 17, 2019 · 82973dc · 82973dc
1 parent 4bdab41
commit 82973dc
Showing 1 changed file with 23 additions and 0 deletions.
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,6 +237,29 @@ protected void deleteTableReloadRequest(ISqlTransaction sqlTransaction,
                         Types.VARCHAR, Types.VARCHAR, Types.VARCHAR });
     }
 
+    public void insertTableReloadRequest(TableReloadRequest request) {
+    	ISqlTransaction transaction = null;
+        try {
+            transaction = engine.getDatabasePlatform().getSqlTemplate().startSqlTransaction();
+            insertTableReloadRequest(transaction, request);
+            transaction.commit();
+        } catch (Error ex) {
+            if (transaction != null) {
+                transaction.rollback();
+            }
+            throw ex;
+        } catch (RuntimeException ex) {
+            if (transaction != null) {
+                transaction.rollback();
+            }
+            throw ex;
+        } finally {
+            if (transaction != null) {
+                transaction.close();
+            }
+        }
+    }
+
     public void insertTableReloadRequest(ISqlTransaction transaction, TableReloadRequest request) {
         Date time = new Date();
         request.setLastUpdateTime(time);