Spring Batch:父子关系的项目编写器

Question

我已经编写了一个返回对象列表的项处理器。此对象需要拆分为2个数据库表(一个父表和一个子表(。一个标题行，对于这个相应的标题ID，我们在子表中有关联的子行。我使用了ListUnpackingItemWriter的例子来解决列表问题。我已经使用CompositeItemWriter将结果拆分为2个编写器，现在我需要为标头和子表拆分每个编写器。现在，每个编写器都有相同数量的行。有更好的方法吗？解决两个表的主键问题。我需要示例编写自定义项目编写器，它在插入之前进行验证。提前感谢您。

以下是代码

public JdbcBatchItemWriter<T> myWriter() {
JdbcBatchItemWriter<T> myWriter = new JdbcBatchItemWriter<T>(); 
myWriter.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<T>());   
myWriter.setSql("INSERT INTO Parent table( colums) values ( values )");
myWriter.setDataSource(dataSource);
myWriter.afterPropertiesSet();
return myWriter;
}
public JdbcBatchItemWriter<T> myOtherWriter() {
JdbcBatchItemWriter<T> myWriter = new JdbcBatchItemWriter<T>(); 1
myWriter.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<T>());   
myWriter.setSql("INSERT INTO child table( colums) values ( values )");
myWriter.setDataSource(dataSource);
myWriter.afterPropertiesSet();
return myWriter;
}
public CompositeItemWriter<T> compositeItemWriter() {
CompositeItemWriter<T> writer = new CompositeItemWriter<T>();
writer.setDelegates(Arrays.asList(myWriter(),myOtherWriter())); 
return writer;
}
```

Answer 1

如果复合编写器不适合您，那么您可以使用自定义编写器吗，比如：

import java.util.List;
import javax.sql.DataSource;
import org.springframework.batch.item.ItemWriter;
import org.springframework.jdbc.core.JdbcTemplate;
public class MyParentChildWriter implements ItemWriter<Object> {
private JdbcTemplate jdbcTemplate;
public MyParentChildWriter(DataSource dataSource) {
this.jdbcTemplate = new JdbcTemplate(dataSource);
}
@Override
public void write(List<?> items) {
for (Object item : items) {
// get parent/child values from item and use them in the query as needed
jdbcTemplate.update("INSERT INTO Parent table( colums) values ( values )");
jdbcTemplate.update("INSERT INTO child table( colums) values ( values )");
}
}
}

请注意，所有更新语句都将在单个事务中执行，如面向区块的处理部分所述。