小码农的代码(三)----------SpringJDBC多数据源应用

2024-09-04 12:38

本文主要是介绍小码农的代码(三)----------SpringJDBC多数据源应用,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

前面项目中基础的SpringJdbc的配置说明已经简单总结,接下去就是项目中使用到多数据源这个问题了。 
对于多数据源的实现,我的想法是首先配置多个数据源,然后在数据操作时通过切换数据源的方式来达到目的,那么如何在保持jdbctmplate只有一个的时候进行数据源切换呢,我考虑到可以起一个线程来实现在操作中的自由切换。 
首先配置3个数据源,为方便测试就直接在本机新建了三个mysql数据库(实际过程中是使用mysql与多个sql server)来写测试用例
Java代码   收藏代码
  1. <bean id="defaultDateSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"  
  2.         destroy-method="close">  
  3.         <property name="driverClass" value="${jdbc.driverClass}" />  
  4.         <property name="jdbcUrl" value="${jdbc.jdbcUrl}" />  
  5.         <property name="user" value="${jdbc.user}" />  
  6.         <property name="password" value="${jdbc.password}" />  
  7.     </bean>  
Java代码   收藏代码
  1. <bean id="dataSource01" class="com.mchange.v2.c3p0.ComboPooledDataSource"  
  2.         destroy-method="close">  
  3.         <property name="driverClass" value="${jdbc.driverClass01}" />  
  4.         <property name="jdbcUrl" value="${jdbc.jdbcUrl01}" />  
  5.         <property name="user" value="${jdbc.user01}" />  
  6.         <property name="password" value="${jdbc.password01}" />  
  7.     </bean>  
Java代码   收藏代码
  1. <bean id="dataSource02" class="com.mchange.v2.c3p0.ComboPooledDataSource"  
  2.         destroy-method="close">  
  3.         <property name="driverClass" value="${jdbc.driverClass02}" />  
  4.         <property name="jdbcUrl" value="${jdbc.jdbcUrl02}" />  
  5.         <property name="user" value="${jdbc.user02}" />  
  6.         <property name="password" value="${jdbc.password02}" />  
  7.     </bean>  
习惯使用c3p0数据库连接池,下次尝试试用下阿里DruidDataSource,据说功能更加强大,但是一直没有使用过-,-跑题了 新建三个数据库还是只有一个表user(id,name,age;id逐渐自增)。 
然后新建一个单例的线程ThreadLocal(这是一个很好用的东西,下次专门写个测试用例总结下,做项目总是能够不断的引出新的东西,这点真的很好),能够set/get/remove数据源
Java代码   收藏代码
  1. public class DatabaseContextHolder {  
  2.     private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();  
  3.   
  4.     public static void setDateBaseType(String database) {  
  5.         Assert.notNull(database, "DatabaseType cannot be null");  
  6.         contextHolder.set(database);  
  7.     }  
  8.   
  9.     public static String getDateBaseType() {  
  10.         return contextHolder.get();  
  11.     }  
  12.   
  13.     public static void clearDatabaseType() {  
  14.         contextHolder.remove();  
  15.     }  
  16. }  

接下来是Spring支持多数据源切换的核心类AbstractRoutingDataSource,新建一个继承这个抽象类的子类DynamicDataSource,并实现determineCurrentLookupKey方法(抽象类与接口的相似性
Java代码   收藏代码
  1. public class DynamicDataSource extends AbstractRoutingDataSource {  
  2.   
  3.     @Override  
  4.     protected Object determineCurrentLookupKey() {  
  5.         return DatabaseContextHolder.getDateBaseType();  
  6.     }  
  7. }  

继续回到spring的配置文件,通过DynamicDataSource管理多数据源,并设置默认的数据源
Java代码   收藏代码
  1. <bean id="dynamicDataSource" class="com.zh.demo.base.tool.DynamicDataSource">  
  2.         <property name="targetDataSources">  
  3.             <map key-type="java.lang.String">  
  4.                 <entry value-ref="defaultDateSource" key="defaultDateSource"></entry>  
  5.                 <entry value-ref="dataSource01" key="dataSource01"></entry>  
  6.                 <entry value-ref="dataSource02" key="dataSource02"></entry>  
  7.             </map>  
  8.         </property>  
  9.         <property name="defaultTargetDataSource" ref="defaultDateSource">  
  10.         </property>  
  11.     </bean>  
当然jdbctemplate中指向的数据源也需要切换成它
Java代码   收藏代码
  1. <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">  
  2.         <property name="dataSource" ref="dynamicDataSource" />  
最后新建一个DataBaseType类与配置中的数据源名称相关联
Java代码   收藏代码
  1. public class DataBaseType {  
  2.     public static final String DATABASE_DEFAULT = "defaultDateSource";  
  3.     public static final String DATABASE_01 = "dataSource01";  
  4.     public static final String DATABASE_02 = "dataSource02";  
  5. }  
这样就可以写测试用例了。 
简单的新增语句在测试类中进行数据库切换
Java代码   收藏代码
  1. public void test(){  
  2.         userService.saveUser(("insert into user (name,age)values('张三',13)");  
  3.         DatabaseContextHolder.clearDatabaseType();  
  4.         DatabaseContextHolder.setDateBaseType(DataBaseType.DATABASE_01);  
  5.         userService.saveUser("insert into user (name,age)values('张三',13)");  
  6.         DatabaseContextHolder.clearDatabaseType();  
  7.         DatabaseContextHolder.setDateBaseType(DataBaseType.DATABASE_02);  
  8.         userService.saveUser("insert into user (name,age)values('张三',13)");  
  9.     }  
结果是三个数据库中都插入了数据,多数据源配置成功。 
注意点与总结: 
一、实际项目中发现一个问题,就是在同一个事务中不能够进行数据库切换,该问题暂时未解决,有方法的朋友可以的话烦请指导下。 
二、在使用过程中扩展想到能否通过请求来动态的切换数据源,目前考虑到还是需要在请求中带参数来让后台识别进行数据库切换,不知道有没有更好的方法。 
以下内容如存在错误之处烦请斧正以达到共同进步的效果,多谢。
  • SpringJDBC_多数据源_.rar (33.4 KB)
  • 下载次数: 6

这篇关于小码农的代码(三)----------SpringJDBC多数据源应用的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1136047

相关文章

Python实现MQTT通信的示例代码

《Python实现MQTT通信的示例代码》本文主要介绍了Python实现MQTT通信的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录1. 安装paho-mqtt库‌2. 搭建MQTT代理服务器(Broker)‌‌3. pytho

MySQL进行数据库审计的详细步骤和示例代码

《MySQL进行数据库审计的详细步骤和示例代码》数据库审计通过触发器、内置功能及第三方工具记录和监控数据库活动,确保安全、完整与合规,Java代码实现自动化日志记录,整合分析系统提升监控效率,本文给大... 目录一、数据库审计的基本概念二、使用触发器进行数据库审计1. 创建审计表2. 创建触发器三、Java

Redis中Stream详解及应用小结

《Redis中Stream详解及应用小结》RedisStreams是Redis5.0引入的新功能,提供了一种类似于传统消息队列的机制,但具有更高的灵活性和可扩展性,本文给大家介绍Redis中Strea... 目录1. Redis Stream 概述2. Redis Stream 的基本操作2.1. XADD

JSONArray在Java中的应用操作实例

《JSONArray在Java中的应用操作实例》JSONArray是org.json库用于处理JSON数组的类,可将Java对象(Map/List)转换为JSON格式,提供增删改查等操作,适用于前后端... 目录1. jsONArray定义与功能1.1 JSONArray概念阐释1.1.1 什么是JSONA

nginx -t、nginx -s stop 和 nginx -s reload 命令的详细解析(结合应用场景)

《nginx-t、nginx-sstop和nginx-sreload命令的详细解析(结合应用场景)》本文解析Nginx的-t、-sstop、-sreload命令,分别用于配置语法检... 以下是关于 nginx -t、nginx -s stop 和 nginx -s reload 命令的详细解析,结合实际应

Spring Boot集成Druid实现数据源管理与监控的详细步骤

《SpringBoot集成Druid实现数据源管理与监控的详细步骤》本文介绍如何在SpringBoot项目中集成Druid数据库连接池,包括环境搭建、Maven依赖配置、SpringBoot配置文件... 目录1. 引言1.1 环境准备1.2 Druid介绍2. 配置Druid连接池3. 查看Druid监控

PostgreSQL的扩展dict_int应用案例解析

《PostgreSQL的扩展dict_int应用案例解析》dict_int扩展为PostgreSQL提供了专业的整数文本处理能力,特别适合需要精确处理数字内容的搜索场景,本文给大家介绍PostgreS... 目录PostgreSQL的扩展dict_int一、扩展概述二、核心功能三、安装与启用四、字典配置方法

Python中re模块结合正则表达式的实际应用案例

《Python中re模块结合正则表达式的实际应用案例》Python中的re模块是用于处理正则表达式的强大工具,正则表达式是一种用来匹配字符串的模式,它可以在文本中搜索和匹配特定的字符串模式,这篇文章主... 目录前言re模块常用函数一、查看文本中是否包含 A 或 B 字符串二、替换多个关键词为统一格式三、提

Java MQTT实战应用

《JavaMQTT实战应用》本文详解MQTT协议,涵盖其发布/订阅机制、低功耗高效特性、三种服务质量等级(QoS0/1/2),以及客户端、代理、主题的核心概念,最后提供Linux部署教程、Sprin... 目录一、MQTT协议二、MQTT优点三、三种服务质量等级四、客户端、代理、主题1. 客户端(Clien

Java中调用数据库存储过程的示例代码

《Java中调用数据库存储过程的示例代码》本文介绍Java通过JDBC调用数据库存储过程的方法,涵盖参数类型、执行步骤及数据库差异,需注意异常处理与资源管理,以优化性能并实现复杂业务逻辑,感兴趣的朋友... 目录一、存储过程概述二、Java调用存储过程的基本javascript步骤三、Java调用存储过程示