Package org.springframework.integration.jdbc

Class JdbcPollingChannelAdapter

java.lang.Object

org.springframework.integration.util.AbstractExpressionEvaluator

org.springframework.integration.endpoint.AbstractMessageSource<Object>

org.springframework.integration.jdbc.JdbcPollingChannelAdapter

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, MessageSource<Object>, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement

public class JdbcPollingChannelAdapter
extends AbstractMessageSource<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

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Constructor Summary

Constructors

Constructor	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	Description
protected List<?>	doPoll(SqlParameterSource sqlQueryParameterSource)
protected Object	doReceive()	Execute the select query and the update query if provided.
String	getComponentType()
protected void	onInit()
void	setMaxRows(int maxRows)	The maximum number of rows to query.
void	setRowMapper(RowMapper<?> rowMapper)
void	setSelectQuery(String selectQuery)	Set the select query.
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.endpoint.AbstractMessageSource

buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType

Methods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

getThisAs

Methods inherited from interface org.springframework.integration.core.MessageSource

getIntegrationPatternType

Constructor Details

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 Details

setRowMapper

public void setRowMapper(@Nullable RowMapper<?> rowMapper)

setSelectQuery

public final void setSelectQuery(String selectQuery)

Set the select query.

Parameters:

selectQuery - the query.

Since:

5.2.1

setUpdateSql

public void setUpdateSql(String updateSql)

setUpdatePerRow

public void setUpdatePerRow(boolean updatePerRow)

setUpdateSqlParameterSourceFactory

public void setUpdateSqlParameterSourceFactory(SqlParameterSourceFactory sqlParameterSourceFactory)

setSelectSqlParameterSource

public void setSelectSqlParameterSource(@Nullable SqlParameterSource sqlQueryParameterSource)

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

Parameters:

sqlQueryParameterSource - the sql query parameter source to set

setMaxRows

public void setMaxRows(int maxRows)

The maximum number of rows to query. Default is zero - select all records.

Parameters:

maxRows - the max rows to set

Since:

5.1

onInit

protected void onInit()

Overrides:

onInit in class AbstractExpressionEvaluator

getComponentType

public String getComponentType()

doReceive

protected Object doReceive()

Execute the select query and the update query if provided. Returns the rows returned by the select query. If a RowMapper has been provided, the mapped results are returned.

Specified by:

doReceive in class AbstractMessageSource<Object>

Returns:

The value returned.

doPoll

protected List<?> doPoll(@Nullable SqlParameterSource sqlQueryParameterSource)