使用JDBC读取的SpringBatch应用程序无法启动

Question

我有一些非常类似于下面的代码（我不得不做一些困惑）。我正在获取一个应用程序启动失败的错误。未显示的代码是datasource bean和spring boot application类。当我在debug中放置断点并运行所有bean时，所有bean似乎都被创建了，除了Job和Step bean，这两个bean似乎被完全跳过了。我不确定如何进一步诊断。似乎是一些Spring的魔法问题。任何想法都非常感谢。

下面是一个例外：

启动ApplicationContext时出错。若要显示条件报告，请在启用“调试”的情况下重新运行应用程序。2020-08-23 11:26:57.908错误12195---[主]O.S.B.D.LoggingFailureAnalysisReporter：

应用程序启动失败

说明：

进程结束，退出代码为%1

代码如下：

@Configuration
@EnableBatchProcessing
public class BatchConfig {

@Autowired
public JobBuilderFactory jobBuilderFactory;

@Autowired
public StepBuilderFactory stepBuilderFactory;


private static final String GET_DATA =
    "SELECT " +
            "stuffA, " +
            "stuffB, " +
            "FROM STUFF_TABLE " +
            "ORDER BY stuffA ASC";

@Bean
public ItemReader<StuffDto> itemReader(DataSource dataSource) {
    return new JdbcCursorItemReaderBuilder<StuffDto>()
        .name("cursorItemReader")
        .dataSource(dataSource)
        .sql(GET_DATA)
        .rowMapper(new BeanPropertyRowMapper<>(StuffDto.class))
        .build();
}

@Bean
    ItemProcessor<StuffDto, StuffDto> databaseXmlItemProcessor() {
        return new QueryLoggingProcessor();
    }

@Bean
    public ItemWriter<StuffDto> databaseCursorItemWriter() {
        return new LoggingItemWriter();
    }

@Bean
    public Step databaseCursorStep(@Qualifier("databaseCursorItemReader") ItemReader<StuffDto> reader,
                                   @Qualifier("databaseCursorItemWriter") ItemWriter<StuffDto> writer,
                                   StepBuilderFactory stepBuilderFactory) {
        return stepBuilderFactory.get("databaseCursorStep")
            .<StuffDto, StuffDto>chunk(1)
            .reader(reader)
            .writer(writer)
            .build();
}

@Bean
    public Job databaseCursorJob(@Qualifier("databaseCursorStep") Step exampleJobStep,
                                 JobBuilderFactory jobBuilderFactory) {
        return jobBuilderFactory.get("databaseCursorJob")
                .incrementer(new RunIdIncrementer())
                .flow(exampleJobStep)
                .end()
                .build();
    }
}

Answer 1

您的限定Bean名称是itemreader，而不是databasecursoritemreader。或者更改方法名，或者更改为DatabaseCursorStep(@qualifier（“itemreader”）

@Bean
public Step databaseCursorStep(@Qualifier("itemReader") ItemReader<StuffDto> reader,
                                   @Qualifier("databaseCursorItemWriter") ItemWriter<StuffDto> writer,
                                   StepBuilderFactory stepBuilderFactory) {
        return stepBuilderFactory.get("databaseCursorStep")
            .<StuffDto, StuffDto>chunk(1)
            .reader(reader)
            .writer(writer)
            .build();

     }

@Bean
public ItemReader<StuffDto> itemReader(DataSource dataSource) {
    return new JdbcCursorItemReaderBuilder<StuffDto>()
        .name("cursorItemReader")
        .dataSource(dataSource)
        .sql(GET_DATA)
        .rowMapper(new BeanPropertyRowMapper<>(StuffDto.class))
        .build();
}