使用@DS轻松解决动态数据源的问题
短信预约 -IT技能 免费直播动态提醒
@DS解决动态数据源问题
动态切换数据源，无非是继承org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource这个类，重写determineCurrentLookupKey()这个方法，动态变换数据源的key值，有人已经将详细代码封装到框架中，我们只需要使用它的注解@DS就好。
引入maven
<!-- https://mvnrepository.com/artifact/com.baomidou/dynamic-datasource-spring-boot-starter -->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.2.1</version>
</dependency>修改Application.yml
参考的是官网的例子
spring:
datasource:
dynamic:
primary: master #设置默认的数据源或者数据源组,默认值即为master
strict: false #设置严格模式,默认false不启动. 启动后在未匹配到指定数据源时候会抛出异常,不启动则使用默认数据源.
datasource:
master:
url: jdbc:mysql://xx.xx.xx.xx:3306/dynamic
username: root
password: 123456
driver-class-name: com.mysql.jdbc.Driver # 3.2.0开始支持SPI可省略此配置
slave_1:
url: jdbc:mysql://xx.xx.xx.xx:3307/dynamic
username: root
password: 123456
driver-class-name: com.mysql.jdbc.Driver
slave_2:
url: ENC(xxxxx) # 内置加密,使用请查看详细文档
username: ENC(xxxxx)
password: ENC(xxxxx)
driver-class-name: com.mysql.jdbc.Driver
schema: db/schema.sql # 配置则生效,自动初始化表结构
data: db/data.sql # 配置则生效,自动初始化数据
continue-on-error: true # 默认true,初始化失败是否继续
separator: ";" # sql默认分号分隔符
#......省略
#以上会配置一个默认库master，一个组slave下有两个子库slave_1,slave_2这是我自己的:
spring:
datasource:
dynamic:
primary: master #设置默认的数据源或者数据源组,默认值即为master #设置严格模式,默认false不启动. 启动后在未匹配到指定数据源时候会抛出异常,不启动则使用默认数据源.
datasource:
master:
url: jdbc:sqlserver://127.0.0.1:1433;DatabaseName=balabala
username: sa
password: 123456Sa
driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver
sub:
url: jdbc:mysql://127.0.0.1:3307/balabala?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
username: sa
password: 123456Sa
driver-class-name: com.mysql.cj.jdbc.Driver在需要使用非默认数据库的dao层的方法上加上注解@DS(“数据库名”)即可
@DS("sub")
int selectBusiness(@Param("startTime") String startTime,
@Param("endTime") String endTime,
@Param("businessType") String businessType);@DS注解说明
写法：
@DS(value = "数据源名称")
datasource:
数据源名臣注解在类上或方法上来切换数据源
Gradle：
com.baomidou:dynamic-datasource-spring-boot-starter:2.5.3打开一个线程得方法
new Thread(() -> {
方法内容-------------------------------------
}).start();以上为个人经验，希望能给大家一个参考，也希望大家多多支持编程网。
免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
