类 StagingItemProcessor<T>
- java.lang.Object
- org.springframework.batch.sample.common.StagingItemProcessor<T>
- 类型参数:
T
- item type
- 所有已实现的接口:
ItemProcessor<ProcessIndicatorItemWrapper<T>,T>
,org.springframework.beans.factory.InitializingBean
public class StagingItemProcessor<T> extends java.lang.Object implements ItemProcessor<ProcessIndicatorItemWrapper<T>,T>, org.springframework.beans.factory.InitializingBean
Marks the input row as 'processed'. (This change will rollback if there is problem later)- 作者:
- Robert Kasanicky
- 另请参阅:
StagingItemReader
,StagingItemWriter
,ProcessIndicatorItemWrapper
构造器概要
构造器 构造器 说明 StagingItemProcessor()
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 void
afterPropertiesSet()
T
process(ProcessIndicatorItemWrapper<T> wrapper)
Use the technical identifier to mark the input row as processed and return unwrapped item.void
setDataSource(javax.sql.DataSource dataSource)
void
setJdbcTemplate(org.springframework.jdbc.core.JdbcOperations jdbcTemplate)
构造器详细资料
StagingItemProcessor
public StagingItemProcessor()
方法详细资料
setJdbcTemplate
public void setJdbcTemplate(org.springframework.jdbc.core.JdbcOperations jdbcTemplate)
setDataSource
public void setDataSource(javax.sql.DataSource dataSource)
afterPropertiesSet
public void afterPropertiesSet() throws java.lang.Exception
- 指定者:
afterPropertiesSet
在接口中org.springframework.beans.factory.InitializingBean
- 抛出:
java.lang.Exception
process
public T process(ProcessIndicatorItemWrapper<T> wrapper) throws java.lang.Exception
Use the technical identifier to mark the input row as processed and return unwrapped item.- 指定者:
process
在接口中ItemProcessor<ProcessIndicatorItemWrapper<T>,T>
- 参数:
wrapper
- to be processed- 返回:
- potentially modified or new item for continued processing,
null
if processing of the provided item should not continue. - 抛出:
java.lang.Exception
- thrown if exception occurs during processing.