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

建表

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

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

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

# 创建分布式表
-- 在集群中创建实际存放数据的本地表
create table test.user_event on cluster data_cluster(uid String comment '用户id',event String comment '事件名称',c_time DateTime comment '点击时间',dt Date comment '日期'
)
engine = MergeTree()
partition by dt 
order by uid;--创建分布式表
create table test.user_event_distributed (uid String comment '用户id',eventString comment '事件名称',c_time DateTime comment '点击时间',dt Date comment '日期'
)
engine = Distributed('data_cluster', 'test', 'user_event', rand());

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

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

表变更

# 删除特定分区
alter table test.user_event 
on cluster data_cluster 
drop partition '2024-11-30';alter table test.user_event 
on cluster data_cluster 
delete where dt > '2024-11-15';alter table test.user_event 
on cluster data_cluster 
delete where dt='2024-11-30';# 删除满足特定条件数据
alter table test.user_event 
on cluster data_cluster 
delete where user_id='u00001';

自定义函数

/*** 创建自定义函数 x_split* 分割字符串并把类型转换为整数*/
CREATE FUNCTION x_split (x String)
RETURNS Array(UInt32)
AS
(arrayMap((y) -> toUInt32(y), splitByString(',', x))
);