TRANSFER PARTITION

描述

ALTER SYSTEM TRANSFER PARTITION 语句用于将指定分区的迁移至指定的日志流。

使用限制及注意事项

• 仅支持在主租户上执行 Transfer Partition 操作，并且只能 Transfer 用户租户下的分区。

• 关闭租户的 Transfer 功能（即租户下配置项 enable_transfer 的值为 false）后，对该租户执行 TRANSFER PARTITION 语句会报错，已经执行成功了的 TRANSFER PARTITION 语句，其对应的 Transfer Partition 任务可能会被取消。

• 不支持对系统表执行 Transfer Partition 操作。

• 不支持对系统租户下的用户表执行 Transfer Partition 操作。

• 不支持将普通表 Transfer 到广播日志流上，同时也不支持将复制表 Transfer 到普通日志流上。

• 不支持 Transfer 非独立的分区，例如，局部索引表的分区和 LOB 表的分区不支持 Transfer。

• 对于同一个分区，在 Transfer Partition 操作未完成之前，不允许再次发起 Transfer Partition 操作。

• 如果当前集群中已经有一个均衡任务（BALANCE_JOB）正在处理，手动触发的 Transfer Partition 任务不会立刻开始调度。

权限要求

执行 ALTER SYSTEM TRANSFER PARTITION 语句需要当前用户拥有 ALTER SYSTEM 权限。有关 OceanBase 数据库权限的详细介绍，请参见 MySQL 模式下的权限分类 和 Oracle 模式下的权限分类。

语法

ALTER SYSTEM TRANSFER PARTITION TABLE_ID [=] $table_id, OBJECT_ID [=] $object_id TO LS $ls_id [tenant = '$tenant_name']

参数解释

示例

1. 使用 root 用户登录到集群的 sys 租户。

   连接示例如下，连接数据库时请以实际环境为准。

   obclient -h10.xx.xx.xx -P2883 -uroot@sys#obdemo -p***** -A
   

2. 查询视图 DBA_OB_TENANTS，获取目标租户的 TENANT_ID。

   obclient [oceanbase]> SELECT TENANT_ID FROM oceanbase.DBA_OB_TENANTS WHERE TENANT_NAME = 'oracle_tenant';
   

   查询结果如下：

   +-----------+
   | TENANT_ID |
   +-----------+
   |      1006 |
   +-----------+
   1 row in set
   

3. 确认分区信息。

   可以通过查询视图 CDB_OB_TABLE_LOCATIONS，获取指定分区的 TABLE_ID、OBJECT_ID 以及 LS_ID。

   • 获取非分区表的 TABLE_ID、OBJECT_ID 以及 LS_ID

     假设 oracle_tenant 租户下存在非分区表 T1，查询示例如下：

     obclient [oceanbase]> SELECT TABLE_ID AS TABLE_ID, OBJECT_ID, TABLET_ID, LS_ID FROM oceanbase.CDB_OB_TABLE_LOCATIONS WHERE TENANT_ID = 1006 AND DATABASE_NAME = 'SYS' AND TABLE_NAME= 'T1' LIMIT 1;
     

     查询结果如下：

     +----------+-----------+-----------+-------+
     | TABLE_ID | OBJECT_ID | TABLET_ID | LS_ID |
     +----------+-----------+-----------+-------+
     |   500002 |    500002 |    200001 |  1001 |
     +----------+-----------+-----------+-------+
     1 row in set
     

   • 获取一级分区表的 TABLE_ID、OBJECT_ID 以及 LS_ID

     对于一级分区表，查询时只需要指定具体的一级分区名即可。

     假设 oracle_tenant 租户下存在一级分区表 TBL1_LOG_R。

     obclient [SYS]> CREATE TABLE tbl1_log_r(log_id INT,log_date DATE NOT NULL DEFAULT SYSDATE)
      PARTITION BY RANGE(log_date)
       (PARTITION M202001 VALUES LESS THAN(TO_DATE('2020/02/01','YYYY/MM/DD'))
        , PARTITION M202002 VALUES LESS THAN(TO_DATE('2020/03/01','YYYY/MM/DD'))
        , PARTITION M202003 VALUES LESS THAN(TO_DATE('2020/04/01','YYYY/MM/DD'))
        , PARTITION M202004 VALUES LESS THAN(TO_DATE('2020/05/01','YYYY/MM/DD'))
        , PARTITION M202005 VALUES LESS THAN(TO_DATE('2020/06/01','YYYY/MM/DD'))
        , PARTITION M202006 VALUES LESS THAN(TO_DATE('2020/07/01','YYYY/MM/DD'))
        , PARTITION M202007 VALUES LESS THAN(TO_DATE('2020/08/01','YYYY/MM/DD'))
        , PARTITION M202008 VALUES LESS THAN(TO_DATE('2020/09/01','YYYY/MM/DD'))
        , PARTITION M202009 VALUES LESS THAN(TO_DATE('2020/10/01','YYYY/MM/DD'))
        , PARTITION M202010 VALUES LESS THAN(TO_DATE('2020/11/01','YYYY/MM/DD'))
        , PARTITION M202011 VALUES LESS THAN(TO_DATE('2020/12/01','YYYY/MM/DD'))
        , PARTITION M202012 VALUES LESS THAN(TO_DATE('2021/01/01','YYYY/MM/DD'))
        , PARTITION MMAX VALUES LESS THAN (MAXVALUE)
        );
     

     查询该一级分区表中分区 M202005 相关信息的示例如下：

     obclient [oceanbase]> SELECT TABLE_ID AS TABLE_ID, OBJECT_ID, TABLET_ID, LS_ID FROM oceanbase.CDB_OB_TABLE_LOCATIONS WHERE TENANT_ID = 1006 AND DATABASE_NAME = 'SYS' AND TABLE_NAME= 'TBL1_LOG_R' AND PARTITION_NAME = 'M202005' LIMIT 1;
     

     查询结果如下：

     +----------+-----------+-----------+-------+
     | TABLE_ID | OBJECT_ID | TABLET_ID | LS_ID |
     +----------+-----------+-----------+-------+
     |   500003 |    500009 |    200006 |  1002 |
     +----------+-----------+-----------+-------+
     1 row in set
     

   • 获取二级分区表的 TABLE_ID、OBJECT_ID 以及 LS_ID

     对于二级分区表，查询时需要同时指定一级分区名和二级分区名。

     假设 oracle_tenant 租户下存在二级分区表 T2_F_RL。

     obclient [SYS]> CREATE TABLE t2_f_rl(col1 INT,col2 VARCHAR2(50))
      PARTITION BY RANGE(col1)
      SUBPARTITION BY LIST(col2)
      (PARTITION p0 VALUES LESS THAN(100)
        (SUBPARTITION sp0 VALUES('01'),
         SUBPARTITION sp1 VALUES('02')
         ),
       PARTITION p1 VALUES LESS THAN(200)
        (SUBPARTITION sp2 VALUES('01'),
         SUBPARTITION sp3 VALUES('02'),
         SUBPARTITION sp4 VALUES('03')
        )
       );
     

     查询该二级分区表中二级分区 SP2 相关信息的示例如下：

     obclient [oceanbase]> SELECT TABLE_ID AS TABLE_ID, OBJECT_ID, TABLET_ID, LS_ID FROM oceanbase.CDB_OB_TABLE_LOCATIONS WHERE TENANT_ID = 1006 AND DATABASE_NAME = 'SYS' AND TABLE_NAME= 'T2_F_RL' AND PARTITION_NAME = 'P1' AND SUBPARTITION_NAME = 'SP2' LIMIT 1;
     

     查询结果如下：

     +----------+-----------+-----------+-------+
     | TABLE_ID | OBJECT_ID | TABLET_ID | LS_ID |
     +----------+-----------+-----------+-------+
     |   500018 |    500023 |    200017 |  1003 |
     +----------+-----------+-----------+-------+
     1 row in set
     

4. 选择 Transfer 目的端。

   1. 查询视图 CDB_OB_LS，获取租户的日志流状态和信息。

      obclient [oceanbase]> SELECT * FROM oceanbase.CDB_OB_LS WHERE TENANT_ID = 1006;
      

      查询结果如下：

      +-----------+-------+--------+--------------+---------------+-------------+---------------------+----------+---------------------+---------------------+------+-----------|
      | TENANT_ID | LS_ID | STATUS | PRIMARY_ZONE | UNIT_GROUP_ID | LS_GROUP_ID | CREATE_SCN          | DROP_SCN | SYNC_SCN            | READABLE_SCN        | FLAG | UNIT_LIST |
      +-----------+-------+--------+--------------+---------------+-------------+---------------------+----------+---------------------+---------------------+------+-----------|
      |      1006 |     1 | NORMAL | zone1        |             0 |           0 |                NULL |     NULL | 1701244663685197789 | 1701244663685197789 |      |           |
      |      1006 |  1001 | NORMAL | zone1        |             0 |        1001 | 1701239786827662637 |     NULL | 1701244663685197789 | 1701244663685197789 |      | 1001      |
      |      1006 |  1002 | NORMAL | zone1        |             0 |        1002 | 1701239786831568305 |     NULL | 1701244664066906860 | 1701244664066906859 |      | 1002      |
      |      1006 |  1003 | NORMAL | zone1        |             0 |        1003 | 1701239786834300282 |     NULL | 1701244664175263949 | 1701244664175263948 |      | 1003      |
      +-----------+-------+--------+--------------+---------------+-------------+---------------------+----------+---------------------+---------------------+------+-----------|
      4 rows in set
      

   2. 查询视图 CDB_OB_TABLET_TO_LS，获取日志流上 Tablet 的分布信息。

      obclient [oceanbase]> SELECT LS_ID, COUNT(*) AS C FROM oceanbase.CDB_OB_TABLET_TO_LS WHERE TENANT_ID = 1006 GROUP BY LS_ID;
      

      查询结果如下：

      +-------+------+
      | LS_ID | C    |
      +-------+------+
      |     1 |  578 |
      |  1001 |    7 |
      |  1002 |    5 |
      |  1003 |    7 |
      +-------+------+
      4 rows in set
      

      根据上述展示的信息，选择合适的日志流作为 Transfer 目的端。

5. 执行以下命令，进行 Transfer Partition 操作。

   ALTER SYSTEM TRANSFER PARTITION TABLE_ID [=] table_id, OBJECT_ID [=] object_id TO LS ls_id TENANT = 'tenant_name';
   

   其中：

   • table_id：表 ID。

   • object_id：分区的唯一标识。

   • ls_id：Transfer 目的端的日志流 ID。

   • tenant_name：待 Transfer 的分区所属的租户。

   以租户 oracle_tenant 为例，将其 SYS 库下的表 TBL1_LOG_R 的 M202005 分区，从当前 1002 号日志流迁移到 1003 号日志流上，示例如下。

   obclient [oceanbase]> ALTER SYSTEM TRANSFER PARTITION TABLE_ID = 500003, OBJECT_ID = 500009 TO LS 1003 TENANT = 'oracle_tenant';
   

6. Transfer Partition 命令执行成功后，可以通过以下视图查看任务状态。

   1. 查询视图 CDB_OB_TRANSFER_PARTITION_TASKS，获取任务的 TASK_ID、TRANSFER_TASK_ID 和 BALANCE_JOB_ID。

      视图 CDB_OB_TRANSFER_PARTITION_TASKS 展示了所有租户当前正在处理的分区 Transfer 任务。查询示例如下：

      obclient [oceanbase]> SELECT TASK_ID, BALANCE_JOB_ID, TRANSFER_TASK_ID, STATUS FROM oceanbase.CDB_OB_TRANSFER_PARTITION_TASKS WHERE TENANT_ID = 1006 AND TABLE_ID = 500003 AND OBJECT_ID = 500009;
      

      查询结果的示例如下：

      +---------+----------------+------------------+--------+
      | TASK_ID | BALANCE_JOB_ID | TRANSFER_TASK_ID | STATUS |
      +---------+----------------+------------------+--------+
      |       1 |          17304 |                1 | DOING  |
      +---------+----------------+------------------+--------+
      1 row in set
      

      可以根据查询结果中 STATUS 的值确认任务状态，进一步查看任务执行进度：

      • WAITING: 表示任务在等待中，还没有开始调度。
      • INIT：表示任务已经构建 BALANCE_JOB_ID 了，您可以根据 BALANCE_JOB_ID 查看关联的 BALANCE_JOB_ID 执行进度。
      • DOING: 表示任务已经开始执行 Transfer 了，您可以根据 TRANSFER_TASK_ID 查看关联的 Transfer Partition 任务，TRANSFER_TASK_ID 会变化很多次，一个 Transfer Partition 任务会涉及多次 Transfer。

      如果视图 CDB_OB_TRANSFER_PARTITION_TASKS 的查询结果为空，可以通过视图 CDB_OB_TRANSFER_PARTITION_TASK_HISTORY 来查看任务结果。

   2. 根据获取的 BALANCE_JOB_ID 查询视图 CDB_OB_BALANCE_JOBS 或 CDB_OB_BALANCE_JOB_HISTORY，确认关联的 BALANCE_JOB 的执行状态。

      视图 CDB_OB_BALANCE_JOBS 展示了所有租户当前正在执行的负载均衡工作。每个租户同一时间只有一个负载均衡工作（BALANCE_JOB），每个工作会生成多个负载均衡任务（TRANSFER_TASK）。视图 CDB_OB_BALANCE_JOB_HISTORY 展示了所有租户已执行的负载均衡工作历史。查询示例如下：

      obclient [oceanbase]> SELECT * FROM oceanbase.CDB_OB_BALANCE_JOBS WHERE JOB_ID = 17304;
      

      obclient [oceanbase]> SELECT * FROM oceanbase.CDB_OB_BALANCE_JOB_HISTORY WHERE JOB_ID = 17304;
      

      其中，17304 需要替换为上一步获取的 BALANCE_JOB_ID。

      查询结果中的 STATUS 列展示了 BALANCE_JOB 的执行状态：

      • DOING：表示正在执行负载均衡工作。
      • COMPLETED：表示负载均衡工作执行成功。
      • CANCELING：表示负载均衡工作取消中。
      • CANCELED：表示负载均衡工作已取消。

   3. 根据获取的 TRANSFER_TASK_ID 查询视图 CDB_OB_TRANSFER_TASKS 或 CDB_OB_TRANSFER_TASK_HISTORY，确认任务关联的 TRANSFER_TASK 的执行状态。

      视图 CDB_OB_TRANSFER_TASKS 展示了所有租户当前正在执行的负载均衡任务。同一时间可能有多个负载均衡任务正在执行，这些任务（TRANSFER_TASK）都属于同一个负载均衡工作（BALANCE_JOB）。视图 CDB_OB_TRANSFER_TASK_HISTORY 展示了所有租户已执行的负载均衡任务历史。查询示例如下：

      obclient [oceanbase]> SELECT * FROM oceanbase.CDB_OB_TRANSFER_TASKS WHERE TASK_ID = 1;
      

      obclient [oceanbase]> SELECT * FROM oceanbase.CDB_OB_TRANSFER_TASK_HISTORY WHERE TASK_ID = 1;
      

      其中，1 需要替换为前面步骤中获取的 TRANSFER_TASK_ID。

      查询结果中的 STATUS 列展示了 TRANSFER_TASK 的执行状态：

      • INIT：表示正在创建任务。
      • START：表示开始执行 Transfer。
      • DOING：表示正在执行 Transfer。
      • ABORTED：表示 Transfer 任务执行失败，任务终止。
      • COMPLETED：表示 Transfer 任务执行成功。
      • FAILED：表示 Transfer 任务执行失败。
      • CANCELED：表示 Transfer 任务取消。

   4. 根据获取的 TASK_ID 查询视图 CDB_OB_TRANSFER_PARTITION_TASK_HISTORY，确认 Transfer Partition 任务的结果。

      视图 CDB_OB_TRANSFER_PARTITION_TASK_HISTORY 展示了所有租户已执行的 Transfer Partition 任务历史。

      obclient [oceanbase]> SELECT * FROM oceanbase.CDB_OB_TRANSFER_PARTITION_TASK_HISTORY WHERE TASK_ID = 1;
      

      其中，1 需要替换为前面步骤中获取的 TASK_ID。

      查询结果中的 STATUS 列展示了 Transfer Partition 任务的结果：

      • COMPLETED：表示 Transfer Partition 任务执行成功。

      • FAILED ：表示 Transfer Partition 任务执行失败，可以通过 COMMENT 列进一步确认任务失败的原因。

7. Transfer Partition 任务执行成功后，再次查看对应的分区信息。

   obclient [oceanbase]> SELECT TABLE_ID AS TABLE_ID, OBJECT_ID, TABLET_ID, LS_ID FROM oceanbase.CDB_OB_TABLE_LOCATIONS WHERE TENANT_ID = 1006 AND DATABASE_NAME = 'SYS' AND TABLE_NAME= 'TBL1_LOG_R' AND PARTITION_NAME = 'M202005' LIMIT 1;
   

   查询结果如下：

   +----------+-----------+-----------+-------+
   | TABLE_ID | OBJECT_ID | TABLET_ID | LS_ID |
   +----------+-----------+-----------+-------+
   |   500003 |    500009 |    200006 |  1003 |
   +----------+-----------+-----------+-------+
   1 row in set
   

   根据结果可知，SYS 库下的表 TBL1_LOG_R 的 M202005 分区，从之前的 1002 号日志流迁移到了 1003 号日志流上，Transfer Partition 操作成功。

相关文档

有关 Transfer Partition 的详细操作及说明，参见 Transfer Partition。