当前位置: 首页 > news >正文

使用多数据源dynamic-datasource-spring-boot-starter遇到的问题记录

记录使用多数据源dynamic-datasource-spring-boot-starter遇到的问题:
1、工程启动失败
缺少clickhouse连接驱动,引入对应的maven依赖

		<!--ck连接驱动--><dependency><groupId>ru.yandex.clickhouse</groupId><artifactId>clickhouse-jdbc</artifactId><version>0.1.52</version></dependency>

2、clickhouse的sql语句读到了mysql数据库
在工程的配置文件只配置了ck数据源配置的时候,@DS(“数据源名称”)用在service接口上没什么问题。
由于新的需求:代码需要通过不同环境动态选择不同的数据源(测试环境mysql/生产环境ck),但是额外配置了mysql数据源且mysql数据源为默认数据源的时候,对应的ck查询却跑到了mysql数据库查询,并且mysql部分函数语法不兼容ck,导致查询报错,最后将**@DS**注解放在了mapper层的接口上,解决找不到对应数据库的问题

3、mysql函数语法部分不兼容ck
比如mysql的date_format()函数,对标ck的formatDateTime()函数,还有一些其他的函数可根据自己实际情况解决

4、service实现类(简称A)需要根据不同环境引入不同的数据源mapper(可以参考责任链模式)
此时存在ck数据源mapper(简称B)和mysql数据源mapper(简称C),里面方法相同,但service实现类只能允许一个mapper去调用B或者C里面的方法。
将ck和mysql数据源mapper里面的方法提取成一个公共的接口(简称D),编写两个类(简称E、F)实现这个公共接口D,重写接口方法,E类里面注入B的实例,由于E实现D接口,D接口方法来自B接口,所以E类里面可以使用B的实例调用B接口的方法,F类同理。业务流程调用大致图如下:
在这里插入图片描述

A类需要注入D接口实例,D接口的实例需要被E、F类的实例对象赋值,相关代码如下:

/*** ck数据源标识  spring.datasource.dynamic.datasource下的配置*/private static final String CK_PROD = "ck_prod";/*** mysql数据源标识  spring.datasource.dynamic.datasource下的配置*/private static final String MASTER = "master";private CommonAppMapper iovAppMapper;@Autowiredprivate IovAppCkService iovAppCkService;@Autowiredprivate IovAppMySqlService iovAppMySqlService;/*** @PostConstruct注解标记的方法会在Bean初始化完成后自动调用 初始化 iovAppMapper*/@PostConstructpublic void init() {// 在这里执行仅需在启动时执行一次的操作Properties props = new Properties();InputStream inputStream = getClass().getClassLoader().getResourceAsStream("application.yml");try {props.load(inputStream);} catch (IOException e) {e.printStackTrace();}String propertyValue = props.getProperty("dynamic.datasource.name");if (CK_PROD.equals(propertyValue)) {this.iovAppMapper = iovAppCkService;}if (MASTER.equals(propertyValue)) {this.iovAppMapper = iovAppMySqlService;}}
http://www.lryc.cn/news/104740.html

相关文章:

  • 构建语言模型:BERT 分步实施指南
  • ⛳ Java多线程 一,线程基础
  • 【iOS】多线程 锁问题总结
  • Pytorch深度学习-----神经网络之池化层用法详解及其最大池化的使用
  • Docker啥是数据持久化?
  • CGAL 线段简化算法(2D)
  • 在CentOS 7上挂载硬盘到系统的步骤及操作
  • 螺旋矩阵(JS)
  • C#常用数学插值法
  • ELK日志管理平台架构和使用说明
  • 抖音短视频seo矩阵系统源码开发部署技术分享
  • docker 部署一个单节点的rocketmq
  • MySQL优化
  • 【C++】总结9
  • C++报错 XX does not name a type;field `XX’ has incomplete type解决方案
  • 28.利用fminsearch、fminunc 求解最大利润问题(matlab程序)
  • 图像 检测 - FCOS: Fully Convolutional One-Stage Object Detection (ICCV 2019)
  • C# NDArray System.IO.FileLoadException报错原因分析
  • 快速响应,上门维修小程序让您享受无忧生活
  • 05、性能分析思路?
  • 【编程语言 · C语言 · calloc和realloc】
  • 机器学习分布式框架ray运行pytorch实例
  • TypeScript 【type】关键字的进阶使用方式
  • 策略路由实现多ISP接入Internet
  • Socket本质、实战演示两个进程建立TCP连接通信的过程
  • java学习路程之篇四、进阶知识、石头迷阵游戏、绘制界面、打乱石头方块、移动业务、游戏判定胜利、统计步数、重新游戏
  • Git全栈体系(三)
  • JMeter发送get请求并分析返回结果
  • HTML笔记(1)
  • 重新审视MHA与Transformer