Package org.springframework.batch.infrastructure.item.database

Class JdbcCursorItemReader<T>

java.lang.Object

org.springframework.batch.infrastructure.item.ItemStreamSupport

org.springframework.batch.infrastructure.item.support.AbstractItemStreamItemReader<T>

org.springframework.batch.infrastructure.item.support.AbstractItemCountingItemStreamItemReader<T>

org.springframework.batch.infrastructure.item.database.AbstractCursorItemReader<T>

org.springframework.batch.infrastructure.item.database.JdbcCursorItemReader<T>

All Implemented Interfaces:

ItemReader<T>, ItemStream, ItemStreamReader<T>, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

public class JdbcCursorItemReader<T>
extends AbstractCursorItemReader<T>

Simple item reader implementation that opens a JDBC cursor and continually retrieves the next row in the ResultSet.

The statement used to open the cursor is created with the 'READ_ONLY' option since a non read-only cursor may unnecessarily lock tables or rows. It is also opened with 'TYPE_FORWARD_ONLY' option. By default, the cursor will be opened using a separate connection which means that it will not participate in any transactions created as part of the step processing.

Each call to AbstractItemCountingItemStreamItemReader.read() will call the provided RowMapper, passing in the ResultSet.

This reader is not thread-safe.

Author:

Lucas Ward, Peter Zozom, Robert Kasanicky, Thomas Risberg, Mahmoud Ben Hassine, Stefano Cordio, Jimmy Praet

Field Summary

Fields inherited from class org.springframework.batch.infrastructure.item.database.AbstractCursorItemReader

log, rs, VALUE_NOT_SET

Constructor Summary

Constructors

Constructor	Description
JdbcCursorItemReader(DataSource dataSource, String sql, org.springframework.jdbc.core.RowMapper<T> rowMapper)	Create a new JdbcCursorItemReader instance.

Method Summary

Modifier and Type	Method	Description
protected void	cleanupOnClose(Connection connection)	Close the cursor and database connection.
String	getSql()
protected void	openCursor(Connection con)
protected @Nullable T	readCursor(ResultSet rs, int currentRow)	Read the cursor and map to the type of object this reader should return.
void	setPreparedStatementSetter(org.springframework.jdbc.core.PreparedStatementSetter preparedStatementSetter)	Set the PreparedStatementSetter to use if any parameter values that need to be set in the supplied query.
void	setRowMapper(org.springframework.jdbc.core.RowMapper<T> rowMapper)	Set the RowMapper to be used for all calls to read().
void	setSql(String sql)	Set the SQL statement to be used when creating the cursor.

Methods inherited from class org.springframework.batch.infrastructure.item.database.AbstractCursorItemReader

applyStatementSettings, doClose, doOpen, doRead, getDataSource, getExceptionTranslator, handleWarnings, initializeConnection, isUseSharedExtendedConnection, jumpToItem, setConnectionAutoCommit, setDataSource, setDriverSupportsAbsolute, setFetchSize, setIgnoreWarnings, setMaxRows, setQueryTimeout, setUseSharedExtendedConnection, setVerifyCursorPosition, translateSqlException

Methods inherited from class org.springframework.batch.infrastructure.item.support.AbstractItemCountingItemStreamItemReader

close, getCurrentItemCount, isSaveState, open, read, setCurrentItemCount, setMaxItemCount, setSaveState, update

Methods inherited from class org.springframework.batch.infrastructure.item.ItemStreamSupport

getExecutionContextKey, getName, setBeanName, setExecutionContextName, setName

Methods inherited from class java.lang.Object

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

Constructor Details

JdbcCursorItemReader

public JdbcCursorItemReader(DataSource dataSource,
 String sql,
 org.springframework.jdbc.core.RowMapper<T> rowMapper)

Create a new JdbcCursorItemReader instance. The DataSource, SQL query string, and RowMapper must be provided through their respective setters.

Since:

6.0

Method Details

setRowMapper

public void setRowMapper(org.springframework.jdbc.core.RowMapper<T> rowMapper)

Set the RowMapper to be used for all calls to read().

Parameters:

rowMapper - the mapper used to map each item

setSql

public void setSql(String sql)

Set the SQL statement to be used when creating the cursor. This statement should be a complete and valid SQL statement, as it will be run directly without any modification.

Parameters:

sql - SQL statement

setPreparedStatementSetter

public void setPreparedStatementSetter(org.springframework.jdbc.core.PreparedStatementSetter preparedStatementSetter)

Set the PreparedStatementSetter to use if any parameter values that need to be set in the supplied query.

Parameters:

preparedStatementSetter - PreparedStatementSetter responsible for filling out the statement

openCursor

protected void openCursor(Connection con)

Specified by:

openCursor in class AbstractCursorItemReader<T>

readCursor

protected @Nullable T readCursor(ResultSet rs,
 int currentRow)
                          throws SQLException

Description copied from class: AbstractCursorItemReader

Read the cursor and map to the type of object this reader should return. This method must be overridden by subclasses.

Specified by:

readCursor in class AbstractCursorItemReader<T>

Parameters:

rs - The current result set

currentRow - Current position of the result set

Returns:

the mapped object at the cursor position

Throws:

SQLException - if interactions with the current result set fail

cleanupOnClose

protected void cleanupOnClose(Connection connection)

Close the cursor and database connection.

Specified by:

cleanupOnClose in class AbstractCursorItemReader<T>

Parameters:

connection - to the database

getSql

public String getSql()

Specified by:

getSql in class AbstractCursorItemReader<T>