Spring Boot 集成 Mybatis 实现 Druid 多数据源

刺骨的言语ヽ痛彻心扉 2021-11-17 11:48 315阅读 0赞

今天，日月在这里教大家怎么简洁的使用 Spring Boot 集成 Mybatis 实现 Druid 多数据源，也是经过网上很多示例的参考和实践后整理出来的，献给有需要的猿友们。。。

我们还是延用之前[SpringBoot 集成 mybatis的四种方式][SpringBoot _ mybatis]的项目进行改造

**1、pom依赖**

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    
    
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>1.3.2</version>
    </dependency>
    
    
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
    
    
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid</artifactId>
        <version>${druid.version}</version>
    </dependency>

**2、配置文件application.properties**

# master 数据源配置 #

master.datasource.url=jdbc:mysql://localhost:3306/test1?useSSL=false&useUnicode=true&characterEncoding=utf8
    master.datasource.username=root
    master.datasource.password=123456
    master.datasource.maxActive=50
    master.datasource.maxWait=60000
    master.datasource.driverClassName=com.mysql.jdbc.Driver

# cluster 数据源配置 #

cluster.datasource.url=jdbc:mysql://localhost:3306/test2?useSSL=false&useUnicode=true&characterEncoding=utf8
    cluster.datasource.username=root
    cluster.datasource.password=123456
    cluster.datasource.maxActive=50
    cluster.datasource.maxWait=60000
    cluster.datasource.driverClassName=com.mysql.jdbc.Driver

**3、多数据源配置**  
**主数据源**

import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    import com.alibaba.druid.pool.DruidDataSource;
    @Configuration
    // 扫描 Mapper 接口并容器管理
    @MapperScan(basePackages = MasterDataSourceConfiguration.PACKAGE, sqlSessionFactoryRef = "masterSqlSessionFactory")
    public class MasterDataSourceConfiguration {
        // 精确到 master 目录，以便跟其他数据源隔离
        static final String PACKAGE = "com.chenqi.springboot.dao.master";
        static final String MAPPER_LOCATION = "classpath:mapper/master/*.xml";
        @Value("${master.datasource.url}")
        private String url;
        @Value("${master.datasource.username}")
        private String user;
        @Value("${master.datasource.password}")
        private String password;
        
        @Value("${master.datasource.maxActive}")
        private Integer maxActive;
        
        @Value("${master.datasource.maxWait}")
        private Integer maxWait;
        @Value("${master.datasource.driverClassName}")
        private String driverClass;
        @Bean(name = "dataSource")
        @Primary
        public DruidDataSource masterDataSource() {
            DruidDataSource dataSource = new DruidDataSource();
            dataSource.setDriverClassName(driverClass);
            dataSource.setUrl(url);
            dataSource.setUsername(user);
            dataSource.setPassword(password);
            dataSource.setMaxActive(maxActive);
            dataSource.setMaxWait(maxWait);
            return dataSource;
        }
        @Bean(name = "masterTransactionManager")
        @Primary
        public DataSourceTransactionManager masterTransactionManager() {
            return new DataSourceTransactionManager(masterDataSource());
        }
        @Bean(name = "masterSqlSessionFactory")
        @Primary
        public SqlSessionFactory masterSqlSessionFactory(@Qualifier("dataSource") DruidDataSource masterDataSource)
                throws Exception {
            final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
            sessionFactory.setDataSource(masterDataSource);
            sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                    .getResources(MasterDataSourceConfiguration.MAPPER_LOCATION));
            return sessionFactory.getObject();
        }
    }

**注意主数据源要加@Primary注解，并且beanname一定要是 dataSource**

**从数据源**

import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    import com.alibaba.druid.pool.DruidDataSource;
    
    @Configuration
    //扫描 Mapper 接口并容器管理
    @MapperScan(basePackages = ClusterDataSourceConfiguration.PACKAGE, sqlSessionFactoryRef = "clusterSqlSessionFactory")
    public class ClusterDataSourceConfiguration {
    // 精确到 cluster 目录，以便跟其他数据源隔离
    static final String PACKAGE = "com.chenqi.springboot.dao.cluster";
    static final String MAPPER_LOCATION = "classpath:mapper/cluster/*.xml";
    
    @Value("${cluster.datasource.url}")
    private String url;
    
    @Value("${cluster.datasource.username}")
    private String user;
    
    @Value("${cluster.datasource.password}")
    private String password;
    @Value("${cluster.datasource.maxActive}")
    private Integer maxActive;
    @Value("${cluster.datasource.maxWait}")
    private Integer maxWait;
    
    @Value("${cluster.datasource.driverClassName}")
    private String driverClass;
    
    @Bean(name = "clusterDataSource")
    public DruidDataSource clusterDataSource() {
    DruidDataSource dataSource = new DruidDataSource();
    dataSource.setDriverClassName(driverClass);
    dataSource.setUrl(url);
    dataSource.setUsername(user);
    dataSource.setPassword(password);
    dataSource.setMaxActive(maxActive);
    dataSource.setMaxWait(maxWait);
    return dataSource;
    }
    
    @Bean(name = "clusterTransactionManager")
    public DataSourceTransactionManager clusterTransactionManager() {
    return new DataSourceTransactionManager(clusterDataSource());
    }
    
    @Bean(name = "clusterSqlSessionFactory")
    public SqlSessionFactory clusterSqlSessionFactory(@Qualifier("clusterDataSource") DruidDataSource clusterDataSource)
    throws Exception {
    final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
    sessionFactory.setDataSource(clusterDataSource);
    sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
    .getResources(ClusterDataSourceConfiguration.MAPPER_LOCATION));
    return sessionFactory.getObject();
    }
    }

**4、serviceImpl**

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import com.chenqi.springboot.dao.cluster.ClusterMapper;
    import com.chenqi.springboot.dao.master.MasterMapper;
    import com.chenqi.springboot.service.TestService;
    @Service
    public class TestServiceImpl implements TestService {
        
        @Autowired
        MasterMapper masterMapper;
        
        @Autowired
        ClusterMapper clusterMapper;
        @Override
        public String test() {
            return masterMapper.test() + "---" + clusterMapper.test();
        }
    }

**其他就没有什么改动了，根据各数据源中配置的dao路径和xml路径写各自的代码即可。数据库我们还是延用上一章中的test1（master）和test2（cluster）数据库（注意mapper中切记不要加@mapper）**

OK了，我们启动项目，访问http://localhost:8080/hello  
返回：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70]  
至此，说明，多数据源的配置测试成功。

[SpringBoot _ mybatis]: https://blog.csdn.net/weixin_40623736/article/details/97677324
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70]: /images/20211116/f377355a97ce426f872bd1415ab437df.png