org.springframework.integration.jdbc

Class JdbcPollingChannelAdapter

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.jdbc.JdbcPollingChannelAdapter

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, ExpressionCapable, MessageSource<Object>, NamedComponent

public class JdbcPollingChannelAdapter
extends IntegrationObjectSupport
implements MessageSource<Object>

A polling channel adapter that creates messages from the payload returned by executing a select query. Optionally an update can be executed after the select in order to update processed rows.

Since:

2.0

Author:

Jonas Partner, Dave Syer, Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Constructor Summary

Constructors

Constructor and Description
JdbcPollingChannelAdapter(DataSource dataSource, String selectQuery) Constructor taking DataSource from which the DB Connection can be obtained and the select query to execute to retrieve new rows.
JdbcPollingChannelAdapter(JdbcOperations jdbcOperations, String selectQuery) Constructor taking JdbcOperations instance to use for query execution and the select query to execute to retrieve new rows.

Method Summary

Modifier and Type	Method and Description
protected List<?>	doPoll(SqlParameterSource sqlQueryParameterSource)
String	getComponentType() Subclasses may implement this method to provide component type information.
protected void	onInit() Subclasses may implement this for initialization logic.
Message<Object>	receive() Execute the query.
void	setMaxRowsPerPoll(int maxRows) The maximum number of rows to pull out of the query results per poll (if greater than zero, otherwise all rows will be packed into the outgoing message).
void	setRowMapper(RowMapper<?> rowMapper)
void	setSelectSqlParameterSource(SqlParameterSource sqlQueryParameterSource) A source of parameters for the select query used for polling.
void	setUpdatePerRow(boolean updatePerRow)
void	setUpdateSql(String updateSql)
void	setUpdateSqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory)

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcPollingChannelAdapter

public JdbcPollingChannelAdapter(DataSource dataSource,
                                 String selectQuery)

Constructor taking DataSource from which the DB Connection can be obtained and the select query to execute to retrieve new rows.

Parameters:

dataSource - Must not be null

selectQuery - query to execute

JdbcPollingChannelAdapter

public JdbcPollingChannelAdapter(JdbcOperations jdbcOperations,
                                 String selectQuery)

Constructor taking JdbcOperations instance to use for query execution and the select query to execute to retrieve new rows.

Parameters:

jdbcOperations - instance to use for query execution

selectQuery - query to execute

Method Detail

setRowMapper

public void setRowMapper(RowMapper<?> rowMapper)

setUpdateSql

public void setUpdateSql(String updateSql)

setUpdatePerRow

public void setUpdatePerRow(boolean updatePerRow)

setUpdateSqlParameterSourceFactory

public void setUpdateSqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory)

setSelectSqlParameterSource

public void setSelectSqlParameterSource(SqlParameterSource sqlQueryParameterSource)

A source of parameters for the select query used for polling.

Parameters:

sqlQueryParameterSource - the sql query parameter source to set

setMaxRowsPerPoll

public void setMaxRowsPerPoll(int maxRows)

The maximum number of rows to pull out of the query results per poll (if greater than zero, otherwise all rows will be packed into the outgoing message). Default is zero.

Parameters:

maxRows - the max rows to set

onInit

protected void onInit()
               throws Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class IntegrationObjectSupport

Throws:

Exception - Any exception.

receive

public Message<Object> receive()

Execute the query. If a query result set contains one or more rows, the Message payload will contain either a List of Maps for each row or, if a RowMapper has been provided, the values mapped from those rows. If the query returns no rows, this method will return null. #return the Message or null as a result of query.

Specified by:

receive in interface MessageSource<Object>

Returns:

The message or null.

doPoll

protected List<?> doPoll(SqlParameterSource sqlQueryParameterSource)

getComponentType

public String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class IntegrationObjectSupport