Spring批處理 - 如何在處理單個記錄後將數據寫入多行？

Question

我bean類，如下 -

public class Account { 
    private String strAccNumber = ""; 

    private List<Account> accountList = new ArrayList<Account>(); 

    // getter setter 
.... 
... 
@Override 
    public String toString() { 
     // code for PassThroughLineAggregator 
     String data=""; 
        for (int j=0; j<accountList.size(); j++) { 
      Account bean = accountList.get(j); 
      data = data + bean.getStrAccNumber(); 
      if (j<(accountList.size()-1)) { 
       data = data + "\n"; 
           }  
     } 
     return data; 
    } 
} 

寫數據我想設置爲accountList在我的配置文件。 我使用下面的代碼來設置bean屬性。

<bean id="flatFileReader" class="org.springframework.batch.item.file.FlatFileItemReader" 
    scope="step"> 
    <property name="resource" value="classpath:springBatch.csv" /> 
    <property name="strict" value="false"></property> 
    <property name="linesToSkip" value="1" /> 
    <property name="lineMapper"> 
     <bean class="org.springframework.batch.item.file.mapping.DefaultLineMapper"> 
      <property name="lineTokenizer"> 
       <bean 
        class="org.springframework.batch.item.file.transform.DelimitedLineTokenizer"> 
        <property name="names" value="ACC#" /> 
       </bean> 
      </property> 
      <property name="fieldSetMapper"> 
       <bean 
        class="com.abc.reader.AccountDetailsFieldSetMapper" /> 
      </property> 
     </bean> 
    </property> 
</bean> 
<bean id="flatFileProcessor" 
    class="com.abc.processor.AccountItemProcessor" 
    scope="step"></bean> 
<bean id="flatFileWriter" 
     class="com.abc.FlatFileItemWriterListener" 
     scope="step"> 
     <property name="resource" value="classpath:springBatch1.csv" /> 

     <property name="lineAggregator"> 
      <bean class="org.springframework.batch.item.file.transform.DelimitedLineAggregator"> 
       <property name="fieldExtractor"> 
        <bean class="org.springframework.batch.item.file.transform.BeanWrapperFieldExtractor"> 
         <property name="names" value="strAccNumber" /> 
        </bean> 
       </property> 
      </bean> 
     </property> 

    </bean> 

AccountItemProcessor -

public class AccountItemProcessor implements ItemProcessor<Account, List<Account>>{ 

@Override 
public List<Account> process(Account accObj) throws Exception { 
    // logic.. 
} 

，在加工步驟處理單個記錄後，我想寫多個項目（項目列表），我怎麼能在同一時間使用的ArrayList寫多個項目。在我的情況下，我想從帳戶列表中寫入數據。

Answer 1

你會想要實現自己的LineAggregator。這就是String被寫入文件的原因。在你的情況下，你會寫一個返回一個String，這真的是多行。

您可以將文檔在這裏閱讀更多關於LineAggregator接口：http://docs.spring.io/spring-batch/apidocs/org/springframework/batch/item/file/transform/LineAggregator.html