SpringBoot和MyBatis环境下实现动态数据源切换过程

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

spring:
  # 动态数据源配置
  datasource:
    dynamic:
      # 默认数据源，未指定时将使用这个
      primary: master
      datasource:
        # 主库配置 (Key: master)
        master:
          driver-class-name: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://localhost:3306/db_master?serverTimezone=Asia/Shanghai
          username: root
          password: 123
        
        # 从库配置 (Key: slave)
        slave:
          driver-class-name: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://localhost:3306/db_slave?serverTimezone=Asia/Shanghai
          username: root
          password: 123

import com.baomidou.dynamic.datasource.annotation.DS;
import org.springframework.stereotype.Service;

@Service
public class UserService {

    // 默认使用 primary 配置的数据源，即 master
    public User getMasterUser(Long id) {
        // ... 逻辑
    }

    // 明确指定使用 slave 数据源，常用于查询
    @DS("slave")
    public List<User> getSlaveUsers() {
        // ... 逻辑，此方法执行期间会使用 slave 库
        return userMapper.selectAll();
    }
    
    // 明确指定使用 master 数据源，常用于事务性的更新操作
    @DS("master")
    public void updateMasterUser(User user) {
        // ... 逻辑，此方法执行期间会使用 master 库
        userMapper.update(user);
    }
}

import com.baomidou.dynamic.datasource.annotation.DS;
import org.apache.ibatis.annotations.Mapper;

// 整个 Mapper 接口都使用 slave 数据源
@DS("slave")
@Mapper
public interface SlaveUserMapper {
    List<User> selectAll();
    
    // 如果某个方法需要覆盖类上的配置，可以再次使用 @DS
    @DS("master")
    User selectById(Long id); 
}

spring:
  datasource:
    dynamic:
      primary: master-group # 默认使用 master-group
      datasource:
        # 定义一个名为 master-group 的组，它包含一个主库和两个从库
        master-group:
          # 主库
          master:
            url: ...
          # 从库 1
          slave1:
            url: ...
          # 从库 2
          slave2:
            url: ...

@Autowired
private DynamicDataSourceCreator dynamicDataSourceCreator;

@Autowired
private DynamicDataSource dynamicDataSource;

public void addTenantDataSource(String tenantId, DataSourceProperty dp) {
    // 1. 创建新的数据源（例如使用 Druid 或 Hikari 配置）
    DataSource newDs = dynamicDataSourceCreator.createDataSource(dp);
    
    // 2. 将数据源添加到动态数据源管理器中
    dynamicDataSource.addDataSource(tenantId, newDs);
}