springbatch对xml文件的读写数据操作

读数据:

@Configuration
public class ItemReaderXmlDemo {
    @Autowired
    private JobBuilderFactory jobBuilderFactory;
    @Autowired
    private StepBuilderFactory stepBuilderFactory;
    @Autowired
    private ItemReader<Person> xmlReader;

    @Bean
    public Job itemReaderXmlJob() throws ClassNotFoundException {
        return jobBuilderFactory.get("itemReaderXmlJob")
                .start(itemReaderXmlStep())
                .build();
    }

    public Step itemReaderXmlStep() throws ClassNotFoundException {
        return stepBuilderFactory.get("itemReaderXmlStep")
                .<Person, Person>chunk(2)
                .reader(xmlReader)
                .writer(list -> {
                    for (Person person : list) {
                        System.out.println(person);
                    }
                }).build();
    }


}

写数据:

@Configuration
public class ItemWriteXmlDemo {
    @Autowired
    private JobBuilderFactory jobBuilderFactory;
    @Autowired
    private StepBuilderFactory stepBuilderFactory;
    @Autowired
    private ItemReader<Person> dbReader;
    @Autowired
    private ItemWriter<Person> xmlWrite;

    @Bean
    public Job itemWriteXmlJob() {
        return jobBuilderFactory.get("itemWriteXmlJob")
                .start(itemWriteXmlStep())
                .build();
    }

    @Bean
    public Step itemWriteXmlStep() {
        return stepBuilderFactory.get("itemWriteXmlStep")
                .<Person, Person>chunk(1)
                .reader(dbReader)
                .writer(xmlWrite)
                .build();
    }
}

 


版权声明:本文为lyf_ldh原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。