org.jeasy.batch.jdbc

Class JdbcRecordReader

java.lang.Object

org.jeasy.batch.jdbc.JdbcRecordReader

All Implemented Interfaces:

RecordReader

public class JdbcRecordReader
extends java.lang.Object
implements RecordReader

A RecordReader that reads records from a database using the JDBC API. This reader produces JdbcRecord instances.

Author:

Mahmoud Ben Hassine (mahmoud.benhassine@icloud.com)

Constructor Summary

Constructors

Constructor and Description
JdbcRecordReader(javax.sql.DataSource dataSource, java.lang.String query) Create a new JdbcRecordReader.

Method Summary

Modifier and Type	Method and Description
void	close()
void	open()
JdbcRecord	readRecord()
void	setFetchSize(int fetchSize) Set the statement fetch size.
void	setMaxRows(int maxRows) Set the maximum number of rows to fetch.
void	setQueryTimeout(int queryTimeout) Set the statement query timeout.

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcRecordReader

public JdbcRecordReader(javax.sql.DataSource dataSource,
                        java.lang.String query)

Create a new JdbcRecordReader.

Parameters:

dataSource - to read data from

query - to fetch data

Method Detail

open

public void open()
          throws java.lang.Exception

Specified by:

open in interface RecordReader

Throws:

java.lang.Exception

readRecord

public JdbcRecord readRecord()

Specified by:

readRecord in interface RecordReader

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface RecordReader

Throws:

java.lang.Exception

setMaxRows

public void setMaxRows(int maxRows)

Set the maximum number of rows to fetch.

Parameters:

maxRows - the maximum number of rows to fetch

setFetchSize

public void setFetchSize(int fetchSize)

Set the statement fetch size.

Parameters:

fetchSize - the fetch size to set

setQueryTimeout

public void setQueryTimeout(int queryTimeout)

Set the statement query timeout.

Parameters:

queryTimeout - the query timeout in seconds