springboot2+mybatis多種方式實現(xiàn)多數(shù)據(jù)配置方法
更新時間：2020年03月30日 14:21:34 作者：落孤秋葉
這篇文章主要介紹了springboot2+mybatis多種方式實現(xiàn)多數(shù)據(jù)配置方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
業(yè)務系統(tǒng)復雜程度增加，為了解決數(shù)據(jù)庫I/O瓶頸，很自然會進行拆庫拆表分服務來應對。這就會出現(xiàn)一個系統(tǒng)中可能會訪問多處數(shù)據(jù)庫，需要配置多個數(shù)據(jù)源。
第一種場景：項目服務從其它多處數(shù)據(jù)庫取基礎數(shù)據(jù)進行業(yè)務處理，因此各庫之間不會出現(xiàn)重表等情況。
第二種場景：為了減輕寫入壓力進行讀寫分庫，讀走從庫，寫為主庫。此種表名等信息皆為一致。
第三種場景：以上兩種皆有。對于某些業(yè)務需要大數(shù)據(jù)量的匯總統(tǒng)計，希望不影響正常業(yè)務必須走從庫（表信息一致），某些配置信息不存在讀寫壓力，出現(xiàn)不分庫（表信息不一致）
項目源代碼：
https://github.com/zzsong/springboot-multiple-datasource.git
有三個目錄：
one:
直接使用多@Bean配置，@MapperScan來路徑區(qū)分讀何庫
two:
使用注解的方式來標識走何dataSource,AOP攔截注入動態(tài)數(shù)據(jù)源
third:
使用spring的Bean命名策略進行區(qū)分數(shù)據(jù)來源
項目技術選型： springBoot2.2.5 + mybatis + druid + mysql
先看主要的pom包
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.2.5.RELEASE</version>
<relativePath/>
</parent>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-aop</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.1.2</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.19</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.21</version>
</dependency>
application.yml
spring:
datasource:
druid:
core:
url: jdbc:mysql:///kc_core?characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: root
password: 123456
driver-class-name: com.mysql.cj.jdbc.Driver
type: com.alibaba.druid.pool.DruidDataSource
schedule:
url: jdbc:mysql:///kc_schedule?characterEncoding=utf-8&serverTimezone=Asia/Shanghai
username: root
password: 123456
driver-class-name: com.mysql.cj.jdbc.Driver
type: com.alibaba.druid.pool.DruidDataSource
mysql新版本必須帶有serverTimezone，不然會報連接異常。
第一種：通過@MapperScans 掃描匹配相關的數(shù)據(jù)源
@Configuration
@MapperScans({
@MapperScan(basePackages = "com.zss.one.mapper.core", sqlSessionTemplateRef = "coreSqlSessionTemplate",sqlSessionFactoryRef = "coreSqlSessionFactory"),
@MapperScan(basePackages = "com.zss.one.mapper.schedule", sqlSessionTemplateRef = "scheduleSqlSessionTemplate",sqlSessionFactoryRef = "scheduleSqlSessionFactory")
})
public class MybatisOneConfig {
@Bean
@ConfigurationProperties(prefix = "spring.datasource.druid.core")
public DataSource coreDataSource(){
return DruidDataSourceBuilder.create().build();
}
@Bean
public SqlSessionFactory coreSqlSessionFactory(@Qualifier("coreDataSource") DataSource coreDataSource) throws Exception {
SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
sessionFactory.setDataSource(coreDataSource);
sessionFactory.getObject().getConfiguration().setJdbcTypeForNull(null);
sessionFactory.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);
return sessionFactory.getObject();
}
@Bean
public SqlSessionTemplate coreSqlSessionTemplate(@Qualifier("coreSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
//======schedule========
@Bean
@ConfigurationProperties(prefix = "spring.datasource.druid.schedule")
public DataSource scheduleDataSource(){
return DruidDataSourceBuilder.create().build();
}
@Bean
public SqlSessionFactory scheduleSqlSessionFactory(@Qualifier("scheduleDataSource") DataSource coreDataSource) throws Exception {
SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
sessionFactory.setDataSource(coreDataSource);
sessionFactory.getObject().getConfiguration().setJdbcTypeForNull(null);
sessionFactory.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);
return sessionFactory.getObject();
}
@Bean
public SqlSessionTemplate scheduleSqlSessionTemplate(@Qualifier("scheduleSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
}
第二種是動態(tài)數(shù)據(jù)源模式，通過AOP切入注解引導使用何數(shù)據(jù)源。用自定義注解@interface來標識方法走對應的數(shù)據(jù)源。
注意事項：類中的方法再調(diào)用帶數(shù)據(jù)源的方法，不能被AOP切入
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface TargetDataSource {
String value();
}
extends spring的動態(tài)DataSource路由來匹配
public class DynamicDataSource extends AbstractRoutingDataSource {
@Override
protected Object determineCurrentLookupKey() {
return DataSourceContextRouting.getDataSourceName();
}
}
@Configuration
//@EnableConfigurationProperties(MybatisProperties.class)//不要使用此公共配置，Configuration會破壞相關dataSource的配置
@MapperScan("com.zss.two.mapper")
public class MybatisConfig {
@Bean
@ConfigurationProperties(prefix = "spring.datasource.druid.core")
public DataSource coreDataSource() {
return DruidDataSourceBuilder.create().build();
}
@Bean
@ConfigurationProperties(prefix = "spring.datasource.druid.schedule")
public DataSource scheduleDataSource() {
return DruidDataSourceBuilder.create().build();
}
@Autowired
@Qualifier("coreDataSource")
private DataSource coreDataSource;
@Autowired
@Qualifier("scheduleDataSource")
private DataSource scheduleDataSource;
@Bean
public DynamicDataSource dataSource() {
Map<Object, Object> targetDataSources = new HashMap<>();
targetDataSources.put(DataSourceConstants.CORE_DATA_SOURCE, coreDataSource);
targetDataSources.put(DataSourceConstants.SCHEDULE_DATA_SOURCE, scheduleDataSource);
DynamicDataSource dataSource = new DynamicDataSource();
//設置數(shù)據(jù)源映射
dataSource.setTargetDataSources(targetDataSources);
//// 設置默認數(shù)據(jù)源，當無法映射到數(shù)據(jù)源時會使用默認數(shù)據(jù)源
dataSource.setDefaultTargetDataSource(coreDataSource);
dataSource.afterPropertiesSet();
return dataSource;
}
/**
* 根據(jù)數(shù)據(jù)源創(chuàng)建SqlSessionFactory
*/
@Bean
public SqlSessionFactory sqlSessionFactory(DynamicDataSource dataSource) throws Exception {
SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
sessionFactory.setDataSource(dataSource);
sessionFactory.getObject().getConfiguration().setJdbcTypeForNull(null);
sessionFactory.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);
return sessionFactory.getObject();
}
@Bean
public SqlSessionTemplate sqlSessionTemplate(SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
第三種，自定義Bean命名策略，按beanName進行自動匹配使用數(shù)據(jù)源
@Component
public class CoreBeanNameGenerator implements BeanNameGenerator {
@Override
public String generateBeanName(BeanDefinition definition, BeanDefinitionRegistry registry) {
return "core"+ ClassUtils.getShortName(definition.getBeanClassName());
}
}
@Component
public class ScheduleBeanNameGenerator implements BeanNameGenerator {
@Override
public String generateBeanName(BeanDefinition definition, BeanDefinitionRegistry registry) {
return "schedule"+ ClassUtils.getShortName(definition.getBeanClassName());
}
}
使用mybatis MapperScannerConfigurer自動掃描，將Mapper接口生成注入到spring
@Bean
public MapperScannerConfigurer coreMapperScannerConfig(CoreBeanNameGenerator coreBeanNameGenerator){
MapperScannerConfigurer configurer = new MapperScannerConfigurer();
configurer.setNameGenerator(coreBeanNameGenerator);
configurer.setBasePackage("com.zss.third.mapper.core,com.zss.third.mapper.order");
configurer.setSqlSessionFactoryBeanName("coreSqlSessionFactory");
configurer.setSqlSessionTemplateBeanName("coreSqlSessionTemplate");
return configurer;
}
@Bean
public MapperScannerConfigurer scheduleMapperScannerConfig(ScheduleBeanNameGenerator scheduleBeanNameGenerator){
MapperScannerConfigurer configurer = new MapperScannerConfigurer();
configurer.setNameGenerator(scheduleBeanNameGenerator);
configurer.setBasePackage("com.zss.third.mapper.schedule,com.zss.third.mapper.order");
configurer.setSqlSessionFactoryBeanName("scheduleSqlSessionFactory");
configurer.setSqlSessionTemplateBeanName("scheduleSqlSessionTemplate");
return configurer;
}
到此，三種多數(shù)據(jù)源匹配主要點介紹完，詳細直接下載github項目。 在resources/db含有相關測試表及數(shù)據(jù)腳本。
到此這篇關于springboot2+mybatis多種方式實現(xiàn)多數(shù)據(jù)配置方法的文章就介紹到這了,更多相關springboot2+mybatis 多數(shù)據(jù)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:
- 通過Spring Boot整合Mybatis分析自動配置詳解
- 通過springboot+mybatis+druid配置動態(tài)數(shù)據(jù)源
- SpringBoot整合MyBatisPlus配置動態(tài)數(shù)據(jù)源的方法
- Spring Boot集成MyBatis實現(xiàn)通用Mapper的配置及使用
- spring boot配置MySQL數(shù)據(jù)庫連接、Hikari連接池和Mybatis的簡單配置方法
- 詳解Spring Boot整合Mybatis實現(xiàn) Druid多數(shù)據(jù)源配置
- Spring Boot MyBatis 連接數(shù)據(jù)庫配置示例
- SpringBoot Mybatis如何配置多數(shù)據(jù)源并分包
相關文章
java加載properties文件的六種方法總結(jié)
這篇文章主要介紹了java加載properties文件的六種方法總結(jié)的相關資料,需要的朋友可以參考下2017-05-05
在使用TimeUtil時,可能因為IDE版本不兼容導致問題,升級IDEA到2023.2以上版本可解決此問題,詳細步驟可以通過評論區(qū)索取安裝包或直接從官網(wǎng)下載,分享個人經(jīng)驗,希望對大家有幫助2024-10-10
這篇文章主要介紹了SpringBoot集成vue的開發(fā)解決方案，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-12-12
Spring實現(xiàn)動態(tài)切換多數(shù)據(jù)源的解決方案
這篇文章主要給大家介紹了Spring實現(xiàn)動態(tài)切換多數(shù)據(jù)源的解決方案,文中給出了詳細的介紹和示例代碼，相信對大家的理解和學習具有一定的參考借鑒價值，有需要的朋友可以參考學習，下面來一起看看吧。2017-01-01
在新增數(shù)據(jù)時，往往需要自動生成編號，本文主要介紹了Java自動生成編號的方法步驟，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-02-02
本文主要介紹了Maven Repository倉庫的具體使用，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-05-05
在現(xiàn)代應用中,定時任務是一個非常常見的需求,本文將通過7種方式講解如何在SpringBoot中實現(xiàn)定時任務,包括使用@Scheduled注解、ScheduledExecutorService、Quartz、SpringTaskScheduler、Redis、XXL-JOB和Elastic-Job等,各有優(yōu)缺點,選擇時應根據(jù)實際需求進行考慮2024-12-12
Java ThreadLocal原理解析以及應用場景分析案例詳解
這篇文章主要介紹了Java ThreadLocal原理解析以及應用場景分析案例詳解,本篇文章通過簡要的案例,講解了該項技術的了解與使用,以下就是詳細內(nèi)容,需要的朋友可以參考下2021-09-09
使用Springboot封裝一個自適配的數(shù)據(jù)單位轉(zhuǎn)換工具類
我們在接收前臺傳輸?shù)臄?shù)據(jù)時,往往SpringBoot使用內(nèi)置的數(shù)據(jù)類型轉(zhuǎn)換器把我們提交的數(shù)據(jù)自動封裝成對象等類型,下面這篇文章主要給大家介紹了關于使用Springboot封裝一個自適配的數(shù)據(jù)單位轉(zhuǎn)換工具類的相關資料,需要的朋友可以參考下2023-03-03
Java隊列篇之實現(xiàn)數(shù)組模擬隊列及可復用環(huán)形隊列詳解
像棧一樣，隊列（queue）也是一種線性表，它的特性是先進先出，插入在一端，刪除在另一端。就像排隊一樣，剛來的人入隊（push）要排在隊尾(rear)，每次出隊(pop)的都是隊首(front)的人2021-10-10