SpringBoot中怎么在运行时动态添加数据源

SpringBoot中怎么在运行时动态添加数据源,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。

十余年的双辽网站建设经验,针对设计、前端、开发、售后、文案、推广等六对一服务,响应快,48小时及时工作处理。营销型网站建设的优势是能够根据用户设备显示端的尺寸不同,自动调整双辽建站的显示方式,使网站能够适用不同显示终端,在浏览器中调整网站的宽度,无论在任何一种浏览器上浏览网站,都能展现优雅布局与设计,从而大程度地提升浏览体验。创新互联建站从事“双辽网站设计”,“双辽网站推广”以来,每个客户项目都认真落实执行。

一、多数据源应用场景:

1.配置文件配置多数据源,如默认数据源:master,数据源1:salve1...,运行时动态切换已配置的数据源(master、salve1互相切换),无法在运行时动态添加配置文件中未配置的数据源。

2.配置一个默认数据源,运行时动态添加新数据源使用(本博客适用于此场景)

二、解决方案:

Spring提供了AbstractRoutingDataSource用于动态路由数据源,第一种场景继承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 = 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()防止内存泄漏并重置默认数据源。

附上详细使用方法:

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);    此时数据源已切换到druidDataSource ,调用自己的业务方法即可。    使用完后调用DynamicDataSource.clear();重置为默认数据源。

附上工具类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 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);  }}

看完上述内容,你们掌握SpringBoot中怎么在运行时动态添加数据源的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注创新互联行业资讯频道,感谢各位的阅读!


当前标题:SpringBoot中怎么在运行时动态添加数据源
浏览地址:http://csdahua.cn/article/jpsgji.html
扫二维码与项目经理沟通

我们在微信上24小时期待你的声音

解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流