SpringBoot+Mybatis+Dynamic实现多数据源配置方式
前言
多数据源是一种常见的技术需求,它允许应用程序连接和操作多个不同的数据库或数据源。
Dynamic多数据源配置允许根据运行时的条件动态选择要使用的数据源。基本配置流程为:
- 创建数据源配置类:创建一个包含多个数据源配置的类,例如 DataSourceConfig。在该类中,定义多个数据源的连接信息和属性,例如数据库URL、用户名、密码等。
- 创建数据源管理类:创建一个数据源管理类,该类负责动态选择要使用的数据源,该类继承AbstractRoutingDataSource类,并重写determineCurrentLookupKey()方法来实现动态数据源选择逻辑。
- 实现数据源切换逻辑:根据应用程序的需要,在运行时决定使用哪个数据源。
dynamic-datasource是一个开源的Java库,用于实现动态多数据源配置和管理。它提供了在运行时动态选择数据源的功能,可以根据业务需求或其他条件切换不同的数据源。
dynamic-datasource库进行动态多数据源配置的基本步骤:
- 引入依赖:在您的项目中,首先需要将dynamic-datasource库添加到您的构建工具(如Maven或Gradle)的依赖项中。
- 配置数据源信息:在应用程序的配置文件中,您需要定义多个数据源的连接信息。您可以为每个数据源指定唯一的名称、数据库URL、用户名、密码等配置项。
- 配置动态数据源:在配置文件中,使用dynamic-datasource提供的配置方式,指定数据源的切换策略和数据源列表。您可以根据具体的条件或规则,动态选择要使用的数据源。
- 使用动态数据源:在需要访问数据库的代码中,使用dynamic-datasource提供的API来获取当前要使用的数据源。通过配置的切换策略,库将自动选择正确的数据源进行操作。
在引入Dynamic包后,通过使用@DS实现多数据源的使用,该注解可以用于方法上和类上;
1、创建数据库(表)
分别在mysql中创建两个库:system、log,并且创建对应的表(根据项目实际情况的定),如下:

2、POM
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.2.2</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.5.1</version>
</dependency>3、配置yaml
spring:
application:
name: quartz
datasource:
dynamic:
#设置默认的数据源或者数据源组
primary: system
strict: false
datasource:
system:
driverClassName: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://127.0.0.1:3307/system?useUnicode=true&useSSL=false&zeroDateTimeBehavior=convertToNull&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=Asia/Shanghai
username: root
password: lhzlx
log:
driverClassName: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://127.0.0.1:3307/log?useUnicode=true&useSSL=false&zeroDateTimeBehavior=convertToNull&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=Asia/Shanghai
username: root
password: lhzlx
# hikari连接池
type: com.zaxxer.hikari.HikariDataSource
hikari:
#最大连接数,小于等于0会被重置为默认值10;大于零小于1会被重置为minimum-idle的值
maximum-pool-size: 10
#最小空闲连接,默认值 10,小于0或大于maximum-pool-size,都会重置为maximum-pool-size
minimum-idle: 2
#连接超时时间:毫秒,小于250毫秒,否则被重置为默认值30秒
connection-timeout: 60000
#空闲连接超时时间,默认值600000ms(10分钟),大于等于max-lifetime且max-lifetime>0,会被重置为0;
#不等于0且小于10秒,会被重置为10秒。
#只有空闲连接数大于最大连接数且空闲时间超过该值,才会被释放(自动释放过期链接)
idle-timeout: 600000
#连接最大存活时间.不等于0且小于30秒,会被重置为默认值30分钟.设置应该比mysql设置的超时时间短
max-lifetime: 640000
#连接测试查询
connection-test-query: SELECT 1
#mapper 别名扫描
mybatis:
mapper-locations: classpath*:mappers/*.xml
type-aliases-package: com.lhz.demo.model.entity
#数据库类型
configuration.database-id: mysql
#自动驼峰转换
configuration.map-underscore-to-camel-case: true4、Mapper接口
在com.lhz.demo.mapper目录下创建LogMapper与SysMapper,将@DS注解用在Mapper接口上表示为整个Mapper接口指定数据源;
LogMapper:
@Mapper
public interface LogMapper {
List<TbLog> selectAll();
}
SysMapper:
@Mapper
@DS("log")
public interface SysMapper {
List<TbSystem> selectAll();
}
5、Mappeing(XML)
在resources/mappers目录下创建LogMapper.xml与SystemMapper.xml文件
LogMapper.xml:
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.lhz.demo.mapper.LogMapper">
<select id="selectAll" resultType="com.lhz.demo.model.entity.TbLog">
select * from tb_log
</select>
</mapper>SystemMapper.xml:
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.lhz.demo.mapper.SysMapper">
<select id="selectAll" resultType="com.lhz.demo.model.entity.TbSystem">
select * from tb_system
</select>
</mapper>6、Service
将@DS注解用在调用Mapp接口的方法上,表示当前请求会访问指定数据源;
@Service
public class TestService {
@Resource
private SysMapper sysMapper;
@Resource
private LogMapper logMapper;
/**
* 不指定数据源,模式使用system数据源
* @return
*/
public Object sys() {
return sysMapper.selectAll();
}
/**
* 指定数据源查询
* @return
*/
@DS("log")
public Object log() {
return logMapper.selectAll();
}
}
7、Controller
@RestController
@RequestMapping("/test")
@Slf4j
public class TestController {
@Resource
private TestService testService;
/**
* 查询system库
* @return
*/
@GetMapping("/sys")
public Object sys() {
return testService.sys();
}
/**
* 查询log库
* @return
*/
@GetMapping("/log")
public Object log() {
return testService.log();
}
}
8、测试
启动项目分别访问`http://localhost:9090/test/sys`与`http://localhost:9090/test/log`均有数据输出,则表示配置成功;


总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。
相关文章
Java中处理金额计算之使用Long还是BigDecimal详解
在Java后端开发中处理与钱有关的业务时,确保金额计算的准确性和避免错误非常重要,这篇文章主要给大家介绍了关于Java中处理金额计算之使用Long还是BigDecimal的相关资料,需要的朋友可以参考下2024-07-07
Java实现的生成二维码统计扫描次数并转发到某个地址功能详解
这篇文章主要介绍了Java实现的生成二维码统计扫描次数并转发到某个地址功能,可实现生成带统计功能的二维码,涉及java二维码的生成、参数传递、解析等相关操作技巧,需要的朋友可以参考下2018-07-07
Java实现的读取资源文件工具类ResourcesUtil实例【可动态更改值的内容】
这篇文章主要介绍了Java实现的读取资源文件工具类ResourcesUtil,结合实例形式分析了java针对资源文件的读取与修改相关操作技巧,需要的朋友可以参考下2017-10-10
SpringBoot整合Mybatis-plus关键词模糊查询结果为空
SpringBoot整合Mybatis-plus使用关键词模糊查询的时候,数据库中有数据,但是无法查找出来,本文就来介绍一下SpringBoot整合Mybatis-plus关键词模糊查询结果为空的解决方法2025-04-04


最新评论