SpringBoot运行时动态添加数据源

  • 2019 年 10 月 13 日
  • 筆記

此方案适用于解决springboot项目运行时动态添加数据源,非静态切换多数据源!!!

一、多数据源应用场景:

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

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

二、解决方案:

Spring提供了AbstractRoutingDataSource用于动态路由数据源,第一种场景继承AbstractRoutingDataSource类并覆写其protected abstract Object determineCurrentLookupKey()即可;
而第二种场景我们直接覆写protected DataSource determineTargetDataSource方法即可。原理可看下AbstractRoutingDataSource对应源码,比较简单,不做赘述。
直接上干货:

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();      }  }    @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;      }  }

使用时直接调用DynamicDataSource.setDataSource(DataSource dataSource)方法即可,使用完后调用DynamicDataSource.clear()防止内存泄漏并重置默认数据源。