MaxCompute支援通過INSERT INTO或INSERT OVERWRITE操作向動態分區中插入資料。
本文中的命令您可以在如下工具平台執行：
前提條件
執行insert into和insert overwrite操作前需要具備目標表的更新許可權（Update）及源表的元資訊讀取許可權（Select）。授權操作請參見MaxCompute許可權。
功能介紹
在使用MaxCompute SQL處理資料時，INSERT INTO或INSERT OVERWRITE語句中不直接指定分區值，只指定分區列名（分區欄位）。分區列的值在SELECT子句中提供，系統自動根據分區列的值將資料插入到相應分區。
向靜態分區插入資料的操作請參見插入或覆寫資料（INSERT INTO | INSERT OVERWRITE）。
使用限制
通過INSERT INTO和INSERT OVERWRITE操作向動態分區中插入資料的使用限制如下：
INSERT INTO最多可以產生10000個動態分區，INSERT OVERWRITE最多可以產生60000個動態分區。分布式環境下，在使用動態資料分割函數的SQL語句中，單個進程最多隻能輸出512個動態分區，否則會運行異常。
動態產生的分區值不允許為NULL，也不支援特殊字元和中文，否則會報錯
FAILED: ODPS-0123031:Partition exception - invalid dynamic partition value: province=xxx。說明分區值不能包含雙位元組字元（如中文），必須以字母開頭，包含字母、數字和允許的字元，長度不超過255位元組。允許的字元包括空格、冒號（:）、底線（_）、貨幣符號（$）、井號（#）、英文句點（.）、驚嘆號（!）和at（@），其他字元的行為未定義，例如逸出字元
\t、\n和/。聚簇表不支援動態分區。
注意事項
如果您需要更新表資料到動態分區，需要注意：
INSERT INTO PARTITION時，如果分區不存在，會自動建立分區。多個
INSERT INTO PARTITION作業並發時，如果分區不存在，優先執行成功的作業會自動建立分區，但只會成功建立一個分區。如果不能控制
INSERT INTO PARTITION作業並發，建議您通過ALTER TABLE命令提前建立分區，詳情請參見分區操作。如果目標表有多級分區，在執行
INSERT操作時，允許指定部分分區為靜態分區，但是靜態分區必須是進階分區。向動態分區插入資料時，動態分區列必須在
SELECT列表中，否則會執行失敗。
命令格式
INSERT {INTO|OVERWRITE} TABLE <table_name> PARTITION (<ptcol_name>[, <ptcol_name> ...])
<select_statement> FROM <from_statement>;參數說明
參數名 | 是否必填 | 描述 |
table_name | 是 | 需要插入資料的目標表名。 |
ptcol_name | 是 | 目標表分區列的名稱。 |
select_statement | 是 |
如果目標表只有一級動態分區，則 |
from_statement | 是 |
|
樣本資料
--建立一張分區表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);
--向源表增加分區。非必需操作，如果不提前建立，寫入時會自動建立該分區。
ALTER TABLE sale_detail ADD PARTITION (sale_date='2013', region='china');
--向源表追加資料。其中：insert into table table_name可以簡寫為insert into table_name，但insert overwrite table table_name不可以省略table關鍵字。
INSERT INTO sale_detail PARTITION (sale_date='2013', region='china') VALUES ('s1','c1',100.1),('s2','c2',100.2),('s3','c3',100.3);
--開啟全表掃描，僅此Session有效。執行select語句查看錶sale_detail中的資料。
SET odps.sql.allow.fullscan=true;
SELECT * FROM sale_detail;
--返回結果。
+------------+-------------+-------------+------------+------------+
| shop_name | customer_id | total_price | sale_date | region |
+------------+-------------+-------------+------------+------------+
| s1 | c1 | 100.1 | 2013 | china |
| s2 | c2 | 100.2 | 2013 | china |
| s3 | c3 | 100.3 | 2013 | china |
+------------+-------------+-------------+------------+------------+使用樣本
下述樣本中的sale_detail表資料均來自於樣本資料。
樣本1：將源表中的資料插入到目標表中。在運行SQL語句之前，您無法得知會產生哪些分區。只有在語句運行結束後，才能通過region欄位產生的值確定產生的分區。命令樣本如下：
--建立目標表total_revenues。 CREATE TABLE total_revenues (revenue DOUBLE) PARTITIONED BY (region string); --將源表sale_detail中的資料插入到目標表total_revenues。 SET odps.sql.allow.fullscan=true; INSERT OVERWRITE TABLE total_revenues PARTITION(region) SELECT total_price AS revenue, region FROM sale_detail; --執行SHOW PARTITIONS語句查看錶total_revenues的分區。 SHOW PARTITIONS total_revenues; --返回結果。 region=china --開啟全表掃描，僅此Session有效。執行SELECT語句查看錶total_revenues中的資料。 SET odps.sql.allow.fullscan=true; SELECT * FROM total_revenues; --返回結果。 +------------+------------+ | revenue | region | +------------+------------+ | 100.1 | china | | 100.2 | china | | 100.3 | china | +------------+------------+樣本2：將源表中的資料插入到目標表中。多級分區，指定一級分區sale_date。命令樣本如下：
--建立目標表sale_detail_dypart。 CREATE TABLE sale_detail_dypart LIKE sale_detail; --指定一級分區，將資料插入目標表。 SET odps.sql.allow.fullscan=true; INSERT OVERWRITE TABLE sale_detail_dypart PARTITION (sale_date='2013', region) SELECT shop_name,customer_id,total_price,region FROM sale_detail; --開啟全表掃描，僅此Session有效。執行select語句查看錶sale_detail_dypart中的資料。 SET odps.sql.allow.fullscan=true; SELECT * FROM sale_detail_dypart; --返回結果。 +------------+-------------+-------------+------------+------------+ | shop_name | customer_id | total_price | sale_date | region | +------------+-------------+-------------+------------+------------+ | s1 | c1 | 100.1 | 2013 | china | | s2 | c2 | 100.2 | 2013 | china | | s3 | c3 | 100.3 | 2013 | china | +------------+-------------+-------------+------------+------------+樣本3：動態分區中，select_statement欄位和目標表動態分區的對應關係是由欄位順序決定，並不是由列名稱決定的。命令樣本如下：
--將源表sale_detail中的資料插入到目標表sale_detail_dypart。 SET odps.sql.allow.fullscan=true; INSERT OVERWRITE TABLE sale_detail_dypart PARTITION (sale_date, region) SELECT shop_name,customer_id,total_price,sale_date,region FROM sale_detail; --開啟全表掃描，僅此Session有效。執行select語句查看錶sale_detail_dypart中的資料。 SET odps.sql.allow.fullscan=true; SELECT * FROM sale_detail_dypart; --返回結果。決定目標表sale_detail_dypart動態分區的欄位sale_date為源表sale_detail的欄位sale_date；決定目標表sale_detail_dypart動態分區的欄位region為源表sale_detail的欄位region。 +------------+-------------+-------------+------------+------------+ | shop_name | customer_id | total_price | sale_date | region | +------------+-------------+-------------+------------+------------+ | s1 | c1 | 100.1 | 2013 | china | | s2 | c2 | 100.2 | 2013 | china | | s3 | c3 | 100.3 | 2013 | china | +------------+-------------+-------------+------------+------------+ --將源表sale_detail中的資料插入到目標表sale_detail_dypart，調整select欄位順序。 SET odps.sql.allow.fullscan=true; INSERT OVERWRITE TABLE sale_detail_dypart PARTITION (sale_date, region) SELECT shop_name,customer_id,total_price,region,sale_date FROM sale_detail; --開啟全表掃描，僅此Session有效。執行select語句查看錶sale_detail_dypart中的資料。 SET odps.sql.allow.fullscan=true; SELECT * FROM sale_detail_dypart; --返回結果。決定目標表sale_detail_dypart動態分區的欄位sale_date為源表sale_detail的欄位region；決定目標表sale_detail_dypart動態分區的欄位region為源表sale_detail的欄位sale_date。 +------------+-------------+-------------+------------+------------+ | shop_name | customer_id | total_price | sale_date | region | +------------+-------------+-------------+------------+------------+ | s1 | c1 | 100.1 | china | 2013 | | s2 | c2 | 100.2 | china | 2013 | | s3 | c3 | 100.3 | china | 2013 | | s1 | c1 | 100.1 | 2013 | china | | s2 | c2 | 100.2 | 2013 | china | | s3 | c3 | 100.3 | 2013 | china | +------------+-------------+-------------+------------+------------+樣本4（錯誤樣本）：向動態分區插入資料時，動態分區列必須在
SELECT列表中，否則會執行失敗。錯誤命令樣本如下：INSERT OVERWRITE TABLE sale_detail_dypart PARTITION (sale_date='2013', region) SELECT shop_name,customer_id,total_price FROM sale_detail;返回結果如下：
FAILED: ODPS-0130071:[1,24] Semantic analysis exception - wrong columns count 3 in data source, requires 4 columns (includes dynamic partitions if any)樣本5（錯誤樣本）：向動態分區插入資料時，不能僅指定低級子分區，而動態插入進階分區，否則會執行失敗。錯誤命令樣本如下：
INSERT OVERWRITE TABLE sale_detail_dypart PARTITION (sale_date, region='china') SELECT shop_name,customer_id,total_price,sale_date FROM sale_detail_dypart;返回結果如下：
FAILED: ODPS-0130071:[1,72] Semantic analysis exception - static partition region must be a high level partition than any dynamic partitions樣本6：MaxCompute在向動態分區插入資料時，如果分區列的類型與對應
SELECT中列的類型不嚴格一致，會進行隱式轉換，命令樣本如下：--建立源表src。 CREATE TABLE src (c INT, d STRING) PARTITIONED BY (e INT); --向源表src增加分區。 ALTER TABLE src ADD IF NOT EXISTS PARTITION (e=201312); --向源表src追加資料。 INSERT INTO src PARTITION (e=201312) VALUES (1,100.1),(2,100.2),(3,100.3); --建立目標表parttable。 CREATE TABLE parttable(a INT, b DOUBLE) PARTITIONED BY (p STRING); --將源表src資料插入目標表parttable。 SET odps.sql.allow.fullscan=true; INSERT INTO parttable PARTITION (p) SELECT c, d, CURRENT_TIMESTAMP() FROM src; --查詢目標表parttable。 SET odps.sql.allow.fullscan=true; SELECT * FROM parttable; --返回結果樣本如下。 +------------+------------+------------+ | a | b | p | +------------+------------+------------+ | 1 | 100.1 | 2024-12-10 15:59:34.492 | | 2 | 100.2 | 2024-12-10 15:59:34.492 | | 3 | 100.3 | 2024-12-10 15:59:34.492 | +------------+------------+------------+說明如果您的資料是有序的，動態分區插入會把資料隨機打散，導致壓縮率較低。推薦您使用Tunnel命令上傳資料到動態分區，以擷取較好的壓縮率。使用該命令的詳細樣本請參見RDS遷移至MaxCompute實現動態分區。