spring:
  autoconfigure:
    ## 多數(shù)據(jù)源環(huán)境下必須排除掉 DataSourceAutoConfiguration，否則會(huì)導(dǎo)致循環(huán)依賴報(bào)錯(cuò)
    exclude:
      - org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
  datasource:
    # 使用druid連接池
    type: com.alibaba.druid.pool.DruidDataSource
    druid:
      #    打開(kāi)我們的內(nèi)置監(jiān)控頁(yè)面，打開(kāi)后我們才可以有相應(yīng)的web界面
      stat-view-servlet:
        enabled: true
        url-pattern: /druid/*
        login-username: user
        login-password: 123456
jdbc:
  # 數(shù)據(jù)庫(kù)鏈接放在外面 方便連接配置中心 做到測(cè)試和生產(chǎn)不同環(huán)境
  one:
    url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&useSSL=true&allowMultiQueries=true
    user: root
    pwd: 123456
    driver: com.mysql.cj.jdbc.Driver
  two:
    url: jdbc:mysql://ip地址:3306/test?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&useSSL=true&allowMultiQueries=true
    user: root
    pwd: 123456
    driver: com.mysql.cj.jdbc.Driver
  # 配置自己去搜一下吧 這里我沒(méi)有配置完
  datasource:
    # druid 配置
    druid:
      #        打開(kāi)我們的內(nèi)置監(jiān)控功能，打開(kāi)之后我們才可以對(duì)我們的操作進(jìn)行統(tǒng)計(jì)
      filter:
        stat:
          enabled: true
          slow-sql-millis: 2000
        #      配置防火墻，防止sql語(yǔ)句注入，我們可以設(shè)置我們想要那些語(yǔ)句可以執(zhí)行，哪些不行
        wall:
          enabled: true
          config:
            delete-allow: true
      #            select-all-column-allow: false,如果我們?cè)O(shè)置了拒絕查詢，那么我們查詢時(shí)就會(huì)報(bào)錯(cuò)，返回一個(gè)whitePage
      #            selelct-allow: false
      #        打開(kāi)我們的Web關(guān)聯(lián)監(jiān)控配置,即我們對(duì)某些路徑進(jìn)行精確統(tǒng)計(jì)
      web-stat-filter:
        enabled: true
      # 初始化時(shí)建立的物理連接數(shù)。初始化發(fā)生在顯式調(diào)用init方法，或者第一次getConnection時(shí).
      initial-size: 5
      # 連接池最大物理連接數(shù)量。
      max-active: 50
      # 連接池最小物理連接數(shù)量。
      min-idle: 5
      # 獲取連接時(shí)最大等待時(shí)間，單位為毫秒。
      # 配置之后，缺省啟用公平鎖，并發(fā)效率會(huì)有所下降，若需要可以通過(guò)配置useUnfairLock屬性為true使用非公平鎖。
      max-wait: 6000
      # 是否緩存preparedStatement，也就是PSCache。
      # PSCache對(duì)支持游標(biāo)的數(shù)據(jù)庫(kù)性能提升巨大，比如說(shuō)oracle。在mysql下建議關(guān)閉。
      pool-prepared-statements: 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。
      max-pool-prepared-statement-per-connection-size: 20
      # 用來(lái)檢測(cè)連接是否有效的sql，要求是一個(gè)查詢語(yǔ)句，常用select 'x'。
      # 如果validationQuery為null，testOnBorrow、testOnReturn、testWhileIdle都不會(huì)起作用。
      validation-query: select 1 from dual
      # 檢測(cè)連接是否有效的超時(shí)時(shí)間，單位為秒。
      # 底層調(diào)用jdbc Statement對(duì)象的void setQueryTimeout(int seconds)方法。
      #      validation-query-timeout: 30
      # 有兩個(gè)含義：
      #  1) Destroy線程會(huì)檢測(cè)連接的間隔時(shí)間，若連接空閑時(shí)間大于等于minEvictableIdleTimeMillis則關(guān)閉物理連接。
      #  2) testWhileIdle的判斷依據(jù)，詳細(xì)看testWhileIdle屬性的說(shuō)明。
      time-between-eviction-runs-millis: 60000
      # 連接保持空閑而不被驅(qū)逐的最長(zhǎng)時(shí)間。
      min-evictable-idle-time-millis: 300000
      # 建議配置為true，不影響性能，并且保證安全性。
      # 申請(qǐng)連接的時(shí)候檢測(cè)，若空閑時(shí)間大于timeBetweenEvictionRunsMillis，執(zhí)行validationQuery檢測(cè)連接是否有效。
      test-while-idle: true
      # 申請(qǐng)連接時(shí)執(zhí)行validationQuery檢測(cè)連接是否有效，做了這個(gè)配置會(huì)降低性能。
      test-on-borrow: false
      # 歸還連接時(shí)執(zhí)行validationQuery檢測(cè)連接是否有效，做了這個(gè)配置會(huì)降低性能。
      test-on-return: false
      # 類型是字符串，通過(guò)別名的方式配置擴(kuò)展的攔截器插件，常用的攔截器插件有：
      # 監(jiān)控統(tǒng)計(jì)用的filter:stat，日志用的filter:log4j，防御sql注入攻擊的filter:wall，三個(gè)同時(shí)配置的化，用逗號(hào)隔開(kāi)。
      # 注意，Druid中的filter-class-names配置項(xiàng)是不起作用的，必須采用filters配置項(xiàng)才可以。
      filters: stat,wall,log4j2
      # 通過(guò)connectProperties屬性來(lái)打開(kāi)mergeSql功能；慢SQL記錄。
      connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
      # 合并多個(gè)DruidDataSource的監(jiān)控?cái)?shù)據(jù)
      use-global-data-source-stat: true
mybatis-plus:
  configuration:
    # 更新字段的時(shí)候設(shè)置為null，忽略實(shí)體null判斷之后，解決Oracle無(wú)效的列異常, oracle數(shù)據(jù)庫(kù)必須配置
    jdbc-type-for-null: 'null'  # 注意要有單引號(hào)
    # mybatis-plus駝峰映射
    map-underscore-to-camel-case: true
    # 這個(gè)配置會(huì)將執(zhí)行的sql打印出來(lái)，在開(kāi)發(fā)或測(cè)試的時(shí)候可以用
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
  # mybatis的xml文件地址，如果啟動(dòng)文件找不到xml文件，如下去修改pom.xml文件
  mapper-locations: classpath:mybatis/two/*.xml
  global-config:
    # 禁用mybatis-plus的LOGO
    banner: false
    db-config:
      # 邏輯未刪除值，（邏輯刪除下有效）
      logic-delete-value: 1
      # 邏輯未刪除值，（邏輯刪除下有效）需要注入邏輯策略LogicSqlInjector，以@Bean方式注入
      logic-not-delete-value: 0
      # 對(duì)應(yīng)實(shí)體類的字段，寫了這個(gè)在實(shí)體類中就不需要寫注解了
      logic-delete-field: deleted

package com.example.test.config;
import com.alibaba.druid.pool.DruidDataSource;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import java.sql.SQLException;
@Data
@ConfigurationProperties(prefix = "jdbc.datasource.druid")
public class DruidConfig {
    protected String filters;
    protected int initialSize;
    protected int minIdle;
    protected int maxActive;
    protected long maxWait;
    protected long timeBetweenEvictionRunsMillis;
    protected long minEvictableIdleTimeMillis;
    protected String validationQuery;
    protected boolean testWhileIdle;
    protected boolean testOnBorrow;
    protected boolean testOnReturn;
    protected boolean poolPreparedStatements;
    protected int maxPoolPreparedStatementPerConnectionSize;
    /**
     * 初始化
     * @return
     * @throws SQLException
     */
    protected DruidDataSource init() throws SQLException {
        DruidDataSource druid = new DruidDataSource();
        // 監(jiān)控統(tǒng)計(jì)攔截的filters
        druid.setFilters(filters);
        //初始化時(shí)建立物理連接的個(gè)數(shù)
        druid.setInitialSize(initialSize);
        //最大連接池?cái)?shù)量
        druid.setMaxActive(maxActive);
        //最小連接池?cái)?shù)量
        druid.setMinIdle(minIdle);
        //獲取連接時(shí)最大等待時(shí)間，單位毫秒。
        druid.setMaxWait(maxWait);
        //間隔多久進(jìn)行一次檢測(cè)，檢測(cè)需要關(guān)閉的空閑連接
        druid.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
        //一個(gè)連接在池中最小生存的時(shí)間
        druid.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
        //用來(lái)檢測(cè)連接是否有效的sql
        druid.setValidationQuery(validationQuery);
        //建議配置為true，不影響性能，并且保證安全性。
        druid.setTestWhileIdle(testWhileIdle);
        //申請(qǐng)連接時(shí)執(zhí)行validationQuery檢測(cè)連接是否有效
        druid.setTestOnBorrow(testOnBorrow);
        druid.setTestOnReturn(testOnReturn);
        //是否緩存preparedStatement，也就是PSCache，oracle設(shè)為true，mysql設(shè)為false。分庫(kù)分表較多推薦設(shè)置為false
        druid.setPoolPreparedStatements(poolPreparedStatements);
        // 打開(kāi)PSCache時(shí)，指定每個(gè)連接上PSCache的大小
        druid.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
        return druid;
    }
}

package com.example.test.config;
import com.alibaba.druid.pool.DruidDataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import javax.sql.DataSource;
import java.sql.SQLException;
/**
 * 雙數(shù)據(jù)庫(kù)配置 因?yàn)橐徊糠植樵冃枰玫?
 * oneDataSource -》 數(shù)據(jù)庫(kù)一
 * twoDataSource -》 數(shù)據(jù)庫(kù)二
 */
@Configuration
@MapperScan(basePackages = OneDBConfig.PACKAGE, sqlSessionFactoryRef = "oneSqlSessionFactory")
public class OneDBConfig extends DruidConfig {
    /**
     * dao層的包路徑
     */
    static final String PACKAGE = "com.example.test.mapper.one";
    /**
     * mapper文件的相對(duì)路徑
     */
    private static final String MAPPER_LOCATION = "classpath*:mybatis/one/*.xml";
    @Value("${jdbc.one.url}")
    private String url;
    @Value("${jdbc.one.user}")
    private String user;
    @Value("${jdbc.one.pwd}")
    private String pwd;
    @Value("${jdbc.one.driver}")
    private String driverName;
    @Bean(name = "oneDataSource")
    public DataSource oneDataSource() throws SQLException {
        DruidDataSource druid = init();
        // 配置基本屬性
        druid.setDriverClassName(driverName);
        druid.setUsername(user);
        druid.setPassword(pwd);
        druid.setUrl(url);
        return druid;
    }
    @Bean(name = "oneSqlSessionFactory")
    public SqlSessionFactory oneSqlSessionFactory(@Qualifier("oneDataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(MAPPER_LOCATION));
        return bean.getObject();
    }
    @Bean(name = "oneTransactionManager")
    public DataSourceTransactionManager secondaryTransactionManager(@Qualifier("oneDataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }
}

package com.example.test.config;
import com.alibaba.druid.pool.DruidDataSource;
import com.baomidou.mybatisplus.autoconfigure.MybatisPlusProperties;
import com.baomidou.mybatisplus.core.MybatisConfiguration;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.util.StringUtils;
import javax.sql.DataSource;
import java.sql.SQLException;
/**
 * 雙數(shù)據(jù)庫(kù)配置 因?yàn)橐徊糠植樵冃枰玫?
 * 該 數(shù)據(jù)庫(kù)配資源 作為 mybatisPlus 的使用源
 * oneDataSource -》 數(shù)據(jù)庫(kù)一
 * twoDataSource -》 數(shù)據(jù)庫(kù)二
 */
@Configuration
@EnableConfigurationProperties({MybatisPlusProperties.class})
@MapperScan(basePackages = TwoDBConfig.PACKAGE, sqlSessionFactoryRef = "twoSqlSessionFactory")
public class TwoDBConfig extends DruidConfig {
    private final MybatisPlusProperties properties;
    /**
     * dao層的包路徑
     */
    static final String PACKAGE = "com.example.test.mapper.two";
    /**
     * mapper文件的相對(duì)路徑
     */
    private static final String MAPPER_LOCATION = "classpath*:mybatis/two/*.xml";
    @Value("${jdbc.two.url}")
    private String url;
    @Value("${jdbc.two.user}")
    private String user;
    @Value("${jdbc.two.pwd}")
    private String pwd;
    @Value("${jdbc.two.driver}")
    private String driverName;
    public TwoDBConfig(MybatisPlusProperties properties) {
        this.properties = properties;
    }
    @Bean(name = "twoDataSource")
    @Primary
    public DataSource dataSource() throws SQLException {
        DruidDataSource druid = init();
        // 配置基本屬性
        druid.setDriverClassName(driverName);
        druid.setUsername(user);
        druid.setPassword(pwd);
        druid.setUrl(url);
        return druid;
    }
    @Bean(name = "twoSqlSessionFactory")
    @Primary
    public SqlSessionFactory twoSqlSessionFactory(@Qualifier("twoDataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(MAPPER_LOCATION));
        MybatisConfiguration configuration = this.properties.getConfiguration();
        if (configuration == null && !StringUtils.hasText(this.properties.getConfigLocation())) {
            configuration = new MybatisConfiguration();
        }
        bean.setConfiguration(configuration);
        return bean.getObject();
    }
    @Primary
    @Bean(name = "twoTransactionManager")
    public DataSourceTransactionManager twoTransactionManager(@Qualifier("twoDataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }
}

/**
 * MybatisPlus 配置類
 */
@EnableTransactionManagement //事務(wù)控制
@Configuration //配置類
public class MyBatisPlusConfig {
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor(){
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        //分頁(yè)插件
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        return interceptor;
    }
}

@RestController
@Slf4j
@RequestMapping("/cs")
public class TestController {
    @Autowired
    private OneMapper oneMapper;
    @Autowired
    private TwoMapper twoMapper;
    @PostMapping("/test")
    public Results test() {
        int count1 = oneMapper.count();
        int count2 = twoMapper.count();
        log.info("數(shù)據(jù)源一：{}，數(shù)據(jù)源二：{}", count1, count2);
        return Results.success(count1 + "+" + count2);
    }
}