物理分区表迁移为逻辑分区表

表结构转换

逻辑分区表与原物理分区表相比，在建表语句方面，涉及如下转换工作。

• 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（Beta)。

注意事项如下：

• 使用REBUILD功能迁移分区表，迁移后的逻辑分区表表名不变。原物理分区表表名会改为tmp_rebuild_old_<query_id>_<unique_id>_<table_name>。

• 迁移完成后，需要进一步完成剩余事项适配，包括导入任务、查询任务、运维任务适配。

• 适配工作完成前，相关任务可能由于兼容性产生报错，因此不推荐使用该方式迁移分区表。

使用示例：

-- 为分区字段增加NOT NULL约束
ASYNC REBUILD TABLE user_profile ALTER ds SET NOT NULL;

-- 物理分区表转换为逻辑分区表，并保留原物理分区表
ASYNC REBUILD TABLE user_profile WITH (keep_source) 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';