多数据源切换

 第一数据源是mysql 

connection.url=jdbc:mysql://127.0.0.1:3306/bmh?useUnicode=true&characterEncoding=utf8
connection.username=root
connection.password=bNVOqb7WKLX5Bjnw+LMv92taj25KOxDimXxILPQjw42wgv+1lHzOH8kr97xDwWdhpY67QuYCS7sWN4W46YbkFA==

<?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:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="
          http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
          http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd
          http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd">

    <!-- JNDI方式配置数据源 -->
    <!--<bean id="dataSource" class="org.springframework.jndi.JndiObjectFactoryBean"> <property name="jndiName" value="${jndiName}"></property> </bean> -->
    <!-- 数据源 -->
    <!--see https://github.com/alibaba/druid/wiki/%E9%85%8D%E7%BD%AE_DruidDataSource%E5%8F%82%E8%80%83%E9%85%8D%E7%BD%AE -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
        <!-- 基本属性 url、user、password -->
        <property name="url" value="${connection.url}"/>
        <property name="username" value="${connection.username}"/>
        <property name="password" value="${connection.password}"/>
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>


        <!-- 初始化连接大小、连接池最小空闲、最大使用连接数量 -->
        <property name="initialSize" value="${druid.initialSize}"/>
        <property name="minIdle" value="${druid.minIdle}"/>
        <property name="maxActive" value="${druid.maxActive}"/>
        <!-- 获取连接等待超时的时间 -->
        <property name="maxWait" value="${druid.maxWait}"/>

        <!-- 打开PSCache，并且指定每个连接上PSCache的大小 如果用Oracle，则把poolPreparedStatements配置为true，mysql可以配置为false。 -->
        <property name="poolPreparedStatements" value="${druid.poolPreparedStatements}"/>
        <property name="maxPoolPreparedStatementPerConnectionSize"
                  value="${druid.maxPoolPreparedStatementPerConnectionSize}"/>

        <!-- 检测连接是否有效sql，要求是一个查询语句，如果为null，则后三个参数无效。 -->
        <property name="validationQuery" value="${druid.validationQuery}"/>
        <!-- 申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis，执行validationQuery检测连接是否有效。 -->
        <property name="testWhileIdle" value="${druid.testWhileIdle}"/>
        <!-- 申请连接时执行 validationQuery检测连接是否有效，做了这个配置会降低性能。 -->
        <property name="testOnBorrow" value="${druid.testOnBorrow}"/>
        <!-- 归还连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能 -->
        <property name="testOnReturn" value="${druid.testOnReturn}"/>

        <!-- 间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
        <property name="timeBetweenEvictionRunsMillis" value="${druid.timeBetweenEvictionRunsMillis}"/>
        <!-- 一个连接在池中最小生存的时间，单位是毫秒 -->
        <property name="minEvictableIdleTimeMillis" value="${druid.minEvictableIdleTimeMillis}"/>

        <!-- 打开removeAbandoned功能 -->
        <property name="removeAbandoned" value="true"/>
        <property name="removeAbandonedTimeout" value="1800"/>
        <property name="logAbandoned" value="true"/>

        <!-- 配置监控统计拦截的filters -->
        <property name="filters" value="${druid.filters}"/>

        <!-- 慢查询sql打印 -->
        <property name="connectionProperties" value="${druid.connectionProperties}"/>
    </bean>


    <bean id="vendorProperties" class="org.springframework.beans.factory.config.PropertiesFactoryBean">
        <property name="properties">
            <props>
                <prop key="SQL Server">sqlserver</prop>
                <prop key="DB2">db2</prop>
                <prop key="Oracle">oracle</prop>
                <prop key="MySQL">mysql</prop>
            </props>
        </property>
    </bean>
    <bean id="databaseIdProvider" class="org.apache.ibatis.mapping.VendorDatabaseIdProvider">
        <property name="properties" ref="vendorProperties"/>
    </bean>


    <bean id="sqlSessionFactory" class="com.ylzinfo.eva.core.persistence.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource"/>
        <property name="mapperLocations">
            <list>
                <value>classpath:/mappings/**/*.xml</value>
            </list>
        </property>
        <property name="plugins">
            <bean class="com.ylzinfo.framework.sys.web.mybatis.MybatisSpringPageInterceptor"></bean>
        </property>
        <!-- 数据库id标识 -->
        <property name="databaseIdProvider" ref="databaseIdProvider"></property>
        <!-- 注册类型 -->
        <property name="typeAliasesPackage" value="com.ylzinfo.**.domain"></property>

    </bean>

    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="com.ylzinfo.**.dao"></property>
        <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>
    </bean>

    <!--事务管理器配置 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean>


    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <tx:method name="find*" propagation="REQUIRED" read-only="true"/>
            <tx:method name="query*" propagation="REQUIRED" read-only="true"/>
            <tx:method name="read*" propagation="REQUIRED" read-only="true"/>
            <tx:method name="get*" propagation="REQUIRED" read-only="true"/>
            <tx:method name="list*" propagation="REQUIRED" read-only="true"/>
            <tx:method name="count*" propagation="REQUIRED" read-only="true"/>

            <tx:method name="add*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>
            <tx:method name="save*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>
            <tx:method name="insert*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>
            <tx:method name="create*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>

            <tx:method name="update*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>
            <tx:method name="modify*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>
            <tx:method name="edit*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>

            <tx:method name="del*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>
            <tx:method name="remove*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>

            <tx:method name="grant*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>
            <tx:method name="un*" propagation="REQUIRED" rollback-for="java.lang.Exception"/>

            <!-- <tx:method name="*" propagation="REQUIRED" read-only="true"/>-->
        </tx:attributes>
    </tx:advice>

    <aop:config>
        <!-- 只对业务逻辑层实施事务 -->
        <aop:pointcut id="pointcut"
                      expression="execution(* com.ylzinfo..service..*Impl.*(..)) or execution(* com.ylzinfo..task..*Impl.*(..))"/>
        <aop:advisor id="advisor" advice-ref="txAdvice" pointcut-ref="pointcut"/>
    </aop:config>
</beans>

第二数据源oracle

#第二数据源
oracle.jdbc.driver=oracle.jdbc.OracleDriver
oracle.mysql.jdbc.url=jdbc:oracle:thin:@127.0.0.2:1521/SHBX
oracle.myjdbc.username=shbxcard
oracle.jdbc.password=shbxcard


#第三数据源
1oracle.jdbc.driver=oracle.jdbc.OracleDriver
1oracle.mysql.jdbc.url=jdbc:oracle:thin:@127.0.0.3:1521/ZXCSORCL
1oracle.myjdbc.username=nxsi_ykt
1oracle.jdbc.password=YKT@SBH61093

<?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>

    <properties resource="oracle-db.properties" />
    
     <settings>
    
        <!-- 设置自动驼峰转换         -->
        <setting name="mapUnderscoreToCamelCase" value="true" />

        <!-- 开启懒加载 -->        
         <!-- 当启用时，有延迟加载属性的对象在被调用时将会完全加载任意属性。否则，每种属性将会按需要加载。默认：true -->
      <setting name="aggressiveLazyLoading" value="false" />

    </settings>

    <!-- 别名定义 -->
    <typeAliases>
        <package name="com.ylzinfo.socialsecurity.domain.model" />
    </typeAliases>


    <!--配置environment环境 -->
    <environments default="development">
        <!-- 环境配置1，每个SqlSessionFactory对应一个环境 -->
        <environment id="development">
            <transactionManager type="JDBC" />
            <dataSource type="UNPOOLED">
                <property name="driver" value="${oracle.jdbc.driver}" />
                <property name="url" value="${oracle.mysql.jdbc.url}" />
                <property name="username" value="${oracle.myjdbc.username}" />
                <property name="password" value="${oracle.jdbc.password}" />
            </dataSource>
        </environment>


    </environments>

    <!-- 映射文件，mapper的配置文件 -->
    <mappers>
        <!--直接映射到相应的mapper文件 -->
        <mapper resource="mappings/callable/AppGthdDao.xml" />
        <mapper resource="mappings/callable/AppGtdjDao.xml" />
        <mapper resource="mappings/socialsecurity/ABA1Mapper.xml" />
        <mapper resource="mappings/socialsecurity/CBCXMapper.xml" />
        <mapper resource="mappings/socialsecurity/ExpendsQueryMapper.xml" />
        <mapper resource="mappings/socialsecurity/BC18Mapper.xml" />
        <mapper resource="mappings/socialsecurity/SocialCardInfoMapper.xml" />
        <mapper resource="mappings/callable/SocialCardBindMapper.xml" />
        <mapper resource="mappings/socialsecurity/AC01Mapper.xml" />
        <mapper resource="mappings/callable/AppCbdjYLMapper.xml" />
        <mapper resource="mappings/callable/AppCbhdYLMapper.xml" />
    </mappers>


</configuration>  

package com.ylzinfo.socialsecurity.util;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import java.io.IOException;
import java.io.Reader;

/**
 * description
 * created         2019/9/3 14:29
 *
 * @version --添加版本信息
 * @author hoje
 * @since Version 1.0
 */
public class SqlSessionFactoryUtil {

    private static SqlSessionFactory sessionFactory;
    static {
        Reader reader =null;
        try {
            reader= Resources.getResourceAsReader("mybatis-config2.xml");
            sessionFactory =new SqlSessionFactoryBuilder().build(reader,"development");
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                reader.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    public  static SqlSession getSession(){
        return  sessionFactory.openSession();
    }
}

填写映射文件

第三数据源

<?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>

    <properties resource="oracle-db.properties" />
    
     <settings>
    
        <!-- 设置自动驼峰转换         -->
        <setting name="mapUnderscoreToCamelCase" value="true" />

        <!-- 开启懒加载 -->        
         <!-- 当启用时，有延迟加载属性的对象在被调用时将会完全加载任意属性。否则，每种属性将会按需要加载。默认：true -->
      <setting name="aggressiveLazyLoading" value="false" />

    </settings>

    <!-- 别名定义 -->
    <typeAliases>
        <package name="com.ylzinfo.socialsecurity.domain.model" />
    </typeAliases>


    <!--配置environment环境 -->
    <environments default="development">
        <!-- 环境配置1，每个SqlSessionFactory对应一个环境 -->
        <environment id="development">
            <transactionManager type="JDBC" />
            <dataSource type="UNPOOLED">
                <property name="driver" value="${1oracle.jdbc.driver}" />
                <property name="url" value="${1oracle.mysql.jdbc.url}" />
                <property name="username" value="${1oracle.myjdbc.username}" />
                <property name="password" value="${1oracle.jdbc.password}" />
            </dataSource>
        </environment>


    </environments>

    <!-- 映射文件，mapper的配置文件 -->
    <mappers>
        <!--直接映射到相应的mapper文件 -->
        <mapper resource="mappings/callable/AppCbdjYBMapper.xml" />
        <mapper resource="mappings/callable/AppCbhdYBMapper.xml" />
    </mappers>


</configuration>  

package com.ylzinfo.socialsecurity.util;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import java.io.IOException;
import java.io.Reader;

/**
 * description
 * created         2019/9/3 14:29
 *
 * @version --添加版本信息
 * @author hoje
 * @since Version 1.0
 */
public class SqlSessionFactoryUtil3 {

    private static SqlSessionFactory sessionFactory;
    static {
        Reader reader =null;
        try {
            reader= Resources.getResourceAsReader("mybatis-config3.xml");
            sessionFactory =new SqlSessionFactoryBuilder().build(reader,"development");
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                reader.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    public  static SqlSession getSession(){
        return  sessionFactory.openSession();
    }
}

如何调用

以调用存储过程为例

   SqlSession session = SqlSessionFactoryUtil.getSession();
            AppCbdjYLMapper AppCbdjYLMapper = session.getMapper(AppCbdjYLMapper.class);
            Map map = new HashMap();
            map.put("is_aab301", aab301);
            map.put("is_aac002", aac002);
            map.put("is_aac003", aac003);
            map.put("is_aae006", aae006);
            map.put("is_aac067", aac067);
            AppCbdjYLMapper.appcbdjyl(map);
            String info;
            info = (String) map.get("os_errinfo");
  session.commit();//这里一定要提交，不然数据进不去数据库中
            session.close();