新建com.millery.utils包在其下新建DataSourceContextHolder类

package com.millery.utils;public class DataSourceContextHolder {  private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();  public static void setDbType(String dbType) {  contextHolder.set(dbType);  }  public static String getDbType() {  return ((String) contextHolder.get());  }  public static void clearDbType() {  contextHolder.remove();  }
}
复制代码

新建DataSourceContextHolder类

package com.millery.utils;import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;public class DynamicDataSource extends AbstractRoutingDataSource {  @Override  protected Object determineCurrentLookupKey() {  return DataSourceContextHolder.getDbType();  }
}
复制代码

配置mybatis

<?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:tx="http://www.springframework.org/schema/tx"
xmlns:jpa="http://www.springframework.org/schema/data/jpa"
xmlns:util="http://www.springframework.org/schema/util"
xmlns:jaxws="http://cxf.apache.org/jaxws"  xmlns:p="http://www.springframework.org/schema/p"
xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation="http://www.springframework.org/schema/beans     http://www.springframework.org/schema/beans/spring-beans-4.3.xsd     http://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-4.3.xsdhttp://www.springframework.org/schema/tx     http://www.springframework.org/schema/tx/spring-tx-4.3.xsd     http://www.springframework.org/schema/util  http://www.springframework.org/schema/util/spring-util-4.3.xsd http://www.springframework.org/schema/aop     http://www.springframework.org/schema/aop/spring-aop-4.3.xsd   http://www.springframework.org/schema/data/jpa                           http://www.springframework.org/schema/data/jpa/spring-jpa-1.0.xsd        http://www.springframework.org/schema/beans                              http://www.springframework.org/schema/beans/spring-beans.xsd    http://cxf.apache.org/jaxws    http://cxf.apache.org/schemas/jaxws.xsd"><import resource="classpath:META-INF/cxf/cxf.xml"/>  <import resource="classpath:META-INF/cxf/cxf-servlet.xml"/>  <import resource="classpath:META-INF/cxf/cxf-extension-soap.xml"/> <!-- 自动扫描 --><context:component-scan base-package="com.hqgf" /><!-- 引入配置文件 --><bean id="propertyConfigurer"class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"><property name="location" value="classpath:jdbc.properties" /></bean><!-- <util:properties id="APP_PROPERTIES" location="classpath:attendance.properties" local-override="true"/> --><bean id="HrtestSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"><property name="driverClassName" value="com.microsoft.sqlserver.jdbc.SQLServerDriver"/><property name="url" value="jdbc:sqlserver://172.69.1.236;DatabaseName=LongshineWebHr" /><property name="username" value="sa" /><property name="password" value="Hqmart88" /></bean><bean id="HrSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"><property name="driverClassName" value="com.microsoft.sqlserver.jdbc.SQLServerDriver"/><property name="url" value="jdbc:sqlserver://172.88.10.161;DatabaseName=LongshineWebHr " /><property name="username" value="sa" /><property name="password" value="Hqmart88" /></bean><bean id="AttendanceSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"><property name="driverClassName" value="com.mysql.jdbc.Driver" /><property name="url" value="jdbc:mysql://172.69.1.8:3306/hws_sqlservice?useUnicode\=true;characterEncoding\=utf-8" /><property name="username" value="root" /><property name="password" value="mysql_root2017@hqtest.com" /></bean><!-- spring和MyBatis完美整合，不需要mybatis的配置映射文件 --><bean id="dataSource" class="com.millery.utils.DynamicDataSource">    <property name="targetDataSources">    <map key-type="java.lang.String">    <entry value-ref="HrtestSource" key="HrtestSource"></entry>    <entry value-ref="HrSource" key="HrSource"></entry>   <entry value-ref="AttendanceSource" key="AttendanceSource"></entry> </map>    </property>    <property name="defaultTargetDataSource" ref="HrtestSource"></property><!-- 默认使用HrtestSource的数据源 -->  </bean>  <!-- 2. mybatis 的SqlSession 的工厂: SqlSessionFactoryBean -->  <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">  <property name="dataSource" ref="dataSource"/>  <property name="mapperLocations" value="classpath:com/hqgf/mapping/*.xml"/>  </bean> <!-- 3. mybatis 自动扫描加载Sql 映射文件 : MapperScannerConfigurer -->  <!-- <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">  <property name="basePackage" value="com.mapper"/>  <property name="sqlSessionFactory" ref="sqlSessionFactory"/>  </bean>  -->           <!-- 4. 事务管理 : DataSourceTransactionManager -->  <bean  id="txManager"   class="org.springframework.jdbc.datasource.DataSourceTransactionManager">  <property name="dataSource" ref="dataSource"/>  </bean>   <!-- 5. 使用声明式事务 -->  <tx:annotation-driven transaction-manager="txManager" />  <!-- 数据抓取任务 --><!-- 任务实体 --><bean id="eleTaskBean" class="com.hqgf.attendanceupload.HwsTimeTask" /> <bean id="eletasktimingmethod" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="targetObject" ref="eleTaskBean" /> <!-- targetMethod 配置定时执行的方法名 --><property name="targetMethod" value="TimeTaskData" /> <property name="concurrent" value="false" /> </bean><!-- 设置每天凌晨两点执行定时任务 --><bean id="eleTaskTrigger"class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"> <property name="jobDetail" ref="eletasktimingmethod" /> <property name="cronExpression" value="01 50 16 * * ?" /> </bean>  <!-- 订制任务列表 --><bean id="scheduler"class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="triggers"> <list> <ref bean="eleTaskTrigger" /> </list> </property> </bean>
</beans>
复制代码

每个mapper调用之前

    @Overridepublic String queryDept(String hr_dept_code) throws Exception {DataSourceContextHolder.setDbType("AttendanceSource");//注意这里在调用userMapper前切换到AttendanceSource的数据源 String attendanceid= getSqlSession().selectOne("com.hqgf.dao.IUploadAttendanceDao.queryDept",hr_dept_code);System.out.println("部门编码匹配成功__"+attendanceid);return attendanceid;}
复制代码

数据库切换成功。