ClickHouse的基本操作说明
说明
文章内容包括数据库管理、表操作及查询等核心功能
创建数据库
-- 默认引擎（Atomic）
CREATE DATABASE IF NOT EXISTS test_db;
-- MySQL引擎（映射外部MySQL数据库）
CREATE DATABASE mysql_db ENGINE = MySQL('host:port', 'mysql_db_name', 'user', 'password');
CREATE DATABASE mysql_db ENGINE = MySQL('localhost:3306', 'test', 'test', 'test');
use mysql_db;
show tables;
select * from de_dict;
desc de_dict;
删除数据库
DROP DATABASE test_db;
切换数据库
USE test_db;
本地表（MergeTree引擎）
CREATE TABLE user_logs (
log_id UInt64,
user_id UInt32,
event_time DateTime,
metric Float32
) ENGINE = MergeTree()
PARTITION BY toYYYYMM(event_time) -- 按年月分区
ORDER BY (user_id, event_time) -- 主键及排序键
SETTINGS index_granularity = 8192; -- 索引粒度
分布式表
-- 本地表（集群各节点创建）
CREATE TABLE test.user_event ON CLUSTER data_cluster (
uid String,
dt Date
) ENGINE = MergeTree() PARTITION BY dt ORDER BY uid;
-- 分布式表（逻辑视图）
CREATE TABLE test.user_event_distributed
ENGINE = Distributed('data_cluster', 'test', 'user_event', rand()); -- 随机分片
插入数据
INSERT INTO user_logs VALUES
(1, 101, '2023-10-01 10:00:00', 1.5),
(2, 102, '2023-10-01 11:00:00', 2.8);
查询数据
-- 基础查询
SELECT * FROM user_logs WHERE user_id = 101;
-- 聚合统计
SELECT user_id, SUM(metric) FROM user_logs GROUP BY user_id;
-- 排序与分页
SELECT * FROM user_logs ORDER BY event_time DESC LIMIT 10;
更新/删除数据
-- 删除分区
ALTER TABLE user_logs DROP PARTITION '202310';
-- 删除条件数据
ALTER TABLE user_logs DELETE WHERE user_id = 101;
表结构修改
-- 添加列
ALTER TABLE user_logs ADD COLUMN ip String AFTER user_id;
-- 删除列
ALTER TABLE user_logs DROP COLUMN metric;
-- 修改列类型
ALTER TABLE user_logs MODIFY COLUMN ip IPv4;
其他实用操作
SHOW DATABASES; -- 查看所有数据库
SHOW TABLES FROM test_db; -- 查看库中所有表
DESC user_logs; -- 查看表结构
SELECT * FROM system.clusters; --查看已配置的集群信息
数据导入/导出
-- 导出到CSV
SELECT * FROM user_logs INTO OUTFILE 'data.csv' FORMAT CSV;
-- 从文件导入
INSERT INTO user_logs FROM INFILE 'data.csv' FORMAT CSV;
性能优化建议
批量插入数据（每次插入至少数千行）；
避免使用SELECT *，明确指定查询列；
合理使用分区和索引减少扫描范围。