限制條件

• 分區表的分區層級不能超過6級。例如某張表以日期為分區列，分區層級為年/月/周/日/時/分。

• 一張表允許的分區個數支持按照具體的項目配置，默認為6萬個。

更多表的限制條件，請參見SQL使用限制項。

命令格式

創建內部表

CREATE [OR REPLACE] TABLE [IF NOT EXISTS] <table_name> (
<col_name> <data_type>, ... )
[comment <table_comment>]
[PATITIONED BY (<col_name> <data_type> [comment <col_comment>], ...)];

創建聚簇表

CREATE TABLE [IF NOT EXISTS] <table_name> (
<col_name> <data_type>, ... )
[CLUSTERED BY | RANGE CLUSTERED BY (<col_name> [, <col_name>, ...]) 
[SORTED BY (<col_name> [ASC | DESC] [, <col_name> [ASC | DESC] ...])] 
INTO <number_of_buckets> buckets];

創建外部表

以OSS外部表為例，通過內置文本數據解析器創建外部表。

CREATE EXTERNAL TABLE [IF NOT EXISTS] <mc_oss_extable_name> ( 
<col_name> <data_type>, ... ) 
STORED AS '<file_format>' 
[WITH SERDEPROPERTIES (options)]  
LOCATION '<oss_location>';

創建表并指定表類型

• 指定表為Transactional表。后續可以對該表執行更新或刪除表數據操作，但是Transactional表有部分使用限制，請根據需求創建。

  CREATE [EXTERNAL] TABLE [IF NOT EXISTS] <table_name> (
  <col_name <data_type> [NOT NULL] [DEFAULT <default_value>] [comment <col_comment>], ...   
  [PRIMARY KEY (<pk_col_name>[, <pk_col_name2>, ...] )])
  [comment <table_comment>]
  [TBLPROPERTIES ("transactional"="true")];

• 指定表為Delta Table表。結合PRIMARY KEY，后續可以做upsert、增量查詢和Time Travel等操作。

  CREATE [EXTERNAL] TABLE [IF NOT EXISTS] <table_name> (
  <col_name <data_type> [NOT NULL] [DEFAULT <default_value>] [comment <col_comment>], ...   
  [PRIMARY KEY (<pk_col_name>[, <pk_col_name2>, ...] )]) 
  [comment <table_comment>]
  [TBLPROPERTIES ("transactional"="true" 
  [, "write.bucket.num" = "N", "acid.data.retain.hours"="hours"...])] [lifecycle <days>];

基于已存在表創建新表

• 基于已存在的表創建新表并復制數據，但不復制分區屬性。支持外部表和湖倉一體外部項目中的表。

  CREATE TABLE [IF NOT EXISTS] <table_name> [LIFECYCLE <days>] AS <select_statement>;

• 基于已存在的表創建具備相同結構的新表，但不復制數據。支持外部表和湖倉一體外部項目中的表。

  CREATE TABLE [IF NOT EXISTS] <table_name> [LIFECYCLE <days>] LIKE <existing_table_name>;

參數說明

DROP TABLE IF EXISTS <tableName>;  -- 假如目標表存在，則先刪除它
CREATE TABLE <tableName> ...;      -- 創建表

使用示例

創建非分區表

CREATE TABLE test1 (key STRING);

創建分區表

創建一張分區表sale_detail。

CREATE TABLE IF NOT EXISTS sale_detail(
 shop_name     STRING,
 customer_id   STRING,
 total_price   DOUBLE)
PARTITIONED BY (sale_date STRING, region STRING);

創建新表替換原表

1. 創建原有表mytable，并寫入數據。

   CREATE OR REPLACE TABLE my_table(a bigint);
   
   INSERT INTO my_table(a) VALUES (1),(2),(3);

2. 使用OR REPLACE創建新的同名表，并修改字段。

   CREATE OR REPLACE TABLE my_table(b string);

3. 查詢my_table表，返回結果如下。

   +------------+
   | b          | 
   +------------+
   +------------+

以下為非法的SQL語句：

CREATE OR REPLACE TABLE IF NOT EXISTS my_table(b STRING);
CREATE OR REPLACE TABLE my_table AS SELECT;
CREATE OR REPLACE TABLE my_table LIKE newtable;

創建新表并復制已有表數據至新表

創建新表，將已有表數據復制到新表，并設置生命周期。

-- 創建一個新表sale_detail_ctas1，將sale_detail的數據復制到sale_detail_ctas1中，并設置生命周期。
SET odps.sql.allow.fullscan=true;
CREATE TABLE sale_detail_ctas1 LIFECYCLE 10 AS SELECT * FROM sale_detail;

您可以通過DESC EXTENDED sale_detail_ctas1;命令查看到表的結構及生命周期等詳細信息。

創建新表并將SELECT語句常量作為列值

• 指定列的名字。

  SET odps.sql.allow.fullscan=true;
  CREATE TABLE sale_detail_ctas2
  AS
  SELECT shop_name, customer_id, total_price, '2013' AS sale_date, 'China' AS region
  FROM sale_detail;

• 不指定列的名字。

  SET odps.sql.allow.fullscan=true;
  
  CREATE TABLE sale_detail_ctas3
  AS
  SELECT shop_name, customer_id, total_price, '2013', 'China' 
  FROM sale_detail;

創建新表與已有表結構相同

創建新表，與已有表的結構相同，并設置生命周期。

CREATE TABLE sale_detail_like LIKE sale_detail LIFECYCLE 10;

您可以通過DESC EXTENDED sale_detail_like;命令查看到表的結構及生命周期等詳細信息。

創建新表與外部表結構相同

-- 創建一個新表mc_oss_extable_orc_like，與外部表mc_oss_extable_orc具有相同的表結構。
CREATE TABLE mc_oss_extable_orc_like LIKE mc_oss_extable_orc;

您可以通過DESC mc_oss_extable_orc_like;命令查看表結構等詳細信息。

+------------------------------------------------------------------------------------+
| Owner: ALIYUN$****@***.aliyunid.com | Project: max_compute_7u************yoq              |
| TableComment:                                                                      |
+------------------------------------------------------------------------------------+
| CreateTime:               2022-08-11 11:10:47                                      |
| LastDDLTime:              2022-08-11 11:10:47                                      |
| LastModifiedTime:         2022-08-11 11:10:47                                      |
+------------------------------------------------------------------------------------+
| InternalTable: YES      | Size: 0                                                  |
+------------------------------------------------------------------------------------+
| Native Columns:                                                                    |
+------------------------------------------------------------------------------------+
| Field           | Type       | Label | Comment                                     |
+------------------------------------------------------------------------------------+
| id              | string     |       |                                             |
| name            | string     |       |                                             |
+------------------------------------------------------------------------------------+

創建使用新數據類型的表

SET odps.sql.type.system.odps2=true;
CREATE TABLE test_newtype (
    c1 TINYINT,
    c2 SMALLINT,
    c3 INT,
    c4 BIGINT,
    c5 FLOAT,
    c6 DOUBLE,
    c7 DECIMAL,
    c8 BINARY,
    c9 TIMESTAMP,
    c10 ARRAY<MAP<BIGINT,BIGINT>>,
    c11 MAP<STRING,ARRAY<BIGINT>>,
    c12 STRUCT<s1:STRING,s2:BIGINT>,
    c13 VARCHAR(20))
LIFECYCLE 1;

創建Hash聚簇表

• 非分區表

  CREATE TABLE t1 (a STRING, b STRING, c BIGINT) CLUSTERED BY (c) SORTED BY (c) INTO 1024 buckets;

• 分區表

  CREATE TABLE t2 (a STRING, b STRING, c BIGINT) 
  PARTITIONED BY (dt STRING) CLUSTERED BY (c) SORTED BY (c) into 1024 buckets;

創建Range聚簇表

• 非分區表

  CREATE TABLE t3 (a STRING, b STRING, c BIGINT) RANGE CLUSTERED BY (c) SORTED BY (c) INTO 1024 buckets;

• 分區表

  CREATE TABLE t4 (a STRING, b STRING, c BIGINT) 
  PARTITIONED BY (dt STRING) RANGE CLUSTERED BY (c) SORTED BY (c); 

創建Transactional表

• 非分區表

  CREATE TABLE t5(id bigint) tblproperties("transactional"="true");

• 分區表

  CREATE TABLE IF NOT EXISTS t6(id bigint) 
  PARTITIONED BY (ds string) tblproperties ("transactional"="true");

創建非分區表并為字段指定默認值

CREATE TABLE test_default( 
tinyint_name tinyint NOT NULL default 1Y,
smallint_name SMALLINT NOT NULL DEFAULT 1S,
int_name INT NOT NULL DEFAULT 1,
bigint_name BIGINT NOT NULL DEFAULT 1,
binary_name BINARY ,
float_name FLOAT ,
double_name DOUBLE NOT NULL DEFAULT 0.1,
decimal_name DECIMAL(2, 1) NOT NULL DEFAULT 0.0BD,
varchar_name VARCHAR(10) ,
char_name CHAR(2) ,
string_name STRING NOT NULL DEFAULT 'N',
boolean_name BOOLEAN NOT NULL DEFAULT TRUE
);

創建內部表并復制外部分區表數據

• 內部表不包含分區屬性。

  1. 創建OSS外部表和MaxCompute內部表。

     -- 創建oss外部表并插入數據。
     CREATE EXTERNAL table max_oss_test(a int, b int, c int) 
     stored AS TEXTFILE
     location "oss://oss-cn-hangzhou-internal.aliyuncs.com/<bucket_name>";
     
     INSERT INTO max_oss_test VALUES 
     (101, 1, 20241108),
     (102, 2, 20241109),
     (103, 3, 20241110);
     
     SELECT * FROM max_oss_test;
     
     -- 結果
     a    b    c
     101    1    20241108
     102    2    20241109
     103    3    20241110
     
     
     -- 使用create table as創建內部表
     CREATE TABLE from_exetbl_oss AS SELECT * FROM max_oss_test;
     
     -- 查詢新建內部表
     SELECT * FROM from_exetbl_oss;
     
     -- 返回結果，全表數據都有
     a    b    c
     101    1    20241108
     102    2    20241109
     103    3    20241110

  2. 執行DESC from_exetbl_as_par；查詢內部表結構。返回結果如下。

     +------------------------------------------------------------------------------------+
     | Owner:                    ALIYUN$***********                                       |
     | Project:                  ***_*****_***                                            |
     | TableComment:                                                                      |
     +------------------------------------------------------------------------------------+
     | CreateTime:               2023-01-10 15:16:33                                      |
     | LastDDLTime:              2023-01-10 15:16:33                                      |
     | LastModifiedTime:         2023-01-10 15:16:33                                      |
     +------------------------------------------------------------------------------------+
     | InternalTable: YES      | Size: 919                                                |
     +------------------------------------------------------------------------------------+
     | Native Columns:                                                                    |
     +------------------------------------------------------------------------------------+
     | Field           | Type       | Label | Comment                                     |
     +------------------------------------------------------------------------------------+
     | a               | string     |       |                                             |
     | b               | string     |       |                                             |
     | c               | string     |       |                                             |
     +------------------------------------------------------------------------------------+

• 內部表包含分區屬性。

  1. 創建內部表from_exetbl_like。

     -- MaxCompute側查詢湖倉一體外部表
     SELECT * FROM max_oss_test;
     -- 返回結果
     a    b    c
     101    1    20241108
     102    2    20241109
     103    3    20241110
     
     -- 使用create table like創建內部表
     CREATE TABLE from_exetbl_like LIKE max_oss_test;
     
     -- 查詢新建內部表
     SELECT * FROM from_exetbl_like;
     -- 返回結果，只有表結構出現
     a    b    c

  2. 執行DESC from_exetbl_like；查詢內部表結構。返回結果如下。

     +------------------------------------------------------------------------------------+
     | Owner:                    ALIYUN$************                                      |
     | Project:                  ***_*****_***                                            |
     | TableComment:                                                                      |
     +------------------------------------------------------------------------------------+
     | CreateTime:               2023-01-10 15:09:47                                      |
     | LastDDLTime:              2023-01-10 15:09:47                                      |
     | LastModifiedTime:         2023-01-10 15:09:47                                      |
     +------------------------------------------------------------------------------------+
     | InternalTable: YES      | Size: 0                                                  |
     +------------------------------------------------------------------------------------+
     | Native Columns:                                                                    |
     +------------------------------------------------------------------------------------+
     | Field           | Type       | Label | Comment                                     |
     +------------------------------------------------------------------------------------+
     | a               | string     |       |                                             |
     | b               | string     |       |                                             |
     +------------------------------------------------------------------------------------+
     | Partition Columns:                                                                 |
     +------------------------------------------------------------------------------------+
     | c               | string     |                                                     |
     +------------------------------------------------------------------------------------+

相關命令

• ALTER TABLE：修改表操作。

• TRUNCATE：將指定表中的數據清空。

• DROP TABLE：刪除分區表或非分區表。

• DESC TABLE/VIEW：查看MaxCompute內部表、視圖、物化視圖、外部表、聚簇表或Transactional表的信息。

• SHOW：查看表的SQL DDL語句、列出項目下所有的表和視圖或列出一張表中的所有分區。