[camel] branch master updated: CAMEL-16405 Added statement query timeout in sql-stored component (#5294)

[davsclaus]

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 <vishalsrivas...@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 <vis...@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()) {