Hologres:物理パーティションテーブルから論理パーティションテーブルへの移行

テーブル構造の変換

論理パーティションテーブルを作成するためのステートメントは、物理パーティションテーブルを作成するためのステートメントと次の点で異なります。

• DDL ステートメントに LOGICAL キーワードを追加し、パーティションキーに NOT NULL 制約を追加します。

• (オプション) 物理パーティションテーブルは 1 つのパーティションキーのみをサポートしますが、論理パーティションテーブルは最大 2 つをサポートします。必要に応じて 2 番目のパーティションキーを追加できます。

次の例を考えてみましょう。

• 物理パーティションテーブルを作成する：

  BEGIN;
  CREATE TABLE user_profile (
      a TEXT,
      b TEXT,
      ds TEXT
  )
  PARTITION BY LIST (ds);
  CREATE TABLE user_profile_202503 PARTITION OF user_profile FOR VALUES IN ('202503');
  CREATE TABLE user_profile_202504 PARTITION OF user_profile FOR VALUES IN ('202504');
  COMMIT;

• 論理パーティションテーブルを作成する：

  • パーティションキーを 1 つ保持する。

    CREATE TABLE user_profile_lp_1 (
        a TEXT,
        b TEXT,
        ds TEXT NOT NULL)
    LOGICAL PARTITION BY LIST (ds);

  • 2 つのパーティションキー (年と月) に変更します。

    CREATE TABLE user_profile_lp_2 (
        a TEXT,
        b TEXT,
        yy TEXT NOT NULL,
        mm TEXT NOT NULL)
    LOGICAL PARTITION BY LIST (yy, mm);

テーブルマッピング

次の表は、物理パーティションテーブルと論理パーティションテーブル間のテーブルプロパティとパーティションプロパティのマッピングを示しています。

CLONE

テーブルスキーマを変更する必要がなく、データ量が中程度の場合は、CLONE 構文を使用できます。

例:

CALL hg_clone_to_logical_partition('user_profile', 'user_profile_logical');

大量のデータを移行しており、操作に時間がかかると予想される場合は、ASYNC コマンドを使用してタスクをバックグラウンドで実行できます。コマンドが送信されると、CALL ステートメントの query_id が返されます。この query_id を使用して、クエリインサイトで非同期タスクの実行ステータスを確認できます。

SET statement_timeout = 0;
ASYNC CALL hg_clone_to_logical_partition('user_profile', 'user_profile_logical');

手動移行

テーブルスキーマを変更する必要がある場合、またはデータ量が大きくデータ移行の負荷が高い場合は、手動移行メソッドを使用します。このメソッドは、移行ペースを制御するためのより高い柔軟性を提供します。

移行手順：

1. テーブルを作成します。

   詳細については、このトピックの「論理パーティションテーブルを作成する」をご参照ください。

2. hg_insert_overwrite ストアドプロシージャを使用して既存データをインポートします。

   CALL hg_insert_overwrite('logical_partition_table', '{20250601, 20250602}'::text[], 'SELECT * FROM tb');

REBUILD 構文（非推奨）

より長い変更タイムウィンドウと、一部の読み取りおよび書き込みタスクの潜在的な失敗を受け入れることができる場合は、REBUILD 構文を使用して移行できます。詳細については、「REBUILD (ベータ)」をご参照ください。

次の点に注意してください。

• REBUILD 機能を使用してパーティションテーブルを移行すると、新しい論理パーティションテーブルの名前は元のテーブル名と同じになります。元の物理パーティションテーブルは tmp_rebuild_old_<query_id>_<unique_id>_<table_name> に名前が変更されます。

• 移行が完了したら、インポート、クエリ、および O&M タスクを適応させる必要があります。

• 適応が完了する前に、互換性の問題により関連タスクが失敗する可能性があります。このため、このメソッドはパーティションテーブルの移行には推奨されません。

例:

-- パーティションフィールドに NOT NULL 制約を追加します。
ASYNC REBUILD TABLE user_profile ALTER ds SET NOT NULL;

-- 物理パーティションテーブルを論理パーティションテーブルに変換し、元の物理パーティションテーブルを保持します。
ASYNC REBUILD TABLE user_profile WITH (keep_source) TO logical partition;

シナリオ 1: 子テーブルまたはサブパーティションを追加してデータをインポートする

-- 元の物理パーティションテーブルのインポートタスク
CREATE TABLE user_profile_202505 PARTITION OF user_profile FOR VALUES IN ('202505');
INSERT INTO user_profile_202505 SELECT a, b, ds FROM <source_table> WHERE ds = '202505';

-- 新しい論理パーティションテーブルのインポートタスク
INSERT INTO user_profile_lp_1 SELECT a, b, ds FROM <source_table> WHERE ds = '202505';

シナリオ 2: 子テーブルまたはサブパーティションのデータをリフレッシュする

-- 元の物理パーティションテーブルのリフレッシュタスク (一時テーブルを作成して INSERT OVERWRITE を実装)
-- 一時テーブルを作成してデータをインポートします。
CREATE TABLE tmp_user_profile_202505(a text, b text, ds text);
INSERT INTO tmp_user_profile_202505 SELECT a, b, ds FROM <source_table> WHERE ds = '202505';

-- 一時テーブルの名前を変更し、親テーブルにアタッチします。
BEGIN;
DROP TABLE IF EXISTS user_profile_202505;
ALTER TABLE tmp_user_profile_202505 RENAME TO user_profile_202505;
ALTER TABLE user_profile ATTACH PARTITION user_profile_202505 FOR VALUES IN ('202505');
COMMIT;

-- 元の物理パーティションテーブルのリフレッシュタスク (hg_insert_overwrite コマンドを使用)
CALL hg_insert_overwrite('user_profile' , '202505', $$SELECT a, b, mm FROM <source_table> WHERE ds='202505'$$);

-- 新しい論理パーティションテーブルのリフレッシュタスク (ネイティブの INSERT OVERWRITE 構文を使用)
INSERT OVERWRITE user_profile_lp_1 PARTITION (ds = '202505') SELECT a, b, ds FROM <source_table> WHERE ds='202505';