處理多個StoredProcedureItemReader調用

Question

我要實現以下用例在春季批處理作業：

1. 通過列表，經由StoredProcedureItemReader
2. 迭代閱讀供應商的名單，並呼籲另一StoredProcedureItemReader對每個供應商（如輸入參數）。
3. 第二個SP的輸出將被寫入CSV。

我想出了以下策略：

1. 步驟開始
2. SP ItemReader返回供應商的名單。
3. 在ItemWriter，提供者保存到ExecutionContext
4. 步驟1結束
5. 步驟2開始
6. 另一SP ItemReader從ExecutionContext
7. 訪問提供商另一個ItemWriter寫入使用FlatFileItemWriter
到CSV的響應

我無法理解第二個SP ItemReader將如何訪問由第一個SP ItemReader返回的提供者列表。分區會在這裏幫助嗎？另外，有沒有更好的策略來完成這個？

EDIT 1：

下面是原來實行ItemProcessor中的（如富集）：

@Scope("step") 
public class FetchReportFromProviderProcessor implements 
     ItemProcessor<RiscProvider, List<SogReportRecord>>, ItemStream { 

    StoredProcedureItemReader<SogReportRecord> reader = new StoredProcedureItemReader<SogReportRecord>(); 
    private DataSource dataSource; 

    @Value("#{jobParameters['date']}") 
    private String date; 

    @Override 
    public List<SogReportRecord> process(final RiscProvider item) throws Exception { 

     SogReportRecord record = null; 
     List<SogReportRecord> records = new ArrayList<SogReportRecord>(); 

     SqlParameter[] sqlParameters = new SqlParameter[] {new SqlParameter(OracleTypes.CURSOR)};   

     reader.setParameters(sqlParameters); 
     reader.setPreparedStatementSetter(new PreparedStatementSetter() { 

      @Override 
      public void setValues(PreparedStatement ps) throws SQLException { 
       ps.setString(0, item.getPrefix()); 
       ps.setString(1, date); 
      } 
     }); 

     while((record = reader.read()) != null) { 
      records.add(record); 
     } 

     return records; 
    } 

    public DataSource getDataSource() { 
     return dataSource; 
    } 

    public void setDataSource(DataSource dataSource) { 
     this.dataSource = dataSource; 
    } 

    @Override 
    public void open(ExecutionContext executionContext) 
      throws ItemStreamException { 
     reader.setDataSource(dataSource); 
     reader.setProcedureName("RISC_GET_DAYMOVEINOUT"); 
     reader.open(executionContext);  
    } 

    @Override 
    public void update(ExecutionContext executionContext) 
      throws ItemStreamException { 
     reader.update(executionContext);   
    } 

    @Override 
    public void close() throws ItemStreamException { 
     reader.close();  
    } 

} 

和XML部分：

<batch:job id="SOG_MOVEINOUT_REPORT_GENERATOR"> 
    <batch:step id="GET_REPORTS"> 
     <batch:tasklet> 
      <batch:chunk reader="getProviders" 
       processor="fetchRecordsFromProvider" 
       writer="sogReportWriter" commit-interval="500" /> 
     </batch:tasklet> 
    </batch:step> 
</batch:job> 

<!-- Reader to fetch list of providers --> 
<bean id="getProviders" class="org.springframework.batch.item.database.StoredProcedureItemReader"> 
    <property name="dataSource" ref="dataSource" /> 
    <property name="procedureName" value="RISC_GET_PROVIDER" /> 
    <property name="parameters"> 
     <list> 
      <bean class="org.springframework.jdbc.core.SqlOutParameter"> 
       <constructor-arg index="0" value="providers" /> 
       <constructor-arg index="1"> 
        <util:constant static-field="oracle.jdbc.OracleTypes.CURSOR" /> 
       </constructor-arg> 
      </bean> 
     </list> 
    </property> 
    <property name="refCursorPosition" value="1" /> 
    <property name="rowMapper"> 
     <bean class="com.kpn.risc.ProviderRowMapper" /> 
    </property> 
</bean> 

<bean id="fetchRecordsFromProvider" class="com.kpn.risc.FetchReportFromProviderProcessor"> 
    <property name="dataSource" ref="dataSource" /> 
</bean> 

<bean id="sogReportWriter" class="org.springframework.batch.item.file.FlatFileItemWriter" scope="step"> 
    <property name="resource" value="file:///${batch.job.report.dir}/report-#{stepExecutionContext['provider']}.csv" /> 
    <property name="lineAggregator"> 
     <bean class="org.springframework.batch.item.file.transform.DelimitedLineAggregator"> 
      <property name="fieldExtractor"> 
       <bean class="org.springframework.batch.item.file.transform.PassThroughFieldExtractor" /> 
      </property> 
     </bean> 
    </property> 
</bean> 

在上面的代碼中，處理器是將其工作委託給SP ItemReader。但是在調用read()方法之前，讀者無法正確初始化。 ItemProcessor內部是否可以或建議撥打ItemReader？

Answer 1

您所描述的內容直接落入批處理的駕駛查詢模式。從本質上講，查詢定義了另一個查詢用來驅動查詢的id（或在您的案例提供者中）。通常，ItemReader會讀取ID並將每個ID傳遞給ItemProcessor以進行富集（「其他」查詢）。然後將結果傳遞給ItemWriter。

您可以在Spring Batch的文檔，這裏的公共批處理模式部分閱讀更多關於驅動查詢模式：http://docs.spring.io/spring-batch/trunk/reference/html/patterns.html