如何使用带多线程的JdbcCursorItemReader从Oracle Db读取数据

Question

我有spring批处理应用程序，配置步骤如下：

ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
taskExecutor.setCorePoolSize(4);
taskExecutor.setMaxPoolSize(10);
taskExecutor.afterPropertiesSet();
return this.stepBuilderFactory.get("step1")
            .<Mymodel, Mymodel>chunk(2500)              
            .reader(reader())
            .writer(writer())
            .taskExecutor(taskExecutor)
            .build();

像这样的读者：

@Bean
public JdbcCursorItemReader<Mymodel> reader() {
    JdbcCursorItemReader<Mymodel> reader = new JdbcCursorItemReader<Mymodel>();
    reader.setDataSource(dataSource);
    reader.setSql("select * from User");
    reader.setRowMapper(new BeanPropertyRowMapper<>(Mymodel.class));
    reader.setVerifyCursorPosition(false);
    return reader;
}

当我执行应用程序，得到这个错误：

组织。springframework。jdbc。UncategorizedSQLException:尝试处理下一行失败；SQL的未分类SQLException[select*from User]；SQL状态[99999]；错误代码[17289]；最后一行之后的结果集；嵌套的例外是java。sql。SQLException:最后一行之后的结果集

你能帮我解决这个问题吗。

Answer 1

JdbcCursorItemReader不是线程安全的，因为它包装了一个不是线程安全的ResultSet对象。

您可以使用线程安全的JdbcPagingItemReader，并可选择配置页面大小以匹配块大小，以便在同一线程中处理每个页面。

更多细节见以下答案：https://stackoverflow.com/a/28724199/5019386.

希望这有帮助。