spring-boot2.0配置mybatis多数据源，使用druid连接池

素颜马尾好姑娘i 2021-11-10 15:16 305阅读 0赞

本文主要参考：

[https://blog.csdn.net/weixin\_37664872/article/details/80088014][https_blog.csdn.net_weixin_37664872_article_details_80088014]

[https://blog.csdn.net/qq\_42685050/article/details/81451029][https_blog.csdn.net_qq_42685050_article_details_81451029]

[https://github.com/alibaba/druid/wiki/DruidDataSource%E9%85%8D%E7%BD%AE][https_github.com_alibaba_druid_wiki_DruidDataSource_E9_85_8D_E7_BD_AE]

这里需要注意的是，因为spring-boot在类的自动加载上封装的比较好，很多约定如果不知道，根本就是找不到，就比如这个：

DataSourceAutoConfiguration

这个类的作用是自动加载application.properties中的数据源配置，然后使用默认的 HikairCP连接池。导致我们在配置多数据源的时候会无法加载多个数据源。那么我们如何给mybatis配置多数据源呢？

首先说一下思路：

我们知道，无论spring-boot多么的简介，他的配置依然是有的，就是在他自己的包里面，我们需要找，或者根据关键字去搜索。那么这些配置的本质是什么，就是创建一个mybatis的sqlSessionFactory，通过这sqlSessionFactory从而进行对数据源操作。并且，因为spring能够集成mybatis，所以关于mapperscan和指定mapperfile的问题能够通过注解和配置进行解决（当然，这些都建立在spring-boot自动创建的情况下）。

现在我们的问题是我们必须把这个DataSourceAutoConfiguration类排除掉，然后自己创建数据源，连接池和mybatis的sqlSessionFactory，然后在利用spring-mybatis进行整合。

好，下面上货。

1、首先引入pom依赖

<parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.6.RELEASE</version>
            <relativePath/> 
        </parent>
        <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>2.1.0</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework.boot</groupId>
                        <artifactId>spring-boot-starter</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.38</version>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
                <version>1.1.19</version>
            </dependency>

这一步需要注意的是spring-boot使用的是2.1.6，而目前为止，mybatis-spring-boot-starter最高版本是2.1.0，所以我们需要一个排除依赖包的操作，防止加载jar冲突。

2、创建配置类

package com.xueyou.scorpio.mybatis;
    
    
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.SqlSessionTemplate;
    import org.mybatis.spring.annotation.MapperScan;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    
    import javax.sql.DataSource;
    
    @Configuration
    @MapperScan(basePackages = {"com.xueyou.scorpio.mybatis.masterdao"}, sqlSessionFactoryRef = "sqlSessionFactory1")
    public class MybatisScorpioMasterConfig {
    
        private final Logger logger = LoggerFactory.getLogger(MybatisScorpioMasterConfig.class.getSimpleName());
        @Autowired
        @Qualifier("scorpioMaster")
        private DataSource ds1;
    
    
        @Bean
        public SqlSessionFactory sqlSessionFactory1() throws Exception {
            SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
            factoryBean.setDataSource(ds1);
            PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
            factoryBean.setConfigLocation(resolver.getResource("classpath:mybatis/mybatis-config.xml"));
            factoryBean.setMapperLocations(resolver.getResources("classpath:mybatis/mapper/masterMapper/*.xml"));
            return factoryBean.getObject();
        }
    
        @Bean
        public SqlSessionTemplate sqlSessionTemplate1() throws Exception {
            SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory1()); // 使用上面配置的Factory
            return template;
        }
    
    }

package com.xueyou.scorpio.mybatis;
    
    
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.SqlSessionTemplate;
    import org.mybatis.spring.annotation.MapperScan;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    
    import javax.sql.DataSource;
    
    @Configuration
    @MapperScan(basePackages = {"com.xueyou.scorpio.mybatis.slavedao"}, sqlSessionFactoryRef = "sqlSessionFactory2")
    public class MybatisScorpioSlaveConfig {
        private final Logger logger = LoggerFactory.getLogger(MybatisScorpioSlaveConfig.class.getSimpleName());
        @Autowired
        @Qualifier("scorpioSlave")
        private DataSource ds2;
    
    
        @Bean
        public SqlSessionFactory sqlSessionFactory2() throws Exception {
            SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
            factoryBean.setDataSource(ds2);
            PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
            factoryBean.setConfigLocation(resolver.getResource("classpath:mybatis/mybatis-config.xml"));
            factoryBean.setMapperLocations(resolver.getResources("classpath:mybatis/mapper/slaveMapper/*.xml"));
            return factoryBean.getObject();
        }
    
        @Bean
        public SqlSessionTemplate sqlSessionTemplate2() throws Exception {
            SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory2()); // 使用上面配置的Factory
            return template;
        }
    
    }

这一步一定要注意的是sqlSessionFactory需要自己制定mybatis-conifg和mapperfile的位置。原因是，现在的sqlSessionFactory已经不是通过DatasourceAutoConfiguration创建出来的了。所以，一些关键的属性，需要我们自己在代码里面配置。

3、配置datasource

package com.xueyou.scorpio.mybatis;
    
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.boot.jdbc.DataSourceBuilder;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.ImportResource;
    
    import javax.sql.DataSource;
    
    @Configuration
    @ImportResource(locations = {"classpath:mybatis/datasource.xml"})
    public class DataSourceConfig {
    //    @Bean(name = "scorpioMaster")
    //    @ConfigurationProperties(prefix = "spring.datasource.scorpio-master") // application.properteis中对应属性的前缀
    //    public DataSource dataSource1() {
    //        return DataSourceBuilder.create().build();
    //    }
    //
    //
    //    @Bean(name = "scorpioSlave")
    //    @ConfigurationProperties(prefix = "spring.datasource.scorpio-slave") // application.properteis中对应属性的前缀
    //    public DataSource dataSource2() {
    //        return DataSourceBuilder.create().build();
    //    }
    
    }

这里需要看到，我把这种方式已经注释掉了，而采用的xml方式，原因是这样的，我们在使用DataSourceBuilder创建datasource的时候，我们只能使用默认的连接池（Hikair），如果我们要使用自己的指定的数据库连接池，那么就需要自己指定datasource的获取方式。sqlSessionFactory中需要一个datasource，而没有强制要求datasource必须使用什么样的连接池，或者如何获得。所以我们是可以通过自己创建datasource的方式吧sqlSessionFactory和连接池都配置上。

4、配置连接池和连接

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    
        <bean id="scorpioMaster" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
            <property name="name" value="scorpioMasterPool"/>
            <property name="url" value="${scorpio-master.jdbc-url}"/>
            <property name="username" value="${scorpio-master.username}"/>
            <property name="password" value="${scorpio-master.password}"/>
    
            <property name="filters" value="stat"/>
    
            <property name="maxActive" value="${scorpio-master.druid.maxActive}"/>
            <property name="initialSize" value="${scorpio-master.druid.initialSize}"/>
            <property name="maxWait" value="${scorpio-master.druid.maxWait}"/>
            <property name="minIdle" value="${scorpio-master.druid.minIdle}"/>
    
            <property name="timeBetweenEvictionRunsMillis" value="${scorpio-master.druid.timeBetweenEvictionRunsMillis}"/>
            <property name="minEvictableIdleTimeMillis" value="${scorpio-master.druid.minEvictableIdleTimeMillis}"/>
    
            <property name="testWhileIdle" value="true"/>
            <property name="testOnBorrow" value="false"/>
            <property name="testOnReturn" value="false"/>
    
            <property name="poolPreparedStatements" value="true"/>
            <property name="maxOpenPreparedStatements" value="${scorpio-master.maxOpenPreparedStatements}"/>
    
            <property name="asyncInit" value="true"/>
        </bean>
        <bean id="scorpioSlave" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
            <property name="name" value="scorpioSlavePool"/>
            <property name="url" value="${scorpio-slave.jdbc-url}"/>
            <property name="username" value="${scorpio-slave.username}"/>
            <property name="password" value="${scorpio-slave.password}"/>
    
            <property name="filters" value="stat"/>
    
            <property name="maxActive" value="${scorpio-slave.druid.maxActive}"/>
            <property name="initialSize" value="${scorpio-slave.druid.initialSize}"/>
            <property name="maxWait" value="${scorpio-slave.druid.maxWait}"/>
            <property name="minIdle" value="${scorpio-slave.druid.minIdle}"/>
    
            <property name="timeBetweenEvictionRunsMillis" value="${scorpio-slave.druid.timeBetweenEvictionRunsMillis}"/>
            <property name="minEvictableIdleTimeMillis" value="${scorpio-slave.druid.minEvictableIdleTimeMillis}"/>
    
            <property name="testWhileIdle" value="true"/>
            <property name="testOnBorrow" value="false"/>
            <property name="testOnReturn" value="false"/>
    
            <property name="poolPreparedStatements" value="true"/>
            <property name="maxOpenPreparedStatements" value="${scorpio-slave.maxOpenPreparedStatements}"/>
    
            <property name="asyncInit" value="true"/>
        </bean>
    </beans>

能够看到这里的bean的名字就是MybatisScorpioMasterConfig配置类中的DataSource对应的bean(当然，也可以用@Resource注解)。

5、配置文件

# scorpioMaster库
    scorpio-master.jdbc-url=jdbc:mysql://localhost:3306/scorpio?characterEncoding=UTF-8&useSSL=true
    scorpio-master.username=****
    scorpio-master.password=******
    scorpio-master.driver-class-name=com.mysql.jdbc.Driver
    scorpio-master.druid.maxActive=20
    scorpio-master.druid.initialSize=1
    scorpio-master.druid.maxWait=60000
    scorpio-master.druid.minIdle=1
    scorpio-master.druid.timeBetweenEvictionRunsMillis=60000
    scorpio-master.druid.minEvictableIdleTimeMillis=300000
    scorpio-master.maxOpenPreparedStatements=20
    # scorpioSlave库
    scorpio-slave.jdbc-url=jdbc:mysql://localhost:3306/scorpioslave?characterEncoding=UTF-8&useSSL=true
    scorpio-slave.username=****
    scorpio-slave.password=******
    scorpio-slave.driver-class-name=com.mysql.jdbc.Driver
    scorpio-slave.druid.maxActive=20
    scorpio-slave.druid.initialSize=1
    scorpio-slave.druid.maxWait=60000
    scorpio-slave.druid.minIdle=1
    scorpio-slave.druid.timeBetweenEvictionRunsMillis=60000
    scorpio-slave.druid.minEvictableIdleTimeMillis=300000
    scorpio-slave.maxOpenPreparedStatements=20

最后我们看一下目录结构

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dpbGQ0NmNhdA_size_16_color_FFFFFF_t_70][]

可以了。

[https_blog.csdn.net_weixin_37664872_article_details_80088014]: https://blog.csdn.net/weixin_37664872/article/details/80088014
[https_blog.csdn.net_qq_42685050_article_details_81451029]: https://blog.csdn.net/qq_42685050/article/details/81451029
[https_github.com_alibaba_druid_wiki_DruidDataSource_E9_85_8D_E7_BD_AE]: https://github.com/alibaba/druid/wiki/DruidDataSource%E9%85%8D%E7%BD%AE
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dpbGQ0NmNhdA_size_16_color_FFFFFF_t_70]: /images/20211109/6cd312cba9544f4d9b6043aac41c09f2.png