JDBC连接clickhouse cluster
两种方式，一种是使用clickhouse-jdbc连接集群中的每一个节点，另外一种是使用SLB提供一个对外的统一地址
使用BalancedClickhouseDataSource
参考以下clickhouse-jdbc中的代码中的注释：jdbc:clickhouse://localhost:8123,localhost:8123/database?compress=1&decompress=2
/**
* create Datasource for clickhouse JDBC connections
*
* @param url address for connection to the database
* must have the next format {@code jdbc:clickhouse://<first-host>:<port>,<second-host>:<port>/<database>?param1=value1¶m2=value2 }
* for example, {@code jdbc:clickhouse://localhost:8123,localhost:8123/database?compress=1&decompress=2 }
* @throws IllegalArgumentException if param have not correct format, or error happens when checking host availability
*/
public BalancedClickhouseDataSource(final String url) { this(splitUrl(url), getFromUrl(url)); } /** * create Datasource for clickhouse JDBC connections * * @param url address for connection to the database * @param properties database properties * @see #BalancedClickhouseDataSource(String) */ public BalancedClickhouseDataSource(final String url, Properties properties) { this(splitUrl(url), new ClickHouseProperties(properties)); } /** * create Datasource for clickhouse JDBC connections * * @param url address for connection to the database * @param properties database properties * @see #BalancedClickhouseDataSource(String) */ public BalancedClickhouseDataSource(final String url, ClickHouseProperties properties) { this(splitUrl(url), properties.merge(getFromUrlWithoutDefault(url))); }
使用SLB
使用LB均衡到各个副本，保证应用方查询单host，本次不使用BalancedClickhouseDataSource，从github issue上看BalancedClickhouseDataSource在之前版本出现副本故障时没能故障转移，不知道是否有修复。
配置LB：使用标准JDBC连接时需要映射http协议到clickhouse的8123端口(http监听端口)
验证LB配置是否生效
echo 'SELECT * from dm.delphi_membership_properties FORMAT Pretty' | curl 'internal-clickhouse-prod-621097858. cn-north-1.elb.amazonaws.com.cn:80/?' --data-binary @-
贴一下在Springboot中使用标准JDBC数据源HikariDataSource÷连接clickhouse的配置：
package com.kezaihui.delphi.core.config; import com.baomidou.mybatisplus.entity.GlobalConfiguration; import com.baomidou.mybatisplus.enums.DBType; import com.baomidou.mybatisplus.enums.IdType; import com.baomidou.mybatisplus.spring.MybatisSqlSessionFactoryBean; import com.zaxxer.hikari.HikariDataSource; import lombok.extern.slf4j.Slf4j; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.annotation.MapperScan; import org.mybatis.spring.boot.autoconfigure.MybatisProperties; import org.springframework.beans.factory.annotation.Autowired; 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.support.PathMatchingResourcePatternResolver; import org.springframework.core.io.support.ResourcePatternResolver; import javax.sql.DataSource; /** * clickhouse 数据源配置 * * @author Suncle * @date 2019-07-05 */ @Slf4j @Configuration @MapperScan(basePackages = { "com.kezaihui.delphi.core.membership.**.mapper" }, sqlSessionFactoryRef = "ckSqlSessionFactory") public class CkDataSourceConfig { @Autowired private MybatisProperties mybatisProperties; /** * 读取数据源 * * @return javax.sql.DataSource 数据源 */ @Bean(name = "ckDataSource") @ConfigurationProperties(prefix = "spring.clickhouse.datasource") public DataSource dataSource() { return new HikariDataSource(); } /** * sql 会话工厂配置 * * @param ckDataSource javax.sql.DataSource 数据源 * @return SqlSessionFactory */ @Bean(name = "ckSqlSessionFactory") public SqlSessionFactory sqlSessionFactory(@Qualifier("ckDataSource") DataSource ckDataSource) { MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean(); bean.setDataSource(ckDataSource); try { GlobalConfiguration configuration = new GlobalConfiguration(); configuration.setDbType(DBType.OTHER.name()); configuration.setIdType(IdType.AUTO.getKey()); configuration.setDbColumnUnderline(true); bean.setGlobalConfig(configuration); ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver(); bean.setMapperLocations(mybatisProperties.resolveMapperLocations()); bean.setConfigLocation(resolver.getResource(mybatisProperties.getConfigLocation())); return bean.getObject