Hologres:Rebuild

ステートメントのフォーマット

ASYNC REBUILD TABLE [ IF EXISTS ] <table_name>
    [ WITH ( <rebuild_parameter> [= <value>] [, ... ] )]  
    <action> [, ... ];
    
WHERE action IS ONE OF:
    ADD [ COLUMN ] <column_name> <data_type> [ column_constraint [ ... ] ]
    ALTER [ COLUMN ] <column_name> [ SET DATA ] TYPE <data_type> [ USING <expression> ]
    ALTER [ COLUMN ] <column_name> SET DEFAULT <expression>
    ALTER [ COLUMN ] <column_name> DROP DEFAULT
    ALTER [ COLUMN ] <column_name> { SET | DROP } NOT NULL
    ALTER PRIMARY KEY (<column_name> [, ...])
    TO [LOGICAL] PARTITION [BY LIST(<column_name> [, <column_name>])]
    SET ( <parameter> [= <value>] [, ... ] )

WHERE rebuild_parameter IS ONE OF:
    keep_source
    binlog_mode
    rebuild_guc_<guc_name> = '<guc_value>'

パラメーター

Binlog がないテーブルの再構築

-- テーブルを作成し、データをインポートします。
CREATE TABLE rebuild_test (
    a TEXT,
    b TEXT,
    ds TEXT
);

INSERT INTO rebuild_test VALUES ('1', '1', '2025-04-01'), ('2', '2', '2025-04-02'), ('3', '3', '2025-04-03');

-- デフォルト値を持つ非 NULL 列を追加します。
ASYNC REBUILD TABLE rebuild_test ADD COLUMN c text NOT NULL DEFAULT 'a';

-- プライマリキーを列 a に変更します。
ASYNC REBUILD TABLE rebuild_test ALTER PRIMARY KEY (a);

-- サーバーレスリソースを使用して REBUILD タスクを実行し、テーブルの distribution_key と clustering_key を設定し、ストレージを行列ハイブリッドに変更します。
ASYNC REBUILD TABLE rebuild_test 
WITH (
    rebuild_guc_hg_computing_resource = 'serverless'
)
SET (
    distribution_key = 'a',
    clustering_key = 'a',
    orientation = 'row,column'
);

-- 非パーティションテーブルを論理パーティションテーブルに変換し、パーティションキーを ds に設定し、ds 列に NOT NULL 制約を追加します。
ASYNC REBUILD TABLE rebuild_test 
    ALTER COLUMN ds SET NOT NULL,
    TO LOGICAL PARTITION BY LIST(ds);

Binlog があるテーブルの再構築

REBUILD は履歴 Binlog データを保持しません。したがって、Binlog が有効になっているテーブルでは、デフォルトで REBUILD はサポートされていません。ダウンストリームシステムが履歴 Binlog データを完全に消費したことを確認するには、binlog_mode パラメーターを指定し、以下の手順に従う必要があります。

1. REBUILD コマンドを実行します。

   ASYNC REBUILD TABLE rebuild_test 
   WITH (
     binlog_mode
   )
   <YOUR_ACTION>;

2. REBUILD タスクで binlog_mode パラメーターが設定されている場合、set_readonly ステップが完了すると、タスクは自動的に一時停止します。SQL クエリを実行して進捗状況を確認できます。この時点で、テーブルは読み取り専用に設定されています。これにより、テーブルへのデータの書き込みができなくなり、新しい Binlog データは生成されません。

   postgres=# SELECT step, status, progress FROM hologres.rebuild_progress('<query_id>');
                step              | status | progress 
   -------------------------------+--------+----------
    prepare                       | done   | 1/1
    create_tmp_table              | done   | 1/1
    get_src_table_snapshot        | done   | 1/1
    insert                        | done   | 1/1
    set_readonly                  | done   | 1/1
    check_snapshot                |        | 0/1
    re-insert                     |        | -
    check_additional_child_table  |        | -
    create_additional_child_table |        | -
    insert_additional_child_table |        | -
    swap                          |        | 0/1
   (11 rows)

3. 下流クライアントが既存のすべての Binlog データの消費を完了するのを待ちます。その後、次の SQL ステートメントを実行して REBUILD タスクを手動で再開します。このプロセス中、ソーステーブルは読み取り専用モードのままであり、新しい Binlog データは生成されません。

   RESUME '<query_id>';

   REBUILD タスクが完了すると、新しいテーブルで Binlog が自動的に有効になります。その後、ダウンストリームの Binlog 消費タスクを再開し、lsn = 0 から消費を開始できます。

REBUILD タスクの実行ステータスの表示

REBUILD タスクは非同期で実行されます。タスクが正常に送信されると、成功ステータスと query_id が返されます。非同期サブタスクのステータスを表示するには、hologres.rebuild_progress システムテーブルにクエリを実行する必要があります。テーブルに対する REBUILD 操作は、すべてのサブタスクが成功した場合にのみ完了します。コマンドは以下のとおりです。

SELECT * FROM hologres.rebuild_progress('<rebuild_query_id>');

次の表に、システムテーブルの列について説明します。

次の図は、サンプル結果を示しています。

REBUILD タスクの停止と再開

• REBUILD 非同期タスクを停止します。

  SUSPEND '<query_id>';

• CANCEL に設定された非同期タスクを再開します。

  RESUME '<query_id>';

REBUILD タスク例外の処理

REBUILD タスクがエラーで中断された場合、または SUSPEND コマンドを使用して手動で停止した場合は、RESUME コマンドで再開するか、次の手順に従ってタスクを終了し、ソーステーブルを復元できます。

• 次のコマンドを実行して、REBUILD プロセス中に作成された一時テーブルをクリーンアップします。

  CALL hg_clean_rebuild_tmp_tables('<query_id>');

• ソーステーブルが読み取り専用になった後にタスクが中断された場合は、適切なコマンドを実行して書き込みを再度有効にします。

  • Hologres V4.1 より前のバージョンの場合：

    ALTER TABLE <table_name> SET (readonly = false);

  • Hologres V4.1 以降の場合：

    ALTER TABLE <table_name> SET RESET (ddl_options,write_options);