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

spring:
  application:
    name: DynamicDatasource
  datasource:
    druid:
      stat-view-servlet:
        enabled: true
        allow:
        deny:
        reset-enable: false
        login-username: admin
        login-password: 123456
        url-pattern: /druid/*
      web-stat-filter:
        enabled: true
        #對(duì)這些請(qǐng)求放行
        exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"
        #攔截該項(xiàng)目下的一切請(qǐng)求
        url-pattern: /*
        session-stat-enable: true
        principal-session-name: session_name
        principal-cookie-name: cookie_name
        profile-enable: true
      # 包匹配，表示匹配以com.github.wxhnyfy.dynamicdatasource開頭的包名，多個(gè)用逗號(hào)隔開
      aop-patterns: com.github.wxhnyfy.dynamicdatasource.*
    dynamic:
      primary: master # 設(shè)置默認(rèn)的數(shù)據(jù)源或者數(shù)據(jù)源組，默認(rèn)值即為 master
      datasource:
        master:
          #設(shè)置默認(rèn)的數(shù)據(jù)源
          driverClassName: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://localhost:3306/region?autoReconnect=true&useUnicode=true&characterEncoding=utf8&useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=GMT%2B8
          username: root
          password: 123456
          type: com.alibaba.druid.pool.DruidDataSource
          # druid連接池設(shè)置
          druid:
            # 配置初始化線程數(shù)
            initialSize: 5
            # 最小線程數(shù)
            minIdle: 5
            # CPU核數(shù)+1，也可以大些但不要超過(guò)20，數(shù)據(jù)庫(kù)加鎖時(shí)連接過(guò)多性能下降
            maxActive: 11
            # 最大等待時(shí)間，內(nèi)網(wǎng)：800，外網(wǎng)：1200（三次握手1s）
            maxWait: 60000
            # 連接可空閑存活時(shí)間（ms）
            timeBetweenEvictionRunsMillis: 60000
            # 連接保持空閑而不被驅(qū)逐的最長(zhǎng)存活時(shí)間（ms）
            minEvictableIdleTimeMillis: 300000
            # 用來(lái)檢測(cè)連接是否有效的sql，如果validationQuery為空，那么testOnBorrow、testOnReturn、testWhileIdle這三個(gè)參數(shù)都不會(huì)起作用
            validationQuery: SELECT 1
            # 建議配置為true，不影響性能，并且保證安全性。申請(qǐng)連接的時(shí)候檢測(cè)，如果空閑時(shí)間大于timeBetweenEvictionRunsMillis，執(zhí)行validationQuery檢測(cè)連接是否有效；
            testWhileIdle: true
            # 建議配置為false，申請(qǐng)連接時(shí)執(zhí)行validationQuery檢測(cè)連接是否有效，做了這個(gè)配置會(huì)降低性能。
            testOnBorrow: false
            # 建議配置為false，歸還連接時(shí)執(zhí)行validationQuery檢測(cè)連接是否有效，做了這個(gè)配置會(huì)降低性能；
            testOnReturn: false
            # PSCache對(duì)支持游標(biāo)的數(shù)據(jù)庫(kù)性能提升巨大，oracle建議開啟，mysql下建議關(guān)閉
            poolPreparedStatements: false
            # 保持minIdle數(shù)量的長(zhǎng)連接
            keepAlive: true
            # 要啟用PSCache，必須配置大于0，當(dāng)大于0時(shí)，poolPreparedStatements自動(dòng)觸發(fā)修改為true。
            # 在Druid中，不會(huì)存在Oracle下PSCache占用內(nèi)存過(guò)多的問(wèn)題，可以把這個(gè)數(shù)值配置大一些，比如說(shuō)100。缺省值為-1
            # 開啟poolPreparedStatments后生效
            maxPoolPreparedStatementPerConnectionSize: 20
            # 是否合并多個(gè)DruidDataSource的監(jiān)控?cái)?shù)據(jù)
            useGlobalDataSourceStat: true
            # 配置監(jiān)控統(tǒng)計(jì)攔截的filters
            filters: stat,wall,slf4j
            stat:
              logSlowSql: true
              slowSqlMillis: 2000
              mergeSql: true
              dbType: mysql
            wall:
              # 可配置項(xiàng)參考類：com.alibaba.druid.wall.WallConfig
              multi-statement-allow: true
              alter-table-allow: false
              drop-table-allow: false
            slf4j:
              # 只有當(dāng) isStatementExecutableSqlLogEnable() isStatementLogEnabled() 都為ture的情況才打印 可執(zhí)行sql
              # 在{# LogFilter#logExecutableSql }使用
              statement-executable-sql-log-enable: true
              # 在{# LogFilter#logExecutableSql }使用
              statement-log-enabled: true
              statement-create-after-log-enabled: false
              statement-log-error-enabled: true
              result-set-log-enabled: false
              #statementPrepareAfterLogEnable
              # 準(zhǔn)備好的sql語(yǔ)句打?。ù藭r(shí)為執(zhí)行前）未進(jìn)行參數(shù)拼接
              statement-prepare-after-log-enabled: false
              #isStatementParameterSetLogEnabled
              #打印參數(shù)
              statement-parameter-set-log-enabled: false
              #statementExecuteAfterLogEnable
              #sql語(yǔ)句執(zhí)行完成后打?。▓?zhí)行后）未進(jìn)行參數(shù)拼接
              statement-execute-after-log-enabled: false
              #statementCloseAfterLogEnable
              statement-close-after-log-enabled: false
              #不打印清除參數(shù)日志
              statement-parameter-clear-log-enable: false
            # 通過(guò)connectProperties屬性來(lái)打開mergeSql功能；慢SQL記錄
            connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=2000
        slave:
          url: jdbc:mysql://localhost:3307/region?autoReconnect=true&useUnicode=true&characterEncoding=utf8&useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=GMT%2B8
          username: root
          password: 123456
          driver-class-name: com.mysql.cj.jdbc.Driver
          type: com.alibaba.druid.pool.DruidDataSource
          # druid連接池設(shè)置
          druid:
            # 配置初始化線程數(shù)
            initialSize: 5
            # 最小線程數(shù)
            minIdle: 5
            # CPU核數(shù)+1，也可以大些但不要超過(guò)20，數(shù)據(jù)庫(kù)加鎖時(shí)連接過(guò)多性能下降
            maxActive: 11
            # 最大等待時(shí)間，內(nèi)網(wǎng)：800，外網(wǎng)：1200（三次握手1s）
            maxWait: 60000
            # 連接可空閑存活時(shí)間（ms）
            timeBetweenEvictionRunsMillis: 60000
            # 連接保持空閑而不被驅(qū)逐的最長(zhǎng)存活時(shí)間（ms）
            minEvictableIdleTimeMillis: 300000
            # 用來(lái)檢測(cè)連接是否有效的sql，如果validationQuery為空，那么testOnBorrow、testOnReturn、testWhileIdle這三個(gè)參數(shù)都不會(huì)起作用
            validationQuery: SELECT 1
            # 建議配置為true，不影響性能，并且保證安全性。申請(qǐng)連接的時(shí)候檢測(cè)，如果空閑時(shí)間大于timeBetweenEvictionRunsMillis，執(zhí)行validationQuery檢測(cè)連接是否有效；
            testWhileIdle: true
            # 建議配置為false，申請(qǐng)連接時(shí)執(zhí)行validationQuery檢測(cè)連接是否有效，做了這個(gè)配置會(huì)降低性能。
            testOnBorrow: false
            # 建議配置為false，歸還連接時(shí)執(zhí)行validationQuery檢測(cè)連接是否有效，做了這個(gè)配置會(huì)降低性能；
            testOnReturn: false
            # PSCache對(duì)支持游標(biāo)的數(shù)據(jù)庫(kù)性能提升巨大，oracle建議開啟，mysql下建議關(guān)閉
            poolPreparedStatements: false
            # 保持minIdle數(shù)量的長(zhǎng)連接
            keepAlive: true
            # 要啟用PSCache，必須配置大于0，當(dāng)大于0時(shí)，poolPreparedStatements自動(dòng)觸發(fā)修改為true。
            # 在Druid中，不會(huì)存在Oracle下PSCache占用內(nèi)存過(guò)多的問(wèn)題，可以把這個(gè)數(shù)值配置大一些，比如說(shuō)100。缺省值為-1
            # 開啟poolPreparedStatments后生效
            maxPoolPreparedStatementPerConnectionSize: 20
            # 是否合并多個(gè)DruidDataSource的監(jiān)控?cái)?shù)據(jù)
            useGlobalDataSourceStat: true
            # 配置監(jiān)控統(tǒng)計(jì)攔截的filters
            filters: stat,wall,slf4j
            stat:
              logSlowSql: true
              slowSqlMillis: 2000
              mergeSql: true
              dbType: mysql
            wall:
              # 可配置項(xiàng)參考類：com.alibaba.druid.wall.WallConfig
              multi-statement-allow: true
              alter-table-allow: false
              drop-table-allow: false
            slf4j:
              # 只有當(dāng) isStatementExecutableSqlLogEnable() isStatementLogEnabled() 都為ture的情況才打印 可執(zhí)行sql
              # 在{# LogFilter#logExecutableSql }使用
              statement-executable-sql-log-enable: true
              # 在{# LogFilter#logExecutableSql }使用
              statement-log-enabled: true
              statement-create-after-log-enabled: false
              statement-log-error-enabled: true
              result-set-log-enabled: false
              #statementPrepareAfterLogEnable
              # 準(zhǔn)備好的sql語(yǔ)句打?。ù藭r(shí)為執(zhí)行前）未進(jìn)行參數(shù)拼接
              statement-prepare-after-log-enabled: false
              #isStatementParameterSetLogEnabled
              #打印參數(shù)
              statement-parameter-set-log-enabled: false
              #statementExecuteAfterLogEnable
              #sql語(yǔ)句執(zhí)行完成后打?。▓?zhí)行后）未進(jìn)行參數(shù)拼接
              statement-execute-after-log-enabled: false
              #statementCloseAfterLogEnable
              statement-close-after-log-enabled: false
              #不打印清除參數(shù)日志
              statement-parameter-clear-log-enable: false
            # 通過(guò)connectProperties屬性來(lái)打開mergeSql功能；慢SQL記錄
            connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=2000

public enum DataSourceEnum {
    MASTER("master"),
    SLAVE("slave");
    private String value;
    DataSourceEnum(String value) {
        this.value = value;
    }
    public String getValue() {
        return value;
    }
}

@ApiOperation(value = "執(zhí)行自定義SQL")
@ApiImplicitParams({
        @ApiImplicitParam(name = "envCode", value = "數(shù)據(jù)源標(biāo)識(shí)", required = true, paramType = "query", example = "MASTER", dataTypeClass = DataSourceEnum.class),
        @ApiImplicitParam(name = "query", value = "查詢字符串", required = true, paramType = "query", example = "select * from chinapostoffice limit 100", dataTypeClass = String.class),
})
@GetMapping("/getChinaPostOffice ")
public Response<JSONArray> getChinaPostOffice(@RequestParam DataSourceEnum envCode,
                                              @RequestParam String query
) {
    logger.info(">>> query: {}", query);
    List<Map<String, Object>> list = customMapper.selectList(query);
    logger.info(">>> 總共 {} 條數(shù)據(jù)", list.size());
    logger.info(">>> 數(shù)據(jù): {}", JSONArray.from(list, JSONWriter.Feature.WriteMapNullValue).toJSONString(JSONWriter.Feature.WriteMapNullValue));
    return new Response<JSONArray>().success(JSONArray.from(list, JSONWriter.Feature.WriteMapNullValue));
}

@Aspect
@Component
// 確保在事務(wù)切面之前執(zhí)行
@Order(Ordered.HIGHEST_PRECEDENCE)
public class AutoSwitchDataSourceAop {
    private static final Logger logger = LoggerFactory.getLogger(AutoSwitchDataSourceAop.class);
    /**
     * 當(dāng)前指定的默認(rèn)數(shù)據(jù)源
     */
    @Value("${spring.datasource.dynamic.primary}")
    private String dynamicPrimaryDataSource;
    /**
     * 定義匹配需要切換數(shù)據(jù)源的方法的切點(diǎn)
     * 匹配com.github.wxhnyfy.dynamicdatasource.controller包、com.github.wxhnyfy.dynamicdatasource.impl.service包下所有包含DataSourceEnum參數(shù)的方法
     * 支持DataSourceEnum參數(shù)在任意參數(shù)位置（不限于第一個(gè)參數(shù)）
     *
     * @param joinPoint 切點(diǎn)
     * @return 目標(biāo)執(zhí)行方法
     * @throws Throwable 異常
     */
    @Around("execution(* com.github.wxhnyfy.dynamicdatasource.controller.*.*(com.github.wxhnyfy.dynamicdatasource.enums.DataSourceEnum, ..)) " +
         "|| execution(* com.github.wxhnyfy.dynamicdatasource.impl.service.*.*(com.github.wxhnyfy.dynamicdatasource.enums.DataSourceEnum, ..))")
    public Object around(ProceedingJoinPoint joinPoint) throws Throwable {
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        String methodName = signature.getMethod().getName();
        logger.info("進(jìn)入 SwitchDataSourceAspect 的方法名: {}", methodName);
        logger.debug("當(dāng)前指定的默認(rèn)數(shù)據(jù)源：{}", dynamicPrimaryDataSource);
        DataSourceEnum envCode = null;
        try {
            // 獲取方法參數(shù)中的EnvCode值
            envCode = extractEnvCode(joinPoint);
            // 切換數(shù)據(jù)源
            if (envCode != null) {
                logger.info("數(shù)據(jù)庫(kù)環(huán)境標(biāo)識(shí)：{}", envCode);
                String previousDs = DynamicDataSourceContextHolder.peek();
                logger.info("方法 [{}] 切換數(shù)據(jù)源: {} -> {}", methodName, previousDs, envCode.getValue());
                DynamicDataSourceContextHolder.push(envCode.getValue());
            }
            // 執(zhí)行目標(biāo)方法
            return joinPoint.proceed();
        } finally {
            // 清理數(shù)據(jù)源（恢復(fù)到默認(rèn)數(shù)據(jù)源）
            if (envCode != null) {
                DynamicDataSourceContextHolder.clear();
            }
        }
    }
    /**
     * 通過(guò)反射獲取方法參數(shù)
     * 自動(dòng)識(shí)別DataSourceEnum類型的參數(shù)
     * 支持任意位置的DataSourceEnum參數(shù)
     *
     * @param joinPoint 切點(diǎn)
     * @return DataSourceEnum參數(shù)
     */
    private DataSourceEnum extractEnvCode(ProceedingJoinPoint joinPoint) {
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        Parameter[] parameters = signature.getMethod().getParameters();
        // 遍歷參數(shù)查找EnvCode類型的參數(shù)
        for (int i = 0; i < parameters.length; i++) {
            if (parameters[i].getType().isAssignableFrom(DataSourceEnum.class)) {
                Object arg = joinPoint.getArgs()[i];
                if (arg instanceof DataSourceEnum) {
                    return (DataSourceEnum) arg;
                }
            }
        }
        return null;
    }
}

mybatis-plus:
  mapper-locations: classpath:mapper/*.xml
  configuration:
    log-impl: org.apache.ibatis.logging.slf4j.Slf4jImpl
logging:
  level:
    root: info
    # 注意，logback不支持**匹配
    com.github.wxhnyfy.**.mapper: debug
    druid.sql.Statement: debug