ユニークキーテーブル
データ更新が必要な場合は、Unique Key tableを使用します。このテーブルはKeyカラムの一意性を保証し、新しいデータが一致するキーを持つ既存のレコードを上書きすることで、最新のレコードのみが維持されるようにします。このテーブルは更新シナリオに適しており、データ挿入時にユニークキーレベルでの更新が可能です。 Unique Key tableには以下の特徴があります:
-
Unique Key UPSERT:挿入時に、重複するキーを持つレコードは更新され、新しいキーは挿入されます。
-
自動重複排除:テーブルはキーの一意性を保証し、ユニークキーに基づいてデータを自動的に重複排除します。
-
高頻度更新に最適化:更新とクエリのパフォーマンスのバランスを取りながら、高頻度の更新を効率的に処理します。
使用例
-
高頻度データ更新:上流のOLTPデータベースにおいて、ディメンションテーブルが頻繁に更新される場合、Unique Key tableは上流の更新されたレコードを効率的に同期し、効率的なUPSERT操作を実行できます。
-
効率的なデータ重複排除:広告キャンペーンや顧客関係管理システムなど、ユーザーIDに基づく重複排除が必要なシナリオにおいて、Unique Key tableは効率的な重複排除を保証します。
-
部分カラム更新:動的タグが頻繁に変更されるユーザープロファイリングや、取引ステータスの更新が必要な注文処理シナリオなど。Unique Key tableの部分カラム更新機能により、特定のカラムの変更が可能になります。
実装方法
Dorisでは、Unique Key tableには2つの実装方法があります:
-
Merge-on-write:バージョン1.2以降、DorisのUnique Key tableのデフォルト実装はmerge-on-writeモードです。このモードでは、書き込み時に同一Keyのデータが即座にマージされ、各書き込み後のデータストレージ状態がユニークキーの最終マージ結果となり、最新の結果のみが保存されます。Merge-on-writeはクエリと書き込みパフォーマンスの良いバランスを提供し、クエリ時に複数バージョンのデータをマージする必要を回避し、ストレージレイヤーへの述語プッシュダウンを保証します。merge-on-writeテーブルはほとんどのシナリオで推奨されます。
-
Merge-on-read:バージョン1.2以前、DorisのUnique Key tableはデフォルトでmerge-on-readモードでした。このモードでは、書き込み時にデータはマージされず、増分的に追加され、Doris内で複数のバージョンが保持されます。クエリやCompaction時に、同一Keyバージョンでデータがマージされます。Merge-on-readは書き込み重視で読み取り軽量なシナリオに適していますが、クエリ時に複数のバージョンをマージする必要があり、述語をプッシュダウンできないため、クエリ速度に影響を与える可能性があります。
Dorisでは、Unique Key tableには2つのタイプの更新セマンティクスがあります:
-
Full Row Upsert:Unique Key tableのデフォルトの更新セマンティクスはfull row UPSERT、すなわちUPDATE OR INSERTです。行のKeyが存在する場合は更新され、存在しない場合は新しいデータが挿入されます。full row UPSERTセマンティクスでは、ユーザーが
INSERT INTOを使用して特定のカラムにデータを挿入した場合でも、Dorisはプランナーステージで欠落しているカラムをNULL値またはデフォルト値で埋めます。 -
Partial Column Upsert:ユーザーが特定のフィールドを更新したい場合は、merge-on-write実装を使用し、特定のパラメータを通じて部分カラム更新サポートを有効にする必要があります。部分カラム更新のドキュメントを参照してください。
Merge-on-write
Merge-on-writeテーブルの作成
Unique Keyテーブルを作成するには、UNIQUE KEYキーワードを使用します。enable_unique_key_merge_on_write属性を設定してmerge-on-writeモードを有効にします(Doris 2.1以降はデフォルト):
CREATE TABLE IF NOT EXISTS example_tbl_unique
(
user_id LARGEINT NOT NULL,
user_name VARCHAR(50) NOT NULL,
city VARCHAR(20),
age SMALLINT,
sex TINYINT
)
UNIQUE KEY(user_id, user_name)
DISTRIBUTED BY HASH(user_id) BUCKETS 10
PROPERTIES (
"enable_unique_key_merge_on_write" = "true"
);
Merge-on-read
Merge-on-readテーブルの作成
テーブルを作成する際、UNIQUE KEYキーワードを使用してUnique Keyテーブルを指定することができます。merge-on-readモードは、enable_unique_key_merge_on_write属性を明示的に無効にすることで有効にできます。Dorisバージョン2.1以前では、merge-on-readモードはデフォルトで有効になっていました:
CREATE TABLE IF NOT EXISTS example_tbl_unique
(
user_id LARGEINT NOT NULL,
username VARCHAR(50) NOT NULL,
city VARCHAR(20),
age SMALLINT,
sex TINYINT
)
UNIQUE KEY(user_id, username)
DISTRIBUTED BY HASH(user_id) BUCKETS 10
PROPERTIES (
"enable_unique_key_merge_on_write" = "false"
);
データの挿入と保存
Unique Keyテーブルでは、Keyカラムがソートと重複排除の両方の役割を果たします。新しい挿入は、一致するキーを持つ既存のレコードを上書きします。

例に示すように、元のテーブルには4行のデータがありました。2つの新しい行を挿入した後、新しく挿入された行はunique keyに基づいて更新されます:
-- insert into raw data
INSERT INTO example_tbl_unique VALUES
(101, 'Tom', 'BJ', 26, 1),
(102, 'Jason', 'BJ', 27, 1),
(103, 'Juice', 'SH', 20, 2),
(104, 'Olivia', 'SZ', 22, 2);
-- insert into data to update by key
INSERT INTO example_tbl_unique VALUES
(101, 'Tom', 'BJ', 27, 1),
(102, 'Jason', 'SH', 28, 1);
-- check updated data
SELECT * FROM example_tbl_unique;
+---------+----------+------+------+------+
| user_id | username | city | age | sex |
+---------+----------+------+------+------+
| 101 | Tom | BJ | 27 | 1 |
| 102 | Jason | SH | 28 | 1 |
| 104 | Olivia | SZ | 22 | 2 |
| 103 | Juice | SH | 20 | 2 |
+---------+----------+------+------+------+
Notes
-
Unique Keyテーブルの実装モードは作成時に固定され、スキーマ変更では変更できません。
-
完全行UPSERTセマンティクスでは、挿入時に特定の列が省略された場合、Dorisはプランニング中にそれらをNULLまたはデフォルト値で埋めます。
-
部分列upsertの場合は、適切なパラメータでmerge-on-writeモードを有効にしてください。ガイダンスについてはPartial Column Updatesを参照してください。
-
Uniqueテーブルを使用する場合、データの一意性を確保するため、パーティションキーはKey列に含める必要があります。