为SpringBoot应用集成多数据源：快速教程

2023-09-23 09:51:25

在现代应用程序开发中，使用多数据源已成为一种常见实践。它允许应用程序连接到多个数据库，从而实现数据隔离、提高性能和扩展性。SpringBoot作为备受推崇的Java框架，为多数据源配置提供了简便的方法。本教程将引导您完成在SpringBoot应用中配置多数据源的整个过程，包括使用示例代码和最佳实践。

1. 移除自动配置数据源

SpringBoot的默认行为是自动配置数据源。为了使用多数据源，我们需要首先移除此自动配置。在application.properties文件中添加以下配置：

spring.autoconfigure.exclude=org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration

2. 创建多个数据源Bean

接下来，我们需要为每个数据源创建一个Spring Bean。在@SpringBootApplication类中添加以下代码：

@SpringBootApplication
public class MultiDataSourceApplication {

    public static void main(String[] args) {
        SpringApplication.run(MultiDataSourceApplication.class, args);
    }

    @Bean
    public DataSource primaryDataSource() {
        HikariDataSource dataSource = new HikariDataSource();
        dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/primary_db");
        dataSource.setUsername("primary_user");
        dataSource.setPassword("primary_password");
        return dataSource;
    }

    @Bean
    public DataSource secondaryDataSource() {
        HikariDataSource dataSource = new HikariDataSource();
        dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/secondary_db");
        dataSource.setUsername("secondary_user");
        dataSource.setPassword("secondary_password");
        return dataSource;
    }
}

3. 配置事务管理器

为了管理跨多个数据源的事务，我们需要配置一个事务管理器。在application.properties文件中添加以下配置：

spring.transaction.default-timeout=30
spring.transaction.rollback-on-commit-failure=true

4. 配置DataSource路由

为了将不同的数据源映射到不同的Repository，我们需要配置DataSource路由。在application.properties文件中添加以下配置：

spring.jpa.properties.hibernate.default_schema=primary_db
spring.datasource.primary.name=primary_db
spring.datasource.secondary.name=secondary_db

5. 使用@DataSource注解

在Repository中，我们可以使用@DataSource注解来指定要使用的数据源。例如：

@Repository
public class UserRepository {

    @Autowired
    private EntityManager entityManager;

    @DataSource("primary_db")
    public List<User> findAll() {
        return entityManager.createQuery("SELECT u FROM User u", User.class).getResultList();
    }

    @DataSource("secondary_db")
    public User findById(Long id) {
        return entityManager.find(User.class, id);
    }
}