java - ItemReader reader() 无限循环

Question

我用 JdbcTemplate 实现了 ItemReader 。

问题是 read() 在无限循环中被调用。

public class MyReader implements ItemReader<Col>, InitializingBean {
    private JdbcTemplate jdbcTemplate;
    private RowMapper<Col> rowMapper;
    private String sql;
    private DataSource dataSource;

public Col read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException {
     Col col = jdbcTemplate.queryForObject(sql,null, rowMapper);            
     return col;
    }

}

Spring 批量配置:

<chunk reader="itemReader" writer="itemWriter"
            processor="itemProcessor" commit-interval="1" />


<bean id="itemReader"
    class="batch.MyReader"
    scope="step">
    <property name="dataSource" ref="dataSource" />
    <property name="sql" value="#{stepExecutionContext[sql]}" />
    <property name="rowMapper">
        <bean class="batch.ColMapper" />
    </property>
</bean>

Answer 1

这就是 Spring Batch 步骤的工作方式:ItemReader.read() 方法将被调用，直到它返回 null。