SpringBoot中配置双数据源的实现示例

<dependencies>
  <!-- Spring Boot Starter Data JPA -->
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
  </dependency>
  <!-- HikariCP -->
  <dependency>
    <groupId>com.zaxxer</groupId>
    <artifactId>HikariCP</artifactId>
  </dependency>
  <!-- MySQL驱动程序 -->
  <dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
  </dependency>
  <!-- 可选：其他数据库驱动程序 -->
</dependencies>

# 数据源1
spring.datasource.url=jdbc:mysql://localhost:3306/db1
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
# 数据源2
datasource2.url=jdbc:mysql://localhost:3306/db2
datasource2.username=root
datasource2.password=123456
datasource2.driver-class-name=com.mysql.cj.jdbc.Driver

// 实体类1
@Entity
@Table(name = "table1", schema = "db1")
public class Entity1 {
  // 实体类定义...
}
// 存储库接口1
@Repository
public interface Repository1 extends JpaRepository<Entity1, Long> {
  // 存储库方法定义...
}
// 实体类2
@Entity
@Table(name = "table2", schema = "db2")
public class Entity2 {
  // 实体类定义...
}
// 存储库接口2
@Repository
public interface Repository2 extends JpaRepository<Entity2, Long> {
  // 存储库方法定义...
}

@Configuration
@EnableJpaRepositories(
    basePackages = "com.example.repository1",
    entityManagerFactoryRef = "entityManagerFactory1",
    transactionManagerRef = "transactionManager1"
)
public class DataSource1Config {
  // 数据源1的配置...
}
@Configuration
@EnableJpaRepositories(
    basePackages = "com.example.repository2",
    entityManagerFactoryRef = "entityManagerFactory2",
    transactionManagerRef = "transactionManager2"
)
public class DataSource2Config {
  // 数据源2的配置...
}

@Configuration
@EnableTransactionManagement
public class TransactionManagementConfig {
  @Bean
  public PlatformTransactionManager transactionManager(
      EntityManagerFactory entityManagerFactory1,
      EntityManagerFactory entityManagerFactory2
  ) {
    JpaTransactionManager jpaTransactionManager = new JpaTransactionManager();
    jpaTransactionManager.setEntityManagerFactory(entityManagerFactory1);
    jpaTransactionManager.setEntityManagerFactory(entityManagerFactory2);
    return jpaTransactionManager;
  }
}

@SpringBootApplication
@Import({ DataSource1Config.class, DataSource2Config.class, TransactionManagementConfig.class })
public class DualDataSourceApplication {
  public static void main(String[] args) {
    SpringApplication.run(DualDataSourceApplication.class);
  }
}