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

SpringBoot Mybatis動態(tài)數據源切換方案實現(xiàn)過程

 更新時間：2020年04月17日 10:01:21   作者：經典雞翅  
這篇文章主要介紹了SpringBoot+Mybatis實現(xiàn)動態(tài)數據源切換方案過程,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

背景

最近讓我做一個大數據的系統(tǒng)，分析了一下，麻煩的地方就是多數據源切換抽取數據?？紤]到可以跨服務器跨數據庫抽數，再整理數據，就配置了這個動態(tài)數據源的解決方案。在此分享給大家。

實現(xiàn)方案

數據庫配置文件

我們項目使用的是yml形式的配置文件，采用的是hikari的數據庫連接池。第一步我們自然是配置多個數據庫源頭。
我們找到spring的datasource，在下方配置三個數據源。

spring:
 application:
 name: dynamicDatasource
 datasource:
 test1:
  driver-class-name: com.mysql.jdbc.Driver
  url: jdbc:mysql://127.0.0.1:3306/test1?serverTimezone=GMT%2B8&characterEncoding=utf-8&useSSL=false
  username: root
  password: 123456
 test2:
  driver-class-name: com.mysql.jdbc.Driver
  url: jdbc:mysql://127.0.0.1:3306/test2?serverTimezone=GMT%2B8&characterEncoding=utf-8&useSSL=false
  username: root
  password: 123456
 test3:
  driver-class-name: com.mysql.jdbc.Driver
  url: jdbc:mysql://127.0.0.1:3306/test3?serverTimezone=GMT%2B8&characterEncoding=utf-8&useSSL=false
  username: root
  password: 123456
 hikari:
  leak-detection-threshold: 2000

定義數據源實體類

我們可以建立個datasourceBean文件夾專門管理數據源的實體類。

我們這里要建立三個實體類。分別對應test1，test2，test3

@Configuration
public class Test1DataSourceBean {

 @Value("${spring.datasource.test1.driver-class-name}")
 private String test1Driver;

 @Value("${spring.datasource.test1.url}")
 private String test1Url;

 @Value("${spring.datasource.test1.username}")
 private String test1Username;

 @Value("${spring.datasource.test1.password}")
 private String test1Password;

 @Bean(name="test1DataSource")
 public DataSource test1DataSource() throws Exception{
  HikariDataSource dataSource = new HikariDataSource();
  dataSource.setDriverClassName(test1Driver);
  dataSource.setJdbcUrl(test1Url);
  dataSource.setUsername(test1Username);
  dataSource.setPassword(test1Password);
  return dataSource;
 }
}

@Configuration
public class Test2DataSourceBean {

 @Value("${spring.datasource.test2.driver-class-name}")
 private String test2Driver;

 @Value("${spring.datasource.test2.url}")
 private String test2Url;

 @Value("${spring.datasource.test2.username}")
 private String test2Username;

 @Value("${spring.datasource.test2.password}")
 private String test2Password;

 @Bean(name="test2DataSource")
 public DataSource test2DataSource() throws Exception{
  HikariDataSource dataSource = new HikariDataSource();
  dataSource.setDriverClassName(test2Driver);
  dataSource.setJdbcUrl(test2Url);
  dataSource.setUsername(test2Username);
  dataSource.setPassword(test2Password);
  return dataSource;
 }
}

@Configuration
public class Test3DataSourceBean {

 @Value("${spring.datasource.test3.driver-class-name}")
 private String test3Driver;

 @Value("${spring.datasource.test3.url}")
 private String test3Url;

 @Value("${spring.datasource.test3.username}")
 private String test3Username;

 @Value("${spring.datasource.test3.password}")
 private String test3Password;

 @Bean(name="test3DataSource")
 public DataSource test3DataSource() throws Exception{
  HikariDataSource dataSource = new HikariDataSource();
  dataSource.setDriverClassName(test3Driver);
  dataSource.setJdbcUrl(test3Url);
  dataSource.setUsername(test3Username);
  dataSource.setPassword(test3Password);
  return dataSource;
 }
}

定義一個枚舉類管理數據源

public enum DatabaseType {

 test1("test1", "test1"),
 test2("test2", "test2"),
 test3("test3","test3");

 private String name;
 private String value;

 DatabaseType(String name, String value){
  this.name = name;
  this.value = value;
 }

 public String getName(){
  return name;
 }

 public String getValue(){
  return value;
 }
}

定義一個線程安全的數據源容器

public class DatabaseContextHolder {
 private static final ThreadLocal<DatabaseType> contextHolder = new ThreadLocal<>();
 public static void setDatabaseType(DatabaseType type){
  contextHolder.set(type);
 }
 public static DatabaseType getDatabaseType(){
  return contextHolder.get();
 }
}

定義動態(tài)數據源

public class DynamicDataSource extends AbstractRoutingDataSource{
 protected Object determineCurrentLookupKey() {
  return DatabaseContextHolder.getDatabaseType();
 }
}

mybatis配置類

網上的很多文章配置出來都會產生數據源循環(huán)依賴的問題，這里解決了這個問題。

@Configuration
@MapperScan(basePackages="cn.test.jichi", sqlSessionFactoryRef="sessionFactory")
public class MybatisConfig {

 /**
  * @Description:設置動態(tài)數據源
  */
 @Bean(name="dynamicDataSource")
 @Primary
 public DynamicDataSource DataSource(
   @Qualifier("test1DataSource") DataSource test1DataSource,
   @Qualifier("test2DataSource") DataSource test2DataSource,
   @Qualifier("test3DataSource") DataSource test3DataSource){
  Map<Object, Object> targetDataSource = new HashMap<>();
  targetDataSource.put(DatabaseType.test1, test1DataSource);
  targetDataSource.put(DatabaseType.test2, test2DataSource);
  targetDataSource.put(DatabaseType.test3, test3DataSource);
  DynamicDataSource dataSource = new DynamicDataSource();
  dataSource.setTargetDataSources(targetDataSource);
  dataSource.setDefaultTargetDataSource(test1DataSource);
  return dataSource;
 }

 /**
  * @Description:根據動態(tài)數據源創(chuàng)建sessionFactory
  */
 @Bean(name="sessionFactory")
 public SqlSessionFactory sessionFactory(
   @Qualifier("test1DataSource") DataSource test1DataSource,
   @Qualifier("test2DataSource") DataSource test2DataSource,
   @Qualifier("test3DataSource") DataSource test3DataSource) throws Exception{
  SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
  //構造方法，解決動態(tài)數據源循環(huán)依賴問題。
  sessionFactoryBean.setDataSource(this.DataSource(test1DataSource,test2DataSource, test3DataSource));
  return sessionFactoryBean.getObject();
 }
}

示例

 public void testDymnaicDatasource(){
  //不切換數據源默認是自己的。
  System.out.println("-----默認數據源");
  DemoEntity totalCount = demoMapper.getTotalCount();
  String nameCount1 = totalCount.getNameCount();
  String ageCount2 = totalCount.getAgeCount();
  System.out.println("nameCount:"+nameCount1);
  System.out.println("ageCount:"+ageCount2);
  //數據源切換為branch
  System.out.println("-----數據源為test2");
  DynamicDataSourceUtils.chooseBranchDataSource();
  Integer nameCount = demoMapper.getNameCount();
  Integer ageCount = demoMapper.getAgeCount();
  System.out.println("nameCount:"+nameCount);
  System.out.println("ageCount:"+ageCount);
  //數據源為basic
  System.out.println("-----數據源為test3");
  DynamicDataSourceUtils.chooseBasicDataSource();
  Integer ageCount1 = demoMapper.getAgeCount();
  System.out.println("ageCount:"+ageCount1);

 }

總結

至此實現(xiàn)了多數據源的動態(tài)切換?？梢栽谕粋€方法里面進行操作多個數據源。

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

相關文章

  • Java并發(fā)編程 interrupt()方法示例詳解

    Java并發(fā)編程 interrupt()方法示例詳解

    interrrupt()方法可以用來打斷正在運行的線程，也可以打斷sleep()、wait()、join()情況下的線程，但是這些情況下被打斷線程的打斷標記不同，這篇文章主要介紹了Java并發(fā)編程 interrupt()方法示例詳解,需要的朋友可以參考下
    2023-06-06
  • java獲取文件擴展名的方法小結【正則與字符串截取】

    java獲取文件擴展名的方法小結【正則與字符串截取】

    這篇文章主要介紹了java獲取文件擴展名的方法,結合實例形式分析了使用正則與字符串截取兩種獲取擴展名的操作技巧,需要的朋友可以參考下
    2017-01-01
  • java正則替換sql中的參數實例代碼

    java正則替換sql中的參數實例代碼

    這篇文章主要給大家介紹了關于java正則替換sql中參數的相關資料,文中通過實例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2022-10-10
  • Java利用EasyExcel解析動態(tài)表頭及導出實現(xiàn)過程

    Java利用EasyExcel解析動態(tài)表頭及導出實現(xiàn)過程

    以前做導出功能,表頭和數據都是固定的,下面這篇文章主要給大家介紹了關于Java利用EasyExcel解析動態(tài)表頭及導出實現(xiàn)的相關資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下
    2022-12-12
  • 使用SpringBoot自定義starter詳解

    使用SpringBoot自定義starter詳解

    這篇文章主要介紹了使用Spring Boot自定義starter詳解,文中有非常詳細的代碼示例,對正在學習java的小伙伴們有很好地幫助喲,需要的朋友可以參考下
    2021-05-05
  • 基于IOC容器實現(xiàn)管理mybatis過程解析

    基于IOC容器實現(xiàn)管理mybatis過程解析

    這篇文章主要介紹了基于IOC容器實現(xiàn)管理mybatis過程解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-07-07
  • mybatis plus動態(tài)數據源切換及查詢過程淺析

    mybatis plus動態(tài)數據源切換及查詢過程淺析

    這篇文章主要介紹了mybatis plus動態(tài)數據源切換及查詢過程淺析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
    2020-12-12
  • maven插件maven-assembly-plugin打包歸納文件zip/tar使用

    maven插件maven-assembly-plugin打包歸納文件zip/tar使用

    java項目運行的文件需要jar或者war格式,同時還需要使用Java命令,本文主要介紹了maven插件maven-assembly-plugin打包歸納文件zip/tar使用,具有一定的參考價值,感興趣的可以了解一下
    2024-02-02
  • Guava事件總線應用場景最佳實踐

    Guava事件總線應用場景最佳實踐

    這篇文章主要為大家介紹了Guava事件總線應用場景最佳實踐,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-12-12
  • 使用SpringBoot 工廠模式自動注入到Map

    使用SpringBoot 工廠模式自動注入到Map

    這篇文章主要介紹了使用SpringBoot 工廠模式自動注入到Map，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2021-09-09

最新評論