高档网站建,注册网站用什么邮箱,交换友情链接的好处,外贸推广哪家好0.前言
上一篇文章我们讲了如何通过多数据源组件#xff0c;在Spring boot Druid 连接池项目中配置多数据源#xff0c;并且通过DS注解的方式切换数据源#xff0c;《Spring Boot 配置多数据源【最简单的方式】》。但是在多租户的业务场景中#xff0c;我们通常需要手动的…0.前言
上一篇文章我们讲了如何通过多数据源组件在Spring boot Druid 连接池项目中配置多数据源并且通过DS注解的方式切换数据源《Spring Boot 配置多数据源【最简单的方式】》。但是在多租户的业务场景中我们通常需要手动的切换数据源那么本文将解答你的额疑惑。
1. 动态添加移除数据源
dynamic-datasource是一款基于Spring Boot 动态数据源框架在应用程序运行时可以动态添加、移除数据源的功能。
2.基础介绍
本文我们还是以dynamic-datasource来进阶学习。提供了一系列的API和配置项可以非常方便地实现动态添加、移除数据源的功能。本文将介绍如何使用dynamic-datasource动态添加、移除数据源并对相关代码进行解析。在多租户应用、读写分离等场景下动态数据源可以方便地实现数据源的动态切换提高应用程序的灵活性和扩展性。 主要在多租户场景中常常新的一个租户进来需要动态的添加一个数据源到库中使得系统不用重启即可切换数据源。
3. 使用步骤示例
本文我们还是以dynamic-datasource来进阶学习。提供了一系列的API和配置项可以非常方便地实现动态添加、移除数据源的功能。本文将介绍如何使用dynamic-datasource动态添加、移除数据源并对相关代码进行解析。在多租户应用、读写分离等场景下动态数据源可以方便地实现数据源的动态切换提高应用程序的灵活性和扩展性。 主要在多租户场景中常常新的一个租户进来需要动态的添加一个数据源到库中使得系统不用重启即可切换数据源。
import com.baomidou.dynamic.datasource.DynamicRoutingDataSource;
import com.baomidou.dynamic.datasource.creator.*;
import com.baomidou.dynamic.datasource.spring.boot.autoconfigure.DataSourceProperty;
import com.baomidou.samples.ds.dto.DataSourceDTO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;import javax.sql.DataSource;
import java.util.Set;RestController
RequestMapping(/datasources)
Api(tags 添加删除数据源)
public class DataSourceController {Autowiredprivate DataSource dataSource;// private final DataSourceCreator dataSourceCreator; //3.3.1及以下版本使用这个通用强烈推荐sb2用户至少升级到3.5.2版本Autowiredprivate DefaultDataSourceCreator dataSourceCreator;
//如果是用4.x以上版本因为要和spring解绑重构了一些东西比如缺少了懒启动和启动初始化数据库。不太建议用以下独立的创建器只建议用上面的DefaultDataSourceCreator Autowiredprivate BasicDataSourceCreator basicDataSourceCreator;Autowiredprivate JndiDataSourceCreator jndiDataSourceCreator;Autowiredprivate DruidDataSourceCreator druidDataSourceCreator;Autowiredprivate HikariDataSourceCreator hikariDataSourceCreator;Autowiredprivate BeeCpDataSourceCreator beeCpDataSourceCreator;Autowiredprivate Dbcp2DataSourceCreator dbcp2DataSourceCreator;GetMappingApiOperation(获取当前所有数据源)public SetString now() {DynamicRoutingDataSource ds (DynamicRoutingDataSource) dataSource;return ds.getDataSources().keySet();}//通用数据源会根据maven中配置的连接池根据顺序依次选择。//默认的顺序为druidhikaricpbeecpdbcpspring basicPostMapping(/add)ApiOperation(通用添加数据源推荐)public SetString add(Validated RequestBody DataSourceDTO dto) {DataSourceProperty dataSourceProperty new DataSourceProperty();BeanUtils.copyProperties(dto, dataSourceProperty);DynamicRoutingDataSource ds (DynamicRoutingDataSource) dataSource;DataSource dataSource dataSourceCreator.createDataSource(dataSourceProperty);ds.addDataSource(dto.getPoolName(), dataSource);return ds.getDataSources().keySet();}PostMapping(/addBasic(强烈不推荐除了用了马上移除))ApiOperation(value 添加基础数据源, notes 调用Springboot内置方法创建数据源兼容1,2)public SetString addBasic(Validated RequestBody DataSourceDTO dto) {DataSourceProperty dataSourceProperty new DataSourceProperty();BeanUtils.copyProperties(dto, dataSourceProperty);DynamicRoutingDataSource ds (DynamicRoutingDataSource) dataSource;DataSource dataSource basicDataSourceCreator.createDataSource(dataSourceProperty);ds.addDataSource(dto.getPoolName(), dataSource);return ds.getDataSources().keySet();}PostMapping(/addJndi)ApiOperation(添加JNDI数据源)public SetString addJndi(String pollName, String jndiName) {DynamicRoutingDataSource ds (DynamicRoutingDataSource) dataSource;DataSource dataSource jndiDataSourceCreator.createDataSource(jndiName);ds.addDataSource(poolName, dataSource);return ds.getDataSources().keySet();}PostMapping(/addDruid)ApiOperation(基础Druid数据源)public SetString addDruid(Validated RequestBody DataSourceDTO dto) {DataSourceProperty dataSourceProperty new DataSourceProperty();BeanUtils.copyProperties(dto, dataSourceProperty);dataSourceProperty.setLazy(true);DynamicRoutingDataSource ds (DynamicRoutingDataSource) dataSource;DataSource dataSource druidDataSourceCreator.createDataSource(dataSourceProperty);ds.addDataSource(dto.getPoolName(), dataSource);return ds.getDataSources().keySet();}PostMapping(/addHikariCP)ApiOperation(基础HikariCP数据源)public SetString addHikariCP(Validated RequestBody DataSourceDTO dto) {DataSourceProperty dataSourceProperty new DataSourceProperty();BeanUtils.copyProperties(dto, dataSourceProperty);dataSourceProperty.setLazy(true);//3.4.0版本以下如果有此属性需手动设置不然会空指针。DynamicRoutingDataSource ds (DynamicRoutingDataSource) dataSource;DataSource dataSource hikariDataSourceCreator.createDataSource(dataSourceProperty);ds.addDataSource(dto.getPoolName(), dataSource);return ds.getDataSources().keySet();}PostMapping(/addBeeCp)ApiOperation(基础BeeCp数据源)public SetString addBeeCp(Validated RequestBody DataSourceDTO dto) {DataSourceProperty dataSourceProperty new DataSourceProperty();BeanUtils.copyProperties(dto, dataSourceProperty);dataSourceProperty.setLazy(true);//3.4.0版本以下如果有此属性需手动设置不然会空指针。DynamicRoutingDataSource ds (DynamicRoutingDataSource) dataSource;DataSource dataSource beeCpDataSourceCreator.createDataSource(dataSourceProperty);ds.addDataSource(dto.getPoolName(), dataSource);return ds.getDataSources().keySet();}PostMapping(/addDbcp)ApiOperation(基础Dbcp数据源)public SetString addDbcp(Validated RequestBody DataSourceDTO dto) {DataSourceProperty dataSourceProperty new DataSourceProperty();BeanUtils.copyProperties(dto, dataSourceProperty);dataSourceProperty.setLazy(true);//3.4.0版本以下如果有此属性需手动设置不然会空指针。DynamicRoutingDataSource ds (DynamicRoutingDataSource) dataSource;DataSource dataSource dbcp2DataSourceCreator.createDataSource(dataSourceProperty);ds.addDataSource(dto.getPoolName(), dataSource);return ds.getDataSources().keySet();}DeleteMappingApiOperation(删除数据源)public String remove(String name) {DynamicRoutingDataSource ds (DynamicRoutingDataSource) dataSource;ds.removeDataSource(name);return 删除成功;}
}4. 示例项目
https://github.com/dynamic-datasource/dynamic-datasource-samples/tree/master/features-samples/add-remove-datasource-sample
5. 源码分析
public interface DataSourceCreator {/*** 通过属性创建数据源** param dataSourceProperty 数据源属性* return 被创建的数据源*/DataSource createDataSource(DataSourceProperty dataSourceProperty);/*** 当前创建器是否支持根据此属性创建** param dataSourceProperty 数据源属性* return 是否支持*/boolean support(DataSourceProperty dataSourceProperty);
}DataSourceCreator是一个接口定义了根据参数创建数据源的接口。 其他creator实现此接口本项目暂时实现了Druid和Hikaricp的等连接池的实现。 BasicDataSourceCreator 是调用Spring原生的创建方式只支持最最原始的基础配置。 DefaultDataSourceCreator 是一个通用的创建器其根据环境自动选择连接池
