Spring Batch 4.0：带@StepScope的JdbcCursorItemReader方法代码未执行

先来看下你遇到的情况：你定义了一个带有@StepScope的JdbcCursorItemReader，并在Bean定义方法里手动调用了open()、read()、close()方法来测试查询，但作业运行时这部分代码完全没执行；移除@StepScope后代码能跑，但又无法绑定传入的JobParameters。

核心原因 #

这其实是对@StepScope的生命周期和Spring Batch组件管理逻辑的误解导致的：

1. @StepScope的懒加载特性：带有@StepScope的Bean不会在Spring容器启动时就实例化，而是要等到对应的Step开始执行时才会创建真正的实例。你在Bean定义方法里写的手动调用open/read/close的代码，是在容器初始化Bean定义阶段执行的——这时候只是生成了一个代理对象，真正的JdbcCursorItemReader实例还没被创建，所以那部分代码自然不会执行。
2. 手动干预框架生命周期：Spring Batch本身会自动管理ItemReader的生命周期：Step启动时调用open()，读取数据时循环调用read()，Step结束时调用close()。你手动调用这些方法的逻辑完全多余，且时机完全不对。

解决方案 #

把Bean定义方法里手动执行的测试逻辑移除，让Spring Batch框架来管理ItemReader的生命周期，同时通过@StepScope正确注入JobParameters。

修正后的代码示例：

@StepScope
@Bean
public JdbcCursorItemReader<QueryCount> queryCountItemReader(
        @Value("#{jobParameters[fromDate]}") String fromDate,
        @Value("#{jobParameters[toDate]}") String toDate,
        @Value("#{jobParameters[eventType]}") String eventType,
        @Value("#{jobParameters[businessUnit]}") String businessUnit,
        @Value("#{jobParameters[numberOfSearchIds]}") String numberOfSearchIds) throws Exception {

    ListPreparedStatementSetter preparedStatementSetter = new ListPreparedStatementSetter() {
        @Override
        public void setValues(PreparedStatement pstmt) throws SQLException {
            // 直接使用注入的参数，无需重复写SpEL表达式
            pstmt.setString(1, fromDate);
            pstmt.setString(2, toDate);
            pstmt.setString(3, fromDate);
            pstmt.setString(4, toDate);
            pstmt.setString(5, fromDate);
            pstmt.setString(6, toDate);
            pstmt.setString(7, eventType);
            pstmt.setString(8, businessUnit);
            // 注意：原代码中的deviceCategory参数未在JobParameters中传入，需补充对应参数或调整逻辑
            pstmt.setString(9, "your-device-category");
            pstmt.setString(10, numberOfSearchIds);
        }
    };

    JdbcCursorItemReader<QueryCount> queryCountJdbcCursorItemReader = new JdbcCursorItemReader<>();
    queryCountJdbcCursorItemReader.setDataSource(dataSource);
    queryCountJdbcCursorItemReader.setSql(sqlQuery);
    queryCountJdbcCursorItemReader.setRowMapper(new QueryCountMapper());
    queryCountJdbcCursorItemReader.setPreparedStatementSetter(preparedStatementSetter);

    // 移除手动的open/read/close代码，交给Spring Batch框架自动处理
    return queryCountJdbcCursorItemReader;
}

如果需要验证查询结果，可以通过添加ItemListener或者在Step的执行逻辑中处理，不要在Bean定义方法里硬编码测试代码。

内容的提问来源于stack exchange，提问作者spectacledNinja