From 60fd0f110bebafcebfccfc2c8803c832ad37eda9 Mon Sep 17 00:00:00 2001 From: chenson42 Date: Mon, 21 Apr 2014 15:26:34 +0000 Subject: [PATCH] 0001684: Passing the correct data type to select data statement improves performance on Postgres --- .../org/jumpmind/symmetric/service/impl/DataService.java | 6 +++--- 1 file changed, 3 insertions(+), 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 index 76c2d2bf5a..d752697a33 100644 --- 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 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 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 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) {