Spring整合多数据源实现动态切换的实例讲解

在实际项目中时常需要连接多个数据库，而且不同的业务需求在实现过程当中往往需要访问不同的数据库。

jdbc.properties配置文件,配置多个dataSource

##########################MySQL#####################################
hibernate.dialect=org.hibernate.dialect.MySQLInnoDBDialect
connection.driver_class=com.mysql.jdbc.Driver
connection.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8
connection.username=yahu
connection.password=123456

##########################Oracle#####################################
connection1.driver_class=oracle.jdbc.driver.OracleDriver
connection1.url=jdbc\:oracle\:thin\:@localhost\:1521/MEDB
connection1.username=yahu
connection1.password=123456

##########################Sql Server2008#####################################
connection2.driver_class=net.sourceforge.jtds.jdbc.Driver
connection2.url=jdbc:jtds:sqlserver://localhost:1433;DatabaseName=test
connection2.username=yahu
connection2.password=123456

spring-config.xml配置文件如下,将DynamicDataSource Bean加入到Spring的上下文xml配置文件中去，同时配置DynamicDataSource的targetDataSources(多数据源目标)属性的Map映射,使用动态数据源DynamicDataSource是继承与AbstractRoutingDataSource，而AbstractRoutingDataSource又是继承于org.springframework.jdbc.datasource.AbstractDataSource，AbstractDataSource实现了统一的DataSource接口，所以DynamicDataSource同样可以当一个DataSource使用:

<!-- 数据库连接池配置 -->
  <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
  <property name="driverClassName" value="${connection.driver_class}" />
  <property name="url" value="${connection.url}" />
  <property name="username" value="${connection.username}" />
  <property name="password" value="${connection.password}" />
  
  <property name="initialSize" value="5" />
  <property name="minIdle" value="1" /> 
  <property name="maxActive" value="200" />
  
  <!-- 配置获取连接等待超时的时间 -->
  <property name="maxWait" value="30000" />
  
  <!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
  <property name="timeBetweenEvictionRunsMillis" value="60000" />
  
  <!-- 配置一个连接在池中最小生存的时间，单位是毫秒 -->
  <property name="minEvictableIdleTimeMillis" value="300000" />
 </bean>
 
 <!-- Oracle -->
 <bean id="dataSource1" class="org.apache.commons.dbcp.BasicDataSource">
  <property name="driverClassName" value="${connection1.driver_class}" />
  <property name="url" value="${connection1.url}" />
  <property name="username" value="${connection1.username}" />
  <property name="password" value="${connection1.password}" />
 </bean>

 <!-- Sql server 2008 -->
 <bean id="dataSource2" class="org.apache.commons.dbcp.BasicDataSource">
  <property name="driverClassName" value="${connection2.driver_class}" />
  <property name="url" value="${connection2.url}" />
  <property name="username" value="${connection2.username}" />
  <property name="password" value="${connection2.password}" />
 </bean>
 
  <!-- 动态数据源 -->
  <bean id="dynamicDataSource" class="com.yahu.core.dao.DynamicDataSource"> 
  <!-- 通过key-value的形式来关联数据源 --> 
  <property name="targetDataSources"> 
   <map> 
    <entry value-ref="dataSource" key="datasource" /> 
    <entry value-ref="dataSource1" key="datasource1" />
    <entry value-ref="dataSource2" key="datasource2" />   
   </map> 
  </property> 
  <property name="defaultTargetDataSource" ref="dataSource" /> 
 </bean>

DynamicDataSource动态数据源类,扩展Spring的AbstractRoutingDataSource抽象类，实现动态数据源,AbstractRoutingDataSource中的抽象方法determineCurrentLookupKey是实现数据源的route的核心.这里对该方法进行Override:

package com.yahu.core.dao;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

/*******************************************************************
 * @describe : 建立动态数据源类 必须继承AbstractRoutingDataSource
 ********************************************************************/
public class DynamicDataSource extends AbstractRoutingDataSource {
 //coverity 修改
 //private Log log = LogFactory.getLog(getClass());

 protected Object determineCurrentLookupKey() {
  String value = CustomerContextHolder.getCustomerType();
  //log.info(value);
  return value;
 }

}

获得和设置上下文环境,为一线程安全的ThreadLocal:

package com.yahu.core.dao;

/*******************************************************************
 * @describe : 获得和设置上下文环境
 ********************************************************************/
public class CustomerContextHolder {

 /**
  * mysql
  */
 public static final String DATASOURCE = "datasource";

 /**
  * oracle
  */
 public static final String DATASOURCE_1 = "datasource1";
 
 /**
  * sql server
  */
 public static final String DATASOURCE_2 = "datasource2";

 private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();

 public static void setCustomerType(String customerType) {
  contextHolder.set(customerType);
 }

 public static String getCustomerType() {
  return contextHolder.get();
 }

 public static void clearCustomerType() {
  contextHolder.remove();
 }
}

动态数据源的管理,如何选择控制每个业务中需要的具体数据源，可以使用手动控制,业务层通过加入以下代码

CustomerContextHolder.setCustomerType(CustomerContextHolder.DATASOURCE);

即可实现动态切换数据源,如果在service层有比较统一的规则的话，也可以使用aop设置数据源使用,这里一般都是一个service一个数据源，所以最好使用aop在service层执行完之后统一调用

CustomerContextHolder.clearCustomerType();

清空数据源信息。

当然，在上面配置里面有个参数defaultTargetDataSource为默认数据源，就是不设置数据源的话，就是用这个数据源。

以上这篇Spring整合多数据源实现动态切换的实例讲解就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。

# java多数据源动态切换  # Spring Boot 动态数据源示例（多数据源自动切换）  # Springboot如何设置多数据源  # 随时切换  # SpringBoot AOP方式实现多数据源切换的方法  # Spring实现动态切换多数据源的解决方案  # spring boot+mybatis 多数据源切换(实例讲解)  # Spring配置多数据源切换  # 详解Spring多数据源如何切换  # Spring通过拦截器实现多数据源切换的示例代码  # 配置文件  # 多个  # 给大家  # 可以使用  # 都是  # 有个  # 又是  # 希望能  # 在上面  # 这篇  # 中去  # 小编  # 如何选择  # 大家多多  # 清空  # 池中  # 实现了  # 多久  # 连接池  # 抽象类 

相关文章： 如何在建站之星网店版论坛获取技术支持？  教学论文网站制作软件有哪些,写论文用什么软件 ？  已有域名和空间如何搭建网站？  如何在宝塔面板中修改默认建站目录？  SQL查询语句优化的实用方法总结  个人摄影网站制作流程,摄影爱好者都去什么网站？  网站制作知乎推荐,想做自己的网站用什么工具比较好？  建站之星上传入口如何快速找到？  linux top下的 minerd 木马清除方法  如何正确下载安装西数主机建站助手？  建站OpenVZ教程与优化策略：配置指南与性能提升  如何设置并定期更换建站之星安全管理员密码？  如何挑选高效建站主机与优质域名？  中山网站制作网页,中山新生登记系统登记流程？  免费视频制作网站,更新又快又好的免费电影网站？  企业宣传片制作网站有哪些,传媒公司怎么找企业宣传片项目？  C++中的Pimpl idiom是什么，有什么好处？（隐藏实现）  建站之星代理如何优化在线客服效率？  建站中国官网：模板定制+SEO优化+建站流程一站式指南  较简单的网站制作软件有哪些,手机版网页制作用什么软件？  长春网站建设制作公司,长春的网络公司怎么样主要是能做网站的？  如何选择适合PHP云建站的开源框架？  ,石家庄四十八中学官网？  如何快速查询网址的建站时间与历史轨迹？  哪家制作企业网站好,开办像阿里巴巴那样的网络公司和网站要怎么做？  ppt在线制作免费网站推荐,有什么下载免费的ppt模板网站？  在线ppt制作网站有哪些,请推荐几个好的课件下载的网站？  如何在阿里云通过域名搭建网站？  如何用IIS7快速搭建并优化网站站点？  Java解压缩zip - 解压缩多个文件或文件夹实例  百度网页制作网站有哪些,谁能告诉我百度网站是怎么联系？  ,制作一个手机app网站要多少钱？  建站主机是否属于云主机类型？  建站主机是什么？如何选择适合的建站主机？  如何选择美橙互联多站合一建站方案？  微信h5制作网站有哪些,免费微信H5页面制作工具？  c# 在高并发场景下，委托和接口调用的性能对比  青岛网站设计制作公司,查询青岛招聘信息的网站有哪些？  c++怎么编写动态链接库dll_c++ __declspec(dllexport)导出与调用【方法】  如何在万网ECS上快速搭建专属网站？  php json中文编码为null的解决办法  如何选择适配移动端的WAP自助建站平台？  如何获取免费开源的自助建站系统源码？  XML的“混合内容”是什么 怎么用DTD或XSD定义  宝塔建站后网页无法访问如何解决？  如何选择长沙网站建站模板？H5响应式与品牌定制哪个更优？  公众号网站制作网页,微信公众号怎么制作？  宝华建站服务条款解析：五站合一功能与SEO优化设置指南  如何制作新型网站程序文件,新型止水鱼鳞网要拆除吗？  济南网站制作的价格,历城一职专官方网站？