spring-batch - Spring 批| MongoItemReader |如何将 JobParameters 传递给 mongo 查询？

Question

如何将 JobParameters 传递给 MongoItemReader 查询？

我的 ItemReader 看起来像:-

@Bean
public ItemReader<Person> PersonTenantBasedItemReader() {
    MongoItemReader<Person> reader = new MongoItemReader<Person>();
    reader.setTemplate(mongoTemplate);
    reader.setTargetType((Class<? extends Person>) Person.class);
    reader.setQuery("{status:'XYZ',nextCheckpointDate:{$gte:?fromDate,$lte:?toDate}"); // !!!!I want to pass fromDate and toDate as job parameters. !!!!    
    Map<String, Direction> sorts = new HashMap<String, Sort.Direction>(1);
    sorts.put("status", Sort.Direction.ASC);
    reader.setSort(sorts);
    return reader;
}

这就是我启 Action 业的方式:-

@Test
public void test() throws Exception {
    Map<String, JobParameter> map = new HashMap<String, JobParameter>(2);
    map.put("fromDate", new JobParameter(new Date()));
    map.put("toDate", new JobParameter(//some future date comes here);
    JobParameters jobParameters = new JobParameters(map);
    JobExecution run = launcher.run(job, jobParameters);
    Assert.assertNotNull(run);
}

我收到这个异常:-

com.mongodb.util.JSONParseException: 
{status:'DELINQUENT',nextCheckpointDate:{$gte:?fromDate,$lte:?toDate}
                                              ^
    at com.mongodb.util.JSONParser.parse(JSON.java:216)
    at com.mongodb.util.JSONParser.parseObject(JSON.java:249)
    at com.mongodb.util.JSONParser.parse(JSON.java:213)
    at com.mongodb.util.JSONParser.parseObject(JSON.java:249)
    at com.mongodb.util.JSONParser.parse(JSON.java:213)
    at com.mongodb.util.JSONParser.parse(JSON.java:163)
    at com.mongodb.util.JSON.parse(JSON.java:99)
    at com.mongodb.util.JSON.parse(JSON.java:79)
    at org.springframework.data.mongodb.core.query.BasicQuery.<init>(BasicQuery.java:39)
    at org.springframework.batch.item.data.MongoItemReader.doPageRead(MongoItemReader.java:176)
    at org.springframework.batch.item.data.AbstractPaginatedDataItemReader.doRead(AbstractPaginatedDataItemReader.java:59)
    at org.springframework.batch.item.support.AbstractItemCountingItemStreamItemReader.read(AbstractItemCountingItemStreamItemReader.java:88)
    at org.springframework.batch.core.step.item.SimpleChunkProvider.doRead(SimpleChunkProvider.java:91)
    at org.springframework.batch.core.step.item.SimpleChunkProvider.read(SimpleChunkProvider.java:155)
    at org.springframework.batch.core.step.item.SimpleChunkProvider$1.doInIteration(SimpleChunkProvider.java:114)

Answer 1

我发现您的配置存在两个问题:

1. 为了注入(inject)JobParameter 值，您需要使用Step 范围。您的 bean 当前配置为使用单例范围(默认)。
2. 您实际上并没有将参数注入(inject)到您的方法中。

尝试以下方法:

@Bean
@StepScope
public MongoItemReader<Person> PersonTenantBasedItemReader(@Value("#{jobParameters[fromDate]}") String fromDate, @Value("#{jobParameters[toDate]}") String toDate) {
    MongoItemReader<Person> reader = new MongoItemReader<Person>();
    reader.setTemplate(mongoTemplate);
    reader.setTargetType((Class<? extends Person>) Person.class);
    reader.setQuery(String.format("{status:'XYZ',nextCheckpointDate:{ %s ? %s }", fromDate, toDate));
    Map<String, Direction> sorts = new HashMap<String, Sort.Direction>(1);
    sorts.put("status", Sort.Direction.ASC);
    reader.setSort(sorts);
    return reader;
}