W3Cschool
恭喜您成為首批注冊(cè)用戶(hù)
獲得88經(jīng)驗(yàn)值獎(jiǎng)勵(lì)
INSERT 算子用于將指定的數(shù)據(jù)插入數(shù)據(jù)表,數(shù)據(jù)來(lái)源包括直接指定的值和子查詢(xún)的結(jié)果。
OceanBase 數(shù)據(jù)庫(kù)支持的 INSERT 算子包括 INSERT 和 MULTI PARTITION INSERT。
INSERT 算子用于向數(shù)據(jù)表的單個(gè)分區(qū)中插入數(shù)據(jù)。
如下例所示,Q1 查詢(xún)將值 (1, '100') 插入到非分區(qū)表 t1 中。其中 1 號(hào)算子 EXPRESSION 用來(lái)生成常量表達(dá)式的值。
obclient>CREATE TABLE t1 (c1 INT PRIMARY KEY, c2 VARCHAR2(10));
Query OK, 0 rows affected (0.12 sec)
obclient>CREATE TABLE t2 (c1 INT PRIMARY KEY, c2 VARCHAR2(10)) PARTITION BY
HASH(c1) PARTITIONS 10;
Query OK, 0 rows affected (0.12 sec)
obclient>CREATE TABLE t3 (c1 INT PRIMARY KEY, c2 VARCHAR2(10));
Query OK, 0 rows affected (0.12 sec)
obclient>CREATE INDEX IDX_t3_c2 ON t3 (c2) PARTITION BY HASH(c2) PARTITIONS 3;
Query OK, 0 rows affected (0.12 sec)
Q1:
obclient>EXPLAIN INSERT INTO t1 VALUES (1, '100')\G;
*************************** 1. row ***************************
Query Plan:
====================================
|ID|OPERATOR |NAME|EST. ROWS|COST|
------------------------------------
|0 |INSERT | |1 |1 |
|1 | EXPRESSION| |1 |1 |
====================================
Outputs & filters:
-------------------------------------
0 - output([__values.C1], [__values.C2]), filter(nil),
columns([{T1: ({T1: (T1.C1, T1.C2)})}]), partitions(p0)
1 - output([__values.C1], [__values.C2]), filter(nil)
values({1, '100'})
上述示例中,執(zhí)行計(jì)劃展示中的 outputs & filters 詳細(xì)列出了 INSERT 算子的輸出信息如下:
信息名稱(chēng) |
含義 |
---|---|
output |
該算子輸出的表達(dá)式。 |
filter |
該算子上的過(guò)濾條件。 由于示例中 INSERT 算子沒(méi)有設(shè)置 filter,所以為 nil。 |
columns |
插入操作涉及的數(shù)據(jù)表的列。 |
partitions |
插入操作涉及到的數(shù)據(jù)表的分區(qū)(非分區(qū)表可以認(rèn)為是一個(gè)只有一個(gè)分區(qū)的分區(qū)表)。 |
更多 INSERT 算子的示例如下:
Q2 查詢(xún)將值(2, '200')、(3, '300')插入到表 t1 中。
Q2:
obclient>EXPLAIN INSERT INTO t1 VALUES (2, '200'),(3, '300')\G;
*************************** 1. row ***************************
Query Plan:
====================================
|ID|OPERATOR |NAME|EST. ROWS|COST|
------------------------------------
|0 |INSERT | |2 |1 |
|1 | EXPRESSION| |2 |1 |
====================================
Outputs & filters:
-------------------------------------
0 - output([__values.C1], [__values.C2]), filter(nil),
columns([{T1: ({T1: (T1.C1, T1.C2)})}]), partitions(p0)
1 - output([__values.C1], [__values.C2]), filter(nil)
values({2, '200'}, {3, '300'})
Q3 查詢(xún)將子查詢(xún) SELECT * FROM t3
的結(jié)果插入到表 t1 中。
Q3:
obclient>EXPLAIN INSERT INTO t1 SELECT * FROM t3\G;
*************************** 1. row ***************************
Query Plan:
====================================
|0 |INSERT | |100000 |117862|
|1 | EXCHANGE IN DISTR | |100000 |104060|
|2 | EXCHANGE OUT DISTR| |100000 |75662 |
|3 | SUBPLAN SCAN |VIEW1|100000 |75662 |
|4 | TABLE SCAN |T3 |100000 |61860 |
================================================
Outputs & filters:
-------------------------------------
0 - output([VIEW1.C1], [VIEW1.C2]), filter(nil),
columns([{T1: ({T1: (T1.C1, T1.C2)})}]), partitions(p0)
1 - output([VIEW1.C1], [VIEW1.C2]), filter(nil)
2 - output([VIEW1.C1], [VIEW1.C2]), filter(nil)
3 - output([VIEW1.C1], [VIEW1.C2]), filter(nil),
access([VIEW1.C1], [VIEW1.C2])
4 - output([T3.C1], [T3.C2]), filter(nil),
access([T3.C2], [T3.C1]), partitions(p0)
Q4 查詢(xún)將值(1, '100')插入到分區(qū)表 t2 中,通過(guò) partitions
參數(shù)可以看出,該值會(huì)被插入到 t2 的 p5 分區(qū)。
Q4:
obclient>EXPLAIN INSERT INTO t2 VALUES (1, '100')\G;
*************************** 1. row ***************************
Query Plan:
====================================
|ID|OPERATOR |NAME|EST. ROWS|COST|
------------------------------------
|0 |INSERT | |1 |1 |
|1 | EXPRESSION| |1 |1 |
====================================
Outputs & filters:
-------------------------------------
0 - output([__values.C1], [__values.C2]), filter(nil),
columns([{T2: ({T2: (T2.C1, T2.C2)})}]), partitions(p5)
1 - output([__values.C1], [__values.C2]), filter(nil)
values({1, '100'})
MULTI PARTITION INSERT 算子用于向數(shù)據(jù)表的多個(gè)分區(qū)中插入數(shù)據(jù)。
如下例所示,Q5 查詢(xún)將值(2, '200')、(3, '300')插入到分區(qū)表 t2 中,通過(guò) partitions
可以看出,這些值會(huì)被插入到 t2 的 p0 和 p6 分區(qū)。
Q5:
obclient>EXPLAIN INSERT INTO t2 VALUES (2, '200'),(3, '300')\G;
*************************** 1. row ***************************
Query Plan:
===============================================
|ID|OPERATOR |NAME|EST. ROWS|COST|
-----------------------------------------------
|0 |MULTI PARTITION INSERT| |2 |1 |
|1 | EXPRESSION | |2 |1 |
===============================================
Outputs & filters:
-------------------------------------
0 - output([__values.C1], [__values.C2]), filter(nil),
columns([{T2: ({T2: (T2.C1, T2.C2)})}]), partitions(p0, p6)
1 - output([__values.C1], [__values.C2]), filter(nil)
values({2, '200'}, {3, '300'})
上述示例的執(zhí)行計(jì)劃展示中的 outputs & filters 詳細(xì)列出了 MULTI PARTITION INSERT 算子的信息,字段的含義與 INSERT 算子相同。
更多 MULTI PARTITION INSERT 算子的示例如下:
Q6 查詢(xún)將子查詢(xún) SELECT * FROM t3
的結(jié)果插入到分區(qū)表 t2 中,因?yàn)闊o(wú)法確定子查詢(xún)的結(jié)果集,因此數(shù)據(jù)可能插入到 t2 的 p0 到 p9 的任何一個(gè)分區(qū)中。從1 號(hào)算子可以看到,這里的 SELECT * FROM t3
會(huì)被放在一個(gè)子查詢(xún)中,并將子查詢(xún)命名為 VIEW1。當(dāng) OceanBase 數(shù)據(jù)庫(kù)內(nèi)部改寫(xiě) SQL 產(chǎn)生了子查詢(xún)時(shí),會(huì)自動(dòng)為子查詢(xún)命名,并按照子查詢(xún)生成的順序命名為 VIEW1、VIEW2、VIEW3...
Q6:
obclient>EXPLAIN INSERT INTO t2 SELECT * FROM t3\G;
*************************** 1. row ***************************
Query Plan:
==============================================
|ID|OPERATOR |NAME|EST. ROWS|COST|
--------------------------------------------------
|0 |MULTI PARTITION INSERT| |100000 |117862|
|1 | EXCHANGE IN DISTR | |100000 |104060|
|2 | EXCHANGE OUT DISTR | |100000 |75662 |
|3 | SUBPLAN SCAN |VIEW1|100000 |75662 |
|4 | TABLE SCAN |T3 |100000 |61860 |
==================================================
Outputs & filters:
-------------------------------------
0 - output([VIEW1.C1], [VIEW1.C2]), filter(nil),
columns([{T2: ({T2: (T2.C1, T2.C2)})}]), partitions(p[0-9])
1 - output([VIEW1.C1], [VIEW1.C2]), filter(nil)
2 - output([VIEW1.C1], [VIEW1.C2]), filter(nil)
3 - output([VIEW1.C1], [VIEW1.C2]), filter(nil),
access([VIEW1.C1], [VIEW1.C2])
4 - output([T3.C1], [T3.C2]), filter(nil),
access([T3.C2], [T3.C1]), partitions(p0)
Q7 查詢(xún)將值(1, '100')插入到非分區(qū)表 t3 中。雖然 t3 本身是一個(gè)非分區(qū)表,但因?yàn)?t3 上存在全局索引 idx_t3_c2,因此本次插入也涉及到了多個(gè)分區(qū)。
Q7:
obclient>EXPLAIN INSERT INTO t3 VALUES (1, '100')\G;
*************************** 1. row ***************************
Query Plan:
==============================================
|ID|OPERATOR |NAME|EST. ROWS|COST|
-----------------------------------------------
|0 |MULTI PARTITION INSERT| |1 |1 |
|1 | EXPRESSION | |1 |1 |
===============================================
Outputs & filters:
-------------------------------------
0 - output([__values.C1], [__values.C2]), filter(nil),
columns([{T3: ({T3: (T3.C1, T3.C2)}, {IDX_T3_C2: (T3.C2, T3.C1)})}]), partitions(p0)
1 - output([__values.C1], [__values.C2]), filter(nil)
values({1, '100'})
Copyright©2021 w3cschool編程獅|閩ICP備15016281號(hào)-3|閩公網(wǎng)安備35020302033924號(hào)
違法和不良信息舉報(bào)電話:173-0602-2364|舉報(bào)郵箱:jubao@eeedong.com
掃描二維碼
下載編程獅App
編程獅公眾號(hào)
聯(lián)系方式:
更多建議: