SpringBoot多数据源下@Transactional仅主数据源生效问题排查

核心问题分析 #

你遇到的问题本质是多数据源的上下文隔离不彻底：非主数据源的EntityManagerFactory未加载对应实体的命名查询定义，且Repository未绑定到正确的数据源事务上下文。只有@Primary标注的数据源会默认被全局的Jpa组件使用，非主数据源必须手动绑定对应的EntityManagerFactory和TransactionManager。

具体修复步骤 #

1. 拆分数据源配置，为每个数据源独立构建上下文

创建独立的数据源配置类，分别为pims和powwow配置DataSource、EntityManagerFactory、TransactionManager，确保每个上下文只加载对应的数据层组件：

@Configuration
public class MultiDataSourceConfig {

    // PIMS 数据源配置
    @Bean(name = "pimsDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.pims")
    public DataSource pimsDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "pimsEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean pimsEntityManagerFactory(
            EntityManagerFactoryBuilder builder,
            @Qualifier("pimsDataSource") DataSource dataSource) {
        return builder
                .dataSource(dataSource)
                .packages("com.yourproject.pims.entity") // 指定PIMS实体所在包
                .persistenceUnit("pimsPersistenceUnit") // 唯一持久化单元名称
                .build();
    }

    @Bean(name = "pimsTransactionManager")
    public PlatformTransactionManager pimsTransactionManager(
            @Qualifier("pimsEntityManagerFactory") EntityManagerFactory entityManagerFactory) {
        return new JpaTransactionManager(entityManagerFactory);
    }

    // POWWOW 数据源配置
    @Bean(name = "powwowDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.powwow")
    public DataSource powwowDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "powwowEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean powwowEntityManagerFactory(
            EntityManagerFactoryBuilder builder,
            @Qualifier("powwowDataSource") DataSource dataSource) {
        return builder
                .dataSource(dataSource)
                .packages("com.yourproject.powwow.entity") // 指定POWWOW实体所在包
                .persistenceUnit("powwowPersistenceUnit") // 唯一持久化单元名称
                .build();
    }

    @Bean(name = "powwowTransactionManager")
    public PlatformTransactionManager powwowTransactionManager(
            @Qualifier("powwowEntityManagerFactory") EntityManagerFactory entityManagerFactory) {
        return new JpaTransactionManager(entityManagerFactory);
    }
}

2. 绑定Repository到对应数据源上下文

在SpringBoot启动类上，通过@EnableJpaRepositories分别为两个数据源的Repository指定对应的EntityManagerFactory和TransactionManager，避免Repository默认使用主数据源：

@SpringBootApplication
// 绑定PIMS的Repository到对应数据源
@EnableJpaRepositories(
        basePackages = "com.yourproject.pims.repository",
        entityManagerFactoryRef = "pimsEntityManagerFactory",
        transactionManagerRef = "pimsTransactionManager"
)
// 绑定POWWOW的Repository到对应数据源
@EnableJpaRepositories(
        basePackages = "com.yourproject.powwow.repository",
        entityManagerFactoryRef = "powwowEntityManagerFactory",
        transactionManagerRef = "powwowTransactionManager"
)
public class YourApplication {
    public static void main(String[] args) {
        SpringApplication.run(YourApplication.class, args);
    }
}

3. 验证事务注解与查询配置

• 确保Merchants实体位于pims的实体包下，实体上的@NamedQuery或orm.xml中的查询定义能被pimsEntityManagerFactory加载。
• 在非主数据源的Repository/Service方法上使用@Transactional时，指定的事务管理器名称必须与配置类中定义的Bean名称完全一致（大小写敏感）：

  @Repository
  public interface MerchantsRepository extends JpaRepository<Merchants, Long> {
      @Transactional("pimsTransactionManager")
      List<Merchants> findByCustomerNo(String customerNo);
  }
  

常见误区规避 #

• 禁止两个EntityManagerFactory扫描相同的实体包，否则会导致实体重复加载引发上下文冲突。
• 不要依赖@Primary的默认行为处理非主数据源，必须显式绑定所有组件。
• 如果使用XML定义命名查询，需在EntityManagerFactory配置中通过mappingResources指定对应数据源的ORM配置文件。

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