Spring批处理：将内存数据库用于Spring批处理元数据表

Question

我使用Spring批处理从Oracle数据库读取数据并将结果写入CSV文件。

我还需要将spring批处理元数据表与oracle数据库分开，为此，我在批处理配置中配置了两个不同的数据源（spring批处理元数据的内存数据库）。

这是我的代码：

批处理配置。JAVA

@Configuration
@EnableBatchProcessing
@EnableScheduling
public class BatchConfiguration {

  @Autowired
  public JobBuilderFactory jobBuilderFactory;

  @Autowired
  public StepBuilderFactory stepBuilderFactory;    


  @Bean
  @Qualifier("businessDataSource")
  @ConfigurationProperties(prefix = "spring.business.datasource")
  public DataSource primaryDataSource() {
    return DataSourceBuilder.create().build();
  }

  @Bean
  @Primary
  @Qualifier("metadataDataSource")
  @ConfigurationProperties(prefix = "spring.metadata.datasource")
  public DataSource secondaryDataSource() {
    return DataSourceBuilder.create().build();
  }
}

然后我的itemReader bean看起来像：

@Bean
public ItemReader<Person> reader(@Qualifier("businessDataSource") DataSource dataSource) {
  .....
}

当我运行批处理时，一切正常。

但是当我尝试在我的BatchApplication中添加JobLauncher和JobBean时。java是这样的：

@Autowired
private JobLauncher jobLauncher;

@Autowired
private Job job;

批处理正在尝试将元数据数据库用于我的业务数据库：

原因：org。springframework。jdbc。BadSqlGrammarException：执行查询；糟糕的SQL语法

我的代码有问题吗？

真是多谢了

Answer 1

最后我得到了一个解决方案

我的读者bean是：

@Bean
public ItemReader<Person> reader(@Qualifier("businessDataSource") DataSource dataSource) {
  databaseReader.setDataSource(datasource);
   ....
}

我改变了它（现在它开始工作了）

@Bean
  public ItemReader<Person> reader() {
    JdbcCursorItemReader<Person> databaseReader = new JdbcCursorItemReader<>();
    databaseReader.setDataSource(primaryDataSource());
    ....
  }