表

表 DDL 命令用于创建、修改、查询和删除工作空间中的普通表。

表的类型

Lakehouse 提供多种表类型，选型时参考以下对比：

存储格式

普通表默认使用 Parquet 格式存储，具备以下优势：

• 列式存储：只读取查询涉及的列，减少 I/O
• 高效压缩：相比行式存储节省 50%–80% 存储空间
• 向量化执行：配合 Lakehouse 执行引擎，聚合和过滤性能更优

表的约束

NOT NULL

列定义时加

NOT NULL

CREATE TABLE orders ( order_id BIGINT NOT NULL, amount DECIMAL(10, 2) NOT NULL, note STRING -- 允许为空 );

PRIMARY KEY

主键约束有两种行为模式，选择时需了解差异：

ENABLE VALIDATE RELY

PRIMARY KEY (col)

DISABLE NOVALIDATE RELY

PRIMARY KEY (col) DISABLE NOVALIDATE RELY

-- 默认模式：SQL 写入和实时写入都进行主键去重 CREATE TABLE customers ( customer_id BIGINT PRIMARY KEY, name STRING, updated_at TIMESTAMP ); -- DISABLE NOVALIDATE RELY：仅实时写入去重，SQL 写入不检查主键唯一性 -- 适合只通过 CDC 实时同步写入、不走 INSERT SQL 的表 CREATE TABLE customers_cdc ( customer_id BIGINT, name STRING, updated_at TIMESTAMP, PRIMARY KEY (customer_id) DISABLE NOVALIDATE RELY );

DISABLE NOVALIDATE RELY

本章内容

常用操作

创建表

-- 基础建表 CREATE TABLE IF NOT EXISTS public.orders ( order_id BIGINT, customer_id BIGINT, amount DECIMAL(10, 2), status STRING, created_at TIMESTAMP ); -- 带分区（按天分区，推荐时序数据） CREATE TABLE IF NOT EXISTS public.events ( event_id BIGINT, event_type STRING, user_id BIGINT, created_at TIMESTAMP ) PARTITIONED BY (days(created_at)); -- 带主键（CDC 实时写入场景） CREATE TABLE IF NOT EXISTS public.customers ( customer_id BIGINT PRIMARY KEY, name STRING, email STRING, updated_at TIMESTAMP );

修改表

-- 添加列 ALTER TABLE public.orders ADD COLUMN discount DECIMAL(5, 2); -- 重命名表 ALTER TABLE public.orders RENAME TO public.orders_v2; -- 设置数据保留期（天） ALTER TABLE public.orders SET data_retention_days = 7;

查看表

-- 查看表结构 DESC TABLE public.orders; -- 查看建表语句 SHOW CREATE TABLE public.orders; -- 列出所有表 SHOW TABLES; -- 查看分区列表 SHOW PARTITIONS public.events;

删除与恢复

-- 删除表 DROP TABLE IF EXISTS public.temp_orders; -- 恢复已删除的表 UNDROP TABLE public.temp_orders; -- 将表回滚到历史版本 RESTORE TABLE public.orders TO TIMESTAMP AS OF '2024-01-15 00:00:00';

相关文档