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 2021/04/06 04:53:48 UTC
[camel] branch master updated: CAMEL-16405 Added statement query
timeout in sql-stored component (#5294)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new d944320 CAMEL-16405 Added statement query timeout in sql-stored component (#5294)
d944320 is described below
commit d9443201df67cfbf29c9dea4763466f1f98d415a
Author: VISHAL GAURAV <vi...@gmail.com>
AuthorDate: Tue Apr 6 10:23:26 2021 +0530
CAMEL-16405 Added statement query timeout in sql-stored component (#5294)
Co-authored-by: Vishal Gaurav <vi...@ezops.com>
---
.../org/apache/camel/component/sql/stored/SqlStoredComponent.java | 5 +++++
.../apache/camel/component/sql/stored/TemplateStoredProcedure.java | 1 +
2 files changed, 6 insertions(+)
diff --git a/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/SqlStoredComponent.java b/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/SqlStoredComponent.java
index faacd7c..97f4cfd 100644
--- a/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/SqlStoredComponent.java
+++ b/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/SqlStoredComponent.java
@@ -25,6 +25,8 @@ import org.apache.camel.Endpoint;
import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.annotations.Component;
import org.apache.camel.support.DefaultComponent;
+import org.apache.camel.support.PropertyBindingSupport;
+import org.apache.camel.util.PropertiesHelper;
import org.springframework.jdbc.core.JdbcTemplate;
@Component("sql-stored")
@@ -62,6 +64,9 @@ public class SqlStoredComponent extends DefaultComponent {
JdbcTemplate jdbcTemplate = new JdbcTemplate(target);
+ Map<String, Object> templateOptions = PropertiesHelper.extractProperties(parameters, "template.");
+ PropertyBindingSupport.bindProperties(getCamelContext(), jdbcTemplate, templateOptions);
+
SqlStoredEndpoint endpoint = new SqlStoredEndpoint(uri, this, jdbcTemplate);
endpoint.setTemplate(template);
return endpoint;
diff --git a/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/TemplateStoredProcedure.java b/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/TemplateStoredProcedure.java
index 1a12d53..61c7253 100644
--- a/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/TemplateStoredProcedure.java
+++ b/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/TemplateStoredProcedure.java
@@ -48,6 +48,7 @@ public class TemplateStoredProcedure extends StoredProcedure {
setFunction(function);
setDataSource(jdbcTemplate.getDataSource());
+ setQueryTimeout(jdbcTemplate.getQueryTimeout());
setSql(template.getProcedureName());
for (Object parameter : template.getParameterList()) {