SpringBoot+dynamic-datasource实现多数据源(msyql、sqlserver、postgresql)手动切换

2024-01-20 20:44
文章标签 java 实现 springboot 切换 spring postgresql dynamic 手动 sqlserver 数据源 database datasource msyql

本文主要是介绍SpringBoot+dynamic-datasource实现多数据源(msyql、sqlserver、postgresql)手动切换，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

场景

SpringBoot+MybatisPlus+dynamic-datasources实现连接Postgresql和mysql多数据源：

SpringBoot+MybatisPlus+dynamic-datasources实现连接Postgresql和mysql多数据源-CSDN博客

上面实现通过注解和配置文件的方式去进行多数据源操作。

如果业务需求，比如查询第三方接口时提供的是sqlserver的视图连接方式时，需要在调用

接口时手动新增数据源-检验数据源是否可用-切换当前数据源-查询数据-清除当前数据源

实现以上流程，可以通过mybatisplus的dynamic-datasource来实现。

dynamic-datasource

开源文档付费

基础必读（免费） · dynamic-datasource · 看云

多数据源 | MyBatis-Plus

但是可以通过引入依赖后查看其源码以及借助网上一些教程，可以找到源码中需要用到的几个类

注：

博客：
霸道流氓气质-CSDN博客

实现

1、引入pom依赖

这里springboot的版本是2.6.13

dynamic-datasource的版本是3.2.1

        <dependency><groupId>com.baomidou</groupId><artifactId>dynamic-datasource-spring-boot-starter</artifactId><version>3.2.1</version></dependency>

引入msyql、sqlserver、postgresql所需的依赖

        <!--MySQL驱动--><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><dependency><groupId>org.postgresql</groupId><artifactId>postgresql</artifactId></dependency><!-- sqlserver--><dependency><groupId>com.microsoft.sqlserver</groupId><artifactId>mssql-jdbc</artifactId><version>7.4.1.jre8</version></dependency>

引入Mybatisplus所需依赖

        <dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.1</version></dependency>

引入其他依赖

        <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency>   <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency>

2、这里使用默认的HikariCP数据库连接池，没使用Druid，流程一样

参考上面博客已经实现了连接Mysql和sqlserver多数据源

spring:datasource:dynamic:primary: master #设置默认的数据源或者数据源组,默认值即为masterstrict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源datasource:master:url:jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8username: rootpassword: 123456driver-class-name: com.mysql.cj.jdbc.Driverdbcp2:min-idle: 5                                # 数据库连接池的最小维持连接数initial-size: 5                            # 初始化连接数max-total: 5                               # 最大连接数max-wait-millis: 150                       # 等待连接获取的最大超时时间pg:url: jdbc:postgresql://127.0.0.1:5432/testusername: postgrespassword: 123456driver-class-name: org.postgresql.Driverdbcp2:min-idle: 5                                # 数据库连接池的最小维持连接数initial-size: 5                            # 初始化连接数max-total: 5                               # 最大连接数max-wait-millis: 150                       # 等待连接获取的最大超时时间

3、SpringBoot+dynamic-datasource使用DynamicRoutingDataSource获取当前所有数据源

代码实现：

@SpringBootTest
class DynamicDataSourceTest {@Autowiredprivate DataSource dataSource;/*** 获取当前所有数据源*/@Testvoid getAllDataSource() {DynamicRoutingDataSource ds = (DynamicRoutingDataSource) dataSource;System.out.println(ds.getCurrentDataSources().keySet());}
}

其中DataSource是javax.sql包下的。

javax.sql.DataSource 是 jdk 提供的接口，各个连接池厂商 和 Spring 都对 DataSource 进行了设计和实现。

javax.sql.DataSource 是连接到物理数据源的工厂接口。它是 java.sql.DriverManager 功能的替代者，

是获取数据库连接的首选方法。

DataSource 数据源在必要时可以修改它的属性。例如，如果将数据源移动到其他服务器，

则可以更改 DataSource 的属性，这样访问该数据源的代码不需要做任何更改就可以获取到达到目的。

单元测试运行结果：

4、SpringBoot+DynamicRoutingDataSources实现添加与删除数据源

这里通过代码将sqlserver的数据源添加到DynamicRoutingDataSource中

这就需要用到creator包下的各种创建器

这里是默认HikariCP的连接池，所以使用该创建器，如果是其它类型则使用对应的创建器。

数据源创建需要的参数这里新建一个DTO类用来赋值

import lombok.Builder;
import lombok.Data;@Data
@Builder
public class DataSourceDTO {private String dataSourceName;private String driverClassName;private String url;private String username;private String password;
}

编写单元测试

@SpringBootTest
class DynamicDataSourceTest {@Autowiredprivate DataSource dataSource;@Autowired(required = false)private HikariDataSourceCreator hikariDataSourceCreator;/*** 获取当前所有数据源*/@Testvoid getAllDataSource() {DynamicRoutingDataSource ds = (DynamicRoutingDataSource) dataSource;System.out.println(ds.getCurrentDataSources().keySet());}/*** 添加 与 删除 HikariCP数据源*/@Testvoid addHcpDataSource() {DataSourceDTO sqlserver = DataSourceDTO.builder().dataSourceName("sqlserver").driverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver").url("jdbc:sqlserver://127.0.0.1:1433;DatabaseName=test").username("sa").password("123456").build();DataSourceProperty dataSourceProperty = new DataSourceProperty();BeanUtils.copyProperties(sqlserver,dataSourceProperty);DataSource sqlserverDataSource = hikariDataSourceCreator.createDataSource(dataSourceProperty);DynamicRoutingDataSource ds = (DynamicRoutingDataSource) dataSource;ds.addDataSource(sqlserver.getDataSourceName(),sqlserverDataSource);System.out.println(ds.getCurrentDataSources().keySet());ds.removeDataSource(sqlserver.getDataSourceName());System.out.println(ds.getCurrentDataSources().keySet());}
}

单元测试运行结果：

5、SpringBoot中+HikariCP实现检测数据源是否可用

预实现手动切换当前数据源，首先需要确保配置的数据源的相关参数可以正常连接可用

新建检测数据源的方法

    /***  检测数据源* @param dataSourceDTO* @return*/private boolean checkDataBase(DataSourceDTO dataSourceDTO){Connection connection = null;try {DataSource dataSource = creatHcpDataSource(dataSourceDTO);connection = dataSource.getConnection();Statement statement = connection.createStatement();statement.execute("select * from s_user");return true;} catch (Exception exception) {return false;}finally {try {if(null!=connection){connection.close();}} catch (SQLException throwables) {throwables.printStackTrace();}}}

这其中就是创建数据源并进行连接和执行sql，确保无异常发生则代表连接可用，这里执行的sql以及表名

均写死，其中s_user是sqlserver中新建的表。

用到创建数据源的方法creatHcpDataSource的实现

    /*** 创建Hcp datasource* @param dataSourceDTO* @return*/private DataSource creatHcpDataSource(DataSourceDTO dataSourceDTO){HikariDataSource dataSource = new HikariDataSource();//控制客户端（即用户程序）等待池中连接的最长毫秒数。如果在没有连接可用的情况下超过此时间，则将抛出SQLException异常。最低可以接受的连接超时为250毫秒。默认值：3000（30秒）。这是一个很重要的问题排查指标dataSource.setConnectionTimeout(3000l);//HikariCP将尝试仅基于jdbcUrl通过DriverManager解析驱动程序，但对于某些较旧的驱动程序必须指定driverClassName。除非用户收到明显的错误消息，表明未找到驱动程序，否则可忽略此属性。默认值：无//dataSource.setDataSourceClassName(dataSourceDTO.getDriverClassName());dataSource.setJdbcUrl(dataSourceDTO.getUrl());dataSource.setUsername(dataSourceDTO.getUsername());dataSource.setPassword(dataSourceDTO.getPassword());//表示连接池的用户定义名称，主要显示在日志记录和JMX管理控制台中，以标识池和池配置。该属性的默认值：自动生成dataSource.setPoolName(dataSourceDTO.getDataSourceName());return dataSource;}

相关参数和配置自行搜索和设置，这里重点关注

dataSource.setConnectionTimeout(3000l);

设置超时时间3秒。

控制客户端（即用户程序）等待池中连接的最长毫秒数。如果在没有连接可用的情况下超过此时间，则将抛出SQLException异常。

最低可以接受的连接超时为250毫秒。默认值：3000（30秒）。这是一个很重要的问题排查指标

dataSource.setPoolName

示连接池的用户定义名称，主要显示在日志记录和JMX管理控制台中，以标识池和池配置。该属性的默认值：自动生成

编写单元测试：

    /*** 检测数据源*/@Testvoid testDataSource(){DataSourceDTO sqlserver = DataSourceDTO.builder().dataSourceName("sqlserver").driverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver").url("jdbc:sqlserver://127.0.0.1:1433;DatabaseName=test").username("sa").password("123456").build();boolean checkDataBase = checkDataBase(sqlserver);System.out.println(checkDataBase);DataSourceDTO sqlserverWrong = DataSourceDTO.builder().dataSourceName("sqlserver").driverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver").url("jdbc:sqlserver://192.168.1.2:1433;DatabaseName=test").username("sa").password("123456").build();boolean checkDataBaseWrong = checkDataBase(sqlserverWrong);System.out.println(checkDataBaseWrong);}

第二个故意写了一个不存在的数据源的地址

运行单元测试:

6、SpringBoot+DynamicDataSourceContextHolder实现手动切换清除当前数据源

动态数据源切换的关键在于DynamicDataSourceContextHolder类，它提供了一种机制来存储当前使用的数据源。

它主要由两部分组成，一部分是线程本地的数据源容器，另一部分是管理动态数据源的数据源切换类。

查看其源码

主要用到的方法

push 设置当前线程数据源 如非必要不要手动调用，调用后确保最终清除

poll 清空当前线程数据源 如果当前线程是连续切换数据源 只会移除掉当前线程的数据源名称

clear 强制清空本地线程  防止内存泄漏，如手动调用了push可调用此方法确保清除

编写单元测试：

    /*** 手动切换数据源*/@Testvoid changeDataSource() {DataSourceDTO sqlserver = DataSourceDTO.builder().dataSourceName("sqlserver").driverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver").url("jdbc:sqlserver://127.0.0.1:1433;DatabaseName=test").username("sa").password("123456").build();boolean checkDataBase = checkDataBase(sqlserver);if(checkDataBase){DataSourceProperty dataSourceProperty = new DataSourceProperty();BeanUtils.copyProperties(sqlserver,dataSourceProperty);DataSource sqlserverDataSource = hikariDataSourceCreator.createDataSource(dataSourceProperty);DynamicRoutingDataSource ds = (DynamicRoutingDataSource) dataSource;Set<String> dataSourceSet = ds.getCurrentDataSources().keySet();if (!dataSourceSet.contains(sqlserver.getDataSourceName())) {ds.addDataSource(sqlserver.getDataSourceName(),sqlserverDataSource);}//push 设置当前线程数据源 如非必要不要手动调用，调用后确保最终清除DynamicDataSourceContextHolder.push(sqlserver.getDataSourceName());List<SUser> sUsers = sUserMapper.selectList(new LambdaQueryWrapper<>());System.out.println(sUsers);//DynamicDataSourceContextHolder.poll();//poll 清空当前线程数据源 如果当前线程是连续切换数据源 只会移除掉当前线程的数据源名称//clear 强制清空本地线程  防止内存泄漏，如手动调用了push可调用此方法确保清除DynamicDataSourceContextHolder.clear();ds.removeDataSource(sqlserver.getDataSourceName());}else {System.out.println("数据源连接异常");}}

这里一定要对数据源可用性进行校验，确保可用才进行数据源添加和切换当前数据源操作

其中SUser是Sqlserver中新建表对应的实体类

import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@TableName(value = "s_user")
public class SUser implements Serializable {private static final long serialVersionUID = -5514139686858156155L;private Integer id;private String name;private Integer age;private String address;}

调用查询的mapper接口实现

import com.badao.demo.entity.SUser;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.springframework.stereotype.Repository;@Repository
public interface SUserMapper extends BaseMapper<SUser> {}

单元测试运行结果

7、将以上手动切换数据源和执行业务逻辑的操作封装成工具类

import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder;
import java.util.function.Supplier;/*** 数据源切换工具类*/
public class DynamicDSExecute {public static <T> T execute(String dsName, Supplier<T> executor){try {DynamicDataSourceContextHolder.push(dsName);return executor.get();}finally {DynamicDataSourceContextHolder.clear();}}
}

这里用到了函数式接口，可参考如下

java8中常用函数式接口Supplier＜T＞、Consumer＜T＞、Function＜T,R＞、Predicate＜T＞使用示例：

java8中常用函数式接口Supplier＜T＞、Consumer＜T＞、Function＜T,R＞、Predicate＜T＞使用示例_java8 函数式编程supplier接口案例大全-CSDN博客

然后调用工具类时

            Supplier<List<SUser>> supplier = () -> sUserMapper.selectList(new LambdaQueryWrapper<>());List<SUser> sUsers = DynamicDSExecute.execute(sqlserver.getDataSourceName(),supplier);

这篇关于SpringBoot+dynamic-datasource实现多数据源(msyql、sqlserver、postgresql)手动切换的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/627277。

相关文章

MySQL 中的 JSON 查询案例详解

MySQL 中的 JSON 查询案例详解

《MySQL中的JSON查询案例详解》：本文主要介绍MySQL的JSON查询的相关知识,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录mysql 的 jsON 路径格式基本结构路径组件详解特殊语法元素实际示例简单路径复杂路径简写操作符注意MySQL 的 J
阅读更多...
pandas中位数填充空值的实现示例

pandas中位数填充空值的实现示例

《pandas中位数填充空值的实现示例》中位数填充是一种简单而有效的方法,用于填充数据集中缺失的值,本文就来介绍一下pandas中位数填充空值的实现,具有一定的参考价值,感兴趣的可以了解一下... 目录什么是中位数填充？为什么选择中位数填充？示例数据结果分析完整代码总结在数据分析和机器学习过程中，处理缺失数
阅读更多...
Golang HashMap实现原理解析

Golang HashMap实现原理解析

《GolangHashMap实现原理解析》HashMap是一种基于哈希表实现的键值对存储结构,它通过哈希函数将键映射到数组的索引位置,支持高效的插入、查找和删除操作,：本文主要介绍GolangH... 目录HashMap是一种基于哈希表实现的键值对存储结构，它通过哈希函数将键映射到数组的索引位置，支持
阅读更多...
Java学习手册之Filter和Listener使用方法

Java学习手册之Filter和Listener使用方法

《Java学习手册之Filter和Listener使用方法》：本文主要介绍Java学习手册之Filter和Listener使用方法的相关资料,Filter是一种拦截器,可以在请求到达Servl... 目录一、Filter（过滤器）1. Filter 的工作原理2. Filter 的配置与使用二、Listen
阅读更多...
Pandas使用AdaBoost进行分类的实现

Pandas使用AdaBoost进行分类的实现

《Pandas使用AdaBoost进行分类的实现》Pandas和AdaBoost分类算法,可以高效地进行数据预处理和分类任务,本文主要介绍了Pandas使用AdaBoost进行分类的实现,具有一定的参... 目录什么是 AdaBoost？使用 AdaBoost 的步骤安装必要的库步骤一：数据准备步骤二：模型
阅读更多...
Spring Boot中JSON数值溢出问题从报错到优雅解决办法

Spring Boot中JSON数值溢出问题从报错到优雅解决办法

《SpringBoot中JSON数值溢出问题从报错到优雅解决办法》：本文主要介绍SpringBoot中JSON数值溢出问题从报错到优雅的解决办法,通过修改字段类型为Long、添加全局异常处理和... 目录一、问题背景：为什么我的接口突然报错了？二、为什么会发生这个错误？1. Java 数据类型的“容量”限制
阅读更多...
使用Pandas进行均值填充的实现

使用Pandas进行均值填充的实现

《使用Pandas进行均值填充的实现》缺失数据（NaN值）是一个常见的问题,我们可以通过多种方法来处理缺失数据,其中一种常用的方法是均值填充,本文主要介绍了使用Pandas进行均值填充的实现,感兴趣的... 目录什么是均值填充？为什么选择均值填充？均值填充的步骤实际代码示例总结在数据分析和处理过程中，缺失数
阅读更多...
Java对象转换的实现方式汇总

Java对象转换的实现方式汇总

《Java对象转换的实现方式汇总》：本文主要介绍Java对象转换的多种实现方式,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录Java对象转换的多种实现方式1. 手动映射（Manual Mapping）2. Builder模式3. 工具类辅助映
阅读更多...
SpringBoot请求参数接收控制指南分享

SpringBoot请求参数接收控制指南分享

《SpringBoot请求参数接收控制指南分享》：本文主要介绍SpringBoot请求参数接收控制指南,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Spring Boot 请求参数接收控制指南1. 概述2. 有注解时参数接收方式对比3. 无注解时接收参数默认位置
阅读更多...
Go语言开发实现查询IP信息的MCP服务器

Go语言开发实现查询IP信息的MCP服务器

《Go语言开发实现查询IP信息的MCP服务器》随着MCP的快速普及和广泛应用,MCP服务器也层出不穷,本文将详细介绍如何在Go语言中使用go-mcp库来开发一个查询IP信息的MCP... 目录前言mcp-ip-geo 服务器目录结构说明查询 IP 信息功能实现工具实现工具管理查询单个 IP 信息工具的实现服
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2