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:02 UTC
[07/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/9311f825
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/9311f825
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/9311f825
Branch: refs/heads/camel-2.16.x
Commit: 9311f8254a2acfb8586ef344f4512ff2dfae6488
Parents: 6c54fdc
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:17 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/9311f825/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 7efe001..5d45864 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);