我的书签
添加书签
移除书签CREATE
CREATE 用于创建新的数据库或者表。
CREATE DATABASE
Syntax
创建新数据库：
sql
1. CREATE DATABASE [IF NOT EXISTS] db_name
如果 db_name 数据库已经存在，CREATE 语句的行为如下：
- 不会创建新的数据库。
- 当
IF NOT EXISTS子句被指定时，不会返回错误。 - 否则，返回错误。
示例
创建名为 test 的数据库：
sql
1. CREATE DATABASE test;
sql
1. Query OK, 1 row affected (0.05 sec)
使用 IF NOT EXISTS 再次创建：
sql
1. CREATE DATABASE IF NOT EXISTS test;
CREATE TABLE
Syntax
在 db 或当前数据库中创建新表：
sql
1. CREATE TABLE [IF NOT EXISTS] [db.]table_name
2. (
3. column1 type1 [NULL | NOT NULL] [DEFAULT expr1] [TIME INDEX] [PRIMARY KEY] [COMMENT comment1],
4. column2 type2 [NULL | NOT NULL] [DEFAULT expr2] [TIME INDEX] [PRIMARY KEY] [COMMENT comment2],
5. ...
6. [TIME INDEX (column)],
7. [PRIMARY KEY(column1, column2, ...)]
8. ) ENGINE = engine WITH([TTL | REGIONS] = expr, ...)
9. [
10. PARTITION BY RANGE COLUMNS(column1, column2, ...) (
11. PARTITION r0 VALUES LESS THAN (expr1),
12. PARTITION r1 VALUES LESS THAN (expr2),
13. ...
14. )
15. ]
表 schema 由 ENGINE 之前的括号指定，表 schema 是列的定义和表的约束。 列定义包括列名称和数据类型，以及可选的 NULL、NOT NULL、DEFAULT 等。
表约束
表约束包括以下内容：
TIME INDEX指定时间索引列，每个表只能有一个时间索引列。它表示 GreptimeDB 的 数据模型 中的Timestamp类型。PRIMARY KEY指定表的主键列，它表示 GreptimeDB 的 数据模型 中的Tag类型。它不能包含时间索引列，但是它总是隐式地将时间索引列添加到键的末尾。- 其他列是 GreptimeDB 的 数据模型 中的
Field类型。
注意
CREATE 语句中指定的 PRIMARY KEY 不是 传统关系数据库中的主键。 实际上，传统关系数据库中的 PRIMARY KEY 相当于 GreptimeDB 中的 PRIMARY KEY 和 TIME INDEX 的组合。 换句话说，PRIMARY KEY 和 TIME INDEX 一起构成了 GreptimeDB 中行的唯一标识符。
如果表已经存在且创建表时指定了 IF NOT EXISTS，CREATE 语句不会返回错误；否则返回错误。
表选项
用户可以使用 WITH 添加表选项。有效的选项包括以下内容：
| 选项 | 描述 | 值 |
|---|---|---|
ttl |
表数据的存储时间 | 字符串值，例如 ‘60m’, ‘1h’ 代表 1 小时， ‘14d’ 代表 14 天等。支持的时间单位有：s / m / h / d |
regions |
表的 region 值 | 整数值，例如 1, 5, 10 etc. |
write_buffer_size |
表的 memtable 大小 | 表示有效大小的字符串值，例如 32MB, 128MB 等。默认值为 32MB。支持的单位有：MB / GB. |
storage |
自定义表的存储引擎，存储引擎提供商的名字 | 字符串，类似 S3、Gcs 等。 必须在 [[storage.providers]] 列表里配置, 参考 configuration。 |
例如，创建一个存储数据 TTL(Time-To-Live) 为七天，region 数为 10 的表：
sql
1. CREATE TABLE IF NOT EXISTS temperatures(
2. ts TIMESTAMP TIME INDEX,
3. temperature DOUBLE DEFAULT 10,
4. ) engine=mito with(ttl='7d', regions=10);
或者创建一个表单独将数据存储在 Google Cloud Storage 服务上：
sql
1. CREATE TABLE IF NOT EXISTS temperatures(
2. ts TIMESTAMP TIME INDEX,
3. temperature DOUBLE DEFAULT 10,
4. ) engine=mito with(ttl='7d', regions=10, storage="Gcs");
列选项
GreptimeDB 支持以下列选项：
| 选项 | 描述 |
|---|---|
| NULL | 列值可以为 null |
| NOT NULL | 列值不能为 null |
DEFAULT expr |
该列的默认值是 expr，其类型必须是该列的类型 |
COMMENT comment |
列注释，必须为字符串类型 |
表约束 TIME INDEX 和 PRIMARY KEY 也可以通过列选项设置，但是它们只能在列定义中指定一次，在多个列选项中指定 PRIMARY KEY 会报错：
sql
1. CREATE TABLE system_metrics (
2. host STRING PRIMARY KEY,
3. idc STRING PRIMARY KEY,
4. cpu_util DOUBLE,
5. memory_util DOUBLE,
6. disk_util DOUBLE,
7. ts TIMESTAMP DEFAULT CURRENT_TIMESTAMP(),
8. TIME INDEX(ts)
9. );
会得到报错：
sql
1. Illegal primary keys definition: not allowed to inline multiple primary keys in columns options
正确的做法是使用 PRIMARY KEY() 来指定多个列作为主键：
sql
1. CREATE TABLE system_metrics (
2. host STRING,
3. idc STRING,
4. cpu_util DOUBLE,
5. memory_util DOUBLE,
6. disk_util DOUBLE,
7. ts TIMESTAMP DEFAULT CURRENT_TIMESTAMP() TIME INDEX,
8. PRIMARY KEY(host, idc),
9. );
sql
1. Query OK, 0 rows affected (0.01 sec)
Region partition rules
TODO by MichaelScofield
CREATE EXTERNAL TABLE
Syntax
在 db 或当前数据库中创建新的文件外部表：
sql
1. CREATE EXTERNAL TABLE [IF NOT EXISTS] [db.]table_name
2. [
3. (
4. column1 type1 [NULL | NOT NULL] [DEFAULT expr1] [TIME INDEX] [PRIMARY KEY] [COMMENT comment1],
5. column2 type2 [NULL | NOT NULL] [DEFAULT expr2] [TIME INDEX] [PRIMARY KEY] [COMMENT comment2],
6. ...
7. [TIME INDEX (column)],
8. [PRIMARY KEY(column1, column2, ...)]
9. )
10. ] WITH (
11. LOCATION = url,
12. FORMAT = { 'CSV' | 'JSON' | 'PARQUET' | 'ORC' }
13. [,PATTERN = regex_pattern ]
14. [,REGION = region ]
15. [,ENDPOINT = uri ]
16. [,ACCESS_KEY_ID = key_id ]
17. [,SECRET_ACCESS_KEY = access_key ]
18. [,ENABLE_VIRTUAL_HOST_STYLE = { TRUE | FALSE }]
19. [,SESSION_TOKEN = token ]
20. ...
21. )
表选项
| 选项 | 描述 | 是否必需 |
|---|---|---|
LOCATION |
外部表的位置，例如 s3://<bucket>[<path>], /<path>/[<filename>] |
是 |
FORMAT |
目标文件的格式，例如 JSON，CSV，Parquet, ORC | 是 |
PATTERN |
使用正则来匹配文件，例如 *_today.parquet |
可选 |
S3
| 选项 | 描述 | 是否必需 |
|---|---|---|
REGION |
AWS region 名称，例如 us-east-1 | 是 |
ENDPOINT |
The bucket endpoint | 可选 |
ACCESS_KEY_ID |
用于连接 AWS S3 兼容对象存储的访问密钥 ID | 可选 |
SECRET_ACCESS_KEY |
用于连接 AWS S3 兼容对象存储的秘密访问密钥 | 可选 |
ENABLE_VIRTUAL_HOST_STYLE |
如果你想要使用 virtual hosting 来定位 bucket，将其设置为 true |
可选 |
SESSION_TOKEN |
用于连接 AWS S3 服务的临时凭证 | 可选 |
时间索引列
在利用 CREATE EXTERNAL TABLE 语句创建外部表时，要求使用 TIME INDEX 约束来指定一个时间索引列。
示例
你可以在创建外部表时不带有列定义，列定义将会被自动推断：
sql
1. CREATE EXTERNAL TABLE IF NOT EXISTS city WITH (location='/var/data/city.csv',format='csv');
在这个例子中，我们没有明确定义表的列，为满足外边表必须指定时间索引列的要求，CREATE EXTERNAL TABLE 语句会依据下述规则推断出时间索引列：
- 如果可以从文件元数据中推断出时间索引列，那么就用该列作为时间索引列。
- 如果存在名为
greptime_timestamp的列（该列的类型必须为TIMESTAMP，否则将抛出错误），那么就用该列作为时间索引列。 - 否则，将自动创建名为
greptime_timestamp的列作为时间索引列，并添加DEFAULT '1970-01-01 00:00:00+0000'约束。
或者带有列定义：
sql
1. CREATE EXTERNAL TABLE city (
2. host string,
3. ts timestamp,
4. cpu float64 default 0,
5. memory float64,
6. TIME INDEX (ts),
7. PRIMARY KEY(host)
8. ) WITH (location='/var/data/city.csv', format='csv');
在这个例子中，我们明确定义了 ts 列作为时间索引列。如果在文件中没有适合的时间索引列，你也可以创建一个占位符列，并添加 DEFAULT expr 约束。
