Clickhouse使用根本

1. # 查看操作系统版本
2. cat /etc/os-release
4. # clickhouse版本
5. clickhouse -V
7. # 登录clickhouse客户端
8. clickhouse-client -u xxx --password xxx -m
9. # -m 或 --multiline：进入客户端后，运行输入多行sql语句

复制代码

建表

1. # 创建数据库
2. CREATE DATABASE IF NOT EXISTS test;  --使用默认库引擎创建库

复制代码

1. # 创建本地表
2. create table IF NOT EXISTS test.user_table (
3.         uid String comment '用户ID',
4.         sex String comment '性别',
5.         age UInt16 comment '年龄',
6.         phone String comment '联系电话'
7. )
8. engine = MergeTree()
9. order by uid;

复制代码

• 数据类型必要大写开头：String、UInt16
  
• 表引擎类型也必须大写MergeTree
  
• 如果没有指定主键，默认使用 order by 指定的字段
  

1. # 创建分布式表
2. -- 在集群中创建实际存放数据的本地表
3. create table test.user_event on cluster data_cluster(
4.         uid String comment '用户id',
5.         event String comment '事件名称',
6.         c_time DateTime comment '点击时间',
7.         dt Date comment '日期'
8. )
9. engine = MergeTree()
10. partition by dt
11. order by uid;
13. --创建分布式表
14. create table test.user_event_distributed (
15.         uid String comment '用户id',
16.         eventString comment '事件名称',
17.         c_time DateTime comment '点击时间',
18.         dt Date comment '日期'
19. )
20. engine = Distributed('data_cluster', 'test', 'user_event', rand());

复制代码

• 分布式表必要选择Distributed 表引擎：
  
  
  
  • 第1个参数：集群名称
    
  • 第2个参数：数据库名
    
  • 第3个参数：数据表名
    
  • 第4个参数：分片key，数据被到不同服务器依据的字段，相同的值会被分配到同一台服务器
    
  
  

如果在创建分布式表test.user_event_distributed 时没有指定on cluster data_cluster，那么创建是本地表，后续的查询只能在建表的那个节点服务器查询数据
表变更

1. # 删除特定分区
2. alter table test.user_event
3. on cluster data_cluster
4. drop partition '2024-11-30';
6. alter table test.user_event
7. on cluster data_cluster
8. delete where dt > '2024-11-15';
10. alter table test.user_event
11. on cluster data_cluster
12. delete where dt='2024-11-30';
14. # 删除满足特定条件数据
15. alter table test.user_event
16. on cluster data_cluster
17. delete where user_id='u00001';

复制代码

自界说函数

1. /**
2. * 创建自定义函数 x_split
3. * 分割字符串并把类型转换为整数
4. */
5. CREATE FUNCTION x_split (x String)
6. RETURNS Array(UInt32)
7. AS
8. (
9.     arrayMap(
10.         (y) -> toUInt32(y),
11.         splitByString(',', x)
12.     )
13. );

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。