具有不同实体的Spring Batch中的多个写入器

Question

Tasklet类是在以下三个方法中定义的：

    class Tasklet{
        doBeforeStep(){
        //Records a retrieved from the table.
        }

        doExecute(){
        //It opens the file and reads the file.
        //Does all the processing one by one and creates a 2 list of records to update into the database.
        }

        doAfterStep(){
        //The 2 list of records(Entities) are saved into the 2 different tables database using its corresponding repository class. Example:
RepositoryClass.saveall(List containing 105,000 records)  //using the CRUDRepository method
        }
    }

面临的问题：该文件包含150,000条记录，因此，在doExecute（）方法之后，它将150,000条数据记录存储在列表中。在doAfterStep（）方法中，它试图将列表中的所有150,000条记录保存到数据库中，从而导致事务超时错误。

解决办法：

            .get("stepToReadDataFromFile")
            .<Entity1, Entity2>chunk(1000)        
            .reader(FileReader()) 
            .processor(Processor())
            .writer(Writer())
            .build();```

public class FileProcessor extends ItemProcessor<Entity1, Entity2> {

在这个阶段，我们如何在这里发送2个实体，Entity2和entity3？

Answer 1

您可以将entity2和entity3组合在一个对象中，并调整ItemProcessor以返回这个组合的对象。例如：

public class ProcessResult {

    private Entity2 e2;
    private Entity3 e3;
} 

ItemProcessor看起来像：

public class FileProcessor extends ItemProcessor<Entity1, ProcessResult> {


    public ProcessResult process(Entity1 e1){
        //processing ....

        return new ProcessResult(entity2 , entity3);
    }
}

在ItemWriter中，您可以从ProcessResult访问Entity2和Entity3。