SpringBoot中怎么在運行時動態(tài)添加數(shù)據(jù)源,相信很多沒有經(jīng)驗的人對此束手無策,為此本文總結了問題出現(xiàn)的原因和解決方法,通過這篇文章希望你能解決這個問題。
一、多數(shù)據(jù)源應用場景:
1.配置文件配置多數(shù)據(jù)源,如默認數(shù)據(jù)源:master,數(shù)據(jù)源1:salve1...,運行時動態(tài)切換已配置的數(shù)據(jù)源(master、salve1互相切換),無法在運行時動態(tài)添加配置文件中未配置的數(shù)據(jù)源。
2.配置一個默認數(shù)據(jù)源,運行時動態(tài)添加新數(shù)據(jù)源使用(本博客適用于此場景)
二、解決方案:
Spring提供了AbstractRoutingDataSource用于動態(tài)路由數(shù)據(jù)源,第一種場景繼承AbstractRoutingDataSource類并覆寫其protected abstract Object determineCurrentLookupKey()即可;
而第二種場景我們直接覆寫protected DataSource determineTargetDataSource方法即可。原理可看下AbstractRoutingDataSource對應源碼,比較簡單,不做贅述。
直接上干貨:
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> 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;@Configurationpublic 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; }}
使用時直接調用DynamicDataSource.setDataSource(DataSource dataSource)方法即可,使用完后調用DynamicDataSource.clear()防止內存泄漏并重置默認數(shù)據(jù)源。
附上詳細使用方法:
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 ,調用自己的業(yè)務方法即可。 使用完后調用DynamicDataSource.clear();重置為默認數(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;@Componentpublic 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> T getBean(Class<T> 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); }}
看完上述內容,你們掌握SpringBoot中怎么在運行時動態(tài)添加數(shù)據(jù)源的方法了嗎?如果還想學到更多技能或想了解更多相關內容,歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝各位的閱讀!
本文題目:SpringBoot中怎么在運行時動態(tài)添加數(shù)據(jù)源-創(chuàng)新互聯(lián)
文章URL:http://www.chinadenli.net/article8/ceesop.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供標簽優(yōu)化、微信公眾號、搜索引擎優(yōu)化、定制網(wǎng)站、網(wǎng)站維護、軟件開發(fā)
聲明:本網(wǎng)站發(fā)布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經(jīng)允許不得轉載,或轉載時需注明來源: 創(chuàng)新互聯(lián)