use correct type on batch_id

JumpMind · Nov 21, 2007 · ebd3b42 · ebd3b42
1 parent ebb2be8
commit ebd3b42
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java
@@ -91,19 +91,20 @@ public boolean acquireIncomingBatch(IncomingBatch status) {
     }
 
     public void insertIncomingBatch(IncomingBatch status) {
-        jdbcTemplate.update(insertIncomingBatchSql, new Object[] { status.getBatchId(), status.getNodeId(),
-                status.getStatus().toString() });
+        jdbcTemplate.update(insertIncomingBatchSql, new Object[] { Long.valueOf(status.getBatchId()),
+                status.getNodeId(), status.getStatus().toString() });
     }
 
     public int updateIncomingBatch(IncomingBatch status) {
         return jdbcTemplate.update(updateIncomingBatchSql, new Object[] { status.getStatus().toString(),
-                status.getBatchId(), status.getNodeId(), IncomingBatch.Status.ER.toString() });
+                Long.valueOf(status.getBatchId()), status.getNodeId(), IncomingBatch.Status.ER.toString() });
     }
 
     public void insertIncomingBatchHistory(IncomingBatchHistory history) {
-        jdbcTemplate.update(insertIncomingBatchHistorySql, new Object[] { history.getBatchId(), history.getNodeId(),
-                history.getStatus().toString(), history.getHostName(), history.getStatementCount(),
-                history.getFallbackInsertCount(), history.getFallbackUpdateCount(), history.getMissingDeleteCount(),
+        jdbcTemplate.update(insertIncomingBatchHistorySql, new Object[] { Long.valueOf(history.getBatchId()),
+                history.getNodeId(), history.getStatus().toString(), history.getHostName(),
+                history.getStatementCount(), history.getFallbackInsertCount(),
+                history.getFallbackUpdateCount(), history.getMissingDeleteCount(),
                 history.getFailedRowNumber(), history.getStartTime(), history.getEndTime() });
     }