本文介绍在云数据库ClickHouse中创建表。
创建本地表
语法:
CREATE TABLE [IF NOT EXISTS] [db.]local_table_name ON CLUSTER cluster
(
name1 [type1] [DEFAULT|MATERIALIZED|ALIAS expr1],
name2 [type2] [DEFAULT|MATERIALIZED|ALIAS expr2],
...
INDEX index_name1 expr1 TYPE type1(...) GRANULARITY value1,
INDEX index_name2 expr2 TYPE type2(...) GRANULARITY value2
) ENGINE = engine_name()
[PARTITION BY expr]
ORDER BY expr
[PRIMARY KEY expr]
[SAMPLE BY expr]
[SETTINGS name=value, ...];
参数说明:
参数 | 说明 |
| 数据库的名称,默认为当前选择的数据库,本文以default为例。 |
| 本地表名。 |
| 在每一个节点上都创建一个本地表,固定为 |
| 列名。 |
| 列类型。 说明 云数据库ClickHouse支持的数据类型,请参见数据类型。 |
| 表引擎类型。 双副本版集群建表时,需要使用MergeTree系列引擎中支持数据复制的Replicated*引擎,否则副本之间不进行数据复制,导致数据查询结果不一致。使用该引擎建表时,参数填写方式如下。
说明 云数据库ClickHouse支持的表引擎类型,请参见表引擎。 |
| 排序键,必填项,可以是一组列的元组或任意表达式。 |
| 默认表达式。
|
| 索引粒度参数。 |
| 分区键。一般按照日期分区,也可以使用其他字段或字段表达式。 |
| 主键,默认情况下主键和排序键相同。因此,多数情况下,不需要再专门使用 |
| 抽样表达式。如果要使用抽样表达式,主键中必须包含此表达式。 |
| 影响性能的额外参数。 说明
|
参数ORDER BY
、GRANULARITY
、PARTITION BY
、PRIMARY KEY
、SAMPLE BY
和[SETTINGS name=value, ...]
只有MergeTree系列表引擎支持。更多参数说明,请参见CREATE TABLE。
示例:
CREATE TABLE local_table ON CLUSTER default
(
Year UInt16,
Quarter UInt8,
Month UInt8,
DayofMonth UInt8,
DayOfWeek UInt8,
FlightDate Date,
FlightNum String,
Div5WheelsOff String,
Div5TailNum String
)ENGINE = MergeTree()
PARTITION BY toYYYYMM(FlightDate)
PRIMARY KEY (intHash32(FlightDate))
ORDER BY (intHash32(FlightDate),FlightNum)
SAMPLE BY intHash32(FlightDate)
SETTINGS index_granularity= 8192;
创建分布式表
分布式表是本地表的集合,它将多个本地表抽象为一张统一的表,对外提供写入、查询功能。当数据写入分布式表时,会被自动分发到集合中的各个本地表中。当查询分布式表时,集合中的各个本地表都会被分别查询,并且把最终结果汇总后返回。您需要先创建本地表,再创建分布式表。
语法:
CREATE TABLE [db.]distributed_table_name ON CLUSTER default
AS db.local_table_name ENGINE = Distributed(cluster, db, local_table_name [, sharding_key])
参数说明:
参数 | 说明 |
| 数据库的名称,默认为当前选择的数据库,本文以default为例。 |
| 分布式表名。 |
| 在每一个节点上都创建一个表,固定为 |
| 已创建的本地表名。 |
| 分片表达式,用于决定将数据写到哪个分片。
|
示例:
CREATE TABLE distributed_table ON CLUSTER default
AS default.local_table
ENGINE = Distributed(default, default, local_table, rand());
通过复制表结构创建表
您可以通过复制表结构创建与源表具有相同结构的表。
语法:
CREATE TABLE [IF NOT EXISTS] [db.]table_name2 ON CLUSTER cluster AS [db.]table_name1 [ENGINE = engine_name];
参数说明:
参数 | 说明 |
| 数据库的名称,默认为当前选择的数据库,本文以default为例。 |
| 被复制表结构的源表,本文以已创建的本地表local_table为例。 |
| 新创建的表。 |
| 在每一个节点上都创建一个表,固定为 |
| 表引擎类型。如果没有指定表引擎,默认与被复制表结构的表相同。 说明 云数据库ClickHouse支持的表引擎类型,请参见表引擎。 |
示例:
create table t2 ON CLUSTER default as default.local_table;
创建与查询结果集结构相同的表
使用指定的表引擎创建一个与SELECT
子句查询结果集相同结构的表,并使用SELECT子句的结果进行填充。
语法:
CREATE TABLE [IF NOT EXISTS] [db.]s_table_name ON CLUSTER cluster ENGINE = engine_name() AS SELECT ...
参数说明:
参数 | 说明 |
| 数据库的名称,默认为当前选择的数据库,本文以default为例。 |
| 通过SELECT语句创建的表。 |
| 在每一个节点上都创建一个表,固定为 |
| 表引擎类型。 说明 云数据库ClickHouse支持的表引擎类型,请参见表引擎。 |
|
|
示例:
create table t3 ON CLUSTER default ENGINE =MergeTree() order by Year as select * from default.local_table;
参考文档
创建表的更多信息,请参见CREATE TABLE。
通过复制表结构创建表的更多信息,请参见With a Schema Similar to Other Table。
通过SELECT语句创建表的更多信息,请参见From SELECT query。