datasource:
  dynamic:
    primary: master # 默認(rèn)使用master庫(kù)
    strict: false   # 不使用嚴(yán)格模式
    datasource:
      master:
        url: jdbc:mysql://127.0.0.1:3306/test?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false
        username: root
        password: 123456
        driver-class-name: com.mysql.cj.jdbc.Driver
        hikari:
          connection-timeout: 30000
          max-lifetime: 1800000
          max-pool-size: 15
          min-idle: 5
          connection-test-query: select 1
          pool-name: YsxHikariCP
      adcontrol:
        url: jdbc:mysql://ip:3306/test2?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false
        username: test
        password: test
        driver-class-name: com.mysql.cj.jdbc.Driver

<dependency>
    <groupId>com.github.dynamic-datasource</groupId>
    <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
    <version>3.2.1</version> <!-- 確保使用合適的版本 -->
</dependency>

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import com.github.dynamic.datasource.DynamicRoutingDataSource;
import javax.sql.DataSource;
import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;
import java.util.HashMap;
import java.util.Map;

@Configuration
public class DataSourceConfig {

    @Bean
    public DataSource dataSource() {
        DynamicRoutingDataSource dataSource = new DynamicRoutingDataSource();

        // 配置主數(shù)據(jù)源
        DataSource masterDataSource = DataSourceBuilder.create()
                .url("jdbc:mysql://127.0.0.1:3306/test1?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false")
                .username("root")
                .password("123456")
                .driverClassName("com.mysql.cj.jdbc.Driver")
                .build();

        // 配置廣告控制數(shù)據(jù)源
        DataSource adcontrolDataSource = DataSourceBuilder.create()
                .url("jdbc:mysql://ip1:3306/test2?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false")
                .username("test")
                .password("test")
                .driverClassName("com.mysql.cj.jdbc.Driver")
                .build();

        // 將數(shù)據(jù)源放入Map
        Map<Object, Object> dataSourceMap = new HashMap<>();
        dataSourceMap.put("master", masterDataSource);
        dataSourceMap.put("adcontrol", adcontrolDataSource);

        dataSource.setDefaultTargetDataSource(masterDataSource);
        dataSource.setTargetDataSources(dataSourceMap);

        return dataSource;
    }
}

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

@Service
public class MyService {

    @DS("adcontrol")
    public void handleAdControlLogic() {
        // 使用adcontrol數(shù)據(jù)源執(zhí)行操作
    }

    @DS("master")
    public void handleMasterLogic() {
        // 使用master數(shù)據(jù)源執(zhí)行操作
    }
}

import org.springframework.transaction.annotation.Transactional;

@Service
public class MyService {

    @Transactional
    @DS("master")
    public void processTransaction() {
        try {
            // 操作master數(shù)據(jù)庫(kù)
            handleMasterLogic();

            // 切換到adcontrol數(shù)據(jù)源
            handleAdControlLogic();

        } catch (Exception e) {
            // 處理異常，可能需要回滾事務(wù)
            throw new RuntimeException("事務(wù)失敗，進(jìn)行回滾", e);
        }
    }

    @DS("adcontrol")
    public void handleAdControlLogic() {
        // 操作adcontrol數(shù)據(jù)庫(kù)
    }

    @DS("master")
    public void handleMasterLogic() {
        // 操作master數(shù)據(jù)庫(kù)
    }
}