SpringBoot整合Mybatis Plus多數(shù)據(jù)源的實現(xiàn)示例
更新時間：2021年11月04日 11:33:09 作者：陳彥斌
本文主要介紹了SpringBoot整合Mybatis Plus多數(shù)據(jù)源的實現(xiàn)示例，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
導讀
有一個這樣子的需求，線上正在跑的業(yè)務，由于業(yè)務發(fā)展需要，需重新開發(fā)一套新系統(tǒng)，等新系統(tǒng)開發(fā)完成后，需要無縫對接切換，當初具體設計見草圖。
添加依賴
<!--lombok-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.16</version>
<!--scope=provided，說明它是在編譯階段生效，不需要打入包中，Lombok在編譯期將帶Lombok注解的Java文件正確編譯為完整的Class文件-->
<scope>provided</scope>
</dependency>
<!--mysql-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!--mybatis plus和spring boot整合-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.4.0</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.10</version>
</dependency>
application.properties
server.port=9999 spring.datasource.master.driver-class-name=com.mysql.cj.jdbc.Driver spring.datasource.master.url=jdbc:mysql://127.0.0.1/test?useUnicode=true&characterEncoding=utf-8&useSSL=false spring.datasource.master.username=root spring.datasource.master.password=root spring.datasource.slave.driver-class-name=com.mysql.cj.jdbc.Driver spring.datasource.slave.jdbc-url=jdbc:mysql://127.0.0.1/test2?useUnicode=true&characterEncoding=utf-8&useSSL=false spring.datasource.slave.username=root spring.datasource.slave.password=root
2種方式創(chuàng)建DataSource
Master配置，使用druid連接池
import com.alibaba.druid.pool.DruidDataSource;
import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.env.Environment;
import javax.sql.DataSource;
/**
* @Author：chenyanbin
*/
@Configuration
@MapperScan(basePackages = "com.example.demo.mapper", sqlSessionFactoryRef = "masterSqlSessionFactory")
public class MasterDataSourceConfig {
@Autowired
private Environment env;
@Primary
@Bean(name = "masterDataSource")
// @ConfigurationProperties("spring.datasource.master")
public DataSource masterDataSource() {
// return DataSourceBuilder.create().build();
DruidDataSource dataSource = new DruidDataSource();
dataSource.setUrl(env.getProperty("spring.datasource.master.url"));
dataSource.setUsername(env.getProperty("spring.datasource.master.username"));
dataSource.setPassword(env.getProperty("spring.datasource.master.password"));
dataSource.setDriverClassName(env.getProperty("spring.datasource.master.driver-class-name"));
//配置初始化大小、最小、最大
dataSource.setMinIdle(10);
//配置初始化大小、最小、最大
dataSource.setMaxActive(200);
//配置初始化大小、最小、最大
dataSource.setInitialSize(10);
//配置獲取連接等待超時的時間
dataSource.setMaxWait(60000);
//配置一個連接在池中最小生存的時間,單位是毫秒
dataSource.setMinEvictableIdleTimeMillis(300000);
//配置間隔多久才進行一次檢測,檢測需要關閉的空閑連接,單位是毫秒
dataSource.setTimeBetweenEvictionRunsMillis(60000);
//默認的testWhileIdle=true,testOnBorrow=false,testOnReturn=false
dataSource.setValidationQuery("SELECT 1");
//申請連接時執(zhí)行validationQuery檢測連接是否有效
dataSource.setTestOnBorrow(false);
//建議配置為true，不影響性能，并且保證安全性。
dataSource.setTestWhileIdle(true);
//是否緩存preparedStatement，也就是PSCache
dataSource.setPoolPreparedStatements(false);
return dataSource;
}
@Bean(name = "masterSqlSessionFactory")
public SqlSessionFactory sqlSessionFactory(@Qualifier("masterDataSource") DataSource dataSource) throws Exception {
MybatisSqlSessionFactoryBean sessionFactoryBean = new MybatisSqlSessionFactoryBean();
sessionFactoryBean.setDataSource(dataSource);
return sessionFactoryBean.getObject();
}
}
Slave配置
import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.sql.DataSource;
/**
* @Author：chenyanbin
*/
@Configuration
@MapperScan(basePackages = "com.example.demo.mapper2",sqlSessionFactoryRef = "slaveSqlSessionFactory")
public class SlaveDataSourceConfig {
@Bean(name = "slaveDataSource")
@ConfigurationProperties("spring.datasource.slave")
public DataSource slaveDataSource(){
return DataSourceBuilder.create().build();
}
@Bean(name = "slaveSqlSessionFactory")
public SqlSessionFactory sqlSessionFactory(@Qualifier("slaveDataSource") DataSource dataSource) throws Exception {
MybatisSqlSessionFactoryBean sessionFactoryBean = new MybatisSqlSessionFactoryBean();
sessionFactoryBean.setDataSource(dataSource);
return sessionFactoryBean.getObject();
}
}
注意
master和slave掃描不同的mapper包路徑?。。。。?！
如果需要指定.xml文件，需這樣配置?。?！
@Bean(name = "masterSqlSessionFactory")
public SqlSessionFactory sqlSessionFactory(@Qualifier("masterDataSource") DataSource dataSource) throws Exception {
MybatisSqlSessionFactoryBean sessionFactoryBean = new MybatisSqlSessionFactoryBean();
sessionFactoryBean.setDataSource(dataSource);
sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
.getResources("classpath:mapper/**/*.xml"));
return sessionFactoryBean.getObject();
}
MybatisPlus分頁插件設置
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* MybatisPlus分頁配置
*
* @Author：chenyanbin
*/
@Configuration
public class MybatisPlusPageConfig {
/**
* 新版分頁插件
*
* @return
*/
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor() {
MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();
mybatisPlusInterceptor.addInnerInterceptor(new PaginationInnerInterceptor());
return mybatisPlusInterceptor;
}
}
@Bean(name = "masterSqlSessionFactory")
public SqlSessionFactory sqlSessionFactory(
@Qualifier("masterDataSource") DataSource dataSource,
@Qualifier("mybatisPlusInterceptor") MybatisPlusInterceptor mybatisPlusInterceptor
) throws Exception {
MybatisSqlSessionFactoryBean sessionFactoryBean = new MybatisSqlSessionFactoryBean();
sessionFactoryBean.setDataSource(dataSource);
sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
.getResources("classpath:mapper/**/*.xml"));
sessionFactoryBean.setPlugins(mybatisPlusInterceptor);
return sessionFactoryBean.getObject();
}
啟動類
@SpringBootApplication(
exclude = {DataSourceAutoConfiguration.class, MybatisPlusAutoConfiguration.class}
)
啟動類上排查，自動裝配，使用我們自定義的多數(shù)據(jù)源！??！
演示
多個數(shù)據(jù)源，同時也是支持事務的
到此這篇關于SpirngBoot整合Mybatis Plus多數(shù)據(jù)源的實現(xiàn)示例的文章就介紹到這了,更多相關SpirngBoot MybatisPlus多數(shù)據(jù)源內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:
- Springboot多數(shù)據(jù)源配置之整合dynamic-datasource方式
- SpringBoot整合Mybatis實現(xiàn)多數(shù)據(jù)源配置與跨數(shù)據(jù)源事務實例
- Springboot整合JPA配置多數(shù)據(jù)源流程詳解
- SpringBoot+Mybatis plus實現(xiàn)多數(shù)據(jù)源整合的實踐
- SpringBoot使用Atomikos技術整合多數(shù)據(jù)源的實現(xiàn)
- SpringBoot2整合JTA組件實現(xiàn)多數(shù)據(jù)源事務管理
- Springboot整合多數(shù)據(jù)源代碼示例詳解
- Springboot整合多數(shù)據(jù)源配置流程詳細講解
相關文章
spring retry是從spring batch獨立出來的一個能功能，主要實現(xiàn)了重試和熔斷。這篇文章主要介紹了詳解重試框架Spring retry實踐，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-05-05
在web項目開發(fā)的時候，經(jīng)常用到序列化和反序列化用來傳遞大流量的數(shù)據(jù),類只有實現(xiàn)Serializable借口才能被序列化,下來是java序列化和反序列化演示2014-01-01
驗證碼的功能是防止非法用戶惡意去訪問登錄接口而設置的一個功能，今天我們就來看看在前后端分離的項目中，SpringBoot是如何提供服務的2022-05-05
本博客為讀書筆記,讀的是《深入理解Java虛擬機》一書,在看這個書的時候,最大的一個感受便是“當初怎么就沒有好好學習操作系統(tǒng)呢,不然也不會有這么多看的云里霧里的地方了”,不過那都是過去的事了,學習最好的時刻便是現(xiàn)在,需要的朋友可以參考下2021-06-06
本文將詳細介紹java final 對象的使用，需要了解更多的朋友可以參考下2012-11-11
今天小編就為大家分享一篇java 讀取文件路徑空格、"+"和中文的處理方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-07-07
Android?Studio?中Gradle配置sonarqube插件(推薦)
Sonarqube作為一個很實用的靜態(tài)代碼分析工具，在很多項目中都使用，本文重點給大家介紹Android?Studio?中Gradle配置sonarqube插件的相關知識，感興趣的朋友跟隨小編一起看看吧2022-03-03
這篇文章主要介紹了Feign之Multipartfile文件傳輸埋坑及解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-06-06
Monaco?Editor實現(xiàn)sql和java代碼提示實現(xiàn)示例
這篇文章主要為大家介紹了Monaco?Editor代碼提示sql和java實現(xiàn)示例，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-08-08
這篇文章主要介紹了Java類的定義以及執(zhí)行順序?qū)W習教程,包括對象的創(chuàng)建等面向?qū)ο缶幊痰幕A知識,需要的朋友可以參考下2015-09-09