当前位置：首页 > news >正文

Mybatis Plus 多数据源

news 2025/7/28 15:25:53

MyBatis Plus 的多数据源支持是通过 DataSource 来实现的，它允许在同一个应用中同时连接多个数据库，适用于多种场景：纯粹多库、读写分离、一主多从、混合模式等

模拟一个纯粹多库的一个场景，其他场景类似

1、创建数据和表

在数据库 springbootdemo 中创建 t_employee 表，在数据库 springbootdemo1 中创建同名数据表

CREATE TABLE t_employee (id BIGINT PRIMARY KEY AUTO_INCREMENT COMMENT '主键ID',em_name VARCHAR(50) NOT NULL COMMENT '员工姓名',age INT DEFAULT 0 COMMENT '年龄',email VARCHAR(100) COMMENT '邮箱',department VARCHAR(100) COMMENT '部门',hire_date DATE COMMENT '入职日期',salary DECIMAL(10, 2) DEFAULT 0.00 COMMENT '薪资',version INT DEFAULT 1 COMMENT '乐观锁版本号',deleted TINYINT DEFAULT 0 COMMENT '逻辑删除标志（0：未删，1：已删）',create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',update_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间'
) COMMENT='员工表';

2.引入依赖

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

3.配置多数据源

spring:# 配置数据源信息datasource:dynamic:# 设置默认的数据源或者数据源组 ,默认值即为masterprimary: master# 严格匹配数据源 ,默认false.true未匹配到指定数据源时抛异常 ,false使用默认数据源strict: falsedatasource:master:url: jdbc:mysql://localhost:3306/springbootdemodriver-class-name: com.mysql.jdbc.Driverusername: rootpassword: 123456slave1:url: jdbc:mysql://localhost:3306/springbootdemo1driver-class-name: com.mysql.jdbc.Driverusername: rootpassword: 123456

4.创建IEmployeeService

EmployeeMapper

package com.goose.mapper;import com.goose.entity.Employee;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;/*** <p>* 员工表 Mapper 接口* </p>** @author goose* @since 2025-07-27*/
@Mapper
@Repository
public interface EmployeeMapper extends BaseMapper<Employee> {}

IEmployeeService

package com.goose.service;import com.goose.entity.Employee;
import com.baomidou.mybatisplus.extension.service.IService;/*** <p>* 员工表 服务类* </p>** @author goose* @since 2025-07-27*/
public interface IEmployeeService extends IService<Employee> {}

EmployeeServiceImpl

package com.goose.service.impl;import com.goose.entity.Employee;
import com.goose.mapper.EmployeeMapper;
import com.goose.service.IEmployeeService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;/*** <p>* 员工表 服务实现类* </p>** @author goose* @since 2025-07-27*/
@Service
public class EmployeeServiceImpl extends ServiceImpl<EmployeeMapper, Employee> implements IEmployeeService {}

5.创建BossService

BossMapper

package com.goose.mapper;import com.goose.entity.Employee;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;/*** <p>* 员工表 Mapper 接口* </p>** @author goose* @since 2025-07-27*/
@Mapper
@Repository
public interface BossMapper extends BaseMapper<Employee> {}

IBossService

package com.goose.service;import com.goose.entity.Employee;
import com.baomidou.mybatisplus.extension.service.IService;/*** <p>* 员工表 服务类* </p>** @author goose* @since 2025-07-27*/
public interface IBossService extends IService<Employee> {}

BossServiceImpl

package com.goose.service.impl;import com.goose.entity.Employee;
import com.goose.mapper.BossMapper;
import com.goose.mapper.EmployeeMapper;
import com.goose.service.IBossService;
import com.goose.service.IEmployeeService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;/*** <p>* 员工表 服务实现类* </p>** @author goose* @since 2025-07-27*/
@Service
public class BossServiceImpl extends ServiceImpl<BossMapper, Employee> implements IBossService {}

6.测试

@SpringBootTest
public class DataSourceTest {@Autowiredprivate IBossService bossService;@Autowiredprivate IEmployeeService employeeService;@Testpublic void test() {System.out.println("bossService: " + bossService.getById(1L));System.out.println("employeeService: " + employeeService.getById(1L));}
}

输出：

bossService: Employee(id=1, emName=张三, age=30, email=zhangsan@example.com, department=研发部, hireDate=2022-05-15, salary=8000.00, version=1, deleted=0, createTime=2025-07-27T16:57:54, updateTime=2025-07-27T16:57:54)
employeeService: Employee(id=1, emName=张三, age=30, email=zhangsan@example.com, department=研发部, hireDate=2022-05-15, salary=8000.00, version=1, deleted=0, createTime=2025-07-27T16:57:43, updateTime=2025-07-27T16:57:43)

7.注意

@DS 注解是MyBatis Plus中用于实现多数据源切换的功能。通过该注解，我们可以直接在方法级别指定使用哪一个数据源，这对于动态选择数据库非常有用，尤其是当你需要在某些业务操作中切换数据源（如：读写分离、按需访问不同数据库等）时。

使用场景

读写分离

在一些系统中，可能有一个主数据库负责写操作，多个副本数据库负责读操作。通过使用 @DS 注解，可以在写操作时切换到主库，读操作时切换到副本库。

多数据源应用

当系统需要同时访问多个数据源时，例如访问不同的数据库实例或数据库类型，使用 @DS 注解可以在不同方法中动态切换数据源。

不同模块的数据源配置

如果你的系统有多个模块，每个模块有自己的数据源配置（如：财务模块、用户模块等），可以通过 @DS 注解在不同模块的服务方法中指定不同的数据源。

（1）使用 @DS 注解切换数据源

假设有一个 UserService 服务类，分别要在不同的方法中使用不同的数据源。

import com.baomidou.dynamic.datasource.annotation.DS;
import org.springframework.stereotype.Service;@Service
public class UserService {// 使用主数据源@DS("primary")public User getUserFromPrimaryDb(Long userId) {return userMapper.selectById(userId);  // 主数据源的操作}// 使用备份数据源@DS("secondary")public User getUserFromSecondaryDb(Long userId) {return userMapper.selectById(userId);  // 备份数据源的操作}
}

（2）控制器层的使用

在控制器层，也可以使用 @DS 注解来切换数据源。

import com.baomidou.dynamic.datasource.annotation.DS;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class UserController {private final UserService userService;public UserController(UserService userService) {this.userService = userService;}@GetMapping("/getPrimaryUser")@DS("primary")  // 使用主数据源public User getPrimaryUser(Long userId) {return userService.getUserFromPrimaryDb(userId);}@GetMapping("/getSecondaryUser")@DS("secondary")  // 使用备份数据源public User getSecondaryUser(Long userId) {return userService.getUserFromSecondaryDb(userId);}
}