レプリケーションテーブルの属性を変更する

OceanBaseデータベースでは、DUPLICATE_SCOPEパラメータを使用してレプリケーションテーブルの属性を指定します。テーブル作成後、DUPLICATE_SCOPEパラメータの値を変更することで、レプリケーションテーブルと通常テーブルを相互に変換できます。

使用上の制限と注意事項

• レプリケーションテーブルの変換時に、現在のテナントでスケーリング、プライマリゾーンの変更、ローカリティの変更などの操作が行われ、それによってロードバランシングタスクがトリガーされている場合は、レプリケーションテーブル属性の変換タスクは、現在のロードバランシングタスクが完了するまで待機する必要があります。

  注意

  レプリケーションテーブルの変換プロセスは非同期です。DUPLICATE_SCOPEを手動で変更した後、実際に対象属性のテーブルとして使用できるようになるまで、バックグラウンドのパーティションロードバランシングタスクの完了を待つ必要があります。パーティションロードバランシングの詳細については、テナント内ロードバランシングを参照してください。

• レプリケーションテーブルとテーブルグループは相互排他な関係にあるため、通常のテーブルをレプリケーションテーブルに変換する際、変換対象の通常テーブルが特定のテーブルグループに属している場合、その通常テーブルはレプリケーションテーブルに変換できません。

• レプリケーションテーブルの変換は、テナントのロードバランシングおよびTransfer機能に依存します。テナントレベル構成パラメータenable_rebalance、enable_transfer、およびenable_rereplicationのいずれか一方の値がfalse（オフ状態）の場合、レプリケーションテーブルの変換操作はできません。構成パラメータenable_rebalance、enable_transferの値をfalseに変更した際に、実行中のレプリケーションテーブル変換タスクがある場合、該当するレプリケーションテーブル変換タスクはキャンセルされます。

前提条件

レプリケーションテーブルの変換操作を行う前に、以下の構成パラメータの値がTrueに設定されていることを確認してください：

• enable_rebalance

  テナントレベル構成パラメータenable_rebalanceは、システムテナントではテナント間のロードバランシングを行うかどうかを、ユーザーテナントではテナント内のロードバランシングを行うかどうかを制御します。デフォルト値はTrueです。構成パラメータenable_rebalanceの詳細説明および設定については、enable_rebalanceを参照してください。

• enable_transfer

  テナントレベル構成パラメータenable_transferは、テナント内でTransferを行うかどうかを制御します。デフォルト値はTrueです。構成パラメータenable_transferの詳細説明および設定については、enable_transferを参照してください。

• enable_rereplication

  クラスタレベル構成パラメータenable_rereplicationは、ログストリームレプリカの自動移行・複製の総合スイッチです。デフォルト値はTrueです。構成パラメータenable_rereplicationの詳細説明および設定については、enable_rereplicationを参照してください。

レプリケーションテーブル属性の変更構文

レプリケーションテーブル属性を変更するSQLステートメントは以下のとおりです：

ALTER TABLE table_name DUPLICATE_SCOPE= 'none | cluster';

ステートメント内で：

• none：現在のテーブルを通常テーブルに変換します。
• cluster：現在のテーブルをレプリケーションテーブルに変換します。

例

以下のコマンドは、レプリケーションテーブルを通常テーブルに変換する方法を示しています。

1. レプリケーションテーブル tbl1 を作成します。

   obclient [test]> CREATE TABLE tbl1 (c1 int,c2 int) DUPLICATE_SCOPE= 'cluster';
   

2. このレプリケーションテーブルを通常テーブルに変換します。

   ALTER TABLE tbl1 DUPLICATE_SCOPE= 'none';
   

   注意

   上記のSQLステートメントは、テーブルの属性を変更した後すぐに成功を返しますが、実際のレプリケーションテーブルから通常テーブルへの変換処理は、バックグラウンドスレッドによって非同期で実行されます。

3. テーブルのレプリケーションテーブル属性を確認します。

   ビュー oceanbase.DBA_OB_TABLE_LOCATIONS を使用して、テーブルの現在のレプリケーションテーブル属性と存在するログストリームIDを確認できます。ここで、DUPLICATE_SCOPE 列が CLUSTER の場合はレプリケーションテーブル、NONE の場合は通常テーブルを意味します。

   SELECT database_name, table_name, table_id, tablet_id, ls_id, role, duplicate_scope
   FROM oceanbase.DBA_OB_TABLE_LOCATIONS
   WHERE table_name = 'tbl1';
   

   実行結果は次のとおりです：

   +---------------+------------+----------+-----------+-------+--------+-----------------+
   | database_name | table_name | table_id | tablet_id | ls_id | role   | duplicate_scope |
   +---------------+------------+----------+-----------+-------+--------+-----------------+
   | test          | tbl1       |   500011 |    200002 |  1002 | LEADER | NONE            |
   +---------------+------------+----------+-----------+-------+--------+-----------------+
   1 row in set
   

   説明

   以下の手順に従って、レプリケーションテーブルから通常テーブルへの変換後のパーティションレプリカの分散が目標属性に合致しているかどうかを確認できます。

4. レプリケーションテーブル変換の進捗状況を確認します。

   1. ログストリームの属性を確認します。

      テナント内のすべてのレプリケーションテーブルは、レプリケーションテーブルを専門に扱う特別なログストリーム（ブロードキャストログストリーム）に配置されます。ビュー oceanbase.DBA_OB_LS を使用してログストリームの属性を確認できます。ここで、FLAG 列に DUPLICATE が含まれている場合はブロードキャストログストリームを表します。FLAG が空または DUPLICATE を含まない場合は通常ログストリームを表します。

      SELECT * FROM oceanbase.DBA_OB_LS WHERE LS_ID = 1002;
      

      実行結果は次のとおりです：

      +-------+--------+--------------+---------------+-------------+---------------------+----------+---------------------+---------------------+-----------+-----------+
      | LS_ID | STATUS | PRIMARY_ZONE | UNIT_GROUP_ID | LS_GROUP_ID | CREATE_SCN          | DROP_SCN | SYNC_SCN            | READABLE_SCN        | FLAG      | UNIT_LIST |
      +-------+--------+--------------+---------------+-------------+---------------------+----------+---------------------+---------------------+-----------+-----------+
      |  1002 | NORMAL | zone1        |             0 |           0 | 1713164377091593001 |     NULL | 1713171198496433000 | 1713171198496433000 | DUPLICATE |           |
      +-------+--------+--------------+---------------+-------------+---------------------+----------+---------------------+---------------------+-----------+-----------+
      1 row in set
      

   2. レプリケーションテーブル変換タスクを生成する必要があるかどうかを判断します。

      レプリケーションテーブル変換タスクは、バックグラウンドのロードバランシングおよびTransferモジュールによって生成されます。以下のステートメントを使用して、レプリケーションテーブル変換タスクを生成する必要があるかどうかを迅速に判断できます。ここで、DUPLICATE_SCOPE はテーブルの属性、FLAG は現在のテーブルの tablet が属するLSの属性です。FLAG に DUPLICATE が含まれている場合はブロードキャストログストリームを表します。

      SELECT A.duplicate_scope, B.flag
      FROM oceanbase.DBA_OB_TABLE_LOCATIONS AS A JOIN oceanbase.DBA_OB_LS AS B ON A.ls_id = B.ls_id
      WHERE A.table_name = 'tbl1'
      AND A.role = 'LEADER';
      

      実行結果は次のとおりです：

      +-----------------+-----------+
      | duplicate_scope | flag      |
      +-----------------+-----------+
      | NONE            | DUPLICATE |
      +-----------------+-----------+
      1 row in set
      

      実行情報の解釈は以下のとおりです：

      • DUPLICATE_SCOPE が NONE、FLAG に DUPLICATE が含まれている場合：非レプリケーションテーブルがブロードキャストログストリーム上にあり、レプリケーションテーブルから通常テーブルへの変換タスクを生成し、非レプリケーションテーブルをブロードキャストログストリームから通常ログストリームへTransferする必要があります。
      • DUPLICATE_SCOPE が NONE、FLAG に DUPLICATE が含まれていない場合：レプリケーションテーブルが通常ログストリーム上にあり、通常テーブルからレプリケーションテーブルへの変換タスクを生成し、レプリケーションテーブルを通常ログストリームからブロードキャストログストリームへTransferする必要があります。

   3. すぐに変換タスクを生成します。

      構成パラメータ partition_balance_schedule_interval を一時的に小さく設定することで、すぐに変換タスクを生成できます。

      ALTER SYSTEM SET partition_balance_schedule_interval = '30s';
      

   4. レプリケーションテーブル変換タスクを確認します。

      レプリケーションテーブル変換で生成されたタスクは、関連ビュー DBA/CDB_OB_BALANCE_JOB_HISTORY および DBA/CDB_OB_BALANCE_JOBS で確認できます。

      1. 過去の変換タスクの実行状況を確認します。

         過去の履歴がない場合、タスクが実行中またはまだ生成されていない可能性があります。

         SELECT * FROM oceanbase.DBA_OB_BALANCE_JOB_HISTORY;
         

         実行結果は次のとおりです：

         +--------+----------------------------+----------------------------+-------------------+-------------------+-----------------+-------------------------+-----------+---------+
         | JOB_ID | CREATE_TIME                | FINISH_TIME                | BALANCE_STRATEGY  | JOB_TYPE          | TARGET_UNIT_NUM | TARGET_PRIMARY_ZONE_NUM | STATUS    | COMMENT |
         +--------+----------------------------+----------------------------+-------------------+-------------------+-----------------+-------------------------+-----------+---------+
         | 777854 | 2024-04-15 16:54:29.220400 | 2024-04-15 16:54:39.231516 | partition balance | PARTITION_BALANCE |               1 |                       1 | COMPLETED | NULL    |
         +--------+----------------------------+----------------------------+-------------------+-------------------+-----------------+-------------------------+-----------+---------+
         1 row in set
         

      2. 現在のバランシングタスクの実行状況を確認します。

         SELECT * FROM oceanbase.DBA_OB_BALANCE_JOBS;
         

      3. 変換タスクに対応するサブタスク（パーティションリストを含む）を確認します。

         上記のタスクに対応する job_id を以下のSQLステートメントに入力します：

         SELECT * FROM oceanbase.DBA_OB_BALANCE_TASKS WHERE JOB_ID = xxxx;
         

         SELECT * FROM oceanbase.DBA_OB_BALANCE_TASK_HISTORY WHERE JOB_ID = xxxx;
         

関連ドキュメント

• テーブルの作成
• テーブルの変更