這篇文章主要介紹了SpringBoot在運(yùn)行時動態(tài)添加數(shù)據(jù)源的方法，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

專業(yè)從事網(wǎng)站設(shè)計制作、成都網(wǎng)站設(shè)計,高端網(wǎng)站制作設(shè)計,小程序定制開發(fā),網(wǎng)站推廣的成都做網(wǎng)站的公司。優(yōu)秀技術(shù)團(tuán)隊竭力真誠服務(wù)，采用H5高端網(wǎng)站建設(shè)+CSS3前端渲染技術(shù)，響應(yīng)式網(wǎng)站，讓網(wǎng)站在手機(jī)、平板、PC、微信下都能呈現(xiàn)。建站過程建立專項小組，與您實時在線互動，隨時提供解決方案，暢聊想法和感受。

一、多數(shù)據(jù)源應(yīng)用場景：

1.配置文件配置多數(shù)據(jù)源，如默認(rèn)數(shù)據(jù)源：master，數(shù)據(jù)源1：salve1...，運(yùn)行時動態(tài)切換已配置的數(shù)據(jù)源（master、salve1互相切換）,無法在運(yùn)行時動態(tài)添加配置文件中未配置的數(shù)據(jù)源。

2.配置一個默認(rèn)數(shù)據(jù)源，運(yùn)行時動態(tài)添加新數(shù)據(jù)源使用（本博客適用于此場景）

二、解決方案：

Spring提供了AbstractRoutingDataSource用于動態(tài)路由數(shù)據(jù)源，第一種場景繼承AbstractRoutingDataSource類并覆寫其protected abstract Object determineCurrentLookupKey()即可;

而第二種場景我們直接覆寫protected DataSource determineTargetDataSource方法即可。原理可看下AbstractRoutingDataSource對應(yīng)源碼，比較簡單，不做贅述。

直接上干貨：

import com.fizz.utils.spring.SpringUtils;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
import javax.sql.DataSource;

public class DynamicDataSource extends AbstractRoutingDataSource {

  private static final ThreadLocal dataSource = ThreadLocal.withInitial(() -> (DataSource) SpringUtils.getBean("defaultDataSource"));

  public static void setDataSource(DataSource dataSource) {
    DynamicDataSource.dataSource.set(dataSource);
  }

  public static DataSource getDataSource() {
    return DynamicDataSource.dataSource.get();
  }

  @Override
  protected Object determineCurrentLookupKey() {
    return null;
  }

  @Override
  protected DataSource determineTargetDataSource() {
    return getDataSource();
  }

  public static void clear() {
    DynamicDataSource.dataSource.remove();
  }
}

import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import javax.sql.DataSource;
import java.util.HashMap;

@Configuration
public class DataSourceConfig {

  @Bean
  @ConfigurationProperties("spring.datasource.druid")
  public DataSource defaultDataSource() {
    return DruidDataSourceBuilder.create().build();
  }

  @Bean
  @Primary
  public DynamicDataSource dataSource() {
    DynamicDataSource dynamicDataSource = new DynamicDataSource();
    dynamicDataSource.setTargetDataSources(new HashMap<>());
    return dynamicDataSource;
  }
}

使用時直接調(diào)用DynamicDataSource.setDataSource(DataSource dataSource)方法即可，使用完后調(diào)用DynamicDataSource.clear()防止內(nèi)存泄漏并重置默認(rèn)數(shù)據(jù)源。

附上詳細(xì)使用方法：

DruidDataSource druidDataSource = new DruidDataSource();
    druidDataSource.setUrl("jdbc:MySQL://localhost:3306/sys?characterEncoding=utf-8&useSSL=false&serverTimezone=UTC&useAffectedRows=true");
    druidDataSource.setUsername("root");
    druidDataSource.setPassword("root");
    DynamicDataSource.setDataSource(druidDataSource);
    此時數(shù)據(jù)源已切換到druidDataSource ，調(diào)用自己的業(yè)務(wù)方法即可。
    使用完后調(diào)用DynamicDataSource.clear();重置為默認(rèn)數(shù)據(jù)源。

附上工具類SpringUtils ：

import lombok.Getter;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;

@Component
public final class SpringUtils implements ApplicationContextAware {

  @Getter
  private static ApplicationContext applicationContext;

  @Override
  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
    if (SpringUtils.applicationContext == null) {
      SpringUtils.applicationContext = applicationContext;
    }
  }

  public static  T getBean(Class clazz) {
    return SpringUtils.applicationContext.getBean(clazz);
  }

  public static Object getBean(String name) {
    return SpringUtils.applicationContext.getBean(name);
  }

  public static String getProperty(String key) {
    return SpringUtils.applicationContext.getEnvironment().getProperty(key);
  }
}

感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享的“SpringBoot在運(yùn)行時動態(tài)添加數(shù)據(jù)源的方法”這篇文章對大家有幫助，同時也希望大家多多支持創(chuàng)新互聯(lián)，關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，更多相關(guān)知識等著你來學(xué)習(xí)!