Spring Boot Jpa 批处理-CannotCreateTransactionException

Posted 2023-02-27

【中文标题】Spring Boot Jpa 批处理-CannotCreateTransactionException

【英文标题】：Spring Boot Jpa Batch - CannotCreateTransactionException

【发布时间】：2018-10-14 20:32:21

【问题描述】：

我有一个 Spring Boot + JPA + Spring 批处理（+Spring 集成）项目。还有 Flyway，配置分开。 我已将 Spring Batch 配置为使用与默认“spring.jpa.datasource”不同的数据源。这可以。 在我的 tasklet 中，我查询了两个数据源，ds1 上的第一个查询正确，ds2 上的第二个查询出错：

org.springframework.transaction.CannotCreateTransactionException: Could not open JPA EntityManager for transaction; nested exception is java.lang.IllegalStateException: Already value [org.springframework.jdbc.datasource.ConnectionHolder@2fb082ff] for key [HikariDataSource (HikariPool-1)] bound to thread [main]

更多详情： 我为每个数据源都有一个配置类，用

注释

@Configuration 
@EnableTransactionManagement
@EnableJpaRepositories

在每个配置中，为 DataSource、LocalContainerEntityManagerFactoryBean 和 JpaTransactionManager 定义了一个 bean，并具有自定义名称。

为每个数据源定义一个服务：

 @Service @Transactional(transactionManager=JpaApsConfiguration.APS_TRANSACTION_MANAGER, propagation = Propagation.REQUIRES_NEW)

并且使用正确的限定符自动装配实体管理器 （注意：通过 JpaRepository 类进行查询）

关于什么可能导致这种行为的任何建议？谢谢

注意：

数据库连接成功 我之前有一个不同的错误 （已经修复，但可能会有所帮助）： 'NoUniqueBeanDefinitionException' 因为 Spring 无法识别 在我的两个交易之间正确的“PlatformTransactionManager” manager bean 和默认的 transactionManager。

编辑：

这里是错误的完整堆栈跟踪：

2018-05-08 12:12:24 信息 o.s.batch.core.job.SimpleStepHandler - 执行步骤：[STEP#PROCESS_SHIPMENTS] 2018-05-08 12:12:24 错误 o.s.batch.core.step.AbstractStep - 在作业 PROCESS_APS 中执行步骤 STEP#PROCESS_SHIPMENTS 时遇到错误 org.springframework.transaction.CannotCreateTransactionException：无法为事务打开 JPA EntityManager；嵌套异常是 java.lang.IllegalStateException：已为键 [HikariDataSource (HikariPool-1)] 绑定到线程 [main] 的值 [org.springframework.jdbc.datasource.ConnectionHolder@351e89fc] 在 org.springframework.orm.jpa.JpaTransactionManager.doBegin(JpaTransactionManager.java:450) 在 org.springframework.transaction.support.AbstractPlatformTransactionManager.getTransaction(AbstractPlatformTransactionManager.java:378) 在 org.springframework.transaction.interceptor.TransactionAspectSupport.createTransactionIfNecessary(TransactionAspectSupport.java:474) 在 org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:289) 在 org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98) 在 org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) 在 org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:689) 在 dkr.astreconnector.service.GespeService$$EnhancerBySpringCGLIB$$73dbb368.getValueDetailByUniq() 在 dkr.astreconnector.batch.worker.ShipmentProcessor.process(ShipmentProcessor.java:63) 在 dkr.astreconnector.batch.worker.ShipmentProcessor.process(ShipmentProcessor.java:30) 在 org.springframework.batch.core.step.item.SimpleChunkProcessor.doProcess(SimpleChunkProcessor.java:126) 在 org.springframework.batch.core.step.item.SimpleChunkProcessor.transform(SimpleChunkProcessor.java:303) 在 org.springframework.batch.core.step.item.SimpleChunkProcessor.process(SimpleChunkProcessor.java:202) 在 org.springframework.batch.core.step.item.ChunkOrientedTasklet.execute(ChunkOrientedTasklet.java:75) 在 org.springframework.batch.core.step.tasklet.TaskletStep$ChunkTransactionCallback.doInTransaction(TaskletStep.java:406) 在 org.springframework.batch.core.step.tasklet.TaskletStep$ChunkTransactionCallback.doInTransaction(TaskletStep.java:330) 在 org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:140) 在 org.springframework.batch.core.step.tasklet.TaskletStep$2.doInChunkContext(TaskletStep.java:272) 在 org.springframework.batch.core.scope.context.StepContextRepeatCallback.doInIteration(StepContextRepeatCallback.java:81) 在 org.springframework.batch.repeat.support.RepeatTemplate.getNextResult(RepeatTemplate.java:375) 在 org.springframework.batch.repeat.support.RepeatTemplate.executeInternal(RepeatTemplate.java:215) 在 org.springframework.batch.repeat.support.RepeatTemplate.iterate(RepeatTemplate.java:145) 在 org.springframework.batch.core.step.tasklet.TaskletStep.doExecute(TaskletStep.java:257) 在 org.springframework.batch.core.step.AbstractStep.execute(AbstractStep.java:200) 在 org.springframework.batch.core.job.SimpleStepHandler.handleStep(SimpleStepHandler.java:148) 在 org.springframework.batch.core.job.flow.JobFlowExecutor.executeStep(JobFlowExecutor.java:66) 在 org.springframework.batch.core.job.flow.support.state.StepState.handle(StepState.java:67) 在 org.springframework.batch.core.job.flow.support.SimpleFlow.resume(SimpleFlow.java:169) 在 org.springframework.batch.core.job.flow.support.SimpleFlow.start(SimpleFlow.java:144) 在 org.springframework.batch.core.job.flow.FlowJob.doExecute(FlowJob.java:136) 在 org.springframework.batch.core.job.AbstractJob.execute(AbstractJob.java:308) 在 org.springframework.batch.core.launch.support.SimpleJobLauncher$1.run(SimpleJobLauncher.java:141) 在 org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:50) 在 org.springframework.batch.core.launch.support.SimpleJobLauncher.run（SimpleJobLauncher.java:134） 在 org.springframework.boot.autoconfigure.batch.JobLauncherCommandLineRunner.execute(JobLauncherCommandLineRunner.java:163) 在 org.springframework.boot.autoconfigure.batch.JobLauncherCommandLineRunner.executeLocalJobs(JobLauncherCommandLineRunner.java:179) 在 org.springframework.boot.autoconfigure.batch.JobLauncherCommandLineRunner.launchJobFromProperties(JobLauncherCommandLineRunner.java:134) 在 org.springframework.boot.autoconfigure.batch.JobLauncherCommandLineRunner.run(JobLauncherCommandLineRunner.java:128) 在 org.springframework.boot.SpringApplication.callRunner(SpringApplication.java:790) 在 org.springframework.boot.SpringApplication.callRunners(SpringApplication.java:774) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:335) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:1246) 在 org.springframework.boot.SpringApplication.run(SpringApplication.java:1234) 在 dkr.astreconnector.AstreConnectorBatchApplication.main(AstreConnectorBatchApplication.java:14) 引起：java.lang.IllegalStateException：已绑定到线程 [main] 的键 [HikariDataSource (HikariPool-1)] 的值 [org.springframework.jdbc.datasource.ConnectionHolder@351e89fc] 在 org.springframework.transaction.support.TransactionSynchronizationManager.bindResource(TransactionSynchronizationManager.java:193) 在 org.springframework.orm.jpa.JpaTransactionManager.doBegin(JpaTransactionManager.java:425) ...省略了43个常用框架 2018-05-08 12:12:24 信息 osbclsupport.SimpleJobLauncher - 作业：[FlowJob：[name=PROCESS_APS]] 使用以下参数完成：[run.id=128] 和以下状态：[FAILED]

【问题讨论】：

你能添加你得到的错误的完整堆栈跟踪吗？

按要求添加了堆栈跟踪。谢谢。

查看此链接***.com/questions/20907206/…

感谢您的建议：顺便说一句，我已经使用这些提示来调试我的代码，但遗憾的是没有结果

我终于解决了这个问题：只是在我的批处理配置中，我明确声明了事务管理器的限定符，然后将其传递给我的工作创建工厂。 @Autowired @Qualifier("transactionManager") private PlatformTransactionManager transactionManager;

【参考方案1】：

有点晚了，但我想回复@mad_fox

主数据库：

@Configuration
@EnableJpaRepositories(
    entityManagerFactoryRef = JpaAppsConfiguration.APPS_ENTITY_MANAGER,
    transactionManagerRef = "transactionManager",
    basePackages =  JpaAppsConfiguration.APPS_REPOSITORIES )
@EnableAutoConfiguration
public class JpaAppsConfiguration 

public final static String APPS_PERSISTENCE_UNIT = "apps";
public final static String APPS_DATA_SOURCE = "appDs";
public final static String APPS_ENTITY_MANAGER = "appsEmf";
public final static String APPS_TRANSACTION_MANAGER = "appsTm";
protected final static String APPS_PACKAGES = ""; //my models package
protected final static String APPS_REPOSITORIES = ""; //my repos package

@Primary
@Bean(name = APPS_DATA_SOURCE)
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource appsDataSource() 
    return DataSourceBuilder.create().build();


@Primary
@Bean(name = APPS_ENTITY_MANAGER)
@PersistenceContext(unitName = APPS_PERSISTENCE_UNIT)
public LocalContainerEntityManagerFactoryBean appsEntityManagerFactory(EntityManagerFactoryBuilder builder,
        @Qualifier(APPS_DATA_SOURCE) DataSource appsDataSource) 
    LocalContainerEntityManagerFactoryBean emf = builder
            .dataSource(appsDataSource)
            .persistenceUnit(APPS_PERSISTENCE_UNIT)
            .packages(APPS_PACKAGES)
            .build();

    // Vendor adapter
    HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
    emf.setJpaVendorAdapter(vendorAdapter);
    return emf;

二级数据库：

@Configuration
@EnableJpaRepositories(
    entityManagerFactoryRef = JpaGepeConfiguration.GEPE_ENTITY_MANAGER, 
    basePackages =  JpaGepeConfiguration.GEPE_REPOSITORIES )
@EnableAutoConfiguration
public class JpaGepeConfiguration 

public static final String GEPE_PERSISTENCE_UNIT = "gn1";
public static final String GEPE_DATA_SOURCE = "gn1ds";
public static final String GEPE_ENTITY_MANAGER = "gn1emf";
public static final String GEPE_TRANSACTION_MANAGER = "gn1tm";
public static final String GEPE_PACKAGES = ""; //my models package
public static final String GEPE_REPOSITORIES = ""; //my repos package

@Bean(name = GEPE_DATA_SOURCE)
@ConfigurationProperties(prefix = "gn1.datasource")
public DataSource gepeDataSource() 
    return DataSourceBuilder.create().build();


@Bean(name = GEPE_ENTITY_MANAGER)
@PersistenceContext(unitName = GEPE_PERSISTENCE_UNIT)
public LocalContainerEntityManagerFactoryBean gepeEntityManagerFactory(EntityManagerFactoryBuilder builder,
        @Qualifier(GEPE_DATA_SOURCE) DataSource gepeDataSource) 
    LocalContainerEntityManagerFactoryBean emf = builder
            .dataSource(gepeDataSource)
            .persistenceUnit(GEPE_PERSISTENCE_UNIT)
            .packages(GEPE_PACKAGES)
            .build();

    // Vendor adapter
    HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
    emf.setJpaVendorAdapter(vendorAdapter);
    return emf;

主数据库的@Service 类中的方法注释为：

@Transactional(transactionManager = JpaAppsConfiguration.APPS_TRANSACTION_MANAGER, readOnly = false, propagation = Propagation.REQUIRED, noRollbackFor = Exception.class)

属性文件中的参数如下：

#DATABASE CONNECTION
#Primary
spring.datasource.username=
spring.datasource.password=
spring.datasource.driverClassName=
spring.datasource.url=j
spring.datasource.jdbcUrl=
spring.datasource.name=
#Secondary
gepe.datasource.username=
gepe.datasource.password=
gepe.datasource.driverClassName=
gepe.datasource.url=
gepe.datasource.jdbcUrl=
gepe.datasource.name=

希望这会有所帮助。

【讨论】：

APPS_TRANSACTION_MANAGER 未在任何地方配置。它只是定义为最终字符串。 @TRansactional 注释将如何利用它？不应该是“transactionManager”而不是APPS_TRANSACTION_MANAGER吗？

【参考方案2】：

这里是批量配置的代码sn-p。确保您还覆盖了 getTransactionManager 方法。 （用你的替换 qualifires 的值）

@Configuration
public class CustomBatchConfigurer extends DefaultBatchConfigurer 
    @Autowired
    @Qualifier("primaryDataSource")
    private DataSource dataSource;

    @Autowired
    @Qualifier("primaryTransactionManager")
    private PlatformTransactionManager transactionManager;

    @Override
    public PlatformTransactionManager getTransactionManager() 
        return transactionManager;
    

    @Override
    protected JobRepository createJobRepository() throws Exception 
        JobRepositoryFactoryBean factoryBean = new JobRepositoryFactoryBean();
        factoryBean.setIsolationLevelForCreate("ISOLATION_REPEATABLE_READ");
        factoryBean.setDataSource(dataSource);
        factoryBean.setTransactionManager(transactionManager);

        factoryBean.afterPropertiesSet();
        return factoryBean.getObject();
    

【讨论】：

我找不到 DefaultBatchConfigurer 实现的简约工作示例，只在任何地方指定 DataSource 和 TransactionManager 所以：谢谢你，就像一个魅力！