0001684: Passing the correct data type to select data statement impro…

…ves performance on Postgres
JumpMind · Apr 21, 2014 · 60fd0f1 · 60fd0f1
1 parent 9a6856d
commit 60fd0f1
Showing 1 changed file with 3 additions and 3 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
@@ -1428,7 +1428,7 @@ public List<Data> listData(long batchId, String nodeId, long startDataId, String
             final int maxRowsToRetrieve) {
         return sqlTemplate.query(getDataSelectSql(batchId, startDataId, channelId),
                 maxRowsToRetrieve, this.dataMapper, new Object[] {batchId, nodeId, startDataId}, 
-                new int[] { Types.BIGINT, Types.VARCHAR, Types.BIGINT});
+                new int[] { symmetricDialect.getSqlTypeForIds(), Types.VARCHAR, symmetricDialect.getSqlTypeForIds()});
     }
 
     public Data mapData(Row row) {
@@ -1439,12 +1439,12 @@ public ISqlReadCursor<Data> selectDataFor(Batch batch) {
         return sqlTemplate.queryForCursor(
                 getDataSelectSql(batch.getBatchId(), -1l, batch.getChannelId()), dataMapper,
                 new Object[] { batch.getBatchId(), batch.getTargetNodeId() },
-                new int[] { Types.BIGINT, Types.VARCHAR });
+                new int[] { symmetricDialect.getSqlTypeForIds(), Types.VARCHAR });
     }
 
     public ISqlReadCursor<Data> selectDataFor(Long batchId, String channelId) {
         return sqlTemplate.queryForCursor(getDataSelectByBatchSql(batchId, -1l, channelId),
-                dataMapper, new Object[] { batchId }, new int[] { Types.NUMERIC });
+                dataMapper, new Object[] { batchId }, new int[] { symmetricDialect.getSqlTypeForIds() });
     }
 
     protected String getDataSelectByBatchSql(long batchId, long startDataId, String channelId) {