SpringBoot+Mybatis+Dynamic实现多数据源配置方式

 更新时间:2026年06月09日 09:14:41   作者:一恍过去  
这段文章详细介绍了Dynamic DataSource的配置与使用方法,重点在于在于动态数据源选择逻辑和基本配置流程,通过引入dynamic-datasource开源库,开发者可以轻松实现多数据源配置和动态切换功能,提高应用程序的灵活性和扩展性

前言

多数据源是一种常见的技术需求,它允许应用程序连接和操作多个不同的数据库或数据源。

Dynamic多数据源配置允许根据运行时的条件动态选择要使用的数据源。基本配置流程为:

  • 创建数据源配置类:创建一个包含多个数据源配置的类,例如 DataSourceConfig。在该类中,定义多个数据源的连接信息和属性,例如数据库URL、用户名、密码等。
  • 创建数据源管理类:创建一个数据源管理类,该类负责动态选择要使用的数据源,该类继承AbstractRoutingDataSource类,并重写determineCurrentLookupKey()方法来实现动态数据源选择逻辑。
  • 实现数据源切换逻辑:根据应用程序的需要,在运行时决定使用哪个数据源。

dynamic-datasource是一个开源的Java库,用于实现动态多数据源配置和管理。它提供了在运行时动态选择数据源的功能,可以根据业务需求或其他条件切换不同的数据源。

dynamic-datasource库进行动态多数据源配置的基本步骤:

  • 引入依赖:在您的项目中,首先需要将dynamic-datasource库添加到您的构建工具(如Maven或Gradle)的依赖项中。
  • 配置数据源信息:在应用程序的配置文件中,您需要定义多个数据源的连接信息。您可以为每个数据源指定唯一的名称、数据库URL、用户名、密码等配置项。
  • 配置动态数据源:在配置文件中,使用dynamic-datasource提供的配置方式,指定数据源的切换策略和数据源列表。您可以根据具体的条件或规则,动态选择要使用的数据源。
  • 使用动态数据源:在需要访问数据库的代码中,使用dynamic-datasource提供的API来获取当前要使用的数据源。通过配置的切换策略,库将自动选择正确的数据源进行操作。

在引入Dynamic包后,通过使用@DS实现多数据源的使用,该注解可以用于方法上和类上;

1、创建数据库(表)

分别在mysql中创建两个库:systemlog,并且创建对应的表(根据项目实际情况的定),如下:

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: true

4、Mapper接口

com.lhz.demo.mapper目录下创建LogMapperSysMapper,将@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.xmlSystemMapper.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中处理金额计算之使用Long还是BigDecimal详解

    在Java后端开发中处理与钱有关的业务时,确保金额计算的准确性和避免错误非常重要,这篇文章主要给大家介绍了关于Java中处理金额计算之使用Long还是BigDecimal的相关资料,需要的朋友可以参考下
    2024-07-07
  • java实现验证码类生成中文验证码

    java实现验证码类生成中文验证码

    java实现的汉字输入验证码,主要包含两个类,一个是生成验证码,一个是判断验证码输入是否正确,实现原理非常简单,将汉字和干扰线生成图片并将汉字保存到session,前台获取每次生成验证码图片并用文本框值和session值比较,功能就怎么简单
    2014-01-01
  • java客户端线上Apollo服务端的实现

    java客户端线上Apollo服务端的实现

    这篇文章主要介绍了java客户端线上Apollo服务端的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-08-08
  • Java中final关键字详解及实例

    Java中final关键字详解及实例

    这篇文章主要介绍了Java中final关键字详解及实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-03-03
  • 如何使用Idea搭建全注解式开发的SpringMVC项目

    如何使用Idea搭建全注解式开发的SpringMVC项目

    这篇文章主要介绍了如何使用Idea搭建全注解式开发的SpringMVC项目,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-03-03
  • Java工厂模式定义与用法实例分析

    Java工厂模式定义与用法实例分析

    这篇文章主要介绍了Java工厂模式定义与用法,结合具体实例形式分析了java工厂模式定义、使用相关操作技巧,并总结了类图原理,需要的朋友可以参考下
    2019-07-07
  • hashMap扩容时应该注意这些死循环问题

    hashMap扩容时应该注意这些死循环问题

    今天给大家带来的是关于Java的相关知识,文章围绕着hashMap扩容时的死循环问题展开,文中有非常详细的介绍及代码示例,需要的朋友可以参考下
    2021-06-06
  • Java实现的生成二维码统计扫描次数并转发到某个地址功能详解

    Java实现的生成二维码统计扫描次数并转发到某个地址功能详解

    这篇文章主要介绍了Java实现的生成二维码统计扫描次数并转发到某个地址功能,可实现生成带统计功能的二维码,涉及java二维码的生成、参数传递、解析等相关操作技巧,需要的朋友可以参考下
    2018-07-07
  • Java实现的读取资源文件工具类ResourcesUtil实例【可动态更改值的内容】

    Java实现的读取资源文件工具类ResourcesUtil实例【可动态更改值的内容】

    这篇文章主要介绍了Java实现的读取资源文件工具类ResourcesUtil,结合实例形式分析了java针对资源文件的读取与修改相关操作技巧,需要的朋友可以参考下
    2017-10-10
  • SpringBoot整合Mybatis-plus关键词模糊查询结果为空

    SpringBoot整合Mybatis-plus关键词模糊查询结果为空

    SpringBoot整合Mybatis-plus使用关键词模糊查询的时候,数据库中有数据,但是无法查找出来,本文就来介绍一下SpringBoot整合Mybatis-plus关键词模糊查询结果为空的解决方法
    2025-04-04

最新评论