[Java知识库]springBoot多数据源连接池（传统xml配置）

零、需求需要在一个项目中访问多个数据源，解决方案。项目的数据源是通过Druid配置的数据库连接池方案，通过配置Druid的主副数据源配置，实现在应用方可以便捷切换数据库设置。

一、pom依赖

implementation group: 'mysql', name: 'mysql-connector-java', version: '8.0.25'
implementation 'org.mybatis.spring.boot:mybatis-spring-boot-starter:2.1.4'
compile group: 'com.alibaba', name: 'druid', version: '1.2.4'

二、application.properties配置文件

#淘宝主数据源
taobao.jdbc.driverClassName=com.mysql.cj.jdbc.Driver
taobao.jdbc.url=jdbc:mysql://1.2.3.4:3306/taobaodb?allowMultiQueries=true  //允许多sql执行
taobao.jdbc.username=taobao
taobao.jdbc.password=taobao123
taobao.jdbc.maxActive=10 #最大连接数
taobao.jdbc.maxIdle=10 #最大维持空闲连接
taobao.jdbc.minIdle=2 #最小维持空闲连接数
#腾讯副数据源
tencent.jdbc.driverClassName=com.mysql.cj.jdbc.Driver
tencent.jdbc.url=jdbc:mysql://10.20.30.40:3306/tencentdb?allowMultiQueries=true
tencent.jdbc.username=tengcent
tencent.jdbc.password=tengcent1233
tencent.jdbc.maxActive=10 
tencent.jdbc.maxIdle=10
tencent.jdbc.minIdle=2

#其他可配置连接池参数
initialSize 初始化连接数
maxWait 连接池出借连接最长期限，单位毫秒
maxAge 连接寿命，超过寿命连接池会删除连接

三、Main函数，引用xml配置

@SpringBootApplication(exclude= {DataSourceAutoConfiguration.class})
@ImportResource({"classpath:applicationContext.xml"})
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application .class,args);
    }
}

四、applicationContext.xml 配置数据库连接池文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd">

<!--加载配置文件-->
    <context:property-placeholder location="classpath*:*.properties,file:${user.dir}/*.properties"/>

<!--java文件扫描路径-->
    <context:component-scan base-package="com.longze">
    </context:component-scan>

    <bean id="viewResolver" class="org.springframework.web.servlet.view.InternalResourceViewResolver">
        <property name="redirectHttp10Compatible" value="false" />
    </bean>

<!--taobao数据源配置-->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
          destroy-method="close" primary="true">
        <property name="driverClassName" value="${taobao.jdbc.driverClassName}"/>
        <property name="url" value="${taobao.jdbc.url}"/>
        <property name="username" value="${taobao.jdbc.username}"/>
        <property name="password" value="${taobao.jdbc.password}"/>

        <!-- 数据池中最大连接数和最小连接数-->
        <property name="maxActive" value="${taobao.jdbc.maxActive}"/>
        <property name="minIdle" value="${taobao.jdbc.minIdle}"/>
    </bean>

    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean" primary="true">
        <!-- 注入连接池
         给 sqlsessionFactory 的属性 dataSource 赋值
            ref="引用该 spring容器 中的另一个 bean的id"-->
        <property name="dataSource" ref="dataSource"/>
        <property name="configLocation" value="classpath:mybatis-config.xml"/>
        <!-- 注入 映射文件 mapper
         给 sqlsessionFactory 的属性 mapperLocation 赋值
           value="映射文件 XXXmapper.xml 的相对路径"
          -->
        <property name="mapperLocations" value="classpath:mappers/*.xml"/>
    </bean>

    <!-- 3) 获取 SqlSession 对象，并交由 spring 管理  用SqlSessionTemplate得到的SqlSession可以不用我们自己操心事务的管理，以及关闭操作,主数据源-->
    <bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate" primary="true" >
        <!-- 给 SqlSessionTemplate 的构造函数赋值-->
        <constructor-arg index="0" ref="sqlSessionFactory" />
    </bean>

    <!--腾讯数据源 配置-->
    <bean id="tencentDataSource" class="com.alibaba.druid.pool.DruidDataSource"
          destroy-method="close" primary="false">
        <property name="driverClassName" value="${tencent.jdbc.driverClassName}"/>
        <property name="url" value="${tencent.jdbc.url}"/>
        <property name="username" value="${tencent.jdbc.username}"/>
        <property name="password" value="${tencent.jdbc.password}"/>
        <!-- 数据池中最大连接数和最小连接数-->
        <property name="maxActive" value="${tencent.jdbc.maxActive}"/>
        <property name="minIdle" value="${tencent.jdbc.minIdle}"/>
    </bean>
    <bean id="tencentSqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean" primary="false">
        <property name="dataSource" ref="tencentDataSource"/>
        <property name="configLocation" value="classpath:mybatis-config.xml"/>
        <property name="mapperLocations" value="classpath:tencentMappers/*.xml"/>
    </bean>
<!--     3) 获取 SqlSession 对象，并交由 spring 管理  用SqlSessionTemplate得到的SqlSession可以不用我们自己操心事务的管理，以及关闭操作，副数据源-->
    <bean id="tencentSqlSession" class="org.mybatis.spring.SqlSessionTemplate" primary="false" >
        <constructor-arg index="0" ref="tencentSqlSessionFactory" />
    </bean>

</beans>

五、很一般的mybatis-ciconfig.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">

<configuration>
    <settings>
        <setting name="callSettersOnNulls" value="true"/>
        <setting name="jdbcTypeForNull" value="NULL" />
        <setting name="mapUnderscoreToCamelCase" value="true"/>
    </settings>

</configuration>

六、Mybatis引用数据源工具类?MySqlUtil.java

路径：com/longze/MySqlUtil.java

@Component
public class MysqlUtil {

    private static WebApplicationContext context;

    public static WebApplicationContext getContext() {
        return context;
    }

    @Autowired
    public void setContext(WebApplicationContext context) {
        setContextStatic(context);
    }
    //taobao主数据源
    public static SqlSession getTaobaoSqlSession() {
        return (SqlSession) context.getBean("sqlSession");
    }
    //tencent副数据源
    public static SqlSession getTengcentSqlSession() {
        return (SqlSession) context.getBean("tencentSqlSession");
    }

    public static void setContextStatic(WebApplicationContext context){
        MyBatisUtil.context=context;
    }
}

七、两种调用sql方案

在一个普通service文件层

@Service
public class DateServiceImpl {
    public Integer insTaobao(List<String> params){
        Integer result = MyBatisUtil.getTaoBaoSqlSession().insert("com.longze.taobao.dao.taobaoinsert",params);
        return result;
    }

    public Integer insTencent(){
        Integer result = MyBatisUtil.getTencentSqlSession().insert("com.longze.tencent.dao.tancentinsert");
        return result;
    }
}

八、要注意两个文件的xml，sql脚本文件是分开的。对应的分别是配置好的

taobao ->?classpath:mappers/*.xml

tencent ->?classpath:tencentMappers/*.xml

因此对应的sql的xml文件再如下路径中：

taobao: src/main/resource/mappers/sqldao1.xml

tencent:?src/main/resource/tencentMappers/sqldao2.xml

对应的两个sql的xml文件抬头如下

淘宝：

<?xml version="1.0"  encoding="UTF-8"?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

<mapper namespace="com.longze.taobao.dao">
????????<insert id=taobaoinsert></insert>
</mapper>

腾讯：

<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.longze.tencent.dao">
????????<insert id=tencentinsert></insert>
</mapper>

九、完成

完成了如上配置，就可以在代码上自由的加上多数据源配置了。同时还是数据库连接池

创作打卡挑战赛

赢取流量/现金/CSDN周边激励大奖