我创建了一个简单的Boot/Spring Batch 3.0.8.RELEASE作业。我创建了一个简单的类,它实现了JobParametersIncrementer来访问数据库,查找查询应该查找的天数,并将这些放入JobParameters对象中。
我需要在我的JdbcCursorItemReader中使用这个值,因为它是根据一个查找到的JobParameters来选择数据的,但是我无法通过Java来解决这个问题。XML的例子很多,Java的例子就不多了。
下面是我运行作业的BatchConfiguration类。
`
@Autowired
SendJobParms jobParms; // this guy queries DB and puts data into JobParameters
@Bean
public Job job(@Qualifier("step1") Step step1, @Qualifier("step2") Step step2) {
return jobs.get("DW_Send").incrementer(jobParms).start(step1).next(step2).build();
}
@Bean
protected Step step2(ItemReader<McsendRequest> reader,
ItemWriter<McsendRequest> writer) {
return steps.get("step2")
.<McsendRequest, McsendRequest> chunk(5000)
.reader(reader)
.writer(writer)
.build();
}
@Bean
public JdbcCursorItemReader reader() {
JdbcCursorItemReader<McsendRequest> itemReader = new JdbcCursorItemReader<McsendRequest>();
itemReader.setDataSource(dataSource);
// want to get access to JobParameter here so I can pull values out for my sql query.
itemReader.setSql("select xxxx where rownum <= JobParameter.getCount()");
itemReader.setRowMapper(new McsendRequestMapper());
return itemReader;
}
`
转载请注明出处:http://www.kldfzc.com/article/20230526/2482068.html