Использование ItemWriter со списком списков

Question

Наш процессор возвращает список (эффективно передающий List<List<?>>) на наш ItemWriter. Теперь мы заметили, что JdbcBatchItemWriter не запрограммирован для обработки элемента instanceof List. Мы также заметили, что обрабатываем элемент экземпляра List; нам нужно написать обычай ItemSqlParameterSourceProvider. Но печальная часть заключается в том, что он возвращает SqlParameterSource, который может обрабатывать только один объект и снова не способен обрабатывать список. Итак, кто-то может помочь нам понять, как обрабатывать список списков в JdbcBatchItemWriter.

Answer 1

Как правило, дизайн картина:

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

Если ваш процессор возвращается List<Object>, то вам нужен писатель ожидать List<List<Object>>.

Вы могли бы сделать это, обернув вашего JdbcBatchItemWriter в качестве делегата в качестве ItemWriter, который выглядит примерно так:

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; 
    } 

}