欧美一级特黄大片做受成人-亚洲成人一区二区电影-激情熟女一区二区三区-日韩专区欧美专区国产专区

如何實現(xiàn)SpringBootMybatis動態(tài)數(shù)據(jù)源切換方案

這篇文章主要講解了如何實現(xiàn)SpringBoot Mybatis動態(tài)數(shù)據(jù)源切換方案，內(nèi)容清晰明了，對此有興趣的小伙伴可以學習一下，相信大家閱讀完之后會有幫助。

創(chuàng)新互聯(lián)建站服務項目包括壽縣網(wǎng)站建設(shè)、壽縣網(wǎng)站制作、壽縣網(wǎng)頁制作以及壽縣網(wǎng)絡營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，壽縣網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟效益。目前，我們服務的客戶以成都為中心已經(jīng)輻射到壽縣省份的部分城市，未來相信會繼續(xù)擴大服務區(qū)域并繼續(xù)獲得客戶的支持與信任！

背景

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

實現(xiàn)方案

數(shù)據(jù)庫配置文件

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

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

定義數(shù)據(jù)源實體類

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

我們這里要建立三個實體類。分別對應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;
 }
}

定義一個枚舉類管理數(shù)據(jù)源

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

定義一個線程安全的數(shù)據(jù)源容器

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)數(shù)據(jù)源

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

mybatis配置類

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

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

 /**
  * @Description:設(shè)置動態(tài)數(shù)據(jù)源
  */
 @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:根據(jù)動態(tài)數(shù)據(jù)源創(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();
  //構(gòu)造方法，解決動態(tài)數(shù)據(jù)源循環(huán)依賴問題。
  sessionFactoryBean.setDataSource(this.DataSource(test1DataSource,test2DataSource, test3DataSource));
  return sessionFactoryBean.getObject();
 }
}

示例

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

 }

看完上述內(nèi)容，是不是對如何實現(xiàn)SpringBoot Mybatis動態(tài)數(shù)據(jù)源切換方案有進一步的了解，如果還想學習更多內(nèi)容，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

網(wǎng)站欄目：如何實現(xiàn)SpringBootMybatis動態(tài)數(shù)據(jù)源切換方案
瀏覽路徑：http://aaarwkj.com/article28/gihecp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供自適應網(wǎng)站、建站公司、網(wǎng)站制作、定制網(wǎng)站、App開發(fā)、做網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)

外貿(mào)網(wǎng)站制作
中文字幕五月久久婷热| 中国女人内射91熟女| 日韩精品人妻中文字幕满员| 99久久久精品国产免费| 国产精品xxxx国产精品| 日韩欧美高清一区二区| 91精品国产自产永久在线| 在线成人影院中文字幕| 国产女主播福利在线播放| 国产欧美成人精品第一区| 四虎国产最新在线免费| 欧美激情在线精品一区二区| 欧美熟妇精品一级视频| 国产成人一区二区二区三区| 日韩精品二区在线观看| 中文字幕亚洲无级av| 欧美国产日韩一区二区三区视频| 久久青草精品欧美日韩精品| 亚洲国产成人av精品精品国产自| 久久97精品人人做人人爽| 日韩一级不卡高清视频| 欧美日韩亚洲精品内裤| 森泽佳奈在线视频观看| 久久久久久这里都是精品| 亚洲成人影院中文字幕| 国产精品深夜在线观看| 久久 久久国内精品亚洲| 中文字幕人妻丝乱一区三区| 亚洲精品不卡一区二区| 九九热精品只有这里有| 日韩少妇黄色在线观看| 高h视频在线播放观看| 日本高清精品视频在线| 久久东京热日韩精品一区| 日韩亚洲欧美精品另类| 日韩三级一区二区三区| 四虎精品视频在线免费| 在线观看午夜视频免费| 给我免费在线观看视频| 精品国产91乱码一区二区三区| 欧美日韩国产激情在线观看|