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

spring:
  # 動態(tài)數(shù)據(jù)源配置
  datasource:
    dynamic:
      # 默認數(shù)據(jù)源，未指定時將使用這個
      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 配置的數(shù)據(jù)源，即 master
    public User getMasterUser(Long id) {
        // ... 邏輯
    }

    // 明確指定使用 slave 數(shù)據(jù)源，常用于查詢
    @DS("slave")
    public List<User> getSlaveUsers() {
        // ... 邏輯，此方法執(zhí)行期間會使用 slave 庫
        return userMapper.selectAll();
    }
    
    // 明確指定使用 master 數(shù)據(jù)源，常用于事務(wù)性的更新操作
    @DS("master")
    public void updateMasterUser(User user) {
        // ... 邏輯，此方法執(zhí)行期間會使用 master 庫
        userMapper.update(user);
    }
}

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

// 整個 Mapper 接口都使用 slave 數(shù)據(jù)源
@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. 創(chuàng)建新的數(shù)據(jù)源（例如使用 Druid 或 Hikari 配置）
    DataSource newDs = dynamicDataSourceCreator.createDataSource(dp);
    
    // 2. 將數(shù)據(jù)源添加到動態(tài)數(shù)據(jù)源管理器中
    dynamicDataSource.addDataSource(tenantId, newDs);
}