具有多个数据源的spring批处理junit。spring data jpa无法在内存数据库中保存数据

Question

我的场景是，批处理作业应该从1db（H2）读取数据，并将数据转储到另一DB（postgres）中。因此，我配置了多个数据源

我已经使用spring batch 4.2和spring boot 2.2.5编写了批处理作业。释放现在我需要为端到端测试编写测试用例。

我使用ResourcelessTransactionManager使用自定义批处理配置器来避免在内存和实际数据库中保存批处理表元数据，并且它正在工作。但是，我无法通过调用readerRepository.save来将业务数据保存在jUnit中的H2内存数据库中；如果我将H2内存数据库替换为jUnit中的postgres testconatiner，情况也是如此。

存储库测试的junit示例

@Slf4j
@SpringBootTest
@Import(LiquibaseConfigReader.class)
class ReaderRepositoryTest {

    @Autowired
    private ReaderRepository readerRepository;

    @BeforeEach
    void setUp() {
        readerRepository.deleteAll();
    }

    @Test
    void shouldFetchAllRecords() {
        var randomReader = RandomDataGenerator.randomReader();
        assertThat(readerRepository.findAll()).hasSize(0);
        readerRepository.save(randomReader);
        assertThat(readerRepository.findAll()).hasSize(1);
    }
}

我无法理解为什么我能够在运行JUnit Test时将数据保存在postgres测试容器中，而不是在内存H2数据库中。

为了将批处理表元数据保存在内存映射中，我尝试了下面的解决方案，现在批处理表元数据没有保存在DB中的任何位置。但是，如上所述，我开始在jUnit中面临Spring data jpa问题。

JavaSpring Batch使用嵌入式数据库处理元数据，第二个数据库处理其他数据

无数据源的Spring boot Spring批处理

https://github.com/riversoforion/spring-batch-inmem/blob/master/src/main/java/com/example/batch/CustomBatchConfigurer.java

是因为ResourcelessTransactionManager吗？如果是，我如何避免将批处理表元数据保存在任何数据库中，包括内存中。

我已经浏览了这里给出的多个问题，但没有一个能够将业务数据保存在h2数据库中。

Answer 1

没有源代码很难回答。据我所知，您希望有一个DB从（H2）读取数据，一个将数据写入（postgres）。

您不希望Spring batch在两个数据库中都写入元数据。

然后你写，你不明白为什么你不能写H2——我想，你这里指的只是spring批处理元数据。

因此，一个可能的解决方案可能是更改批处理配置器：

...
public class CustomBatchConfigurer extends DefaultBatchConfigurer {

    @Autowired
    @Qualifier("repoDataSource")
    private DataSource dataSource;

    @Override
    protected JobRepository createJobRepository() throws Exception {
        JobRepositoryFactoryBean factoryBean = new JobRepositoryFactoryBean();
        factoryBean.setDatabaseType(DatabaseType.POSTGRES.getProductName());
        factoryBean.setTablePrefix("TMP_");
        factoryBean.setIsolationLevelForCreate("ISOLATION_REPEATABLE_READ");
        factoryBean.setDataSource(this.dataSource);
        factoryBean.afterPropertiesSet();
        return factoryBean.getObject();
    }

在这里，您自动连接数据源repoDataSource，然后覆盖createJobRepository（），而DefaultBatchConfigurer使用它来创建JobRepository。它使用一个表前缀TMP，而不是默认的BATCH，事务隔离级别设置为ISOLATION\u REPEATABLE\u READ，而不是默认的ISOLATION\u SERIALIZED。

Spring没有直接调用DefaultBatchConfigurer中的任何create-方法作为bean定义，因此必须明确地调用初始化bean 和 FactoryBean getObject（）。

如果您真的不想让Spring Batch完成大部分工作，并帮助批次管理其元数据，那么您的问题是，在不将元数据持久化到数据库的情况下，可能会复制Spring Batch。