SpringBoot+MyBatis-Plus多數據源操作MySQL讀寫分離

MySQL做了讀寫分離，一主兩從。主服務器寫數據，從服務器只可以讀數據，不可以寫數據

所以現在有三個數據源，寫一個，讀兩個

使用MyBatis-Plus的多數據源來做數據源的切換

加入依賴

<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>3.4.2</version>
</dependency>
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
    <version>3.4.1</version>
</dependency>

配置多數據源

spring:
  datasource:
    dynamic:
      primary: master #設置默認的數據源或者數據源組,默認值即為master
      strict: false #嚴格匹配數據源,默認false. true未匹配到指定數據源時拋異常,false使用默認數據源
      datasource:
        master:
          url: jdbc:mysql://192.168.43.208:3306/test?serverTimezone=GMT%2B8&characterEncoding=utf-8
          username: root
          password: orange
          driver-class-name: com.mysql.cj.jdbc.Driver # 3.2.0開始支持SPI可省略此配置
        slave_1:
          url: jdbc:mysql://192.168.43.163:3306/test?serverTimezone=GMT%2B8&characterEncoding=utf-8
          username: orange123
          password: orange123
          driver-class-name: com.mysql.cj.jdbc.Driver
        slave_2:
          url: jdbc:mysql://192.168.43.116:3306/test?serverTimezone=GMT%2B8&characterEncoding=utf-8
          username: orange
          password: orange123
          driver-class-name: com.mysql.cj.jdbc.Driver

約定

1. 本框架只做 切換數據源 這件核心的事情，並不限制你的具體操作，切換了數據源可以做任何CRUD。
2. 配置文件所有以下划線 _ 分割的數據源 首部 即為組的名稱，相同組名稱的數據源會放在一個組下。
3. 切換數據源可以是組名，也可以是具體數據源名稱。組名則切換時采用負載均衡算法切換。
4. 默認的數據源名稱為 master ，你可以通過 spring.datasource.dynamic.primary 修改。
5. 方法上的注解優先於類上注解。
6. DS支持繼承抽象類上的DS，暫不支持繼承接口上的DS。

使用 @DS 切換數據源。

@DS 可以注解在方法上或類上，同時存在就近原則 方法上注解 優先於 類上注解。

注解	結果
沒有@DS	默認數據源
@DS("dsName")	dsName可以為組名也可以為具體某個庫的名稱

@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, UserDO> implements UserService {

    @DS("master")
    @Override
    public ResponseData<Void> addUser(UserDO userDO) {
        int insert = baseMapper.insert(userDO);
        if (insert < 1) {
            new ResponseData<Void>().field();
        }
        return new ResponseData<Void>().ok();
    }

    @DS("slave")
    @Override
    public ResponseData<UserDO> getUserById(Long id) {
        return new ResponseData<UserDO>().ok(super.getById(id));
    }
}