-- 創(chuàng)建數(shù)據(jù)庫(kù) mybatis_plus_1
CREATE DATABASE `mybatis_plus_1` /*!40100 DEFAULT CHARACTER SET utf8mb4 */;
USE `mybatis_plus_1`;

-- 創(chuàng)建 product 表
CREATE TABLE product
(
    id      BIGINT(20) NOT NULL COMMENT '主鍵 ID',
    name    VARCHAR(30) NULL DEFAULT NULL COMMENT '商品名稱 ',
    price   INT(11) DEFAULT 0 COMMENT '價(jià)格 ',
    version INT(11) DEFAULT 0 COMMENT '樂(lè)觀鎖版本號(hào) ',
    PRIMARY KEY (id)
);

-- 添加測(cè)試數(shù)據(jù)
INSERT INTO product (id, NAME, price) VALUES (1, '外星人筆記本 ', 100);

-- 刪除 mybatis_plus 庫(kù)中的 product 表
-- 請(qǐng)先連接到 mybatis_plus 數(shù)據(jù)庫(kù)
USE mybatis_plus;
DROP TABLE IF EXISTS product;

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

spring:
  # 配置數(shù)據(jù)源信息
  datasource:
    dynamic:
      # 設(shè)置默認(rèn)的數(shù)據(jù)源或者數(shù)據(jù)源組 ,默認(rèn)值即為 master
      primary: master
      # 嚴(yán)格匹配數(shù)據(jù)源 ,默認(rèn) false.true 未匹配到指定數(shù)據(jù)源時(shí)拋異常 ,false 使用默認(rèn)數(shù)據(jù)源
      strict: false
    datasource:
      master:
        url: jdbc:mysql://localhost:3306/mybatis_plus?characterEncoding=utf-8&useSSL=false
        driver-class-name: com.mysql.cj.jdbc.Driver
        username: root
        password: 123456
      slave_1:
        url: jdbc:mysql://localhost:3306/mybatis_plus_1?characterEncoding=utf-8&useSSL=false
        driver-class-name: com.mysql.cj.jdbc.Driver
        username: root
        password: 123456

import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

// 指定所操作的數(shù)據(jù)源
@DS("master") 
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
}

import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

@DS("slave_1")
@Service
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService {
}

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
public class DynamicDataSourceTest {

    @Autowired
    private UserService userService;

    @Autowired
    private ProductService productService;

    @Test
    public void testDynamicDataSource() {
        System.out.println(userService.getById(1L));
        System.out.println(productService.getById(1L));
    }
}

import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

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

    // 寫操作使用主庫(kù)
    @DS("master")
    @Override
    public boolean save(User user) {
        return super.save(user);
    }

    // 讀操作使用從庫(kù)
    @DS("slave_1")
    @Override
    public User getById(Serializable id) {
        return super.getById(id);
    }
}