Java Spring批处理StoredProcedureItemReader实现（SYSBASE IQ）

Question

@Bean(destroyMethod="")
@StepScope
public StoredProcedureItemReader<TransactionReportingBean>  dataExtractReader(
    @Value("#{jobParameters[clientName]}") String clientName) throws Exception {

    StoredProcedureItemReader<TransactionReportingBean> 
    storedProcedureItemReader = new StoredProcedureItemReader<>();    
    storedProcedureItemReader.setDataSource(sybaseIqSource);

    storedProcedureItemReader.setProcedureName("getResult"); /**getClientPositionIBORData**/
    SqlParameter[] parameters = {new SqlParameter("ClientName", Types.VARCHAR)};
    storedProcedureItemReader.setParameters(parameters);

    storedProcedureItemReader.setPreparedStatementSetter(new PreparedStatementSetter() {
        @Override
        public void setValues(PreparedStatement arg0) throws SQLException {
            arg0.setString(1,clientName);
         }
        });

    storedProcedureItemReader.setRowMapper(new BeanPropertyRowMapper<TransactionReportingBean>(TransactionReportingBean.class));
    storedProcedureItemReader.afterPropertiesSet();

    storedProcedureItemReader.setVerifyCursorPosition(false);
    storedProcedureItemReader.close();
    return storedProcedureItemReader;
}

错误：

Answer 1

首先，您需要删除StoredProcedureItemReader.close()，Spring批处理将在结果集的末尾自动关闭读取器。

根据stacktrace,您可能需要将refcursorposition设置为1：

storedProcedureItemReader.setRefCursorPosition(1);

希望这有帮助。