com.poscoict.glueframework.batch.item

Class GlueCursorItemReader<T>

java.lang.Object

org.springframework.batch.item.ItemStreamSupport

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

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

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

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

com.poscoict.glueframework.batch.item.GlueCursorItemReader<T>

All Implemented Interfaces:

org.springframework.batch.item.ItemReader<T>, org.springframework.batch.item.ItemStream, org.springframework.batch.item.ItemStreamReader<T>, org.springframework.beans.factory.InitializingBean

public class GlueCursorItemReader<T>
extends org.springframework.batch.item.database.JdbcCursorItemReader<T>

JdbcCursorItemReader 확장.

 Bean Property
 
 - dataSource : (필수)
 
 - rowMapper : (필수)
 
 - queryId : (필수)
 
 - queryManager : (필수)
 
 - preparedStatementSetter : (선택)
 
 
 예제
 사용 예# 1
 
     <bean id="itemReader" class="com.poscoict.glueframework.batch.item.GlueCursorItemReader">
         <property name="dataSource" ref="dataSource" />
         <property name="rowMapper" ref="empRowMapper" />
         <property name="queryManager" ref="queryManager" />
         <property name="queryId" value="emp.select" />
     </bean>
     <bean id="dataSource" .../>
     <bean id="queryManager" class="com.poscoict.glueframework.dao.manager.GlueQueryManagerImpl">
         <property name="cacheManager" ref="cacheManager"/>
         <property name="queryLoader" ref="queryLoader"/>
     </bean>
     <bean id="cacheManager" .../>
     <bean id="queryLoader" .../>
     <bean id="empRowMapper" class="sample.mapper.EmpRowMapper" />
 
 
 
 참고 : {name}-query.glue_sql
 
     <query id="emp.select" desc="" resultType="sample.vo.EmpVO">
         <![CDATA[
               select EMPNO, ENAME, JOB, MGR, HIREDATE, SAL,DEPTNO
               from EMP
         ]]>
     </query>
 
 
 참고 : EmpRowMapper.java
 
     import java.sql.ResultSet;
     import java.sql.SQLException;
     import org.springframework.jdbc.core.RowMapper;
     import sample.vo.EmpVO;
     public class EmpRowMapper implements RowMapper<EmpVO> {
         public EmpVO mapRow(ResultSet rs,int rowNum) throws SQLException{
             EmpVO emp = new EmpVO();
             emp.setEmpno(rs.getString("empno"));
             emp.setEname(rs.getString("ename"));
             emp.setDeptno(rs.getString("deptno"));
             return emp;
         }
     }
 
 
 참고 : EmpVO.java
 
     public class EmpVO{
         private String empno;
         private String ename;
         private String deptno;
         public String getEmpno() {
             return empno;
         }
         public void setEmpno( String empno ) {
             this.empno = empno;
         }
         public String getEname() {
             return ename;
         }
         public void setEname( String ename ) {
             this.ename = ename;
         }
         public Long getDeptno() {
             return deptno;
         }
         public void setDeptno( String deptno ) {
             this.deptno = deptno;
         }
 

Field Summary

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

log, rs, VALUE_NOT_SET

Constructor Summary

Constructors

Constructor and Description
GlueCursorItemReader()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	setQueryId(String queryId) setter method for DI.
void	setQueryManager(GlueQueryManager queryManager) setter method for DI.

Methods inherited from class org.springframework.batch.item.database.JdbcCursorItemReader

cleanupOnClose, getSql, openCursor, readCursor, setPreparedStatementSetter, setRowMapper, setSql

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

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

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

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

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

getExecutionContextKey, setExecutionContextName, setName

Methods inherited from class java.lang.Object

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

Constructor Detail

GlueCursorItemReader

public GlueCursorItemReader()

Method Detail

setQueryManager

public void setQueryManager(GlueQueryManager queryManager)

setter method for DI.

Parameters:

queryManager -

setQueryId

public void setQueryId(String queryId)

setter method for DI.

Parameters:

queryId -

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

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

Overrides:

afterPropertiesSet in class org.springframework.batch.item.database.JdbcCursorItemReader<T>

Throws:

Exception