<dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.2.24</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.2.24</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>dynamic-datasource-spring-boot3-starter</artifactId>
            <version>4.3.1</version>
        </dependency>

spring:
  application:
    name: project-name
  datasource:
    dynamic:
      type: com.alibaba.druid.pool.DruidDataSource
      # 設(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: true
      datasource:
        # 主庫數(shù)據(jù)源
        master:
          type: ${spring.datasource.type}
          driver-class-name: 
          url: 
          username: 
          password: 
        # 從庫數(shù)據(jù)源
        slave:
          type: ${spring.datasource.type}
          driver-class-name: 
          url: 
          username: 
          password: 
      druid:
        inital-size: 10
        #最大連接數(shù)
        max-active: 50
        #最小連接數(shù)
        min-idle: 10
        #獲取鏈接等待超時(shí)時(shí)間
        max-wait: 5000
        pool-prepared-statements: true #是否緩存preparedStatement，也就是PSCache。PSCache對支持游標(biāo)的數(shù)據(jù)庫性能提升巨大，比如說oracle。在mysql下建議關(guān)閉。
        max-pool-prepared-statement-per-connection-size: 20
        validation-query: SELECT 1 FROM DUAL
        validation-query-timeout: 20000
        test-on-borrow: false  #申請連接時(shí)執(zhí)行validationQuery檢測連接是否有效，做了這個(gè)配置會(huì)降低性能。
        test-on-return: false #歸還連接時(shí)執(zhí)行validationQuery檢測連接是否有效，做了這個(gè)配置會(huì)降低性能。
        test-while-idle: true #建議配置為true，不影響性能，并且保證安全性。申請連接的時(shí)候檢測，如果空閑時(shí)間大于timeBetweenEvictionRunsMillis，執(zhí)行validationQuery檢測連接是否有效。
        time-between-eviction-runs-millis: 60000  #配置間隔多久才進(jìn)行一次檢測，檢測需要關(guān)閉的空閑連接，單位是毫秒
        min-evictable-idle-time-millis: 300000  #一個(gè)連接在池中最小生存的時(shí)間，單位是毫秒
        max-evictable-idle-time-millis: 900000 # 配置一個(gè)連接在池中最大生存的時(shí)間，單位是毫秒
        #StatViewServlet配置。（因?yàn)楸┞兜谋O(jiān)控信息比較敏感，支持密碼加密和訪問ip限定）
        web-stat-filter:
          enableed: true
        stat-view-servlet:
          enabled: true
          url-pattern: /druid/*
          #可以增加訪問賬號(hào)密碼【去掉注釋就可以】
          #login-username: admin
          #login-password: admin
        filter:
          stat:
            enabled: true
            # 慢SQL 記錄
            log-slow-sql: true
            slow-sql-millis: 1000
            merge-sql: true
          wall:
            config:
              multi-statement-allow: true

package com.guyk.common.config;
import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import javax.sql.DataSource;
import java.util.HashMap;
import java.util.Map;
@Slf4j
@Configuration
@EnableTransactionManagement(order = 1)
// @MapperScan(basePackages = {"com.guyk.dao.mapper"})
public class DruidConfig {
    @Bean
    @Primary
    public DataSource dataSource() {
        DynamicDataSource dynamicDataSource = new DynamicDataSource();
        Map<Object, Object> targetDataSources = new HashMap<>();
        targetDataSources.put("master", masterDataSource());
        targetDataSources.put("slave", slaveDataSource());
        dynamicDataSource.setDefaultTargetDataSource(masterDataSource());
        dynamicDataSource.setTargetDataSources(targetDataSources);
        return dynamicDataSource;
    }
    @Bean
    @ConfigurationProperties("spring.datasource.dynamic.datasource.master")
    public DataSource masterDataSource() {
        return DruidDataSourceBuilder.create().build();
    }
    @Bean
    @ConfigurationProperties("spring.datasource.dynamic.datasource.slave")
    public DataSource slaveDataSource() {
        return DruidDataSourceBuilder.create().build();
    }
}

package com.guyk.common.config;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class DataSourceContextHolder {
    private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();
    // 設(shè)置數(shù)據(jù)源類型
    public static void setDataSourceType(String dataSourceType) {
        log.info("切換數(shù)據(jù)源: {}", dataSourceType);
        contextHolder.set(dataSourceType);
    }
    // 獲取當(dāng)前線程的數(shù)據(jù)源類型
    public static String getDataSourceType() {
        return contextHolder.get();
    }
    // 清除當(dāng)前線程的數(shù)據(jù)源類型
    public static void clearDataSourceType() {
        String current = getDataSourceType();
        contextHolder.remove();
        log.info("清除數(shù)據(jù)源: {}", current);
    }
}

package com.guyk.common.annotation;
import java.lang.annotation.*;
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface DataSource {
    /**
     * 數(shù)據(jù)源名稱
     */
    String value() default "master";
}

package com.guyk.common.config;
import com.hhubrain.common.annotation.DataSource;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;
import java.lang.reflect.Method;
@Slf4j
@Aspect
@Component
@Order(-1)
public class DataSourceAspect {
    /**
     * 攔截帶有@DataSource注解的方法
     */
    @Around("@annotation(com.hhubrain.common.annotation.DataSource)")
    public Object around(ProceedingJoinPoint point) throws Throwable {
        MethodSignature signature = (MethodSignature) point.getSignature();
        Method method = signature.getMethod();
        // 獲取注解中的數(shù)據(jù)源類型
        DataSource dataSourceAnnotation = method.getAnnotation(DataSource.class);
        String dataSourceType = dataSourceAnnotation.value();
        // 獲取當(dāng)前線程的數(shù)據(jù)源類型
        String oldDataSource = DataSourceContextHolder.getDataSourceType();
        log.info("數(shù)據(jù)源切換: {} -> {}", oldDataSource, dataSourceType);
        // 切換數(shù)據(jù)源
        DataSourceContextHolder.setDataSourceType(dataSourceType);
        try {
            return point.proceed();
        } finally {
            // 還原數(shù)據(jù)源
            if (oldDataSource != null) {
                DataSourceContextHolder.setDataSourceType(oldDataSource);
                log.info("恢復(fù)數(shù)據(jù)源: {}", oldDataSource);
            } else {
                DataSourceContextHolder.clearDataSourceType(); // 清除線程數(shù)據(jù)源
                log.info("清除數(shù)據(jù)源上下文");
            }
        }
    }
}