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.Exceptionpublic 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.InitializingBeanjava.lang.Exceptionpublic 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)