Spring Batch-连接到Postgres数据库的问题

Question

到目前为止，我一直在Spring Batch中使用内存中的H2 DB。然而，现在我切换到连接外部postgres DB。这是我的连接对象（有些模糊）：

@Bean
public DataSource postgresDatasource() {
    DriverManagerDataSource datasource = new DriverManagerDataSource();
    datasource.setDriverClassName("org.postgresql.Driver");
    datasource.setUrl("jdbc:postgresql://x.x.x.x:xxxx/blah");
    datasource.setUsername("Joe");
    datasource.setPassword("password");
    return datasource;
}

当我开始申请时，我得到：

原因：org。springframework。jdbc。BadSqlGrammarException:PreparedStatementCallback；错误的SQL语法[从批处理作业实例中选择作业实例ID、作业名称，其中作业名称=？和作业密钥=？]；嵌套的异常是org。postgresql。util。PSQLException:错误：关系“批处理作业实例”不存在

然后我读到Spring Batch使用数据库保存元数据以实现其恢复/重试功能，对于嵌入式数据库，这些是Spring Batch默认设置的表。这就解释了为什么我以前从未见过这个错误。

但是，它说我可以设置这个属性：

spring.batch.initialize-schema=never

所以我把这个放在我的application.properties文件中。然而，我仍然得到错误。我将感谢任何想法。

Answer 1

我自己也能解决这个问题。最终，我需要独立于实际目标关系数据库的Spring批处理存储库。所以我找到了这个参考：

https://github.com/spring-projects/spring-batch/blob/342d27bc1ed83312bdcd9c0cb30510f4c469e47d/spring-batch-core/src/main/java/org/springframework/batch/core/configuration/annotation/DefaultBatchConfigurer.java#L84

我能够从该示例中获取DefaultBatchConfigurer类，并通过添加@Qualifier for embedded/local data source对数据源进行了一个小的更改：

@Autowired(required = false)
public void setDataSource(@Qualifier("dataSource") DataSource dataSource) {
    this.dataSource = dataSource;
    this.transactionManager = new DataSourceTransactionManager(dataSource);
}

然后，在我的Spring批处理阅读器（在我的另一个批处理配置类中）上，我对数据源做了一个小改动，添加了@Qualifier for postgres数据源：

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

然后最后（或者首先真的像我首先做的那样），我明确地命名了我的数据源bean，以便java可以区分它们以如上所述使用：

@Configuration
public class PersistenceContext {


    @Bean(name = "dataSource")
    public DataSource dataSource() {
        DriverManagerDataSource datasource = new DriverManagerDataSource();
        datasource.setDriverClassName("org.h2.Driver");
        datasource.setUrl("jdbc:h2:file:/tmp/test");
        datasource.setUsername("sa");
        datasource.setPassword("");
        return datasource;
    }

    @Bean(name = "postgresDataSource")
    public DataSource postgresDatasource() {
        DriverManagerDataSource datasource = new DriverManagerDataSource();
        datasource.setDriverClassName("org.postgresql.Driver");
        datasource.setUrl("jdbc:postgresql://x.x.x.x:xxxx/blah");
        datasource.setUsername("joe");
        datasource.setPassword("password");
        return datasource;    }
}

一旦我完成了以上所有操作，错误就消失了，一切都正常了。