org.springframework.cloud.task.jdbchdfs.common

Class NamedColumnJdbcItemReaderFactory

java.lang.Object

org.springframework.cloud.task.jdbchdfs.common.NamedColumnJdbcItemReaderFactory

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<NamedColumnJdbcItemReader>, org.springframework.beans.factory.InitializingBean

public class NamedColumnJdbcItemReaderFactory
extends Object
implements org.springframework.beans.factory.FactoryBean<NamedColumnJdbcItemReader>, org.springframework.beans.factory.InitializingBean

Factory for configuring a NamedColumnJdbcItemReader. This factory will verify the type of database and configure the appropriate properties so that a streaming cursor is returned. Specifically, it will configure fetchSize=Integer.MIN_VALUE for MySql and set verifyCursorPosition=false for both MySql and SQLite.

Author:

Michael Minella, Thomas Risberg

Constructor Summary

Constructors

Constructor and Description
NamedColumnJdbcItemReaderFactory()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
NamedColumnJdbcItemReader	getObject()
Class<?>	getObjectType()
boolean	isSingleton()
void	setColumnNames(String columnNames)
void	setDataSource(DataSource dataSource)
void	setDelimiter(String delimiter)
void	setFetchSize(int fetchSize)
void	setPartitionClause(String partitionClause)
void	setSql(String sql)
void	setTableName(String tableName)
void	setVerifyCursorPosition(boolean verify)

Methods inherited from class java.lang.Object

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

Constructor Detail

NamedColumnJdbcItemReaderFactory

public NamedColumnJdbcItemReaderFactory()

Method Detail

getObject

public NamedColumnJdbcItemReader getObject()
                                    throws Exception

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<NamedColumnJdbcItemReader>

Throws:

Exception

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<NamedColumnJdbcItemReader>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<NamedColumnJdbcItemReader>

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

setDataSource

public void setDataSource(DataSource dataSource)

setTableName

public void setTableName(String tableName)

setColumnNames

public void setColumnNames(String columnNames)

setPartitionClause

public void setPartitionClause(String partitionClause)

setSql

public void setSql(String sql)

setFetchSize

public void setFetchSize(int fetchSize)

setVerifyCursorPosition

public void setVerifyCursorPosition(boolean verify)

setDelimiter

public void setDelimiter(String delimiter)