代码之家 › 专栏 › 技术社区 › Tyvain

Springbatch处理器:在这种情况下是什么对象?

spring-batch

Tyvain · 技术社区 · 6 年前

我有一个输入数据库myinpuntety,比如:

id, name, someCode
1,john,code_abc
2,jack,code_xyz

此文件由Spring批处理作业处理,它在这两个表中创建的每一行都是:

OutPerson:
id
name

OutCode:
code

配置为:

@Bean
public Step step3_readDBWriteDB(OutCodeRepository outCodeRepository) {
    return stepBuilderFactory.get("step3_readDBWriteDB")
            .<MyInputEntity, OutPerson>chunk(100)
            .reader(myReader())
            .processor(new MyItemProcessor(outCodeRepository))
            .writer(myWriter()).build();
}

项处理器如下所示:

@Override
 public OutPerson process(MyInputEntity myInput) {       
        // creation of Person
        OutPerson outPerson = MyMapper.convert(myInput);

        // Create and save outCode
        OutCode outCode = new outCode(myInput.getCode());
        OutCodeRepository.save(outCode)

        return outPerson;
    }

这里的问题是,这个人被处理成100块。所以代码保存在Everyline上,每100行保存一个人。

我觉得有问题,应该换个方法,但我不知道怎么办?我应该为“代码”创建另一个处理器吗?在这种情况下,最佳实践是什么(对于Everyline,在多表中创建)?

2 回复 | 直到 6 年前

Mahmoud Ben Hassine 6 年前

我建议创建一个包装类,例如 MyOutputEntity 封装的 OutPerson 和 OutCode . 这个类将是处理器的输出和编写器的输入。作者将在同一个事务中同时插入人员和代码(这样在失败的情况下,您的数据是一致的)。例如:

class MyOutputEntity {
   private OutPerson outPerson;
   private OutCode outCode;
   // getters and setters
}

public ItemProcessor<MyInputEntity, MyOutputEntity> itemProcessor() {
    return myInputEntity -> {
        // create Person
        OutPerson outPerson = MyMapper.convert(myInputEntity);

        // Create outCode
        OutCode outCode = new outCode(myInputEntity.getCode());

        MyOutputEntity myOutputEntity = new MyOutputEntity();
        myOutputEntity.setOutPerson(outPerson);
        myOutputEntity.setOutCode(outCode);

        return myOutputEntity;
    };
}

public ItemWriter<MyOutputEntity> itemWriter() {
    return items -> {
        for (MyOutputEntity outputEntity : items) {
            outPersonRepository.save(outputEntity.getOutPerson());
            outCodeRepository.save(outputEntity.getOutCode());
        }
    };
}

希望这有帮助。

Igor Konoplyanko 6 年前

我建议继续把所有的逻辑写进作家,因为这就是作家的目的。我认为最好的方法是在编写器中同时编写代码和人员(假设这是相同的数据库,所以它们将在相同的事务中编写)。

但请注意,它们将用块写入= chunk(100)

这样,当对数据库的一次写入可能因任何错误而失败时,您还可以从Spring批处理的回退机制中获益。根据目前的情况,我认为你需要自己解决。

推荐文章

Abhilash Muthuraj · 用于构建文件操作过程的Spring批处理或Spring核心库

7 年前

Nipuna Don Pranciscu · Spring批处理读取器抱怨资源

7 年前

PlickPlick · 使用@MockBean模拟带有@BeforeStep的ItemReader会对带有@BeforeStep Anotion的许多方法引发异常。我该如何解决它?

7 年前

Sheep · Spring聚合器聚合输入组

7 年前

Ares91 · Java Spring批处理使用嵌入式数据库作为元数据,使用第二个数据库作为其他数据

7 年前

R.Henderson · 我只能使用spring batch的itemReader吗

7 年前

Nikhil Pareek · 如何使用具有Java配置的CommandLineJobRunner启动Spring批处理作业

7 年前

bernardo · 无需声明额外的TaskScheduler

7 年前

Florent06 · 在上一个批处理作业启动5秒后启动计划的spring批处理作业

7 年前

tero17 · 读取大文件的最佳方式spring boot

7 年前