欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Mybatis+Druid+MybatisPlus多數(shù)據(jù)源配置方法

 更新時(shí)間:2024年09月19日 10:25:32   作者:我認(rèn)不到你  
在項(xiàng)目開發(fā)中,經(jīng)常需要連接多個(gè)數(shù)據(jù)庫(kù),使用Mybatis、Druid和MybatisPlus可以實(shí)現(xiàn)多數(shù)據(jù)源配置,通過(guò)定義配置類和修改配置文件,如properties或yaml,可以設(shè)置多個(gè)數(shù)據(jù)源,本文介紹了配置項(xiàng)包括Druid基本配置、數(shù)據(jù)源一、數(shù)據(jù)源二,感興趣的朋友一起看看吧

Mybatis+Druid+MybatisPlus多數(shù)據(jù)源配置

平常我們使用的是 properties 或者 yaml 來(lái)配置數(shù)據(jù)庫(kù)的地址、用戶名、密碼等

但是這樣只能配置一個(gè)數(shù)據(jù)源

現(xiàn)在我們想在一個(gè)項(xiàng)目里面配置多個(gè)數(shù)據(jù)源,那么我們就需要配置自己的配置類

配置類和配置文件

Mybatis+mysql+druid配置

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:
      #    打開我們的內(nèi)置監(jiān)控頁(yè)面,打開后我們才可以有相應(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
  # 配置自己去搜一下吧 這里我沒有配置完
  datasource:
    # druid 配置
    druid:
      #        打開我們的內(nèi)置監(jiān)控功能,打開之后我們才可以對(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
      #        打開我們的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ò)多的問題,可以把這個(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)隔開。
      # 注意,Druid中的filter-class-names配置項(xiàng)是不起作用的,必須采用filters配置項(xiàng)才可以。
      filters: stat,wall,log4j2
      # 通過(guò)connectProperties屬性來(lá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),在開發(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

項(xiàng)目的配置項(xiàng)文件:

配置項(xiàng):Druid配置

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);
        // 打開PSCache時(shí),指定每個(gè)連接上PSCache的大小
        druid.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
        return druid;
    }
}

配置項(xiàng):數(shù)據(jù)源一

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);
    }
}

配置項(xiàng):數(shù)據(jù)源二 ,該數(shù)據(jù)源作為MybatisPlus的使用數(shù)據(jù)源

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插件

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

Mapper路徑

XML路徑

測(cè)試: controller

@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);
    }
}

postman:

Druid頁(yè)面:

到此這篇關(guān)于Mybatis+Druid+MybatisPlus多數(shù)據(jù)源配置的文章就介紹到這了,更多相關(guān)Mybatis Druid MybatisPlus多數(shù)據(jù)源內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • JFreeChart實(shí)現(xiàn)實(shí)時(shí)曲線圖

    JFreeChart實(shí)現(xiàn)實(shí)時(shí)曲線圖

    這篇文章主要為大家詳細(xì)介紹了JFreeChart實(shí)現(xiàn)實(shí)時(shí)曲線圖的方法,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2018-06-06
  • springboot手動(dòng)事務(wù)回滾的實(shí)現(xiàn)代碼

    springboot手動(dòng)事務(wù)回滾的實(shí)現(xiàn)代碼

    這篇文章主要介紹了springboot手動(dòng)事務(wù)回滾的實(shí)現(xiàn)方法,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2020-07-07
  • 一文總結(jié)RabbitMQ中的消息確認(rèn)機(jī)制

    一文總結(jié)RabbitMQ中的消息確認(rèn)機(jī)制

    RabbitMQ消息確認(rèn)機(jī)制指的是在消息傳遞過(guò)程中,發(fā)送方發(fā)送消息后,接收方需要對(duì)消息進(jìn)行確認(rèn),以確保消息被正確地接收和處理,本文為大家整理了RabbitMQ中的消息確認(rèn)機(jī)制,需要的可以參考一下
    2023-06-06
  • Java項(xiàng)目如何引入日志生成器及其日志分級(jí)

    Java項(xiàng)目如何引入日志生成器及其日志分級(jí)

    這篇文章主要介紹了Java項(xiàng)目引入日志生成器及其日志分級(jí),本文結(jié)合示例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2022-12-12
  • Mybatis實(shí)體類和表映射問題(推薦)

    Mybatis實(shí)體類和表映射問題(推薦)

    在項(xiàng)目開發(fā)中我們經(jīng)常會(huì)遇到表中的字段名和表對(duì)應(yīng)實(shí)體類的屬性名稱不一定都是完全相同的。下面小編給大家介紹下這種情況下如何解決字段名與實(shí)體類屬性名不相同的沖突問題。下面小編給大家?guī)?lái)了Mybatis實(shí)體類和表映射的解決方法,小伙伴們一起學(xué)習(xí)吧
    2016-09-09
  • 基于spring+hibernate+JQuery開發(fā)之電子相冊(cè)(附源碼下載)

    基于spring+hibernate+JQuery開發(fā)之電子相冊(cè)(附源碼下載)

    本篇文章介紹了,基于spring+hibernate+JQuery開發(fā)之電子相冊(cè)(附源碼下載)。需要的朋友參考下
    2013-05-05
  • java獲取微信accessToken的方法

    java獲取微信accessToken的方法

    這篇文章主要為大家詳細(xì)介紹了java獲取微信accessToken的方法,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2019-09-09
  • Java?精煉解讀遞歸的概念與使用

    Java?精煉解讀遞歸的概念與使用

    一說(shuō)起遞歸,我想每個(gè)人都不陌生。舉個(gè)從小就聽過(guò)的例子:從前有座山,山里有座廟,廟里有個(gè)和尚,和尚在講故事,從前有座山,山里有座廟,廟里有個(gè)和尚,和尚在講故事,從前有座山,要理解遞歸,就得先了解什么是遞歸,實(shí)際上這句話就是一個(gè)遞歸
    2022-03-03
  • java OOM內(nèi)存泄漏原因及解決方法

    java OOM內(nèi)存泄漏原因及解決方法

    這篇文章主要介紹了java OOM內(nèi)存泄漏原因及解決方法,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2019-08-08
  • 分享一個(gè)簡(jiǎn)單的java爬蟲框架

    分享一個(gè)簡(jiǎn)單的java爬蟲框架

    這篇文章主要介紹了分享一個(gè)簡(jiǎn)單的java爬蟲框架,具有一定參考價(jià)值,需要的朋友可以了解下。
    2017-11-11

最新評(píng)論