public class NamedColumnJdbcItemReaderFactory extends java.lang.Object implements org.springframework.beans.factory.FactoryBean<NamedColumnJdbcItemReader>, org.springframework.beans.factory.InitializingBean
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.Constructor and Description |
---|
NamedColumnJdbcItemReaderFactory() |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
NamedColumnJdbcItemReader |
getObject() |
java.lang.Class<?> |
getObjectType() |
boolean |
isSingleton() |
void |
setColumnNames(java.lang.String columnNames) |
void |
setDataSource(javax.sql.DataSource dataSource) |
void |
setDelimiter(java.lang.String delimiter) |
void |
setFetchSize(int fetchSize) |
void |
setPartitionClause(java.lang.String partitionClause) |
void |
setSql(java.lang.String sql) |
void |
setTableName(java.lang.String tableName) |
void |
setVerifyCursorPosition(boolean verify) |
public NamedColumnJdbcItemReader getObject() throws java.lang.Exception
getObject
in interface org.springframework.beans.factory.FactoryBean<NamedColumnJdbcItemReader>
java.lang.Exception
public java.lang.Class<?> getObjectType()
getObjectType
in interface org.springframework.beans.factory.FactoryBean<NamedColumnJdbcItemReader>
public boolean isSingleton()
isSingleton
in interface org.springframework.beans.factory.FactoryBean<NamedColumnJdbcItemReader>
public void afterPropertiesSet() throws java.lang.Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
java.lang.Exception
public void setDataSource(javax.sql.DataSource dataSource)
public void setTableName(java.lang.String tableName)
public void setColumnNames(java.lang.String columnNames)
public void setPartitionClause(java.lang.String partitionClause)
public void setSql(java.lang.String sql)
public void setFetchSize(int fetchSize)
public void setVerifyCursorPosition(boolean verify)
public void setDelimiter(java.lang.String delimiter)