无法使用groovy/spock从端到端启动Spring批处理作业-集成测试

Question

我最近开始进行groovy测试，以测试使用一个步骤（ItemReader、ItemProcessor、ItemWriter）的spring批处理作业

知道我正在使用h2内存数据库，我已尝试通过单元测试启动作业，但无法验证作业是否已完成：

    def 'test launch job'() {
    given:
    def projectId = 1234L
    def fileType = FileType.TEST
    def sourceId = 1234506L
    def enteredBy = 'groovy_unit_test'
    def prePlanYear = 2022L

    when:
 
    JobParametersBuilder builder = new JobParametersBuilder();
    builder.addLong("projectId", projectId)
            .addString("fileType", fileType.toString())
            .addLong("sourceId", sourceId)
            .addString("enteredBy", enteredBy)
            .addLong("prePlanYear", prePlanYear)
    //JobExecution jobExecution = jobLauncher.launchJob( builder.toJobParameters())
    JobExecution jobExecution = jobLauncher.launchStep(JobConstants.StepNames.xwalkMappingStep.name(), builder.toJobParameters())
  then: 'Job completes with no errors.'
   jobExecution.status == BatchStatus.COMPLETED
   //jobExecution.exitStatus == ExitStatus.COMPLETED
}

此外，当我试图调试它时，它不会从一端到另一端，而是在测试完成后在ItemReader中停止。我知道这不是等待工作完成。

有没有办法在工作完成后才完成测试？

@PropertySource('classpath:application.properties')
@ActiveProfiles('test')
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.DEFINED_PORT, properties = ["spring.h2.console.enabled=true"])
@ImportAutoConfiguration([ FeignAutoConfiguration.class])
@Import([TestConfig.class])
class BaseSpec extends Specification{

    @PersistenceContext
    EntityManager entityManager

    @Autowired
    JobRepository jobRepository

    @Autowired
    DataSource dataSource

    @Autowired
    JpaTransactionManager jpaTransactionManager

    @Autowired
    JobLauncherTestUtils jobLauncher

}

@Configuration
@EnableBatchProcessing
class TestConfig {
}

非常感谢。

Answer 1

这是因为您没有运行整个作业，而只是在这里执行其步骤：

JobExecution jobExecution = jobLauncher.launchStep(JobConstants.StepNames.xwalkMappingStep.name(), builder.toJobParameters())

您应该使用JobLauncher#launchJob运行作业，而不仅仅是步骤。