1.配置两个不同的数据源，如下（由于项目使用的是druid数据库连接，配置可以会复杂点比较）：

<!-- 数据源配置1 --> 
  <bean id="testDataSource1" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">  
   <property name="driverClassName" value="${db.driver}" /> 
    <property name="url" value="${unity.db.jdbc.url}" />  
   <property name="username" value="${db.login.name}"></property> 
   <property name="password" value="${db.login.password}" /> 
   <property name="filters" value="${db.filters}"></property> 
   <property name="maxActive" value="${db.pool.maxActive}"></property> 
   <property name="initialSize" value="${db.pool.initialSize}"></property> 
   <property name="minIdle" value="${db.pool.minIdle}"></property> 
   <property name="maxWait" value="${db.maxWait}"></property>   
   <property name="timeBetweenEvictionRunsMillis" value="${db.timeBetweenEvictionRunsMillis}"></property> 
   <property name="minEvictableIdleTimeMillis" value="${db.minEvictableIdleTimeMillis}"></property> 
   <property name="validationQuery" value="${db.validationQuery}"></property> 
   <property name="testWhileIdle" value="${db.testWhileIdle}"></property> 
   <property name="testOnBorrow" value="${db.testOnBorrow}"></property> 
   <property name="testOnReturn" value="${db.testOnReturn}"></property> 
   <property name="poolPreparedStatements" value="${db.poolPreparedStatements}"></property> 
   <property name="maxOpenPreparedStatements" value="${db.maxOpenPreparedStatements}"></property> 
   <!-- 监控数据库 --> 
    <property name="proxyFilters"> 
      <list> 
        <ref bean="log-filter" /> 
      </list>  
    </property> 
    
 </bean> 

<!-- 数据源配置2 --> 
 <bean id="testDataSource2" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">  
  <property name="driverClassName" value="${db.driver}" /> 
   <property name="url" value="${pub.db.jdbc.url}" />  
  <property name="username" value="${db.login.name}"></property> 
  <property name="password" value="${db.login.password}" /> 
  <property name="filters" value="${db.filters}"></property> 
  <property name="maxActive" value="${db.pool.maxActive}"></property> 
  <property name="initialSize" value="${db.pool.initialSize}"></property> 
  <property name="minIdle" value="${db.pool.minIdle}"></property> 
  <property name="maxWait" value="${db.maxWait}"></property>   
  <property name="timeBetweenEvictionRunsMillis" value="${db.timeBetweenEvictionRunsMillis}"></property> 
  <property name="minEvictableIdleTimeMillis" value="${db.minEvictableIdleTimeMillis}"></property> 
  <property name="validationQuery" value="${db.validationQuery}"></property> 
  <property name="testWhileIdle" value="${db.testWhileIdle}"></property> 
  <property name="testOnBorrow" value="${db.testOnBorrow}"></property> 
  <property name="testOnReturn" value="${db.testOnReturn}"></property> 
  <property name="poolPreparedStatements" value="${db.poolPreparedStatements}"></property> 
  <property name="maxOpenPreparedStatements" value="${db.maxOpenPreparedStatements}"></property> 
  <!-- 监控数据库 --> 
   <property name="proxyFilters"> 
     <list> 
       <ref bean="log-filter" /> 
     </list>  
   </property> 
   
</bean> 

2.定义一个类继承AbstractRoutingDataSource实现determineCurrentLookupKey方法，该方法可以实现数据库的动态切换，如下：

public class DynamicDataSource extends AbstractRoutingDataSource { 
  @Override 
  protected Object determineCurrentLookupKey() { 
    return DataSourceContextHolder.getDataSourceType(); 
  } 
} 

3.定义一个可以设置当前线程的变量的工具类，用于设置对应的数据源名称：

public class DataSourceContextHolder { 
  private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>(); 
  /** 
   * @Description: 设置数据源类型 
   * @param dataSourceType 数据库类型 
   * @return void 
   * @throws 
   */ 
  public static void setDataSourceType(String dataSourceType) { 
    contextHolder.set(dataSourceType); 
  } 
   
  /** 
   * @Description: 获取数据源类型 
   * @param 
   * @return String 
   * @throws 
   */ 
  public static String getDataSourceType() { 
    return contextHolder.get(); 
  } 
   
  /** 
   * @Description: 清除数据源类型 
   * @param 
   * @return void 
   * @throws 
   */ 
  public static void clearDataSourceType() { 
    contextHolder.remove(); 
  } 
} 

然后在spring中配置，如下：

 <!-- 编写spring 配置文件的配置多数源映射关系 --> 
<bean class="com.sino.access.database.DynamicDataSource" id="dataSource"> 
  <property name="targetDataSources"> 
    <map key-type="java.lang.String"> 
      <entry value-ref="testDataSource1" key="<span style="font-family: Arial, Helvetica, sans-serif;">testDataSource1</span><span style="font-family: Arial, Helvetica, sans-serif;">"></entry></span> 
      <entry value-ref="testDataSource2" key="testDataSource2"></entry> 
    </map> 
  </property> 
  <property name="defaultTargetDataSource" ref="testDataSource1"> 
  </property> 
</bean> 
 </bean>

这样配置两个数据源对应的key分别为testDataSource1和testDataSource2，默认数据库是testDataSource。

4.完成以上步骤后，如果没有数据库的事务管理，已经可以实现数据库的动态切换了。但是如果涉及到数据库的事务管理，需要在数据库事务开启切换数据库，

否则数据库的切换只能在下次数据库操作时才生效。可以定义一个aop处理类在数据库事务开启之前切换数据库，如下：

public class DataSourceAspect implements MethodBeforeAdvice,AfterReturningAdvice  
{ 
 
  @Override 
  public void afterReturning(Object returnValue, Method method, 
      Object[] args, Object target) throws Throwable { 
    // TODO Auto-generated method stub 
    DataSourceContextHolder.clearDataSourceType(); 
  } 
 
  @Override 
  public void before(Method method, Object[] args, Object target) 
      throws Throwable { 
   
    if (method.isAnnotationPresent(DataSource.class))  
    { 
      DataSource datasource = method.getAnnotation(DataSource.class); 
      DataSourceContextHolder.setDataSourceType(datasource.name()); 
    } 
    else 
    { 
      DataSourceContextHolder.setDataSourceType(SinoConstant.DataSourceType.unityDataSource.toString()); 
    } 
     
  } 
} 

5.设置数据库事务切面和切换数据库切面执行的顺序，如下：

<aop:config> 
  <aop:pointcut id="transactionPointCut" expression="execution(* com.test.service.*.*(..))" /> 
  <aop:advisor pointcut-ref="transactionPointCut" 
    advice-ref="txAdvice" order="2" /> 
  <aop:advisor advice-ref="dataSourceExchange" pointcut-ref="transactionPointCut" order="1"/> 
</aop:config> 

利用aop的order属性设置执行的顺序，这样实现了带事务管理的spring数据库动态切换。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# spring动态切换数据源  # spring  # 多数据源切换  # 动态数据源  # Spring整合多数据源实现动态切换的实例讲解  # spring boot多数据源动态切换代码实例  # Spring Boot 动态数据源示例（多数据源自动切换）  # Spring实现动态切换多数据源的解决方案  # druid多数据源配置+Datasurce动态切换方式  # 可以实现  # 的是  # 如果没有  # 分别为  # 涉及到  # 时才  # 配置文件  # 大家多多  # 实现了  # filter  # log  # determineCurrentLookupKey  # AbstractRoutingDataSource  # pub  # ref  # testOnBorrow  # testOnReturn  # testWhileIdle  # druid  # proxyFilters 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Laravel Blade模板引擎语法_Laravel Blade布局继承用法  Laravel怎么做缓存_Laravel Cache系统提升应用速度的策略与技巧  如何在阿里云ECS服务器部署织梦CMS网站？  JavaScript常见的五种数组去重的方式  Laravel如何处理和验证JSON类型的数据库字段  Laravel如何实现多级无限分类_Laravel递归模型关联与树状数据输出【方法】  网页设计与网站制作内容,怎样注册网站？  如何在Tomcat中配置并部署网站项目？  微信小程序 闭包写法详细介绍  如何使用 jQuery 正确渲染 Instagram 风格的标签列表  C语言设计一个闪闪的圣诞树  如何在香港服务器上快速搭建免备案网站？  打开php文件提示内存不足_怎么调整php内存限制【解决方案】  Laravel如何使用Socialite实现第三方登录？（微信/GitHub示例）  Laravel怎么配置.env环境变量_Laravel生产环境敏感数据保护与读取【方法】  深圳网站制作的公司有哪些,dido官方网站？  Laravel如何使用查询构建器？（Query Builder高级用法）  Laravel如何发送邮件和通知_Laravel邮件与通知系统发送步骤  如何在 React 中条件性地遍历数组并渲染元素  微信公众帐号开发教程之图文消息全攻略  高防服务器租用如何选择配置与防御等级？  武汉网站设计制作公司,武汉有哪些比较大的同城网站或论坛，就是里面都是武汉人的？  详解MySQL数据库的安装与密码配置  高端云建站费用究竟需要多少预算？  怎样使用JSON进行数据交换_它有什么限制  在centOS 7安装mysql 5.7的详细教程  Gemini手机端怎么发图片_Gemini手机端发图方法【步骤】  微信小程序 配置文件详细介绍  php8.4header发送头信息失败怎么办_php8.4header函数问题解决【解答】  简单实现Android验证码  Win11怎么关闭透明效果_Windows11辅助功能视觉效果设置  MySQL查询结果复制到新表的方法(更新、插入)  如何确保西部建站助手FTP传输的安全性？  Android自定义控件实现温度旋转按钮效果  Laravel定时任务怎么设置_Laravel Crontab调度器配置  Laravel中的Facade(门面)到底是什么原理  如何在云主机上快速搭建多站点网站？  移动端脚本框架Hammer.js  Laravel怎么实现软删除SoftDeletes_Laravel模型回收站功能与数据恢复【步骤】  INTERNET浏览器怎样恢复关闭标签页_INTERNET浏览器标签恢复快捷键与方法【指南】  香港服务器网站生成指南：免费资源整合与高速稳定配置方案  宙斯浏览器视频悬浮窗怎么开启 边看视频边操作其他应用教程  Laravel事件监听器怎么写_Laravel Event和Listener使用教程  Laravel如何从数据库删除数据_Laravel destroy和delete方法区别  Laravel如何与Inertia.js和Vue/React构建现代单页应用  制作企业网站建设方案,怎样建设一个公司网站？  WEB开发之注册页面验证码倒计时代码的实现  如何用搬瓦工VPS快速搭建个人网站？  Laravel怎么使用artisan命令缓存配置和视图  如何安全更换建站之星模板并保留数据？