blob: 15386105b014b6db24be398800303f5d51559e52 [file] [view]
---
{
"title": "UPDATE コマンドによるデータの更新",
"description": "このドキュメントでは、Dorisでデータを変更するためのUPDATEコマンドの使用方法について説明します。",
"language": "ja"
}
---
この文書では、Dorisでデータを変更するための`UPDATE`コマンドの使用方法について説明します。`UPDATE`コマンドは、Uniqueデータモデルを持つtableにのみ適用可能です。
## 適用シナリオ
- 小規模データ更新:少量のデータを修正する必要があるシナリオに最適です。例えば、特定のレコードの誤ったフィールドの修正や、特定フィールドのステータス更新(注文ステータス更新など)。
- 特定フィールドのETLバッチ処理:特定フィールドの大規模な更新に適しており、ETL処理シナリオでよく見られます。注意:大規模データ更新は頻繁でないべきです。
## 動作原理
クエリエンジンは独自のフィルタリングロジックを使用して、更新が必要な行を特定します。その後、UniqueモデルのValue列ロジックを使用して古いデータを新しいデータで置き換えます。更新対象の行は変更され、tableに再挿入されて行レベル更新が実現されます。
### 同期性
DorisUPDATE構文は同期的です。つまり、UPDATE文が正常に実行されると、更新操作が完了し、データは即座に表示されます。
### パフォーマンス
UPDATE文のパフォーマンスは、更新対象の行数とクエリ条件の効率に密接に関連しています。
- 更新対象の行数:更新が必要な行が多いほど、UPDATE文は遅くなります。小規模更新の場合、DorisINSERT INTO文と同様の頻度をサポートします。大規模更新の場合、実行時間が長いため、頻繁でない呼び出しにのみ適しています。
- クエリ条件の効率:UPDATE実装は最初にクエリ条件を満たす行を読み取ります。そのため、クエリ条件が効率的であれば、UPDATE速度は高速になります。理想的には、条件列はインデックスまたはパーティションバケットプルーニングにヒットするべきで、そうすればDoristable全体をスキャンする必要がなく、更新が必要な行を迅速に特定でき、更新効率が向上します。条件列にvalue列を含めないことを強く推奨します。
## 使用例
金融リスク管理シナリオで、以下の構造を持つ取引詳細tableがあると仮定します:
```sql
CREATE TABLE transaction_details (
transaction_id BIGINT NOT NULL, -- Unique transaction ID
user_id BIGINT NOT NULL, -- User ID
transaction_date DATE NOT NULL, -- Transaction date
transaction_time DATETIME NOT NULL, -- Transaction time
transaction_amount DECIMAL(18, 2), -- Transaction amount
transaction_device STRING, -- Transaction device
transaction_region STRING, -- Transaction region
average_daily_amount DECIMAL(18, 2), -- Average daily transaction amount over the last 3 months
recent_transaction_count INT, -- Number of transactions in the last 7 days
has_dispute_history BOOLEAN, -- Whether there is a dispute history
risk_level STRING -- Risk level
)
UNIQUE KEY(transaction_id)
DISTRIBUTED BY HASH(transaction_id) BUCKETS 16
PROPERTIES (
"replication_num" = "3", -- Number of replicas, default is 3
"enable_unique_key_merge_on_write" = "true" -- Enable MOW mode, support merge updates
);
```
以下のトランザクションデータが存在します:
```sql
+----------------+---------+------------------+---------------------+--------------------+--------------------+--------------------+----------------------+--------------------------+---------------------+------------+
| transaction_id | user_id | transaction_date | transaction_time | transaction_amount | transaction_device | transaction_region | average_daily_amount | recent_transaction_count | has_dispute_history | risk_level |
+----------------+---------+------------------+---------------------+--------------------+--------------------+--------------------+----------------------+--------------------------+---------------------+------------+
| 1001 | 5001 | 2024-11-24 | 2024-11-24 14:30:00 | 100.00 | iPhone 12 | New York | 100.00 | 10 | 0 | NULL |
| 1002 | 5002 | 2024-11-24 | 2024-11-24 03:30:00 | 120.00 | iPhone 12 | New York | 100.00 | 15 | 0 | NULL |
| 1003 | 5003 | 2024-11-24 | 2024-11-24 10:00:00 | 150.00 | Samsung S21 | Los Angeles | 100.00 | 30 | 0 | NULL |
| 1004 | 5004 | 2024-11-24 | 2024-11-24 16:00:00 | 300.00 | MacBook Pro | high_risk_region1 | 200.00 | 5 | 0 | NULL |
| 1005 | 5005 | 2024-11-24 | 2024-11-24 11:00:00 | 1100.00 | iPad Pro | Chicago | 200.00 | 10 | 0 | NULL |
+----------------+---------+------------------+---------------------+--------------------+--------------------+--------------------+----------------------+--------------------------+---------------------+------------+
```
以下のリスク制御ルールに従って、すべての日次取引記録のリスクレベルを更新してください:
1. 紛争履歴のある取引のリスクレベルはhighです。
2. 高リスク地域での取引のリスクレベルはhighです。
3. 異常な金額の取引(日平均の5倍を超える)のリスクレベルはhighです。
4. 過去7日間の頻繁な取引:
a. 取引回数が50回を超える場合、リスクレベルはhighです。
b. 取引回数が20回から50回の場合、リスクレベルはmediumです。
5. 営業時間外(午前2時から午前4時)の取引のリスクレベルはmediumです。
6. デフォルトのリスクレベルはlowです。
```sql
UPDATE transaction_details
SET risk_level = CASE
-- Transactions with a dispute history or in high-risk regions
WHEN has_dispute_history = TRUE THEN 'high'
WHEN transaction_region IN ('high_risk_region1', 'high_risk_region2') THEN 'high'
-- Abnormal transaction amount
WHEN transaction_amount > 5 * average_daily_amount THEN 'high'
-- High transaction frequency in the last 7 days
WHEN recent_transaction_count > 50 THEN 'high'
WHEN recent_transaction_count BETWEEN 20 AND 50 THEN 'medium'
-- Transactions during non-working hours
WHEN HOUR(transaction_time) BETWEEN 2 AND 4 THEN 'medium'
-- Default risk level
ELSE 'low'
END
WHERE transaction_date = '2024-11-24';
```
更新されたデータは以下の通りです:
```sql
+----------------+---------+------------------+---------------------+--------------------+--------------------+--------------------+----------------------+--------------------------+---------------------+------------+
| transaction_id | user_id | transaction_date | transaction_time | transaction_amount | transaction_device | transaction_region | average_daily_amount | recent_transaction_count | has_dispute_history | risk_level |
+----------------+---------+------------------+---------------------+--------------------+--------------------+--------------------+----------------------+--------------------------+---------------------+------------+
| 1001 | 5001 | 2024-11-24 | 2024-11-24 14:30:00 | 100.00 | iPhone 12 | New York | 100.00 | 10 | 0 | low |
| 1002 | 5002 | 2024-11-24 | 2024-11-24 03:30:00 | 120.00 | iPhone 12 | New York | 100.00 | 15 | 0 | medium |
| 1003 | 5003 | 2024-11-24 | 2024-11-24 10:00:00 | 150.00 | Samsung S21 | Los Angeles | 100.00 | 30 | 0 | medium |
| 1004 | 5004 | 2024-11-24 | 2024-11-24 16:00:00 | 300.00 | MacBook Pro | high_risk_region1 | 200.00 | 5 | 0 | high |
| 1005 | 5005 | 2024-11-24 | 2024-11-24 11:00:00 | 1100.00 | iPad Pro | Chicago | 200.00 | 10 | 0 | high |
+----------------+---------+------------------+---------------------+--------------------+--------------------+--------------------+----------------------+--------------------------+---------------------+------------+
```
## More Help
データ更新のより詳細な構文については、[UPDATE](../../../sql-manual/sql-statements/data-modification/DML/UPDATE)コマンドマニュアルを参照してください。また、MySQLクライアントのコマンドラインで`HELP UPDATE`を入力すると、より多くのヘルプを得ることができます。