Spring批处理：单元测试后期绑定

Question

我的阅读器配置如下：

<bean name="reader" class="...Reader" scope="step">
    <property name="from" value="#{jobParameters[from]}" />
    <property name="to" value="#{jobParameters[to]}" />
    <property name="pageSize" value="5"/>
    <property name="saveState" value="false" /> <!-- we use a database flag to indicate processed records -->
</bean>

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration({"classpath:testApplicationContext.xml"})
@ActiveProfiles({"default","mock"})
@TestExecutionListeners( {StepScopeTestExecutionListener.class })
public class TestLeadsReader extends    AbstractTransactionalJUnit4SpringContextTests {

@Autowired
private ItemStreamReader<Object[]> reader;

public StepExecution getStepExecution() {
    StepExecution execution = MetaDataInstanceFactory.createStepExecution();
    execution.getExecutionContext().putLong("campaignId", 1);
    execution.getExecutionContext().putLong("partnerId", 1);

    Calendar.getInstance().set(2015, 01, 20, 17, 12, 00);
    execution.getExecutionContext().put("from", Calendar.getInstance().getTime());
    Calendar.getInstance().set(2015, 01, 21, 17, 12, 00);
    execution.getExecutionContext().put("to", Calendar.getInstance().getTime());
    return execution;
}

@Test
public void testMapper() throws Exception {
    for (int i = 0; i < 10; i++) {
        assertNotNull(reader.read());
    }
    assertNull(reader.read());
}

另外，在读取器进入测试方法之前，不调用open（executionContext）方法，这是不对的，因为我使用这些作业参数来检索调用读取方法时需要可用的一些数据。这可能与上面的问题有关，因为关于使用后期绑定进行测试的文档说“读取器被初始化并绑定到输入数据”。

Answer 1

您正在将from和to设置为测试中的步骤执行上下文变量。但是在您的应用程序上下文配置中，您将它们作为作业参数进行检索。您应该将它们设置为单元测试中的作业参数。

另外，如果希望调用Open/Update/CloseItemStream生命周期方法，则应该执行该步骤。参见http://docs.spring.io/spring-batch/trunk/apidocs/org/springframework/batch/test/joblaunchertestutils.html#launchstep-java.lang.string-org.springframework.batch.core.jobparameters-