使用Spring批处理时，Spring数据JPA未保存到数据库

Question

我有一个使用JPA的Spring Boot应用程序，它有一个PostgreSQL数据库。我使用的是Spring Batch。场景是我正在读取一个文件并将数据写入PostgreSQL数据库。当程序在数据库中创建Spring Batch使用的元数据表时，它与PostgreSQL一起工作。但我需要的是Spring Boot不要创建元数据表，并通过Spring Batch使用内存中基于映射的作业存储库。我根本不想在数据库中创建元数据表。只需在内存中执行映射即可。我试了很多答案，但都不管用。我明白了，

MapJobRepositoryFactoryBean已被弃用

这是我的批处理配置。java类，

@Configuration
@EnableBatchProcessing
public class BatchConfiguration {

    private @Autowired JobBuilderFactory jobBuilderFactory;
    private @Autowired StepBuilderFactory stepBuilderFactory;
    private @Autowired UserItemReader userItemReader;
    private @Autowired UserItemProcessor userItemProcessor;
    private @Autowired UserItemWriter userItemWriter;

    @Bean
    public Step importUsersStep() {
        return stepBuilderFactory.get("STEP-01")
                .<User, User>chunk(10)
                .reader(userItemReader)
                .processor(userItemProcessor)
                .writer(userItemWriter)
                .build();
    }

    @Bean
    public Job importUsersJob() {
        return jobBuilderFactory.get("JOB-IMPORT")
                .flow(importUsersStep())
                .end()
                .build();
    }
}

存储库。java类，

public interface UserRepository extends JpaRepository<User, Long> {

}

在UserItemWriter中。java在write方法中调用userRepository。saveAll（）

那么，我怎样才能使它与基于内存映射的方法一起工作呢？而且，因为我使用Spring Data JPA将用户保存到数据库中，所以保存也应该可以正常工作，因为当我尝试一些方法时，我没有看到任何提交给PostgreSQL的内容，我认为甚至用户数据也提交给了内存映射。有人能帮我吗？提前谢谢。




Answer 1

MapJobRepositoryFactoryBean只建议用于测试和开发目的，而不是用于生产，它有很多问题，这就是为什么它被弃用的原因。

Spring Batch将尝试使用应用程序上下文中的数据源（如果有）。如果您不想让Spring批处理使用它来存储其状态，可以使用带有嵌入式数据库的JobRepositoryFactoryBean。最简单的方法是定义BatchConfigurerbean：

@Bean
public BatchConfigurer configurer() {
    return new DefaultBatchConfigurer(dataSource());
}

public DataSource dataSource(){
    return new EmbeddedDatabaseBuilder()
            .setType(EmbeddedDatabaseType.HSQL)
            .addScript("classpath:org/springframework/batch/core/schema-drop-hsqldb.sql")
            .addScript("classpath:org/springframework/batch/core/schema-hsqldb.sql")
            .build();
}

Answer 2

我们通过定义多个数据源来解决这个问题。一个内存数据源用于Spring批处理元数据，另一个或多个数据源用于作业，具体取决于配置。

# for spring batch metadata
spring.datasource.url=jdbc:h2:mem:testdb
spring.datasource.driverClassName=org.h2.Driver
spring.datasource.username=sa
spring.datasource.password=password

# for jobs
job.datasource.url=jdbc:postgresql://localhost:5432/postgres
job.datasource.username=user
job.datasource.password=password

我们手动创建数据源，就像

    @Bean
    @Primary
    @ConfigurationProperties("spring.datasource")
    public DataSourceProperties mysqlDataSourceProperties() {
        return new DataSourceProperties();
    }

和另一个。

@Configuration
@EnableJpaRepositories(basePackages = "your.package.name",
        entityManagerFactoryRef = "postgresEntityManagerFactory",
        transactionManagerRef= "postgresTransactionManager")
public class PostgresDataConfig {

    @Bean
    @ConfigurationProperties("postgres.datasource")
    public DataSourceProperties postgresDataSourceProperties() {
        return new DataSourceProperties();
    }

    @Bean(name = "postgresEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean postgresEntityManagerFactory(
            EntityManagerFactoryBuilder builder) {
        return builder
                .dataSource(postgresDataSource())
                .packages("com.bimurto.multipledatasource.postgres")
                .build();
    }

    @Bean(name = "postgresTransactionManager")
    public PlatformTransactionManager postgresTransactionManager(
            final @Qualifier("postgresEntityManagerFactory") LocalContainerEntityManagerFactoryBean entityManagerFactory) {
        return new JpaTransactionManager(Objects.requireNonNull(entityManagerFactory.getObject()));
    }
}

这允许存储库使用默认数据源以外的另一个数据源。