在spring-boot-batch项目中，对jobrepository使用不同的数据源是否可能？

Question

只需使用spring-data-jpa设置我的第一个spring-boot-batch项目。在我的开发环境中，我有一个可行的解决方案，即在itemReader中使用来自Oracle DB的一些行，在处理器中为每一行解析一些XML/html，然后使用自定义ItemWriter将每个提取的html写入单个文件。（每行1个文件）

我的数据源是通过引导项目（application.properties）中的spring-data-jpa配置的...

我尝试配置了2个数据源，正如我遇到的spring文档中概述的那样…但不能让它工作。我也尝试使用内存，但也无法使其工作。

那么这可能吗？或者我应该继续努力让内存中的作业repo工作？

在这一点上，我不太关心可重启性..批处理作业将作为独立的spring-boot应用程序在我的桌面上运行。

任何帮助，提示，信息都非常感谢。

   @Configuration
@EnableBatchProcessing
public class BatchConfiguration {


    private static final Logger log = LoggerFactory.getLogger(BatchConfiguration.class);


    @Autowired
    public JobBuilderFactory jobBuilderFactory;

    @Autowired
    public StepBuilderFactory stepBuilderFactory;

    @Autowired
    EntityManagerFactory emf;

    @Bean
    public SimpleJobLauncher jobLauncher(JobRepository jobRepository) {
        SimpleJobLauncher simpleJobLauncher = new SimpleJobLauncher();
        simpleJobLauncher.setJobRepository(jobRepository);
        return simpleJobLauncher;
    }

    @Bean
    public JobRepository jobRepository(ResourcelessTransactionManager transactionManager) throws Exception {
        MapJobRepositoryFactoryBean mapJobRepositoryFactoryBean = new MapJobRepositoryFactoryBean(transactionManager);
        mapJobRepositoryFactoryBean.setTransactionManager(transactionManager);
        return mapJobRepositoryFactoryBean.getObject();
    }

    @Bean
    public ResourcelessTransactionManager transactionManager() {
        return new ResourcelessTransactionManager();
    }

因此，它似乎仍然试图连接到Oracle，而不使用内存中的数据库。

Answer 1

嗯...似乎这个配置对我的情况很有用。

@Configuration
@EnableBatchProcessing
public class BatchConfiguration {


    private static final Logger log = LoggerFactory.getLogger(BatchConfiguration.class);


    @Autowired
    public JobBuilderFactory jobBuilderFactory;

    @Autowired
    public StepBuilderFactory stepBuilderFactory;

    @Autowired
    EntityManagerFactory emf;

    @Bean
    public SimpleJobLauncher jobLauncher(JobRepository jobRepository) throws Exception {
        SimpleJobLauncher simpleJobLauncher = new SimpleJobLauncher();
        simpleJobLauncher.setJobRepository(jobRepository);
        simpleJobLauncher.afterPropertiesSet();
        return simpleJobLauncher;
    }

    @Bean
    public MapJobRepositoryFactoryBean mapJobRepositoryFactory(ResourcelessTransactionManager txManager)
            throws Exception {
        MapJobRepositoryFactoryBean factory = new MapJobRepositoryFactoryBean(txManager);
        factory.afterPropertiesSet();
        return factory;
    }

    @Bean
    public JobRepository jobRepository(MapJobRepositoryFactoryBean factory) throws Exception {
         return factory.getObject();
    }

    @Bean
    public ResourcelessTransactionManager  resourcelessTransactionManager() {
        return new ResourcelessTransactionManager();
    }

    @Bean
    public JobExplorer jobExplorer(MapJobRepositoryFactoryBean factory) {
        return new SimpleJobExplorer(factory.getJobInstanceDao(), factory.getJobExecutionDao(),
                factory.getStepExecutionDao(), factory.getExecutionContextDao());
    }