通过包装来自Processor Spring Batch的数据写入两个不同的表

Question

我有一个需求，需要使用两个不同的Object填充两个不同表。我正在将(List和List(包装到CustEmp对象中，但我无法弄清楚如何使用CompositeItemWriter使用单独的数据源编写它。请帮助

我已经更新了代码，不幸的是，由于某些原因，我无法上传确切的代码。如果不清楚，请告诉我。我在这里发现了一个类似的问题，但无法在作者中找出展开部分：使用Spring Batch在不同的数据源中进行编写

RecordsDomain.java

public class RecordsDomain{
private List<XYRecords> xyRecords;
private YZRecords yzRecords;
//getters & setters

}

ProcessorDomain.java-基于新要求

@Configuration
public class DomainProcessor implements ItemProcessor<InputDomain, RecordsDomain> {

@Override
public DomainProcessor process(InputDomain input) throws Exception {
RecordsDomain allRecords = new RecordsDomain();
//Processing logic- listXyRecords is of type List<XYRecords> 
and yxRecords is of type YXRecords, I am setting both in 
RecordsDomain//
dtrRecords.setXyRecords(listXyRecords);
dtrRecords.setYzRecords(yzRecords);
return dtrRecords;
}
}

DomainWriter.java

@Configuration
public class DomainWriter {
//CURRENTLY I have a Writer which unpacks and inserts/update a table based off List<XYRecords>. I need to add another writer which updates based off YZRecords. How do i go about that.//
@Autowired
DataSource dataSource;
public ItemWriter<List<XYRecords>> writer() throws Exception {
ListUnpackingItemWriter<XYRecords> listUnpackingItemWriter = new ListUnpackingItemWriter<>();
listUnpackingItemWriter.setDelegate(itemWriter());
return listUnpackingItemWriter;
}

public CompositeItemWriter<XYRecords> itemWriter() throws Exception {
CompositeItemWriter<XYRecords> itemWriter = new CompositeItemWriter<>();
ClassifierCompositeItemWriter<XYRecords> classifierCompositeItemWriter = getDataItemWriters(
insertItemWriter(), updateItemWriter());        
itemWriter.setDelegates(Arrays.asList(classifierCompositeItemWriter));
itemWriter.afterPropertiesSet();
return itemWriter;
}
public JdbcBatchItemWriter<XYRecords> insertItemWriter() {
JdbcBatchItemWriter<XYRecords> itemWriter = new JdbcBatchItemWriter<>();
itemWriter.setDataSource(dataSource);
itemWriter.setAssertUpdates(false);
itemWriter.setSql("INSERT QUERY");
ItemPreparedStatementSetter<XYRecords> setterStatus = new InsertPreparedStatementSetter();
itemWriter.setItemPreparedStatementSetter(setterStatus);
return itemWriter;
}

public JdbcBatchItemWriter<XYRecords> updateItemWriter() {
JdbcBatchItemWriter<XYRecords> itemWriter = new JdbcBatchItemWriter<>();
itemWriter.setDataSource(dataSource);
itemWriter.setAssertUpdates(false);
itemWriter.setSql("UPDATE QUERY");
ItemPreparedStatementSetter<XYRecords> setterStatus = new UpdatePreparedStatementSetter();
itemWriter.setItemPreparedStatementSetter(setterStatus);
return itemWriter;
}
private ClassifierCompositeItemWriter<XYRecords> getDataItemWriters(
ItemWriter<XYRecords> insertItemWriter,
ItemWriter<XYRecords> updateItemWriter) {
ClassifierCompositeItemWriter<XYRecords> classifierCompositeItemWriter = new ClassifierCompositeItemWriter<>();
classifierCompositeItemWriter
.setClassifier((Classifier<XYRecords, ItemWriter<? super XYRecords>>) XYRecords-> {
if ("Check if qualifies to update the table") {
return updateItemWriter;

} else {
CompositeItemWriter<XYRecords> compositeItemWriter=new CompositeItemWriter<>();
compositeItemWriter.setDelegates(Arrays.asList(insertItemWriter,updateItemWriter));
return compositeItemWriter;
}

});
return classifierCompositeItemWriter;
}
}

Answer 1

您正在返回一个用于"插入"；这里的案例：

private ClassifierCompositeItemWriter<XYRecords> getDataItemWriters(
ItemWriter<XYRecords> insertItemWriter,
ItemWriter<XYRecords> updateItemWriter) {
ClassifierCompositeItemWriter<XYRecords> classifierCompositeItemWriter = new ClassifierCompositeItemWriter<>();
classifierCompositeItemWriter
.setClassifier((Classifier<XYRecords, ItemWriter<? super XYRecords>>) XYRecords-> {
if ("Check if qualifies to update the table") {
return updateItemWriter;
} else {
CompositeItemWriter<XYRecords> compositeItemWriter=new CompositeItemWriter<>();
compositeItemWriter.setDelegates(Arrays.asList(insertItemWriter,updateItemWriter));
return compositeItemWriter;
}
});
return classifierCompositeItemWriter;
}

我认为这应该是类似于：

private ClassifierCompositeItemWriter<XYRecords> getDataItemWriters(
ItemWriter<XYRecords> insertItemWriter,
ItemWriter<XYRecords> updateItemWriter) {
ClassifierCompositeItemWriter<XYRecords> classifierCompositeItemWriter = new ClassifierCompositeItemWriter<>();
classifierCompositeItemWriter
.setClassifier((Classifier<XYRecords, ItemWriter<? super XYRecords>>) XYRecords-> {
if ("Check if qualifies to update the table") {
return updateItemWriter;
} else { // insert case
return insertItemWriter;;
}
});
return classifierCompositeItemWriter;
}