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<Node> oneNodeSet = new HashSet<Node>();
                     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);
                     }