spring-boot多数据源动态切换
时间:2020-01-09
本文章向大家介绍spring-boot多数据源动态切换,主要包括spring-boot多数据源动态切换使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
当项目中存在多数据源时,就涉及到数据源的动态切换,通过研究,特此记录一下。
1、maven依赖
<!--数据库连接--> <dependency> <groupId>com.oracle</groupId> <artifactId>ojdbc6</artifactId> <version>11.2.0.4</version> <scope>runtime</scope> </dependency> <!--数据库连接池-> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>1.1.10</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jdbc</artifactId> </dependency> <!--aop-> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-aop</artifactId> </dependency>
2、多数据源信息配置
#多数据源测试 spring: datasource: druid: master: driver-class-name: oracle.jdbc.driver.OracleDriver username: test password: test url: jdbc:oracle:thin:@//ip1:1521/orcl slave: driver-class-name: oracle.jdbc.driver.OracleDriver username: test password: test url: jdbc:oracle:thin:@//ip2:1521/orcl
3、数据源配置信息转换成实体类
@ConfigurationProperties(prefix = "spring.datasource.druid") @Data @Component public class DataSourceProperties { private Map<String,String>master; private Map<String,String>slave; }
4、动态数据源切换类
public class DynamicDataSource extends AbstractRoutingDataSource { private static final ThreadLocal<String> contextHolder = new ThreadLocal<>(); public DynamicDataSource(DataSource defaultTargetDataSource, Map<Object, Object> targetDataSources) { super.setDefaultTargetDataSource(defaultTargetDataSource); super.setTargetDataSources(targetDataSources); super.afterPropertiesSet(); } @Override protected Object determineCurrentLookupKey() { return getDataSource(); } public static void setDataSource(String dataSource) { contextHolder.set(dataSource); } public static String getDataSource() { return contextHolder.get(); } public static void clearDataSource() { contextHolder.remove(); } }
5、多数据源配置类
@Configuration public class DynamicDataSourceConfig { @Bean public DataSource master(@Autowired DataSourceProperties dataSourceProperties){ DruidDataSource druidDataSource = new DruidDataSource(); Map<String, String> master = dataSourceProperties.getMaster(); druidDataSource.setUsername(master.get("username")); druidDataSource.setPassword(master.get("password")); druidDataSource.setUrl(master.get("url")); //其他参数配置 省略 return druidDataSource; } @Bean public DataSource slave(@Autowired DataSourceProperties dataSourceProperties){ DruidDataSource druidDataSource = new DruidDataSource(); Map<String, String> slave = dataSourceProperties.getSlave(); druidDataSource.setUsername(slave.get("username")); druidDataSource.setPassword(slave.get("password")); druidDataSource.setUrl(slave.get("url")); //其他参数配置 省略 return druidDataSource; } @Bean @Primary public DynamicDataSource dataSource(DataSource master,DataSource slave){ Map<Object,Object>map = new HashMap<>(4); map.put("master",master); map.put("slave",slave); return new DynamicDataSource(master,map); } }
6、自定义@DataSource注解
@Target(ElementType.METHOD) @Retention(RetentionPolicy.RUNTIME) public @interface DataSource { String name() default "master"; }
7、Aop切面类配置
@Component @Aspect public class DataSourceAspect { @Pointcut("@annotation(com.zxgeo.sso.muiltDatasource.anons.DataSource)") public void dataSourcePointCut(){} @Around(value = "dataSourcePointCut()") public Object around(ProceedingJoinPoint point) throws Throwable { MethodSignature signature = (MethodSignature) point.getSignature(); Method method = signature.getMethod(); DataSource dataSource = method.getAnnotation(DataSource.class); if(dataSource == null){ DynamicDataSource.setDataSource("master"); }else { DynamicDataSource.setDataSource(dataSource.name()); } try { return point.proceed(); } finally { DynamicDataSource.clearDataSource(); } } }
8、启动配置注解信息,重要(不然运行会报错)
@SpringBootApplication(exclude= {DataSourceAutoConfiguration.class})
9、测试
(1)、service层(此处没有使用mybatis)
@Service public class TestService { @Autowired private javax.sql.DataSource dataSource; @DataSource public Map<String,Object> getMasterDataSource() throws SQLException { Connection connection = dataSource.getConnection(); Map<String,Object> map; try (PreparedStatement preparedStatement = connection.prepareStatement("SELECT * FROM AA WHERE A=10001")) { ResultSet resultSet = preparedStatement.executeQuery(); map = new HashMap<>(); while (resultSet.next()){ map.put("A",resultSet.getString("A")); map.put("B",resultSet.getString("B")); map.put("C",resultSet.getString("C")); } } return map; } @DataSource(name = "slave") public Map<String,Object> getSlaveDataSource() throws SQLException { Connection connection = dataSource.getConnection(); Map<String,Object> map; try (PreparedStatement preparedStatement = connection.prepareStatement("SELECT * FROM AA WHERE A=10002")) { ResultSet resultSet = preparedStatement.executeQuery(); map = new HashMap<>(); while (resultSet.next()){ map.put("A",resultSet.getString("A")); map.put("B",resultSet.getString("B")); map.put("C",resultSet.getString("C")); } } return map; } }
(2)、单元测试
@SpringBootTest @RunWith(SpringRunner.class) class SsoApplicationTests { @Autowired private TestService testService; @Test public void muliDatasorce() throws SQLException { Map<String, Object> masterDataSourceUrl = testService.getMasterDataSource(); System.out.println(masterDataSourceUrl); Map<String, Object> slaveDataSourceUrl = testService.getSlaveDataSource(); System.out.println(slaveDataSourceUrl); } }
(3)、结果:
原文地址:https://www.cnblogs.com/cq-yangzhou/p/12172584.html
- Nginx的各种报错总结
- 谷歌TensorFlowLite正式发布,机器学习框架向移动端大步挺进!
- ABP+AdminLTE+Bootstrap Table权限管理系统一期
- 18888元秒下的域名sdhlx.com已建站
- 锂离子电池发明人:自动驾驶汽车电池需要更加耐用
- Linux中MySQL5.6编译安装与MySQL5.7二进制安装步骤
- Nginx服务编译安装、日志功能、状态模块及访问认证模式实操
- 快速入门系列--WebAPI--03框架你值得拥有
- 快速入门系列--MVC--06视图
- 腾讯入局物业管理 欲改造传统服务?
- ExtJs学习笔记(4)_EditorGridPanel(可编辑的网格控件)
- ansible批量管理软件部署及剧本
- 快速入门系列--MVC--02路由
- Javascript生成GUID
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- 如何在 Linux 上恢复误删除的文件或目录
- 浙大版《C语言程序设计(第3版)》题目集 习题8-2 在数组中查找指定元素
- Pandas学习笔记之时间序列总结
- HTML+JS动态获取当前时间
- HTML+JS实现时钟
- SQL-spj库创建脚本
- Sublime Text3 通过Package Control安装插件时找不到可用安装包的解决方法
- SwiftUI:手动发布 ObservableObject 更改
- 卧槽,又一款 Markdown 组合神器!!!
- SQL-查询各工程项目使用所提供零件最多的供应商
- 浙大版《C语言程序设计(第3版)》题目集 习题8-3 数组循环右移
- SwiftUI:控制图像插值
- SQL-查询比p6零件供应数量都高的零件
- 浙大版《C语言程序设计(第3版)》题目集 习题8-5 使用函数实现字符串部分复制
- 最小生成树-Magicpig密室出逃(Kruskal+并查集)