1

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

我已经更新了代码，不幸的是由于某些原因我无法上传确切的代码。如果不清楚，请告诉我。我在这里发现了一个类似的问题，但无法弄清楚作者中的展开部分：Use Spring Batch to write in different Data Sources

记录域.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;
        }

}
4

1 回答 1

0

您将在此处返回“插入”案例的复合项目编写器：

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;
    }
于 2020-11-04T09:45:00.407 回答