レプリケーションテーブルのプロパティを変更する

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      |
      +-------+--------+--------------+---------------+-------------+---------------------+----------+---------------------+---------------------+-----------+
      |  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;
         

関連ドキュメント

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