SpringBoot实现mysql与clickhouse多数据源的项目实践
更新时间：2023年11月09日 10:44:59 作者：爱上雪茄
本文主要介绍了SpringBoot实现mysql与clickhouse多数据源的项目实践,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
一、我们来实现一个mysql与clickhouse多数据源配置
二、数据源配置
# 指定服务名称
spring:
application:
name: demobigdata
datasource:
driver-class-name: com.mysql.jdbc.Driver
url: jdbc:mysql://127.0.0.1:3306/db?createDatabaseIfNotExist=true&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&useSSL=false&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useAffectedRows=true&allowPublicKeyRetrieval=true
username: root
password: 123456
type: com.alibaba.druid.pool.DruidDataSource
druid:
# 数据源 clickhouse
clickhouse:
driverClassName: com.clickhouse.jdbc.ClickHouseDriver
url: jdbc:clickhouse://192.168.42.142:8123/bigdata
username: default
password: 123456
initialSize: 10
maxActive: 100
minIdle: 10
maxWait: 6000三、MysqlDuridConfig
import javax.sql.DataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
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.Resource;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import com.alibaba.druid.pool.DruidDataSource;
@Configuration
@MapperScan(basePackages = "org.demoflowable.mysql.dao")
public class MysqlDuridConfig {
@javax.annotation.Resource
MysqlJdbcParamConfig mysqlJdbcParamConfig;
@Bean("mysqlDataSource")
@Primary
public DataSource mysqlDataSource() {
DruidDataSource datasource = new DruidDataSource();
datasource.setUrl(mysqlJdbcParamConfig.getUrl());
datasource.setDriverClassName(mysqlJdbcParamConfig.getDriverClassName());
datasource.setUsername(mysqlJdbcParamConfig.getUsername());
datasource.setPassword(mysqlJdbcParamConfig.getPassword());
return datasource;
}
@Bean("mysqlTransactionManager")
@Primary
public DataSourceTransactionManager getDataSourceTransactionManager(
@Qualifier("mysqlDataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
@Bean("sqlSessionFactory")
@Primary
public SqlSessionFactory getSqlSessionManager(@Qualifier("mysqlDataSource") DataSource dataSource)
throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dataSource);
Resource[] resource = new PathMatchingResourcePatternResolver().getResources("classpath:META-INF/mapper/mysql/*.xml");
bean.setMapperLocations(resource);
Resource configLocation=new PathMatchingResourcePatternResolver().getResource("classpath:META-INF/spring/mybatis-config.xml");
bean.setConfigLocation(configLocation);
return bean.getObject();
}
}四、MysqlJdbcParamConfig
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
@Component
@ConfigurationProperties(prefix = "spring.datasource")
public class MysqlJdbcParamConfig {
private String driverClassName;
private String url;
private String username;
private String password;
public String getDriverClassName() {
return driverClassName;
}
public void setDriverClassName(String driverClassName) {
this.driverClassName = driverClassName;
}
public String getUrl() {
return url;
}
public void setUrl(String url) {
this.url = url;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
}五、ClickHouseJdbcParamConfig
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
@Component
@ConfigurationProperties(prefix = "spring.datasource.druid.clickhouse")
public class ClickHouseJdbcParamConfig {
private String driverClassName;
private String url;
private Integer initialSize;
private Integer maxActive;
private Integer minIdle;
private Integer maxWait;
private String username;
private String password;
public String getDriverClassName() {
return driverClassName;
}
public void setDriverClassName(String driverClassName) {
this.driverClassName = driverClassName;
}
public String getUrl() {
return url;
}
public void setUrl(String url) {
this.url = url;
}
public Integer getInitialSize() {
return initialSize;
}
public void setInitialSize(Integer initialSize) {
this.initialSize = initialSize;
}
public Integer getMaxActive() {
return maxActive;
}
public void setMaxActive(Integer maxActive) {
this.maxActive = maxActive;
}
public Integer getMinIdle() {
return minIdle;
}
public void setMinIdle(Integer minIdle) {
this.minIdle = minIdle;
}
public Integer getMaxWait() {
return maxWait;
}
public void setMaxWait(Integer maxWait) {
this.maxWait = maxWait;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
}
六、ClickHouseConfig
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.Resource;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import com.alibaba.druid.pool.DruidDataSource;
@Configuration
@ConfigurationProperties
@MapperScan(basePackages = "org.demoflowable.clickhouse.dao", sqlSessionFactoryRef = "clickhouseSqlSessionFactory")
public class ClickHouseConfig {
@javax.annotation.Resource
private ClickHouseJdbcParamConfig jdbcParamConfig;
@Bean("clickDataSource")
public DataSource dataSource() {
DruidDataSource datasource = new DruidDataSource();
datasource.setUrl(jdbcParamConfig.getUrl());
datasource.setDriverClassName(jdbcParamConfig.getDriverClassName());
datasource.setInitialSize(jdbcParamConfig.getInitialSize());
datasource.setMinIdle(jdbcParamConfig.getMinIdle());
datasource.setMaxActive(jdbcParamConfig.getMaxActive());
datasource.setMaxWait(jdbcParamConfig.getMaxWait());
datasource.setUsername(jdbcParamConfig.getUsername());
datasource.setPassword(jdbcParamConfig.getPassword());
return datasource;
}
@Bean("clickTransactionManager")
public DataSourceTransactionManager getDataSourceTransactionManager(
@Qualifier("clickDataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
@Bean("clickhouseSqlSessionFactory")
public SqlSessionFactory getSqlSessionManager(@Qualifier("clickDataSource") DataSource dataSource)
throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dataSource);
Resource[] resource = new PathMatchingResourcePatternResolver()
.getResources("classpath:META-INF/mapper/clickhouse/*.xml");
bean.setMapperLocations(resource);
return bean.getObject();
}
}七、启动类Application
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
/**
* @Description: 启动类
*/
@SpringBootApplication
@ComponentScan({ "org.demoflowable" })
public class Application {
/**
* @Title: main
* @Description: 启动类
* @param args
* @date 2023-11-08 01:49:23
*/
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}到此这篇关于SpringBoot实现mysql与clickhouse多数据源的项目实践的文章就介绍到这了,更多相关SpringBoot mysql与clickhouse多数据源内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
SpringBoot熔断机制之CircuitBreaker详解
这篇文章主要介绍了SpringBoot熔断机制之CircuitBreaker详解,SpringBoot的熔断机制在微服务架构中扮演着重要角色,其中CircuitBreaker是其核心机制之一,用于防止服务的异常状态影响到整个系统的运作,需要的朋友可以参考下2023-10-10
Springboot2.7+Minio8 实现大文件分片上传
本文主要介绍了Springboot2.7+Minio8 实现大文件分片上传,通过文件切片上传,我们能够提高文件上传的速度,优化用户体验,具有一定的参考价值,感兴趣的可以了解一下2023-12-12
这篇文章主要介绍了解决使用IDEA时跳转到.class的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-08-08
有时候参数的传递还需要更多的参数，比如一个获取用户信息的请求中既有用户ID等基本参数，还要求对查询结果进行分页，针对这种场景，一般都会将分页参数封装成一个对象，然后将它和基本参数一起传给控制器2023-02-02
这篇文章主要介绍了使用chatgpt实现微信聊天小程序(秒回复)，文中有详细的代码示例，对大家了解chatgpt聊天有一定的帮助，感兴趣的同学可以参考阅读2023-05-05
今天上线遇到了问题，所以抽空记录一下，本文主要介绍了spring中@Reference注入为空的解决方法，需要的朋友们下面随着小编来一起学习学习吧2021-06-06
聊聊Controller中RequestMapping的作用
这篇文章主要介绍了Controller中RequestMapping的作用，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-02-02
Ribbon是一个客户端负载均衡器，它提供了对HTTP和TCP客户端的行为的大量控制。这篇文章主要介绍了SpringCloud Ribbon 负载均衡的实现，感兴趣的小伙伴们可以参考一下2019-01-01
SpringBoot整合Redis并且用Redis实现限流的方法 附Redis解压包
这篇文章主要介绍了SpringBoot整合Redis并且用Redis实现限流的方法 附Redis解压包,本文给大家介绍的非常详细,感兴趣的朋友跟随小编一起看看吧2024-06-06
程序运行时发生的不被期望的事件,它阻止了程序按照程序员的预期正常执行,这就是异常,下面这篇文章主要给大家介绍了关于Java常见踩坑记录之异常处理的相关资料,需要的朋友可以参考下2022-01-01
最新评论