说明
ClickHouse 是一款用于大数据实时分析的列式数据库管理系统,在大数据量查询时有着非常优秀的性能,
但是也有缺点,就是不支持事务,不支持真正的删除 / 更新,所以笔者只演示插入和查询。
1.添加maven依赖
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-aop</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> </dependency> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.3.2</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>1.1.13</version> </dependency> <dependency> <groupId>commons-lang</groupId> <artifactId>commons-lang</artifactId> <version>2.6</version> </dependency> <!-- clickHouse数据库 --> <dependency> <groupId>ru.yandex.clickhouse</groupId> <artifactId>clickhouse-jdbc</artifactId> <version>0.1.53</version> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency>
2、配属数据源
spring: datasource: type: com.alibaba.druid.pool.DruidDataSource clickhouse: driverClassName: ru.yandex.clickhouse.ClickHouseDriver url: jdbc:clickhouse://106.55.55.249:8123/default password: ck的密码 initialSize: 10 maxActive: 100 minIdle: 10 maxWait: 6000 mybatis: mapper-locations: classpath:mapper/*Mapper.xml type-aliases-package: com.wyu.tt16clickhouse.entity server: port: 8090
3、参数配置
import lombok.Data; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; @Data @Component public class ChParam { private String driverClassName; private String url; private String password; private Integer initialSize; private Integer maxActive; private Integer minIdle; private Integer maxWait; @Value("${clickhouse.driverClassName}") public void setDriverClassName(String driverClassName) { this.driverClassName = driverClassName; } @Value("${clickhouse.url}") public void setUrl(String url) { this.url = url; } @Value("${clickhouse.password}") public void setPassword(String password) { this.password = password; } @Value("${clickhouse.initialSize}") public void setInitialSize(Integer initialSize) { this.initialSize = initialSize; } @Value("${clickhou<i style="color:transparent">本文来源gaodai$ma#com搞$代*码6网</i>se.maxActive}") public void setMaxActive(Integer maxActive) { this.maxActive = maxActive; } @Value("${clickhouse.minIdle}") public void setMinIdle(Integer minIdle) { this.minIdle = minIdle; } @Value("${clickhouse.maxWait}") public void setMaxWait(Integer maxWait) { this.maxWait = maxWait; } }
4、Druid连接池配置
import com.alibaba.druid.pool.DruidDataSource; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import javax.sql.DataSource; @Configuration public class DruidConfig { @Autowired private ChParam chParam; @Bean public DataSource dataSource() { DruidDataSource datasource = new DruidDataSource(); datasource.setUrl(chParam.getUrl()); datasource.setDriverClassName(chParam.getDriverClassName()); datasource.setInitialSize(chParam.getInitialSize()); datasource.setMinIdle(chParam.getMinIdle()); datasource.setMaxActive(chParam.getMaxActive()); datasource.setMaxWait(chParam.getMaxWait()); datasource.setPassword(chParam.getPassword()); return datasource; } }