如何为两个不同数据源配置各自对应的JpaRepository？

核心逻辑是为每个数据源单独配置对应的JPA上下文、事务管理器，并指定各自扫描的Repository和实体类包路径，避免默认自动配置的单JPA上下文覆盖所有Repository。

第一步：调整项目包结构 #

首先把两个数据源对应的Repository和实体类分到不同的包下，举个参考结构：

com.example.demo
├── mysql
│   ├── entity  # 存放MySQL对应的实体类
│   └── repository  # 存放操作MySQL的JpaRepository接口
└── snowflake
    ├── entity  # 存放Snowflake对应的实体类
    └── repository  # 存放操作Snowflake的JpaRepository接口

第二步：配置多数据源参数 #

在application.yml或application.properties里分开配置两个数据源的参数，不要都用默认的spring.datasource前缀：

# MySQL数据源配置
mysql:
  datasource:
    jdbc-url: jdbc:mysql://localhost:3306/your_mysql_db?useUnicode=true&characterEncoding=utf8
    username: root
    password: your_mysql_pwd
    driver-class-name: com.mysql.cj.jdbc.Driver

# Snowflake数据源配置
snowflake:
  datasource:
    jdbc-url: jdbc:snowflake://your_account.snowflakecomputing.com/?db=your_db&schema=your_schema
    username: your_snowflake_user
    password: your_snowflake_pwd
    driver-class-name: net.snowflake.client.jdbc.SnowflakeDriver

注意必须用jdbc-url而不是url，否则自定义数据源配置会读取失败

第三步：编写MySQL对应的JPA配置类 #

创建MySQL专属的JPA配置类，指定扫描MySQL的Repository包、实体类包，绑定对应的数据源，主数据源需加@Primary避免注入冲突：

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        basePackages = "com.example.demo.mysql.repository", // 扫描MySQL对应的Repository包
        entityManagerFactoryRef = "mysqlEntityManagerFactory",
        transactionManagerRef = "mysqlTransactionManager"
)
public class MysqlJpaConfig {

    @Bean
    @Primary 
    @ConfigurationProperties(prefix = "mysql.datasource")
    public DataSource mysqlDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean
    @Primary
    public LocalContainerEntityManagerFactoryBean mysqlEntityManagerFactory(
            EntityManagerFactoryBuilder builder,
            @Qualifier("mysqlDataSource") DataSource dataSource
    ) {
        HashMap<String, Object> properties = new HashMap<>();
        // 配置MySQL对应的Hibernate方言
        properties.put("hibernate.dialect", "org.hibernate.dialect.MySQL8Dialect");
        // 按需配置ddl-auto等其他JPA参数
        properties.put("hibernate.hbm2ddl.auto", "none");

        return builder
                .dataSource(dataSource)
                .packages("com.example.demo.mysql.entity") // 扫描MySQL对应的实体类包
                .persistenceUnit("mysqlPersistenceUnit")
                .properties(properties)
                .build();
    }

    @Bean
    @Primary
    public PlatformTransactionManager mysqlTransactionManager(
            @Qualifier("mysqlEntityManagerFactory") LocalContainerEntityManagerFactoryBean entityManagerFactory
    ) {
        return new JpaTransactionManager(entityManagerFactory.getObject());
    }
}

第四步：编写Snowflake对应的JPA配置类 #

和MySQL配置逻辑一致，仅调整扫描路径、绑定数据源、Hibernate方言即可，不要加@Primary注解：

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        basePackages = "com.example.demo.snowflake.repository", // 扫描Snowflake对应的Repository包
        entityManagerFactoryRef = "snowflakeEntityManagerFactory",
        transactionManagerRef = "snowflakeTransactionManager"
)
public class SnowflakeJpaConfig {

    @Bean
    @ConfigurationProperties(prefix = "snowflake.datasource")
    public DataSource snowflakeDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean
    public LocalContainerEntityManagerFactoryBean snowflakeEntityManagerFactory(
            EntityManagerFactoryBuilder builder,
            @Qualifier("snowflakeDataSource") DataSource dataSource
    ) {
        HashMap<String, Object> properties = new HashMap<>();
        // 配置Snowflake对应的Hibernate方言
        properties.put("hibernate.dialect", "org.hibernate.dialect.SnowflakeDialect");
        properties.put("hibernate.hbm2ddl.auto", "none");

        return builder
                .dataSource(dataSource)
                .packages("com.example.demo.snowflake.entity") // 扫描Snowflake对应的实体类包
                .persistenceUnit("snowflakePersistenceUnit")
                .properties(properties)
                .build();
    }

    @Bean
    public PlatformTransactionManager snowflakeTransactionManager(
            @Qualifier("snowflakeEntityManagerFactory") LocalContainerEntityManagerFactoryBean entityManagerFactory
    ) {
        return new JpaTransactionManager(entityManagerFactory.getObject());
    }
}

第五步：禁用Spring Boot默认自动配置 #

在启动类的@SpringBootApplication注解上排除自动配置类，避免默认配置覆盖自定义的多数据源规则：

@SpringBootApplication(exclude = {
        DataSourceAutoConfiguration.class,
        DataSourceTransactionManagerAutoConfiguration.class,
        HibernateJpaAutoConfiguration.class
})
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

常见问题排查 #

• 所有Repository仍指向MySQL：检查两个配置类的basePackages路径是否正确，是否准确对应到不同的Repository包
• 启动报错找不到数据源：检查配置文件的数据源前缀和@ConfigurationProperties的prefix是否一致，是否使用了jdbc-url而非url
• 数据库操作时报方言错误：检查两个配置类的hibernate.dialect参数是否和对应数据库类型匹配

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