使用 JdbcBatchItemWriter 编写项目列表

Question

目前我正在使用 JpaItemWriter 编写对象列表，如下所示，工作正常。由于性能问题，现在我想将 JpaItemWriter 更改为 JdbcBatchItemWriter。

    public class MyItemWriter implements ItemWriter<List<MyDomainObject>> {

    @Override  
    public void write(List<? extends Lists<MyDomainObject>> items) {
    JpaItemWriter<MyDomainObject> writer = new JpaItemWriter<>();    
    for(List<MyDomainObject> o : items)
        {
          writer.write(o);
        }
      }
    }

建议使用 JdbcBatchItemWriter 编写对象列表的示例片段会有所帮助。尝试使用 ItemSqlParameterSourceProvider 它并没有帮助结束 org.springframework.dao.InvalidDataAccessApiUsageException: No value supplied for the SQL parameter 异常

Answer 1

你的例子不正确。您正在 write 方法中创建一个 JpaItemWriter，因此每次调用 write 时都会创建一个新实例。这可能是您的性能问题的原因。

更重要的是，委托编写器 (open/update/close) 的生命周期方法将不会得到尊重（JpaItemWriter 不实现 ItemStream 的情况并非如此，但这是如果委托是项目流，则会出现问题）。您的 MyItemWriter 实施应该类似于：

public class MyItemWriter implements ItemWriter<List<MyDomainObject>> {

   private JpaItemWriter jpaItemWriter;

   public MyItemWriter(JpaItemWriter jpaItemWriter) {
      this. jpaItemWriter = jpaItemWriter;
   }

   @Override  
   public void write(List<? extends Lists<MyDomainObject>> items) {  
     for(List<MyDomainObject> o : items) {
       this. jpaItemWriter.write(o);
     }
   }
}

现在如果要使用JdbcBatchItemWriter写列表列表，请参见。

编辑：添加了如何按照评论中的要求设置委托的示例代码：

@Bean
public ListUnpackingItemWriter<T> itemWriter() {
    JdbcBatchItemWriter<T> jdbcBatchItemWriter = null; // configure your jdbcBatchItemWriter
    ListUnpackingItemWriter<T> listUnpackingItemWriter = new ListUnpackingItemWriter<>();
    listUnpackingItemWriter.setDelegate(jdbcBatchItemWriter);
    return listUnpackingItemWriter;
}

使用 JdbcBatchItemWriter 编写项目列表

Writing List of Items using JdbcBatchItemWriter

list

spring-jdbc

spring-batch

compositeitemwriter