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 <[email protected]> Authored: Fri Jan 8 16:54:01 2016 +0100 Committer: Claus Ibsen <[email protected]> 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);
