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

Mybatis Plus + Spring 分包配置 ClickHouse 和 Mysql 双数据源

news 2025/9/10 12:13:24

 

目录

一、背景

二、各个配置文件总览（文件位置因人而异）

2.1 DataSourceConfig

2.2 MybatisClickHouseConfig （ClickHouse 配置类）

2.3 MybatisMysqlConfig（Mysql 配置类）

2.4 application.properties 配置

2.5 mapper 分包情况

2.6  主类中的 @MapperScan 去掉，因为在上面 ClickHouse 配置类 和 Mysql配置类 中已经定义

2.7 引用依赖（关键性依赖）

三、参考大神，感谢分享！

一、背景

业务需求，连接池之前用的 Hikari，换成了 Druid 注意一下 ~

我选择 分包 配置动态双数据源

二、各个配置文件总览（文件位置因人而异）

2.1 DataSourceConfig

package xxx.xxx.xxx.common.config;import javax.sql.DataSource;import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import com.alibaba.druid.pool.DruidDataSource;/*** 双数据源配置类** @Author Elenda* @Date 2024/03/12 10:10* @Version 1.0*/
@Configuration
public class DataSourceConfig {/*** Mysql** @return DataSource*/@Bean(name = "mysqlDatasource")@ConfigurationProperties(prefix = "spring.datasource.druid.mysql")public DataSource mysqlDatasource() {return new DruidDataSource();}/*** ClickHouse** @return DataSource*/@Bean(name = "clickHouseDatasource")@ConfigurationProperties(prefix = "spring.datasource.druid.clickhouse")public DataSource clickHouseDatasource() {return new DruidDataSource();}
}

2.2 MybatisClickHouseConfig （ClickHouse 配置类）

package xxx.xxx.xxx.common.config;import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;import javax.sql.DataSource;/*** clickHouse数据源配置** @Author Elenda* @Date 2024/03/12 10:10* @Version 1.0*/
@Configuration
@MapperScan(basePackages = {"xxx.xxx.xxx.mapper.clickhouse"}, sqlSessionFactoryRef = "sqlSessionFactoryDsClickhouse")
public class MybatisClickHouseConfig {@Autowired@Qualifier("clickHouseDatasource")private DataSource clickHouseDatasource;@Beanpublic SqlSessionFactory sqlSessionFactoryDsClickhouse() throws Exception {MybatisSqlSessionFactoryBean factoryBean = new MybatisSqlSessionFactoryBean();factoryBean.setDataSource(clickHouseDatasource);/*factoryBean.setMapperLocations(//设置mybatis的xml所在位置new PathMatchingResourcePatternResolver().getResources("classpath:/mappings/clickhouse/*.xml"));*/return factoryBean.getObject();}@Beanpublic SqlSessionTemplate sqlSessionTemplateDsClickhouse() throws Exception {SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactoryDsClickhouse());return template;}@Beanpublic DataSourceTransactionManager transactionManagerClickhouse() {return new DataSourceTransactionManager(clickHouseDatasource);}
}

2.3 MybatisMysqlConfig（Mysql 配置类）

package xxx.xxx.xxx.common.config;import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;import javax.sql.DataSource;/*** mysql数据源配置** @Author Elenda* @Date 2024/03/12 10:10* @Version 1.0*/
@Configuration
@MapperScan(basePackages = {"xxx.xxx.xxx.mapper.mysql"}, sqlSessionFactoryRef = "sqlSessionFactoryDsMysql")
public class MybatisMysqlConfig {@Autowired@Qualifier("mysqlDatasource")private DataSource mysqlDatasource;@Bean@Primarypublic SqlSessionFactory sqlSessionFactoryDsMysql() throws Exception {MybatisSqlSessionFactoryBean factoryBean = new MybatisSqlSessionFactoryBean();factoryBean.setDataSource(mysqlDatasource);factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:/mappings/mysql/*.xml"));//向Mybatis过滤器链中添加拦截器MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));factoryBean.setPlugins(interceptor);return factoryBean.getObject();}@Bean@Primarypublic SqlSessionTemplate sqlSessionTemplateDsMysql() throws Exception {SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactoryDsMysql());return template;}@Bean@Primarypublic DataSourceTransactionManager transactionManagerMysql() {return new DataSourceTransactionManager(mysqlDatasource);}}

2.4 application.properties 配置

# datasource 配置
# clickhouse
spring.datasource.druid.clickhouse.test-while-idle=true
spring.datasource.druid.clickhouse.validation-query=SELECT 1
spring.datasource.druid.clickhouse.username=username
spring.datasource.druid.clickhouse.password=password
spring.datasource.druid.clickhouse.url=url
spring.datasource.druid.clickhouse.driver-class-name=com.clickhouse.jdbc.ClickHouseDriver
spring.datasource.druid.clickhouse.type=com.alibaba.druid.pool.DruidDataSource# mysql
spring.datasource.druid.mysql.test-while-idle=true
spring.datasource.druid.mysql.validation-query=SELECT 1
spring.datasource.druid.mysql.username=username
spring.datasource.druid.mysql.password=password
spring.datasource.druid.mysql.url=url
spring.datasource.druid.mysql.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.druid.mysql.type=com.alibaba.druid.pool.DruidDataSource

其中，spring.datasource.druid.clickhouse.validation-query=SELECT 1

该选项用来验证数据库连接的有效性

2.5 mapper 分包情况

2.6  主类中的 @MapperScan 去掉，因为在上面 ClickHouse 配置类 和 Mysql配置类 中已经定义

2.7 引用依赖（关键性依赖）

<!-- druid -->
<dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.2.15</version>
</dependency>
<!-- clickhouse-->
<dependency><groupId>com.clickhouse</groupId><artifactId>clickhouse-jdbc</artifactId><version>0.3.2-patch11</version>
</dependency>
<!-- mysql-->
<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- mybatis-plus-->
<dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.3</version>
</dependency>

三、参考大神，感谢分享！

正确可用版：SpringBoot+Mybatis-plus+Druid 实现配置多数据源（数据库）_spring_Oxye-华为云开发者联盟前言此文介绍的是在SpringBoot中使用Mybatis配置多数据源（多个数据库），整合Druid网上有很多文章，翻了翻，但是都有问题啊，有的是没使用Druid，使用了默认的Hirika，有的是配置文件不给或者给的是Hirika能用的配置，层级不对，所以我自己来记一下代码pom文件maven依赖<dependency><groupId>com.alibaba</gr Oxye 华为云开发者联盟icon-default.png?t=N7T8https://huaweicloud.csdn.net/6387524cdacf622b8df8ab9f.html?dp_token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpZCI6ODI0NzQsImV4cCI6MTcxMDgwOTA1MywiaWF0IjoxNzEwMjA0MjUzLCJ1c2VybmFtZSI6IkVsZW5kYUxlZSJ9.EAq9dDI8MxXQwa-msFI9Urbg_N59E13lEQS3o95rCVw

http://www.lryc.cn/news/320032.html

相关文章：

  • 27-3 文件上传漏洞 - 文件类型绕过（后端绕过）
  • widget一些控件的使用
  • Python基础（七）之数值类型集合
  • 电脑充电器能充手机吗？如何给手机充电？
  • 矩阵中移动的最大次数
  • Linux：系统初始化，内核优化，性能优化（3）
  • 使用 GitHub Actions 通过 CI/CD 简化 Flutter 应用程序开发
  • 微软 CEO Satya Nadella 的访谈
  • 万界星空科技商业开源MES,技术支持+项目合作
  • Docker Mysql无root账户创建最高权限用户
  • 常用芯片学习——DS3231M芯片
  • 蓝桥杯单片机快速开发笔记——矩阵键盘
  • 每周一算法：双向深搜
  • 蓝桥杯刷题（十）
  • ioDraw：与 GitHub、gitee、gitlab、OneDrive 无缝对接，绘图文件永不丢失！
  • 利用 Python 处理遥感影像数据：计算年度平均影像
  • 【Leetcode-73.矩阵置零】
  • redis 常见的异常
  • npm包、全局数据共享、分包
  • UnityShader：IBL
  • 每日五道java面试题之mybatis篇（三）
  • C#开发五子棋游戏：从新手到高手的编程之旅
  • ELK日志管理实现的3种常见方法
  • 深度强化学习01
  • C++ 智能指针的使用
  • Flutter 核心原理 - UI 框架（UI Framework）
  • Hive优化
  • React 的 diff 算法
  • 综合知识篇07-软件架构设计考点（2024年软考高级系统架构设计师冲刺知识点总结系列文章）
  • 【GPT-SOVITS-05】SOVITS 模块-残差量化解析