Springboot整合多数据源代码示例详解

下面我将为您详细讲解“Springboot整合多数据源代码示例详解”的完整攻略。

一、Spring Boot整合多数据源的背景

在实际的开发过程中，经常会遇到需要使用多个数据源的情况，比如我们的应用程序需要连接多个数据库，或者需要连接主从分离的数据库等等，这种情况下我们就需要使用 Spring Boot 来整合多个数据源，以方便我们的应用程序能够更好地管理和维护多个数据源。

二、Spring Boot整合多数据源的核心配置

1. 配置数据源信息

在 Spring Boot 中，我们需要通过配置文件来配置多个数据源的信息，例如：

# 数据源1的配置信息
spring.datasource.datasource1.url=jdbc:mysql://localhost:3306/db1
spring.datasource.datasource1.username=root
spring.datasource.datasource1.password=123456
spring.datasource.datasource1.driver-class-name=com.mysql.jdbc.Driver

# 数据源2的配置信息
spring.datasource.datasource2.url=jdbc:mysql://localhost:3306/db2
spring.datasource.datasource2.username=root
spring.datasource.datasource2.password=123456
spring.datasource.datasource2.driver-class-name=com.mysql.jdbc.Driver

2. 配置数据源和事务管理器

在 Spring Boot 中，我们可以使用 @Configuration 注解来配置多个数据源以及相关的事务管理器。示例代码如下：

@Configuration
public class DataSourceConfig {
   // 数据源1的配置
     @Bean(name = "datasource1")
     @Primary
     @ConfigurationProperties(prefix = "spring.datasource.datasource1")
     public DataSource dataSource1(){
         return DataSourceBuilder.create().build();
     }
     // 数据源2的配置
     @Bean(name = "datasource2")
     @ConfigurationProperties(prefix = "spring.datasource.datasource2")
     public DataSource dataSource2(){
         return DataSourceBuilder.create().build();
     }
     // 数据源1对应的事务管理器
     @Bean(name = "transactionManager1")
     public DataSourceTransactionManager transactionManager1(@Qualifier("datasource1") DataSource dataSource) {
         return new DataSourceTransactionManager(dataSource);
     }
     // 数据源2对应的事务管理器
     @Bean(name = "transactionManager2")
     public DataSourceTransactionManager transactionManager2(@Qualifier("datasource2") DataSource dataSource) {
         return new DataSourceTransactionManager(dataSource);
     }

}

在上面的代码中，我们使用 @Bean 注解来配置多个数据源，其中 @Primary 注解用于标识默认数据源，而 @ConfigurationProperties 注解则用于注入数据源的配置信息。

另外，在这里我们还配置了 2 个事务管理器，分别对应两个数据源。

3. 配置多数据源支持

在 Spring Boot 中，我们需要通过 @EnableTransactionManagement 注解来启动事务管理功能。此外，我们还需要使用 @MapperScan 注解来扫描多个数据源下的所有 Mapper 文件，示例代码如下：

@Configuration
@MapperScan(basePackages = "com.example.demo.mapper1" ,sqlSessionFactoryRef = "sqlSessionFactory1")
public class MybatisConfig1 {
    @Autowired
    @Qualifier("datasource1")
    private DataSource dataSource1;

    @Bean(name = "sqlSessionFactory1")
    public SqlSessionFactory sqlSessionFactory1() throws Exception {
        // Mybatis-Spring 会自动搜索该包下的所有 Mapper 接口并且注册它们
        final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(dataSource1);
        PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
        sessionFactory.setMapperLocations(resolver.getResources("classpath*:mapper1/*.xml"));
        sessionFactory.setTypeAliasesPackage("com.example.demo.entity1");//扫描entity包，不加解析不了实体类
        return sessionFactory.getObject();
    }

    @Bean(name = "sqlSessionTemplate1")
    public SqlSessionTemplate sqlSessionFactoryTemplate1() throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory1()); // 使用上面配置的Factory
    }

}

在上面的代码中，我们使用 @MapperScan 注解来指定 Mapper 文件的扫描路径，并且指定了 sqlSessionFactoryRef 属性为 sqlSessionFactory1。

三、示例代码

示例1：基于 JdbcTemplate 的多数据源访问

@Service
public class MutilDatasourceByJdbcTemplateService {
    @Autowired
    private JdbcTemplate jdbcTemplate1;

    @Autowired
    private JdbcTemplate jdbcTemplate2;

    public List<User> getUserListFromDs1(){
        return jdbcTemplate1.query("select * from user",new UserMapper());
    }

    public List<User> getUserListFromDs2(){
        return jdbcTemplate2.query("select * from user",new UserMapper());
    }

}

示例2：基于 Mybatis 的多数据源访问

@Service
public class MutilDatasourceByMybatisService {
    @Autowired
    @Qualifier("sqlSessionTemplate1")
    private SqlSessionTemplate sqlSessionTemplate1;

    @Autowired
    @Qualifier("sqlSessionTemplate2")
    private SqlSessionTemplate sqlSessionTemplate2;

    public List<User> getUserListFromDs1(){
        return sqlSessionTemplate1.selectList("com.example.demo.mapper1.UserMapper.selectUsers");
    }

    public List<User> getUserListFromDs2(){
        return sqlSessionTemplate2.selectList("com.example.demo.mapper2.UserMapper.selectUsers");
    }
}

在上面的代码中，我们分别使用 JdbcTemplate 和 Mybatis 两种方式来访问多个数据源，其中 JdbcTemplate 是基于 Spring 提供的 JDBC 封装框架，而 Mybatis 则是一款优秀的 ORM 框架。

至此，我们就成功地完成了 Spring Boot 整合多数据源的详细讲解和示例代码。