リストリストにItemWriterを使用

Question

私たちのプロセッサはリストを返します（実質的にはList<List<?>>を渡します）。ItemWriterです。ここで、JdbcBatchItemWriterは、項目instanceof Listを処理するようにプログラムされていないことがわかりました。我々はまた、項目instanceof Listを処理することを観察した。カスタムItemSqlParameterSourceProviderを書く必要があります。しかし、悲しいことに、それはSqlParameterSourceを返すということです。これは1つのオブジェクトしか扱えず、再びListを扱うことができません。したがって、誰かがJdbcBatchItemWriterのリストのリストを処理する方法を理解するのを助けることができますか？

Answer 1

通常、デザインパターンは次のとおりです。

Reader -> reads something, returns ReadItem 
Processor -> ingests ReadItem, returns ProcessedItem 
Writer -> ingests List<ProcessedItem> 

プロセッサがList<Object>を返している場合、あなたはList<List<Object>>を期待するあなたのライターを必要としています。

あなたは次のようになりますItemWriterに代理人としてあなたJdbcBatchItemWriterをラップすることによってこれを行うことができます：

public class ListUnpackingItemWriter<T> implements ItemWriter<List<T>>, ItemStream, InitializingBean { 

    private ItemWriter<T> delegate; 

    @Override 
    public void write(final List<? extends List<T>> lists) throws Exception { 
     final List<T> consolidatedList = new ArrayList<>(); 
     for (final List<T> list : lists) { 
      consolidatedList.addAll(list); 
     } 
     delegate.write(consolidatedList); 
    } 

    @Override 
    public void afterPropertiesSet() { 
     Assert.notNull(delegate, "You must set a delegate!"); 
    } 

    @Override 
    public void open(ExecutionContext executionContext) { 
     if (delegate instanceof ItemStream) { 
      ((ItemStream) delegate).open(executionContext); 
     } 
    } 

    @Override 
    public void update(ExecutionContext executionContext) { 
     if (delegate instanceof ItemStream) { 
      ((ItemStream) delegate).update(executionContext); 
     } 
    } 

    @Override 
    public void close() { 
     if (delegate instanceof ItemStream) { 
      ((ItemStream) delegate).close(); 
     } 
    } 

    public void setDelegate(ItemWriter<T> delegate) { 
     this.delegate = delegate; 
    } 

}