org.apache.camel.component.elsql

Class ElsqlSqlProcessingStrategy

java.lang.Object

org.apache.camel.component.elsql.ElsqlSqlProcessingStrategy

All Implemented Interfaces:

org.apache.camel.component.sql.SqlNamedProcessingStrategy, org.apache.camel.component.sql.SqlProcessingStrategy

public class ElsqlSqlProcessingStrategy
extends Object
implements org.apache.camel.component.sql.SqlNamedProcessingStrategy

Constructor Summary

Constructors

Constructor and Description
ElsqlSqlProcessingStrategy(com.opengamma.elsql.ElSql elSql)

Method Summary

Modifier and Type	Method and Description
int	commit(org.apache.camel.component.sql.DefaultSqlEndpoint defaultSqlEndpoint, org.apache.camel.Exchange exchange, Object data, org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, String query)
int	commit(org.apache.camel.component.sql.DefaultSqlEndpoint defaultSqlEndpoint, org.apache.camel.Exchange exchange, Object data, org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate jdbcTemplate, org.springframework.jdbc.core.namedparam.SqlParameterSource parameterSource, String query)
int	commitBatchComplete(org.apache.camel.component.sql.DefaultSqlEndpoint defaultSqlEndpoint, org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, String query)
int	commitBatchComplete(org.apache.camel.component.sql.DefaultSqlEndpoint endpoint, org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate namedJdbcTemplate, org.springframework.jdbc.core.namedparam.SqlParameterSource parameterSource, String query)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ElsqlSqlProcessingStrategy

public ElsqlSqlProcessingStrategy(com.opengamma.elsql.ElSql elSql)

Method Detail

commit

public int commit(org.apache.camel.component.sql.DefaultSqlEndpoint defaultSqlEndpoint,
                  org.apache.camel.Exchange exchange,
                  Object data,
                  org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate jdbcTemplate,
                  org.springframework.jdbc.core.namedparam.SqlParameterSource parameterSource,
                  String query)
           throws Exception

Specified by:

commit in interface org.apache.camel.component.sql.SqlNamedProcessingStrategy

Throws:

Exception

commitBatchComplete

public int commitBatchComplete(org.apache.camel.component.sql.DefaultSqlEndpoint endpoint,
                               org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate namedJdbcTemplate,
                               org.springframework.jdbc.core.namedparam.SqlParameterSource parameterSource,
                               String query)
                        throws Exception

Specified by:

commitBatchComplete in interface org.apache.camel.component.sql.SqlNamedProcessingStrategy

Throws:

Exception

commit

public int commit(org.apache.camel.component.sql.DefaultSqlEndpoint defaultSqlEndpoint,
                  org.apache.camel.Exchange exchange,
                  Object data,
                  org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
                  String query)
           throws Exception

Specified by:

commit in interface org.apache.camel.component.sql.SqlProcessingStrategy

Throws:

Exception

commitBatchComplete

public int commitBatchComplete(org.apache.camel.component.sql.DefaultSqlEndpoint defaultSqlEndpoint,
                               org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
                               String query)
                        throws Exception

Specified by:

commitBatchComplete in interface org.apache.camel.component.sql.SqlProcessingStrategy

Throws:

Exception