记录使用多数据源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;
@Autowired
private IovAppCkService iovAppCkService;
@Autowired
private IovAppMySqlService iovAppMySqlService;
/**
* @PostConstruct注解标记的方法会在Bean初始化完成后自动调用 初始化 iovAppMapper
*/
@PostConstruct
public 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;
}
}