DELETE

指定された条件に基づいてテーブルからデータ行を削除します。テーブルはパーティション化されているものとされていないもののどちらでもかまいません。

重複キーテーブル、集計テーブル、ユニークキーテーブルでは、指定されたパーティションからデータを削除できます。v2.3から、主キーテーブルは完全な DELETE...WHERE セマンティクスをサポートし、主キー、任意のカラム、またはサブクエリの結果に基づいてデータ行を削除できます。v3.0から、StarRocks は DELETE...WHERE セマンティクスをマルチテーブルジョインおよび共通テーブル式 (CTE) で強化しました。データベース内の他のテーブルと主キーテーブルをジョインする必要がある場合、USING句またはCTEでこれらの他のテーブルを参照できます。

使用上の注意

• DELETEを実行するテーブルとデータベースに対する権限が必要です。
• 頻繁なDELETE操作は推奨されません。必要な場合は、ピーク時間外に実行してください。
• DELETE操作はテーブル内のデータのみを削除します。テーブル自体は残ります。テーブルを削除するには、DROP TABLE を実行してください。
• 誤操作によってテーブル全体のデータが削除されるのを防ぐため、DELETE文にはWHERE句を指定する必要があります。
• 削除された行は即座にクリーンアップされません。それらは「削除済み」とマークされ、セグメントに一時的に保存されます。物理的には、データバージョンのマージ (コンパクション) が完了した後にのみ行が削除されます。
• この操作は、このテーブルを参照するマテリアライズドビューのデータも削除します。

重複キーテーブル、集計テーブル、およびユニークキーテーブル

構文

DELETE FROM  [<db_name>.]<table_name> [PARTITION <partition_name>]
WHERE
column_name1 op { value | value_list } [ AND column_name2 op { value | value_list } ...]

パラメータ

パラメータ	必須	説明
db_name	いいえ	対象テーブルが属するデータベース。このパラメータが指定されていない場合、デフォルトで現在のデータベースが使用されます。
table_name	はい	データを削除したいテーブル。
partition_name	いいえ	データを削除したいパーティション。
column_name	はい	DELETE条件として使用したいカラム。1つ以上のカラムを指定できます。
op	はい	DELETE条件で使用される演算子。サポートされている演算子は =, >, <, >=, <=, !=, IN, NOT IN です。

制限と使用上の注意

• 重複キーテーブルでは、任意のカラム をDELETE条件として使用できます。集計テーブルおよびユニークキーテーブルでは、キー列 のみをDELETE条件として使用できます。

• 指定する条件はAND関係でなければなりません。OR関係で条件を指定したい場合は、別々のDELETE文で条件を指定する必要があります。

• 重複キーテーブル、集計テーブル、およびユニークキーテーブルでは、DELETE文でサブクエリの結果を条件として使用することはサポートされていません。

影響

DELETE文を実行した後、クラスターのクエリパフォーマンスが一時的に低下する可能性があります（コンパクションが完了するまで）。低下の程度は、指定する条件の数に基づいて異なります。条件の数が多いほど、低下の程度が高くなります。

例

テーブルを作成しデータを挿入

次の例では、パーティション化された重複キーテーブルを作成します。

CREATE TABLE `my_table` (
    `date` date NOT NULL,
    `k1` int(11) NOT NULL COMMENT "",
    `k2` varchar(65533) NULL DEFAULT "" COMMENT "")
DUPLICATE KEY(`date`)
PARTITION BY RANGE(`date`)
(
    PARTITION p1 VALUES [('2022-03-11'), ('2022-03-12')),
    PARTITION p2 VALUES [('2022-03-12'), ('2022-03-13'))
)
DISTRIBUTED BY HASH(`date`)
PROPERTIES
("replication_num" = "3");

INSERT INTO `my_table` VALUES
('2022-03-11', 3, 'abc'),
('2022-03-11', 2, 'acb'),
('2022-03-11', 4, 'abc'),
('2022-03-12', 2, 'bca'),
('2022-03-12', 4, 'cba'),
('2022-03-12', 5, 'cba');

データをクエリ

select * from my_table order by date;
+------------+------+------+
| date       | k1   | k2   |
+------------+------+------+
| 2022-03-11 |    3 | abc  |
| 2022-03-11 |    2 | acb  |
| 2022-03-11 |    4 | abc  |
| 2022-03-12 |    2 | bca  |
| 2022-03-12 |    4 | cba  |
| 2022-03-12 |    5 | cba  |
+------------+------+------+

データを削除

指定されたパーティションからデータを削除

p1 パーティションから k1 の値が 3 の行を削除します。

DELETE FROM my_table PARTITION p1
WHERE k1 = 3;

-- クエリ結果は、`k1` の値が `3` の行が削除されたことを示しています。

select * from my_table partition (p1);
+------------+------+------+
| date       | k1   | k2   |
+------------+------+------+
| 2022-03-11 |    2 | acb  |
| 2022-03-11 |    4 | abc  |
+------------+------+------+

ANDを使用して指定されたパーティションからデータを削除

p1 パーティションから k1 の値が 3 以上で、k2 の値が "abc" の行を削除します。

DELETE FROM my_table PARTITION p1
WHERE k1 >= 3 AND k2 = "abc";

select * from my_table partition (p1);
+------------+------+------+
| date       | k1   | k2   |
+------------+------+------+
| 2022-03-11 |    2 | acb  |
+------------+------+------+

すべてのパーティションからデータを削除

すべてのパーティションから k2 の値が "abc" または "cba" の行を削除します。

DELETE FROM my_table
WHERE  k2 in ("abc", "cba");

select * from my_table order by date;
+------------+------+------+
| date       | k1   | k2   |
+------------+------+------+
| 2022-03-11 |    2 | acb  |
| 2022-03-12 |    2 | bca  |
+------------+------+------+

主キーテーブル

v2.3から、主キーテーブルは完全な DELETE...WHERE セマンティクスをサポートし、主キー、任意のカラム、またはサブクエリに基づいてデータ行を削除できます。

構文

[ WITH <with_query> [, ...] ]
DELETE FROM <table_name>
[ USING <from_item> [, ...] ]
[ WHERE <where_condition> ]

パラメータ

パラメータ	必須	説明
with_query	いいえ	DELETE文で名前で参照できる1つ以上のCTE。CTEは一時的な結果セットで、複雑な文の可読性を向上させることができます。
table_name	はい	データを削除したいテーブル。
from_item	いいえ	データベース内の1つ以上の他のテーブル。これらのテーブルは、WHERE句で指定された条件に基づいて操作対象のテーブルとジョインできます。ジョインクエリの結果セットに基づいて、StarRocks は操作対象のテーブルから一致する行を削除します。たとえば、USING句が USING t1 WHERE t0.pk = t1.pk; の場合、StarRocks はDELETE文を実行する際にUSING句のテーブル式を t0 JOIN t1 ON t0.pk=t1.pk; に変換します。
where_condition	はい	行を削除したい条件。このWHERE条件を満たす行のみが削除されます。このパラメータは、テーブル全体を誤って削除するのを防ぐために必須です。テーブル全体を削除したい場合は、'WHERE true' を使用できます。

制限と使用上の注意

• 主キーテーブルは、指定されたパーティションからのデータ削除をサポートしていません。たとえば、DELETE FROM <table_name> PARTITION <partition_id> WHERE <where_condition> のような操作はできません。
• 次の比較演算子がサポートされています: =, >, <, >=, <=, !=, IN, NOT IN。
• 次の論理演算子がサポートされています: AND および OR。
• DELETE文を使用して同時にDELETE操作を実行したり、データロード時にデータを削除したりすることはできません。そのような操作を行うと、トランザクションの原子性、一貫性、分離性、および耐久性 (ACID) が保証されない可能性があります。

例

テーブルを作成しデータを挿入

score_board という名前の主キーテーブルを作成します:

CREATE TABLE `score_board` (
  `id` int(11) NOT NULL COMMENT "",
  `name` varchar(65533) NULL DEFAULT "" COMMENT "",
  `score` int(11) NOT NULL DEFAULT "0" COMMENT ""
) ENGINE=OLAP
PRIMARY KEY(`id`)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`id`)
PROPERTIES (
"replication_num" = "3",
"storage_format" = "DEFAULT",
"enable_persistent_index" = "false"
);

INSERT INTO score_board VALUES
(0, 'Jack', 21),
(1, 'Bob', 21),
(2, 'Stan', 21),
(3, 'Sam', 22);

データをクエリ

次の文を実行して score_board テーブルにデータを挿入します:

select * from score_board;
+------+------+------+
| id   | name | score|
+------+------+------+
|    0 | Jack |   21 |
|    1 | Bob  |   21 |
|    2 | Stan |   21 |
|    3 | Sam  |   22 |
+------+------+------+
4 rows in set (0.00 sec)

データを削除

主キーでデータを削除

DELETE文で主キーを指定することができるため、StarRocks はテーブル全体をスキャンする必要がありません。

score_board テーブルから id の値が 0 の行を削除します。

DELETE FROM score_board WHERE id = 0;

select * from score_board;
+------+------+------+
| id   | name | score|
+------+------+------+
|    1 | Bob  |   21 |
|    2 | Stan |   21 |
|    3 | Sam  |   22 |
+------+------+------+

条件でデータを削除

例1: score_board テーブルから score の値が 22 の行を削除します。

DELETE FROM score_board WHERE score = 22;

select * from score_board;
+------+------+------+
| id   | name | score|
+------+------+------+
|    0 | Jack |   21 |
|    1 | Bob  |   21 |
|    2 | Stan |   21 |
+------+------+------+

例2: score_board テーブルから score の値が 22 未満の行を削除します。

DELETE FROM score_board WHERE score < 22;

select * from score_board;
+------+------+------+
| id   | name | score|
+------+------+------+
|    3 | Sam  |   22 |
+------+------+------+

例3: score_board テーブルから score の値が 22 未満で、name の値が Bob でない行を削除します。

DELETE FROM score_board WHERE score < 22 and name != "Bob";

select * from score_board;
+------+------+------+
| id   | name | score|
+------+------+------+
|    1 | Bob  |   21 |
|    3 | Sam  |   22 |
+------+------+------+
2 rows in set (0.00 sec)

サブクエリ結果でデータを削除

DELETE 文に1つ以上のサブクエリをネストし、サブクエリの結果を条件として使用できます。

データを削除する前に、次の文を実行して users という名前の別のテーブルを作成します:

CREATE TABLE `users` (
  `uid` int(11) NOT NULL COMMENT "",
  `name` varchar(65533) NOT NULL COMMENT "",
  `country` varchar(65533) NULL COMMENT ""
) ENGINE=OLAP
PRIMARY KEY(`uid`)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`uid`)
PROPERTIES (
"replication_num" = "3",
"storage_format" = "DEFAULT",
"enable_persistent_index" = "false"
);

users テーブルにデータを挿入します:

INSERT INTO users VALUES
(0, "Jack", "China"),
(2, "Stan", "USA"),
(1, "Bob", "China"),
(3, "Sam", "USA");

select * from users;
+------+------+---------+
| uid  | name | country |
+------+------+---------+
|    0 | Jack | China   |
|    1 | Bob  | China   |
|    2 | Stan | USA     |
|    3 | Sam  | USA     |
+------+------+---------+
4 rows in set (0.00 sec)

サブクエリをネストして users テーブルから country の値が China の行を見つけ、そのサブクエリから返された行と同じ name の値を持つ行を score_board テーブルから削除します。次のいずれかの方法を使用して目的を達成できます:

• 方法1

DELETE FROM score_board
WHERE name IN (select name from users where country = "China");
    
select * from score_board;
+------+------+------+
| id   | name | score|
+------+------+------+
|    2 | Stan |   21 |
|    3 | Sam  |   22 |
+------+------+------+

• 方法2

DELETE FROM score_board
WHERE EXISTS (select name from users
              where score_board.name = users.name and country = "China");
    
select * from score_board;
+------+------+-------+
| id   | name | score |
+------+------+-------+
|    2 | Stan |    21 |
|    3 | Sam  |    22 |
+------+------+-------+
2 rows in set (0.00 sec)

マルチテーブルジョインまたはCTEを使用してデータを削除

プロデューサー "foo" によって制作されたすべての映画を削除するには、次の文を実行します:

DELETE FROM films USING producers
WHERE producer_id = producers.id
    AND producers.name = 'foo';

上記の文をCTEを使用して書き直し、可読性を向上させることもできます。

WITH foo_producers as (
    SELECT * from producers
    where producers.name = 'foo'
)
DELETE FROM films USING foo_producers
WHERE producer_id = foo_producers.id;

参考文献

SHOW DELETE: 重複キーテーブル、集計テーブル、およびユニークキーテーブルで正常に実行された過去のDELETE操作をクエリします。