說明
ClickHouse 是一款用于大數據實時分析的列式數據庫管理系統，在大數據量查詢時有著非常優秀的性能，
但是也有缺點，就是不支持事務，不支持真正的刪除 / 更新，所以筆者只演示插入和查詢。
1.添加maven依賴
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
<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、配屬數據源
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
spring: datasource: type: com.alibaba.druid.pool.DruidDataSourceclickhouse: driverClassName: ru.yandex.clickhouse.ClickHouseDriver url: jdbc:clickhouse://106.55.55.249:8123/default password: ck的密碼 initialSize: 10 maxActive: 100 minIdle: 10 maxWait: 6000mybatis: mapper-locations: classpath:mapper/*Mapper.xml type-aliases-package: com.wyu.tt16clickhouse.entityserver: port: 8090 |
3、參數配置
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
import lombok.Data;import org.springframework.beans.factory.annotation.Value;import org.springframework.stereotype.Component;@Data@Componentpublic 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("${clickhouse.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連接池配置
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
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;@Configurationpublic 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; }} |
5、Mapper.xml
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.wyu.tt16clickhouse.UserMapper"> <select id="queryUser" resultType="com.wyu.tt16clickhouse.entity.User"> select userId, appId, version, regTime from `default`.`user` </select> <insert id="insertUser" parameterType="com.wyu.tt16clickhouse.entity.User"> INSERT INTO `default`.`user` (`userId`, `appId`, `version`, `regTime`) VALUES (#{userId}, #{appId}, #{version}, #{regTime}) </insert></mapper> |
6、Mapper接口
|
1
2
3
4
5
6
7
|
@Mapperpublic interface UserMapper { List<User> queryUser(); Integer insertUser(User user);} |
7.controller接口
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
@Slf4j@RestControllerpublic class UserController { @Autowired private UserMapper userMapper; @RequestMapping("/queryUser") public Object query(){ List userList = userMapper.queryUser(); log.info(userList.toString()); return userList.toString(); } @RequestMapping("/insertUser") public Object insertUser(){ User user = new User(); user.setAppId("SS"); user.setRegTime(new Date()); user.setUserId(777744); user.setVersion("3.2"); Integer flag = userMapper.insertUser(user); return flag; }} |
8.創建一個clickhouse表，然后插入幾條數據測試一下
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
create table user( userId Int32, appId String, version String, regTime Date) engine = MergeTree PARTITION BY toYYYYMM(regTime) ORDER BY userId SETTINGS index_granularity = 8192; INSERT INTO default.user (userId, appId, version, regTime) VALUES (123457, 'RR', '3.6', '2020-01-07');INSERT INTO default.user (userId, appId, version, regTime) VALUES (43234, 'HH', '2.5', '2020-06-06');INSERT INTO default.user (userId, appId, version, regTime) VALUES (1234, 'TT', '2.4', '2020-07-24');INSERT INTO default.user (userId, appId, version, regTime) VALUES (12345, 'RR', '2.5', '2020-07-29');INSERT INTO default.user (userId, appId, version, regTime) VALUES (123456, 'TT', '2.1', '2020-07-09');INSERT INTO default.user (userId, appId, version, regTime) VALUES (234561, 'GG', '3.0', '2020-07-31'); |
9.測試
參考文章：SpringBoot2 整合 ClickHouse數據庫案例解析
總結
到此這篇關于springboot+mybatis配置clickhouse實現插入查詢功能的文章就介紹到這了,更多相關springboot+mybatis配置clickhouse內容請搜索服務器之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持服務器之家！
原文鏈接：https://blog.csdn.net/weixin_39025362/article/details/107715706
