From 2b2b511de261ae103286fd0dfcdb9abcdc063f77 Mon Sep 17 00:00:00 2001 From: chenson42 Date: Mon, 12 Jul 2010 14:56:06 +0000 Subject: [PATCH] SYMMETRICDS-296 - Put cursor in non auto commit mode before extracting result set. This is required by postgres. --- .../symmetric/service/impl/DataExtractorService.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/symmetric/symmetric-ds/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/symmetric/symmetric-ds/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java index 78785a0754..ca5b5645f7 100644 --- a/symmetric/symmetric-ds/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java +++ b/symmetric/symmetric-ds/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java @@ -262,9 +262,14 @@ public Object doInConnection(Connection conn) throws SQLException, DataAccessExc : new NodeChannel(triggerRouter.getTrigger().getChannelId()); Set oneNodeSet = new HashSet(); oneNodeSet.add(node); + + boolean autoCommitFlag = conn.getAutoCommit(); PreparedStatement st = null; ResultSet rs = null; try { + + conn.setAutoCommit(false); + st = conn.prepareStatement(sql, java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY); st.setQueryTimeout(jdbcTemplate.getQueryTimeout()); @@ -297,6 +302,7 @@ public Object doInConnection(Connection conn) throws SQLException, DataAccessExc dataExtractor.commit(batch, writer); } } finally { + conn.setAutoCommit(autoCommitFlag); JdbcUtils.closeResultSet(rs); JdbcUtils.closeStatement(st); }