SpringBoot實現(xiàn)mysql與clickhouse多數(shù)據(jù)源的項目實踐
更新時間：2023年11月09日 10:44:59 作者：愛上雪茄
本文主要介紹了SpringBoot實現(xiàn)mysql與clickhouse多數(shù)據(jù)源的項目實踐,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
一、我們來實現(xiàn)一個mysql與clickhouse多數(shù)據(jù)源配置
二、數(shù)據(jù)源配置
# 指定服務(wù)名稱
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:
# 數(shù)據(jù)源 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);
}
}到此這篇關(guān)于SpringBoot實現(xiàn)mysql與clickhouse多數(shù)據(jù)源的項目實踐的文章就介紹到這了,更多相關(guān)SpringBoot mysql與clickhouse多數(shù)據(jù)源內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
有朋友說jpa相比mybatis太難用，多表聯(lián)合的查詢寫起來也比較費勁，所以便加入了mybatis的支持，在配置jpa時遇到各種問題，需要修改相關(guān)配置文件，下面小編給大家分享下修改配置文件的思路，感興趣的朋友參考下2016-10-10
線程池的使用并不復(fù)雜，麻煩的是如何判斷線程池中的任務(wù)已經(jīng)全部執(zhí)行完了，所以接下來，我們就來看看如何判斷線程中的任務(wù)是否已經(jīng)全部執(zhí)行完吧2023-08-08
Java如何處理數(shù)據(jù)成為樹狀結(jié)構(gòu)
這篇文章主要介紹了Java如何處理數(shù)據(jù)成為樹狀結(jié)構(gòu)問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-07-07
springboot配置http跳轉(zhuǎn)https的過程
SSL是為網(wǎng)絡(luò)通信提供安全以及保證數(shù)據(jù)完整性的的一種安全協(xié)議，SSL在網(wǎng)絡(luò)傳輸層對網(wǎng)絡(luò)連接進行加密，這篇文章主要介紹了springboot配置http跳轉(zhuǎn)https的過程,需要的朋友可以參考下2023-04-04
文章主要講解了Java Collection單列集合的基礎(chǔ)知識,包括Collection接口及其子接口List和Set的特點與實現(xiàn)類,常用方法以及遍歷方式,如迭代器、增強for循環(huán)、forEach方法,并通過代碼實例展示了如何遍歷存儲自定義對象的集合,感興趣的朋友一起看看吧2026-05-05
本文主要介紹了SpringBoot小程序推送信息的項目實踐，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-04-04
Digester是apache開源項目Commons中的一個子項目,用于解析XML文檔的工具,本文為大家整理了Digester解析XML文件的三種方式,希望對大家有所幫助2024-01-01
Springboot集成RabbitMQ死信隊列的實現(xiàn)
在大多數(shù)的MQ中間件中，都有死信隊列的概念。本文主要介紹了Springboot集成RabbitMQ死信隊列的實現(xiàn)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-09-09
下面小編就為大家分享一篇讓JPA的Query查詢接口返回Map對象的方法，具有很的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2017-12-12
這篇文章主要介紹了Java enum 對枚舉元素的賦值和取值方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-05-05