fix for sql lite

JumpMind · Dec 3, 2012 · fe3dd8f · fe3dd8f
1 parent b987ce2
commit fe3dd8f
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java
@@ -22,6 +22,7 @@
 package org.jumpmind.symmetric.service.impl;
 
 import java.sql.Timestamp;
+import java.sql.Types;
 import java.text.SimpleDateFormat;
 import java.util.Calendar;
 import java.util.Date;
@@ -212,12 +213,14 @@ private int purgeByMinMax(long[] minMax, MinMaxDeleteSql identifier, Date retent
 
             String deleteSql = null;
             Object[] args = null;
+            int[] argTypes = null;
 
             switch (identifier) {
                 case DATA:
                     deleteSql = getSql("deleteDataSql");
                     args = new Object[] { minId, maxId, cutoffTime, minId, maxId, minId, maxId,
                             OutgoingBatch.Status.OK.name() };
+                    argTypes = new int[] { Types.NUMERIC, Types.NUMERIC, Types.TIMESTAMP, Types.NUMERIC, Types.NUMERIC, Types.NUMERIC, Types.NUMERIC};
                     break;
                 case DATA_EVENT:
                     deleteSql = getSql("deleteDataEventSql");
@@ -235,7 +238,7 @@ private int purgeByMinMax(long[] minMax, MinMaxDeleteSql identifier, Date retent
                     break;
             }
 
-            totalCount += sqlTemplate.update(deleteSql, args);
+            totalCount += sqlTemplate.update(deleteSql, args, argTypes);
 
             if (totalCount > 0
                     && (System.currentTimeMillis() - ts > DateUtils.MILLIS_PER_MINUTE * 5)) {
@@ -384,5 +387,7 @@ public void purgeAllIncomingEventsForNode(String nodeId) {
                 new Object[] { nodeId });
         log.info("Purged all {} incoming batch for node {}", count, nodeId);
     }
+
+
 
 }