パーティション交換

OceanBaseデータベースのパーティション交換機能は、主にパーティションテーブルへのデータを迅速にインポートし、効率的なデータロードを実現するために使用されます。具体的には、フルダイレクトロードにより新規作成された非パーティションテーブルにデータを高速にインポートした後、パーティション交換機能を利用して非パーティションテーブルのデータをパーティションテーブルに迅速にインポートし、既存のパーティションテーブルへの増分データインポートのパフォーマンスを向上させます。

パーティション交換機能は、増分ダイレクトロードの代替案として検討できます。例えば、パーティション交換機能を利用してパーティションテーブルAの増分データをインポートする手順は以下の通りです：

1. テーブルAに空の新しいパーティションPを作成します。
2. テーブルAと構造が完全に同じ非パーティションテーブルBを新規作成し、ダイレクトロードによって増分データをテーブルBにインポートします。
3. パーティション交換機能を利用して、テーブルAの新しいパーティションPとテーブルBを交換します。

サポートされているパーティション交換の状況

パーティション交換のサポート状況は以下の表のとおりです。ここで、タイプの列はターゲットテーブル(target_partition_table_name)を、タイプの行はソーステーブル(origin_table_name)を表します。

制限事項と注意点

• データ検証はサポートされていないため、WITHOUT VALIDATIONを指定する必要があります。ユーザーは交換データの有効性を自己保証する必要があります。

• パーティションテーブルと非パーティションテーブルのテーブルレベルおよび列レベルの属性要件は、一対一で対応している必要があります。

• パーティションテーブルと非パーティションテーブルの制約要件は完全に同じであり、現在のバージョンでは両テーブル間で外部キー制約を持つことはサポートされていません。

• パーティションテーブルのローカルインデックステーブルと非パーティションテーブルのインデックステーブルは、一対一で対応している必要があります。

• INCLUDING INDEXESの動作のみがサポートされています(MySQLモードではデフォルトでINCLUDING INDEXESが含まれます)。ローカルインデックスが対応するパーティションのデータも交換に含まれ、交換後も交換前と同じ可用状態を維持します。

• UPDATE GLOBAL INDEXESはサポートされていないため、グローバルインデックスは交換成功後すべてUnusable状態(無効状態)になります。

• 現在のパーティション交換機能は、増分ダイレクトロードの一時的な代替機能としてのみ使用することを推奨します。増分ダイレクトロードの詳細については、ダイレクトロードの概要を参照してください。

• パーティションテーブルと非パーティションテーブルのデータ交換を行う場合：

  • パーティションはRange/Range columns/Listパーティションである必要があります。

• セカンダリパーティションテーブルのセカンダリパーティションと非パーティションテーブルのデータ交換を行う場合：

  • パーティションの種類に制限はありませんが、セカンダリパーティションはRange/Range columnsパーティションである必要があります。

• セカンダリパーティションテーブルのパーティションとパーティションテーブルのデータ交換を行う場合：

  • target_partition_table_nameはセカンダリパーティションテーブルである必要があり、交換するパーティションはそのテーブルのパーティション名である必要があります。また、そのセカンダリパーティションテーブルのパーティションはRange/Range Columns/List/List Columnsパーティションである必要があります。
  • origin_table_nameはパーティションテーブルである必要があり、そのパーティションの種類は交換用のパーティションの下のセカンダリパーティションと完全に一致している必要があります。
  • パーティションテーブルとセカンダリパーティションテーブルを交換した後、関連するテーブルの統計情報は無効になり、再収集する必要があります。

構文

ALTER TABLE target_partition_table_name
    EXCHANGE PARTITION partition_name
    WITH TABLE origin_table_name
    WITHOUT VALIDATION;

パラメータ説明

使用方法

現在のパーティション交換機能は、パーティションテーブルの1つのパーティションと非パーティションテーブルとのデータ交換を実装しており、主に増分ダイレクトロード機能の一時的な代替ツールとして使用されます。ここで、パーティションテーブルと非パーティションテーブルは通常、以下の特性を持ちます：

• パーティションテーブル(partitioned table)：履歴データを含むパーティションテーブルで、通常データ量が多いです。
• ノンパーティションテーブル（non-partitioned table）：増分データを含みます。

パーティション交換機能の使用にあたっては、不適切な操作により元のテーブルのパーティションキーの条件を満たさなくなる可能性があり、連鎖エラーを引き起こすおそれがあるため、極めて慎重に行う必要があります。そのため、パーティション交換を実行する際には、以下の手順に従って、パーティションテーブルとノンパーティションテーブルがパーティション交換を行えるかどうかを判断してください。

1. SHOW CREATE TABLE ステートメントを使用して、パーティションテーブルのパーティションキーとターゲットパーティション情報を確認します。ノンパーティションテーブルのデータを確認し、そのデータがターゲットパーティションのパーティションキーのデータ範囲要件を満たしているかどうかを判断します。

   ここで、table_name はクエリ対象のテーブル名です。

   SHOW CREATE TABLE table_name;
   

2. クエリ結果に基づき、パーティションテーブルとノンパーティションテーブルが上記の 制限事項および注意点 を満たしていることを確認します。

3. パーティション交換を行う前に、少なくとも以下の条件が満たされていることを確認する必要があります。

   プロパティ	要求
   同一テナント内に存在するかどうか	はい
   同一データベース内に存在するかどうか	いいえ、MySQL互換であり、データベース間での交換をサポートします
   同一のテーブルグループ（TableGroup）に属するかどうか	はい
   同一のテーブルスペース（TableSpace）に属するかどうか	はい
   使用する文字セット形式が一致しているかどうか	はい
   テーブルタイプが一致しているかどうか	はい。どちらもユーザーテーブル、すなわち USER_TABLE である必要があります
   主キーの数が一致しているかどうか	はい
   行ストレージ形式が一致しているかどうか	はい
   列形式と列の相対順序が一致しているかどうか	はい
   自動インクリメント列であるかどうか	はい
   列のデフォルト値や生成列式が一致しているかどうか	はい
   暗号化方式が一致しているかどうか	はい
   カラムストア形式が一致しているかどうか	はい
   インデックス形式、状態、数が一致しているかどうか	はい。パーティションテーブルのローカルインデックスは、ノンパーティションテーブルのインデックスと一対一で対応している必要があります
   インデックステーブル名が一致しているかどうか	はい。MySQL互換であり、同じテーブル名のインデックス定義は一対一で対応しています
   制約の形式や含まれる列が一致しているかどうか	はい

4. パーティション交換の構文を使用してパーティション交換を行います。交換後、パーティションテーブルの指定されたパーティションのデータはノンパーティションテーブルに移行し、ノンパーティションテーブルのデータはパーティションテーブルの指定されたパーティションに移行します。パーティションテーブルのグローバルインデックスの状態は Unusable になります。

例

例1：RANGEパーティションテーブルと非パーティションテーブルのデータ交換

• RANGEパーティションテーブルと非パーティションテーブルのデータを交換します。

  1. RANGEパーティションテーブル tbl1_r を作成します。

     obclient> CREATE TABLE tbl1_r (col1 INT PRIMARY KEY, col2 VARCHAR(50))
         PARTITION BY RANGE(col1) 
             (PARTITION p0 VALUES LESS THAN(10),
             PARTITION p1 VALUES LESS THAN(20),
             PARTITION p2 VALUES LESS THAN(30)
             );
     

  2. 非パーティションテーブル tbl1 を作成します。

     obclient> CREATE TABLE tbl1 (col1 INT PRIMARY KEY, col2 VARCHAR(50));
     

  3. テーブル tbl1 にデータを挿入します。

     obclient> INSERT INTO tbl1 VALUES(1, 'a1'),(2, 'a2');
     

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

     Query OK, 2 rows affected
     Records: 2  Duplicates: 0  Warnings: 0
     

  4. パーティションテーブル tbl1_r のパーティション p0 と非パーティションテーブル tbl1 の間でデータを交換します。

     obclient> ALTER TABLE tbl1_r
         EXCHANGE PARTITION p0
         WITH TABLE tbl1
         WITHOUT VALIDATION;
     

  5. パーティションテーブル tbl1_r のパーティション p0 のデータを確認します。

     obclient> SELECT * FROM tbl1_r PARTITION(p0);
     

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

     +------+------+
     | col1 | col2 |
     +------+------+
     |    1 | a1   |
     |    2 | a2   |
     +------+------+
     2 rows in set
     

• LISTパーティションテーブルと非パーティションテーブルのデータを交換します。

  1. LISTパーティションテーブル tbl1_l を作成します。

     obclient> CREATE TABLE tbl1_l (col1 INT, col2 VARCHAR(50), col3 INT)
         PARTITION BY LIST(col3) 
             (PARTITION p0 VALUES IN (1, 2, 3, 4),
             PARTITION p1 VALUES IN (5, 6, 7, 8, 9),
             PARTITION p2 VALUES IN (DEFAULT)
             );
     

  2. 非パーティションテーブル tbl1_2 を作成します。

     obclient> CREATE TABLE tbl1_2 (col1 INT, col2 VARCHAR(50), col3 INT);
     

  3. テーブル tbl1_2 にデータを挿入します。

     obclient> INSERT INTO tbl1_2 VALUES(1, 'a1', 1),
         (2, 'a2', 2),
         (3, 'a3', 3),
         (4, 'a4', 4),
         (5, 'a5', 5);
     

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

     Query OK, 5 rows affected
     Records: 5  Duplicates: 0  Warnings: 0
     

  4. パーティションテーブル tbl1_l のパーティション p0 と非パーティションテーブル tbl1_2 をパーティション交換します。

     obclient> ALTER TABLE tbl1_l
         EXCHANGE PARTITION p0
         WITH TABLE tbl1_2
         WITHOUT VALIDATION;
     

  5. パーティションテーブル tbl1_l のパーティション p0 のデータを確認します。

     obclient> SELECT * FROM tbl1_l PARTITION(p0);
     

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

     +------+------+------+
     | col1 | col2 | col3 |
     +------+------+------+
     |    1 | a1   |    1 |
     |    2 | a2   |    2 |
     |    3 | a3   |    3 |
     |    4 | a4   |    4 |
     |    5 | a5   |    5 |
     +------+------+------+
     5 rows in set
     

例2：サブパーティションテーブルのパーティションとパーティションテーブルのデータ交換

1. Range + Hash サブパーティションテーブル tbl2_rh を作成します。

   obclient> CREATE TABLE tbl2_rh (col1 INT PRIMARY KEY, col2 INT)
       PARTITION BY RANGE(col1)
       SUBPARTITION BY HASH(col1) SUBPARTITIONS 5
           (PARTITION p0 VALUES LESS THAN (10),
           PARTITION p1 VALUES LESS THAN (20),
           PARTITION p2 VALUES LESS THAN (30),
           PARTITION p3 VALUES LESS THAN (MAXVALUE)
           );
   

2. Hash パーティションテーブル tbl2_h を作成します。

   obclient> CREATE TABLE tbl2_h (col1 INT PRIMARY KEY, col2 INT)
       PARTITION BY HASH(col1) PARTITIONS 5;
   

3. テーブル tbl2_rh にデータを挿入します。

   obclient> INSERT INTO tbl2_rh VALUES(11, 30), (14, 40), (26, 150), (29, 160);
   

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

   Query OK, 4 rows affected
   Records: 4  Duplicates: 0  Warnings: 0
   

4. パーティションテーブル tbl2_rh のパーティション p1 のデータを確認します。

   obclient> SELECT * FROM tbl2_rh PARTITION(p1);
   

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

   +------+------+
   | col1 | col2 |
   +------+------+
   |   11 |   30 |
   |   14 |   40 |
   +------+------+
   2 rows in set
   

5. テーブル tbl2_h にデータを挿入します。

   obclient> INSERT INTO tbl2_h VALUES(12, 20), (16, 110), (17, 170), (19, 120);
   

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

   Query OK, 4 rows affected
   Records: 4  Duplicates: 0  Warnings: 0
   

6. サブパーティションテーブル tbl2_rh のパーティション p1 とパーティションテーブル tbl2_h をパーティション交換します。

   obclient> ALTER TABLE tbl2_rh
       EXCHANGE PARTITION p1
       WITH TABLE tbl2_h
       WITHOUT VALIDATION;
   

7. パーティションテーブル tbl2_rh のパーティション p1 のデータを確認します。

   obclient> SELECT * FROM tbl2_rh PARTITION(p1);
   

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

   +------+------+
   | col1 | col2 |
   +------+------+
   |   16 |  110 |
   |   12 |   20 |
   |   17 |  170 |
   |   19 |  120 |
   +------+------+
   4 rows in set
   

例3：サブパーティションテーブルのサブパーティションと非パーティションテーブルとのデータ交換

1. Range + Range サブパーティションテーブル tbl3_rr を作成します。

   obclient> CREATE TABLE tbl3_rr(col1 INT, col2 INT)
       PARTITION BY RANGE(col1)
       SUBPARTITION BY RANGE(col2)
           (PARTITION p0 VALUES LESS THAN(10)
           (SUBPARTITION sp0 VALUES LESS THAN(20),
           SUBPARTITION sp1 VALUES LESS THAN(50),
           SUBPARTITION sp2 VALUES LESS THAN (MAXVALUE)
           ),
           PARTITION p1 VALUES LESS THAN(20)
           (SUBPARTITION sp3 VALUES LESS THAN(20),
           SUBPARTITION sp4 VALUES LESS THAN(50),
           SUBPARTITION sp5 VALUES LESS THAN (MAXVALUE)
           )
           );
   

2. 非パーティションテーブル tbl3 を作成します。

   obclient> CREATE TABLE tbl3 (col1 INT, col2 INT);
   

3. テーブル tbl3_rr にデータを挿入します。

   obclient> INSERT INTO tbl3_rr VALUES(1, 10), (4, 15), (6, 12), (19, 160);
   

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

   Query OK, 4 rows affected
   Records: 4  Duplicates: 0  Warnings: 0
   

4. パーティションテーブル tbl3_rr のパーティション sp0 のデータを確認します。

   obclient> SELECT * FROM tbl3_rr PARTITION(sp0);
   

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

   +------+------+
   | col1 | col2 |
   +------+------+
   |    1 |   10 |
   |    4 |   15 |
   |    6 |   12 |
   +------+------+
   3 rows in set
   

5. テーブル tbl3 にデータを挿入します。

   obclient> INSERT INTO tbl3 VALUES(2, 20), (3, 10), (5, 17), (8, 12);
   

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

   Query OK, 4 rows affected
   Records: 4  Duplicates: 0  Warnings: 0
   

6. サブパーティションテーブル tbl3_rr のパーティション sp0 とパーティションテーブル tbl3 との間でパーティション交換を実行します。

   obclient> ALTER TABLE tbl3_rr
       EXCHANGE PARTITION sp0
       WITH TABLE tbl3
       WITHOUT VALIDATION;
   

7. パーティションテーブル tbl3_rr のパーティション sp0 のデータを確認します。

   obclient> SELECT * FROM tbl3_rr PARTITION(sp0);
   

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

   +------+------+
   | col1 | col2 |
   +------+------+
   |    2 |   20 |
   |    3 |   10 |
   |    5 |   17 |
   |    8 |   12 |
   +------+------+
   4 rows in set
   

関連ドキュメント

• ALTER TABLE
• SELECT