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

这篇具有很好参考价值的文章主要介绍了使用多数据源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类同理。业务流程调用大致图如下：
使用多数据源dynamic-datasource-spring-boot-starter遇到的问题记录,java,数据库

A类需要注入D接口实例，D接口的实例需要被E、F类的实例对象赋值，相关代码如下：文章来源地址https://www.toymoban.com/news/detail-613992.html

/**
     * 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;
        }
    }