Hologres：物理分區表遷移為邏輯分區表

表結構轉換

邏輯分區表與原物理分區表相比，在建表語句方面，涉及如下轉換工作。

• DDL需增加LOGICAL關鍵字，並增加分區鍵的NOT NULL約束。

• （可選）物理分區表僅支援一個分區鍵，邏輯分區表支援最多兩個分區鍵，您可根據需要增加分區鍵數量。

樣本如下。

• 建立物理分區表：

  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在Query洞察進一步查看非同步任務的執行狀況。

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>。

• 遷移完成後，需要進一步完成剩餘事項適配，包括匯入任務、查詢任務、營運任務適配。

• 適配工作完成前，相關任務可能由於相容性產生報錯，因此不推薦使用該方式遷移分區表。

使用樣本：

ASYNC REBUILD TABLE user_profile
  WITH (keep_source) -- 保留原物理分區表
ALTER ds SET NOT NULL,   -- 為分區欄位增加NOT NULL約束
TO logical partition;    -- 物理分區錶轉換為邏輯分區表

情境一：新增子表/子分區並匯入資料

-- 原物理分區表匯入任務
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';

情境二：回刷子表/子分區資料

-- 原物理分區表回刷任務（通過建立暫存資料表實現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';

-- 暫存資料表RENAME並ATTACH到父表
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';