DELETE 演算子は、データテーブルから指定された条件に合致するデータ行を削除するために使用されます。
OceanBase データベースでサポートされている DELETE 演算子には、DELETE と DISTRIBUTED DELETE があります。
DELETE
DELETE 演算子は、データテーブルの単一パーティション内のデータを削除するために使用されます。
以下の例のように、Q1 クエリは t1 テーブルから c2 > '100' を満たすすべての行を削除します。
--Oracleモード：
obclient> CREATE TABLE t1 (c1 INT PRIMARY KEY, c2 VARCHAR2(10));
Query OK, 0 rows affected
obclient> CREATE TABLE t2 (c1 INT PRIMARY KEY, c2 VARCHAR2(10)) PARTITION BY
HASH(c1) PARTITIONS 10;
Query OK, 0 rows affected
obclient> CREATE TABLE t3 (c1 INT PRIMARY KEY, c2 VARCHAR2(10));
Query OK, 0 rows affected
obclient> CREATE INDEX IDX_t3_c2 ON t3 (c2) PARTITION BY HASH(c2) PARTITIONS 3;
Query OK, 0 rows affected
--MySQLモード：
obclient> CREATE TABLE t1 (c1 INT PRIMARY KEY, c2 INT);
Query OK, 0 rows affected
obclient> CREATE TABLE t2 (c1 INT PRIMARY KEY, c2 INT) PARTITION BY
HASH(c1) PARTITIONS 10;
Query OK, 0 rows affected
obclient> CREATE TABLE t3 (c1 INT PRIMARY KEY, c2 INT);
Query OK, 0 rows affected
obclient> CREATE INDEX IDX_t3_c2 ON t3 (c2) PARTITION BY HASH(c2) PARTITIONS 3;
Query OK, 0 rows affected
Q1:
obclient> EXPLAIN DELETE FROM t1 WHERE c2 > '100';
Query Plan:
======================================
|ID|OPERATOR |NAME|EST. ROWS|COST |
--------------------------------------
|0 |DELETE | |10000 |118697|
|1 | TABLE SCAN|T1 |10000 |108697|
======================================
Outputs & filters:
-------------------------------------
0 - output(nil), filter(nil), table_columns([{T1: ({T1: (T1.C1, T1.C2)})}])
1 - output([T1.C1], [T1.C2]), filter([T1.C2 > '100')),
access([T1.C1], [T1.C2]), partitions(p0)
上記の例では、実行計画表示の outputs & filters が DELETE 演算子の出力情報を詳細に示しています：
情報名 |
意味 |
|---|---|
| output | この演算子が出力する式です。 |
| filter | この演算子のフィルター条件です。例では DELETE 演算子に filter が設定されていないため、nil となります。削除文では、WHERE 句の述語がベーステーブルにプッシュダウンされます。例えば、Q1 クエリの c2>'100' は、1 番目の演算子にプッシュダウンされます。 |
| table_columns | 削除操作に関連するデータテーブルの列です。 |
DELETE 演算子のその他の例：
Q2 クエリは
t1テーブルのすべてのデータ行を削除します。Q3 クエリは、パーティションテーブル
t2からc1 = 1を満たすデータ行を削除します。Q4 クエリは、パーティションテーブル
t2からc2 > '100'を満たすデータ行を削除します。実行計画からわかるように、DELETE演算子はEXCHANGE演算子の下に配置されているため、演算子番号2と3はパーティション単位でスケジュールされるタスクとして実行されます。計画の実行時、演算子番号4がt2テーブルのうちc2 > '100'を満たすデータを1つのパーティションでスキャンし、演算子番号3のDELETE演算子は対応するパーティションでスキャンされたデータのみを削除します。
Q2:
obclient> EXPLAIN DELETE FROM t1;
Query Plan:
======================================
|ID|OPERATOR |NAME|EST. ROWS|COST |
--------------------------------------
|0 |DELETE | |100000 |161860|
|1 | TABLE SCAN|T1 |100000 |61860 |
======================================
Outputs & filters:
-------------------------------------
0 - output(nil), filter(nil), table_columns([{T1: ({T1: (T1.C1, T1.C2)})}])
1 - output([T1.C1], [T1.C2]), filter(nil),
access([T1.C1], [T1.C2]), partitions(p0)
Q3:
obclient> EXPLAIN DELETE FROM t2 WHERE c1 = 1;
Query Plan:
===================================
|ID|OPERATOR |NAME|EST. ROWS|COST|
-----------------------------------
|0 |DELETE | |1 |53 |
|1 | TABLE GET|T2 |1 |52 |
===================================
Outputs & filters:
-------------------------------------
0 - output(nil), filter(nil), table_columns([{T2: ({T2: (T2.C1, T2.C2)})}])
1 - output([T2.C1], [T2.C2]), filter(nil),
access([T2.C1], [T2.C2]), partitions(p5)
Q4:
obclient> EXPLAIN DELETE FROM t2 WHERE c2 > '100';
Query Plan:
===============================================
|ID|OPERATOR |NAME |EST. ROWS|COST |
-------------------------------------------------------
|0 |PX COORDINATOR | |100000 |1186893|
|1 | EXCHANGE OUT DISTR |:EX10000|100000 |1186893|
|2 | PX PARTITION ITERATOR| |100000 |1186893|
|3 | DELETE | |100000 |1186893|
|4 | TABLE SCAN |T2 |100000 |1086893|
==================================================
Outputs & filters:
-------------------------------------
0 - output(nil), filter(nil)
1 - output(nil), filter(nil), dop=1
2 - output(nil), filter(nil)
3 - output(nil), filter(nil), table_columns([{T2: ({T2: (T2.C1, T2.C2)})}])
4 - output([T2.C1], [T2.C2]), filter([T2.C2 > '100']),
access([T2.C1], [T2.C2]), partitions(p[0-9])
DISTRIBUTED DELETE
DISTRIBUTED DELETE 演算子は、データテーブルの複数のパーティションからデータを削除するために使用されます。
以下の例のように、Q5 クエリはテーブル t3 内の c2 > '100' を満たすすべてのデータ行を削除します。t3 は本来非パーティションテーブルですが、t3 にグローバルインデックス idx_t3_c2 が存在するため、各行は複数のパーティションにまたがって存在します。
Q5:
obclient> EXPLAIN DELETE FROM t3 WHERE c2 > '100';
+----------------------------------------------------------------------------------+
| Query Plan |
+----------------------------------------------------------------------------------+
| ==================================================================== |
| |ID|OPERATOR |NAME |EST.ROWS|EST.TIME(us)| |
| -------------------------------------------------------------------- |
| |0 |DISTRIBUTED DELETE | |1 |26 | |
| |1 |└─PX COORDINATOR | |1 |8 | |
| |2 | └─EXCHANGE OUT DISTR |:EX10000 |1 |8 | |
| |3 | └─PX PARTITION ITERATOR| |1 |7 | |
| |4 | └─TABLE RANGE SCAN |t3(IDX_t3_c2)|1 |7 | |
| ==================================================================== |
| Outputs & filters: |
| ------------------------------------- |
| 0 - output(nil), filter(nil) |
| table_columns([{t3: ({t3: (t3.c1, t3.c2)}, {IDX_t3_c2: (t3.c2, t3.c1)})}]) |
| 1 - output([t3.c1], [t3.c2]), filter(nil), rowset=16 |
| 2 - output([t3.c1], [t3.c2]), filter(nil), rowset=16 |
| dop=1 |
| 3 - output([t3.c1], [t3.c2]), filter(nil), rowset=16 |
| force partition granule |
| 4 - output([t3.c1], [t3.c2]), filter(nil), rowset=16 |
| access([t3.c1], [t3.c2]), partitions(p[0-2]) |
| is_index_back=false, is_global_index=true, |
| range_key([t3.c2], [t3.c1]), range(100,MAX ; MAX,MAX), |
| range_cond([t3.c2 > demote_cast('100', INT(11, 0))]) |
+----------------------------------------------------------------------------------+
23 rows in set
上記の例の実行計画表示における outputs & filters は、DISTRIBUTED DELETE 演算子の情報を詳細に示しています。フィールドの意味は DELETE 演算子と同じです。