描述

该语句用来在数据库中创建一张新表。

格式

  1. CREATE [TEMPORARY] TABLE [IF NOT EXISTS] table_name
  2. (table_definition_list) [table_option_list] [partition_option] [AS] select;
  3. CREATE [TEMPORARY] TABLE [IF NOT EXISTS] table_name
  4. LIKE table_name;
  5. table_definition_list:
  6. table_definition [, table_definition ...]
  7. table_definition:
  8. column_definition
  9. | [CONSTRAINT [constraint_name]] PRIMARY KEY index_desc
  10. | [CONSTRAINT [constraint_name]] UNIQUE {INDEX | KEY} [index_name] index_desc
  11. | {INDEX | KEY} [index_name] index_desc
  12. | FULLTEXT [INDEX | KEY] [index_name] fulltext_index_desc
  13. column_definition_list:
  14. column_definition [, column_definition ...]
  15. column_definition:
  16. column_name data_type
  17. [DEFAULT const_value] [AUTO_INCREMENT]
  18. [NULL | NOT NULL] [[PRIMARY] KEY] [UNIQUE [KEY]] comment
  19. index_desc:
  20. (column_desc_list) [index_type] [index_option_list]
  21. fulltext_index_desc:
  22. (column_desc_list) CTXCAT(column_desc_list) [index_option_list]
  23. column_desc_list:
  24. column_desc [, column_desc ...]
  25. column_desc:
  26. column_name [(length)] [ASC | DESC]
  27. index_type:
  28. USING BTREE
  29. index_option_list:
  30. index_option [ index_option ...]
  31. index_option:
  32. [GLOBAL | LOCAL]
  33. | block_size
  34. | compression
  35. | STORING(column_name_list)
  36. | comment
  37. table_option_list:
  38. table_option [ table_option ...]
  39. table_option:
  40. [DEFAULT] {CHARSET | CHARACTER SET} [=] charset_name
  41. | [DEFAULT] COLLATE [=] collation_name
  42. | primary_zone
  43. | replica_num
  44. | table_tablegroup
  45. | block_size
  46. | compression
  47. | AUTO_INCREMENT [=] INT_VALUE
  48. | comment
  49. | DUPLICATE_SCOPE [=] "none|zone|region|cluster"
  50. | LOCALITY [=] "locality description"
  51. | ROW_FORMAT [=] REDUNDANT|COMPACT|DYNAMIC|COMPRESSED|DEFAULT
  52. | PCTFREE [=] num
  53. | parallel_clause
  54. parallel_clause:
  55. {NOPARALLEL | PARALLEL integer}
  56. partition_option:
  57. PARTITION BY HASH(expression)
  58. [subpartition_option] PARTITIONS partition_count
  59. | PARTITION BY KEY([column_name_list])
  60. [subpartition_option] PARTITIONS partition_count
  61. | PARTITION BY RANGE {(expression) | COLUMNS (column_name_list)}
  62. [subpartition_option] (range_partition_list)
  63. | PARTITION BY LIST {(expression) | COLUMNS (column_name_list)}
  64. [subpartition_option] PARTITIONS partition_count
  65. subpartition_option:
  66. SUBPARTITION BY HASH(expression)
  67. SUBPARTITIONS subpartition_count
  68. | SUBPARTITION BY KEY(column_name_list)
  69. SUBPARTITIONS subpartition_count
  70. | SUBPARTITION BY RANGE {(expression) | COLUMNS (column_name_list)}
  71. (range_subpartition_list)
  72. | SUBPARTITION BY LIST(expression)
  73. range_partition_list:
  74. range_partition [, range_partition ...]
  75. range_partition:
  76. PARTITION partition_name
  77. VALUES LESS THAN {(expression_list) | MAXVALUE}
  78. range_subpartition_list:
  79. range_subpartition [, range_subpartition ...]
  80. range_subpartition:
  81. SUBPARTITION subpartition_name
  82. VALUES LESS THAN {(expression_list) | MAXVALUE}
  83. expression_list:
  84. expression [, expression ...]
  85. column_name_list:
  86. column_name [, column_name ...]
  87. partition_name_list:
  88. partition_name [, partition_name ...]
  89. partition_count | subpartition_count:
  90. INT_VALUE

参数说明

参数

描述

DUPLICATE_SCOPE

用来指定复制表属性,取值如下:

  • none:表示该表是一个普通表

  • zone:表示该表是一个复制表,leader 需要将事务复制到本 zone 的所有 F 副本及 R 副本

  • region:表示该表是一个复制表,leader 需要将事务复制到本 region 的所有 F 副本及 R 副本

  • cluster:表示该表是一个复制表,leader 需要将事务复掉到 cluster 的所有 F 副本及 R 副本

不指定 DUPLICATE_SCOPE 的情况下,默认值为 none。

ROW_FORMAT

指定表是否开启 encoding 存储格式

  • redundant

    • 不开启 encoding 存储格式

  • compact

    • 不开启 encoding 存储格式

  • dynamic

    • encoding 存储格式

  • compressed

    • encoding 存储格式

  • default

    • 等价 dynamic 模式

BLOCK_SIZE

指定表的微块大小

COMPRESSION

指定表的压缩算法,取值如下:

  1. none:不使用压缩算法

  2. lz4_1.0: 使用 lz4 压缩算法

  3. zstd_1.0: 使用 zstd 压缩算法

  4. snappy_1.0: 使用 snappy 压缩算法

CHARSET | CHARACTER SET

指定表中列的默认字符集,可使用:utf8, utf8mb4, gbk, utf16, gb18030

COLLATE

指定表中列的默认比较规则,可使用:

utf8_bin, utf8_general_ci, utf8_unicode_ci, gbk_bin, gbk_chinese_ci, utf8mb4_general_ci, utf8mb4__general_cs, utf8mb4_bin, utf8mb4_unicode_ci, utf16_general_ci, utf16_bin, utf16_unicode_ci, gb18030_chinese_ci, gb18030_bin

primary_zone

指定主 Zone(副本 Leader 所在 Zone)。

replica_num

指定副本数。

table_tablegroup

指定表所属的 talegroup。

AUTO_INCREMENT

指定表中自增列的初始值。

comment

注释。

LOCALITY

描述副本在 Zone 间的分布情况,如:F@z1,F@z2,F@z3,R@z4 表示 z1, z2, z3 为全功能副本,z4 为只读副本。

PCTFREE

指定宏块保留空间百分比。

parallel_clause

指定表级别的并行度:

  • NOPARALLEL:并行度为 1,默认配置

  • PARALLEL integer:指定并行度,integer 取值大于等于 1。

举例

  • 创建数据库表。
  1. CREATE TABLE test (c1 int primary key, c2 VARCHAR(50)) REPLICA_NUM = 3, PRIMARY_ZONE = 'zone1';
  • 创建一个复制表。
  1. CREATE TABLE item(id int, name varchar(10)) DUPLICATE_SCOPE="cluster";
  • 创建带索引的表。
  1. CREATE TABLE t1 (c1 int primary key, c2 int, c3 int, index i1 (c2));
  • 创建 hash 分区,分区数为 8 的表。
  1. CREATE TABLE t1 (c1 int primary key, c2 int) partition by hash(c1) partitions 8;
  • 创建一级分区为 range 分区,二级分区为 key 分区的表。
  1. CREATE TABLE t1 (c1 int, c2 int, c3 int)
  2. partition by range(c1) subpartition by key(c2, c3) subpartitions 5
  3. (partition p0 values less than(0), partition p1 values less than(100));
  • 创建一列为 gbk, 一列为 utf8 的表。
  1. CREATE TABLE t1 (c1 varchar(10),
  2. c2 varchar(10) charset gbk collate gbk_bin)
  3. default charset utf8 collate utf8mb4_general_ci;
  • 开启 encoding 并使用 zstd 压缩,宏块保留空间为 5%。
  1. CREATE TABLE t1 (c1 int, c2 int, c3 varchar(64))
  2. compression 'zstd_1.0'
  3. ROW_FORMAT dynamic
  4. pctfree 5;
  • 创建表 t1,并设置并行度为 3。
  1. create table t1(c1 int primary key, c2 int) parallel 3;