SYMMETRICDS-399 - change the size of the incoming and outgoing batch …

…stat columns to support bigger data loads
JumpMind · Mar 1, 2011 · 23eb299 · 23eb299
1 parent 43822d9
commit 23eb299
Show file tree

Hide file tree

Showing 6 changed files with 231 additions and 63 deletions.
diff --git a/...ic/symmetric-core/src/main/java/org/jumpmind/symmetric/service/IIncomingBatchService.java b/...ic/symmetric-core/src/main/java/org/jumpmind/symmetric/service/IIncomingBatchService.java
@@ -36,9 +36,9 @@ public interface IIncomingBatchService {
 
     public List<IncomingBatch> findIncomingBatchErrors(int maxRows);
 
-    public boolean acquireIncomingBatch(IncomingBatch status);
+    public boolean acquireIncomingBatch(IncomingBatch batch);
 
-    public void insertIncomingBatch(IncomingBatch status);
+    public void insertIncomingBatch(IncomingBatch batch);
 
     public int updateIncomingBatch(JdbcTemplate jdbcTemplate, IncomingBatch batch);
 

diff --git a/...ymmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java b/...ymmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/OutgoingBatchService.java
@@ -111,12 +111,12 @@ public void updateOutgoingBatch(OutgoingBatch outgoingBatch) {
                                 outgoingBatch.getFailedDataId(),
                                 outgoingBatch.getLastUpdatedHostName(),
                                 outgoingBatch.getLastUpdatedTime(), outgoingBatch.getBatchId() },
-                        new int[] { Types.CHAR, Types.INTEGER, Types.INTEGER, Types.INTEGER,
-                                Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.INTEGER,
-                                Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.INTEGER,
-                                Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.INTEGER,
-                                Types.INTEGER, Types.INTEGER, Types.VARCHAR, Types.INTEGER,
-                                Types.VARCHAR, Types.INTEGER, Types.VARCHAR, Types.TIMESTAMP,
+                        new int[] { Types.CHAR, Types.INTEGER, Types.INTEGER, Types.BIGINT,
+                                Types.BIGINT, Types.BIGINT, Types.BIGINT, Types.BIGINT,
+                                Types.BIGINT, Types.BIGINT, Types.BIGINT, Types.BIGINT,
+                                Types.BIGINT, Types.BIGINT, Types.BIGINT, Types.BIGINT,
+                                Types.BIGINT, Types.BIGINT, Types.VARCHAR, Types.INTEGER,
+                                Types.VARCHAR, Types.BIGINT, Types.VARCHAR, Types.TIMESTAMP,
                                 Types.INTEGER });
     }