问题描述
我有一个要求，我需要使用两个不同的对象填充两个不同的表。我将（列表和列表）包装到Custemp对象中，但是无法弄清楚如何使用CompositeItemWriter使用单独的数据源编写它。 请帮忙
很遗憾，我已经更新了代码，由于某些原因，我无法上传确切的代码。如果不清楚，请通知我。 我在这里找到了类似的问题，但无法找出作者中的展开部分：Use Spring Batch to write in different Data Sources
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;
}
}
解决方法
您将在此处为“插入”案例返回一个复合项目编写器：
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<? super XYRecords>>) XYRecords-> {
if ("Check if qualifies to update the table") {
return updateItemWriter;
} else { // insert case
return insertItemWriter;;
}
});
return classifierCompositeItemWriter;
}