You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2016/01/08 17:41:05 UTC
[10/10] camel git commit: CAMEL-9491 : statement.maxRows not working as expected camel jdbc
CAMEL-9491 : statement.maxRows not working as expected camel jdbc
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e36c7bfc
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e36c7bfc
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e36c7bfc
Branch: refs/heads/camel-2.15.x
Commit: e36c7bfcb4a903f3d8f5971f2b29e5267636a2d8
Parents: c080086
Author: gautric <ga...@redhat.com>
Authored: Fri Jan 8 16:54:01 2016 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Fri Jan 8 17:40:47 2016 +0100
----------------------------------------------------------------------
.../main/java/org/apache/camel/component/jdbc/JdbcProducer.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/e36c7bfc/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java b/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java
index 13ecade..6ece40c 100644
--- a/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java
+++ b/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java
@@ -23,10 +23,12 @@ import java.sql.SQLDataException;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
+import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
+
import javax.sql.DataSource;
import org.apache.camel.Exchange;
@@ -193,7 +195,8 @@ public class JdbcProducer extends DefaultProducer {
stmt = conn.createStatement();
if (parameters != null && !parameters.isEmpty()) {
- IntrospectionSupport.setProperties(stmt, parameters);
+ Map<String, Object> copy = new HashMap<String, Object>(parameters);
+ IntrospectionSupport.setProperties(stmt, copy);
}
LOG.debug("Executing JDBC Statement: {}", sql);