org.apache.camel.component.elsql

Class ElsqlSqlProcessingStrategy

java.lang.Object

org.apache.camel.component.elsql.ElsqlSqlProcessingStrategy

All Implemented Interfaces:

SqlNamedProcessingStrategy, SqlProcessingStrategy

public class ElsqlSqlProcessingStrategy
extends Object
implements SqlNamedProcessingStrategy

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
int	commit(DefaultSqlEndpoint defaultSqlEndpoint, Exchange exchange, Object data, org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, String query) Commit callback if there are a query to be run after processing.
int	commit(DefaultSqlEndpoint defaultSqlEndpoint, Exchange exchange, Object data, org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate jdbcTemplate, org.springframework.jdbc.core.namedparam.SqlParameterSource parameterSource, String query) Commit callback if there are a query to be run after processing.
int	commitBatchComplete(DefaultSqlEndpoint defaultSqlEndpoint, org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, String query) Commit callback when the batch is complete.
int	commitBatchComplete(DefaultSqlEndpoint endpoint, org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate namedJdbcTemplate, org.springframework.jdbc.core.namedparam.SqlParameterSource parameterSource, String query) Commit callback when the batch is complete.

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(DefaultSqlEndpoint defaultSqlEndpoint,
                  Exchange exchange,
                  Object data,
                  org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate jdbcTemplate,
                  org.springframework.jdbc.core.namedparam.SqlParameterSource parameterSource,
                  String query)
           throws Exception

Description copied from interface: SqlNamedProcessingStrategy

Commit callback if there are a query to be run after processing.

Specified by:

commit in interface SqlNamedProcessingStrategy

Parameters:

defaultSqlEndpoint - the endpoint

exchange - The exchange after it has been processed

data - The original data delivered to the route

jdbcTemplate - The JDBC template

parameterSource - Parameter sources for the named JDBC template

query - The SQL query to execute

Returns:

the update count if the query returned an update count

Throws:

Exception - can be thrown in case of error

commitBatchComplete

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

Description copied from interface: SqlNamedProcessingStrategy

Commit callback when the batch is complete. This allows you to do one extra query after all rows has been processed in the batch.

Specified by:

commitBatchComplete in interface SqlNamedProcessingStrategy

Parameters:

endpoint - the endpoint

namedJdbcTemplate - The JDBC template

parameterSource - Parameter sources for the named JDBC template

query - The SQL query to execute

Returns:

the update count if the query returned an update count

Throws:

Exception - can be thrown in case of error

commit

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

Description copied from interface: SqlProcessingStrategy

Commit callback if there are a query to be run after processing.

Specified by:

commit in interface SqlProcessingStrategy

Parameters:

defaultSqlEndpoint - the endpoint

exchange - The exchange after it has been processed

data - The original data delivered to the route

jdbcTemplate - The JDBC template

query - The SQL query to execute

Returns:

the update count if the query returned an update count

Throws:

Exception - can be thrown in case of error

commitBatchComplete

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

Description copied from interface: SqlProcessingStrategy

Commit callback when the batch is complete. This allows you to do one extra query after all rows has been processed in the batch.

Specified by:

commitBatchComplete in interface SqlProcessingStrategy

Parameters:

defaultSqlEndpoint - the endpoint

jdbcTemplate - The JDBC template

query - The SQL query to execute

Returns:

the update count if the query returned an update count

Throws:

Exception - can be thrown in case of error