SpringBoot多数据源配置下实体保存失败问题排查

核心错误点 #

1. 从库事务管理器配置错误 #

在SecondaryConfig中，事务管理器方法存在两个问题：

• 方法名语义混淆（写了primaryDbTransactionManager），虽通过@Bean(name)指定了正确bean名称，但逻辑不严谨；
• 直接调用secondaryDbEntityManager().getObject()创建新的EntityManagerFactory实例，而非复用Spring容器中已初始化的bean，导致事务无法与正确的EntityManager绑定。

2. 事务注解未指定对应事务管理器 #

仓库类中的@Transactional未明确指定事务管理器，默认会使用@Primary标注的主库事务管理器，导致从库操作无法进入自身事务上下文，触发TransactionRequiredException。

3. EntityManager注入方式不当 #

直接用@Qualifier注入EntityManagerFactory对应的bean，无法获取Spring代理的、与事务绑定的EntityManager实例，可能引发实体管理异常。

修复步骤 #

步骤1：修正从库事务管理器配置 #

修改SecondaryConfig中的事务管理器方法，注入Spring管理的EntityManagerFactory bean：

@Configuration
@EnableJpaRepositories(
    basePackages = ["org.my.app.repository.secondary"],
    entityManagerFactoryRef = "secondaryDbEntityManager",
    transactionManagerRef = "secondaryDbTransactionManager"
)
class SecondaryConfig {
    // ... 其他方法保持不变 ...

    @Bean(name = ["secondaryDbTransactionManager"])
    fun secondaryDbTransactionManager(@Qualifier("secondaryDbEntityManager") entityManagerFactory: EntityManagerFactory): PlatformTransactionManager {
        return JpaTransactionManager(entityManagerFactory)
    }
}

步骤2：为事务注解指定对应管理器 #

分别为主库和从库的仓库方法指定事务管理器：

主库仓库

package org.my.app.repository.primary

@Service
class PrimaryDbRepository(
    @PersistenceContext(unitName = "primaryPersistenceUnit")
    private val entityManager: EntityManager
) {
    @Transactional(transactionManager = "primaryDbTransactionManager")
    fun batchInsert(entityList: List<PrimaryEntity>) {
        entityList.forEach { entityManager.persist(it) }
        entityManager.clear()
    }
}

从库仓库

package org.my.app.repository.secondary

@Service
class SecondaryDbRepository(
    @PersistenceContext(unitName = "secondaryPersistenceUnit")
    private val entityManager: EntityManager
) {
    @Transactional(transactionManager = "secondaryDbTransactionManager")
    fun batchInsert(entityList: List<SecondaryEntity>) {
        entityList.forEach { entityManager.persist(it) }
        entityManager.clear()
    }
}

步骤3：为EntityManagerFactory指定持久化单元名称 #

在主库和从库的EntityManagerFactory配置中添加persistenceUnitName，确保@PersistenceContext能正确匹配：

主库配置

@Primary
@Bean
@ConfigurationProperties("hibernate.primary-db")
fun primaryDbEntityManager(): LocalContainerEntityManagerFactoryBean {
    val em = LocalContainerEntityManagerFactoryBean()
    em.dataSource = primaryDbDataSource()
    em.setPackagesToScan("org.my.app.entity.primary")
    em.persistenceUnitName = "primaryPersistenceUnit" // 添加此行
    val vendorAdapter = HibernateJpaVendorAdapter()
    em.jpaVendorAdapter = vendorAdapter
    val properties = HashMap<String, String?>()
    properties["hibernate.dialect"] = "org.hibernate.dialect.PostgreSQLDialect"
    properties["hibernate.temp.use_jdbc_metadata_defaults"] = "false"
    em.setJpaPropertyMap(properties)
    return em
}

从库配置

@Bean
@ConfigurationProperties("hibernate.secondary-db")
fun secondaryDbEntityManager(): LocalContainerEntityManagerFactoryBean {
    val em = LocalContainerEntityManagerFactoryBean()
    em.dataSource = secondaryDbDataSource()
    em.setPackagesToScan("org.my.app.entity.secondary")
    em.persistenceUnitName = "secondaryPersistenceUnit" // 添加此行
    val vendorAdapter = HibernateJpaVendorAdapter()
    em.jpaVendorAdapter = vendorAdapter
    val properties = HashMap<String, String?>()
    properties["hibernate.dialect"] = "org.hibernate.dialect.PostgreSQLDialect"
    properties["hibernate.temp.use_jdbc_metadata_defaults"] = "false"
    em.setJpaPropertyMap(properties)
    return em
}

步骤4：清理数据源配置冲突 #

数据源配置中@ConfigurationProperties与硬编码的url/username/password冲突，二选其一：

• 若使用外部配置文件（如application.properties），移除硬编码内容，保留@ConfigurationProperties("spring.primary-db")和@ConfigurationProperties("spring.secondary-db")；
• 若坚持硬编码，删除@ConfigurationProperties注解。

额外优化建议 #

• 批量插入可添加hibernate.jdbc.batch_size配置提升性能；
• 若需要跨库事务一致性，可引入分布式事务框架（如Atomikos），需根据业务场景评估必要性。

内容的提问来源于stack exchange，提问作者Andrew