フラッシュマテリアライズドビュー

ベーステーブルのデータを更新すると、マテリアライズドビューのデータとベーステーブルのデータが一致しなくなる可能性があります。このため、OceanBaseデータベースはマテリアライズドビューのデータを維持するために、マテリアライズドビューをフラッシュすることで対応します。

OceanBaseデータベースがサポートするマテリアライズドビューのフラッシュ戦略には、完全フラッシュと増分フラッシュがあり、手動スケジュールと自動スケジュールもサポートされています。

フル更新

OceanBaseデータベースでは、リモート更新方式によるフル更新が行われます。具体的には、隠れたテーブルを作成し、その隠れたテーブルに対して更新ステートメントを実行した後、元のテーブルと隠れたテーブルを切り替えます。そのため、フル更新操作には追加のスペースが必要であり、インデックス（存在する場合）も完全に再構築されます。

フル更新の注意点

• フル更新は非常に時間のかかるプロセスになる可能性があります。特に大量のデータを読み取り処理する必要がある場合に顕著です。そのため、フル更新を実行する前に、フル更新に必要な時間を常に考慮する必要があります。
• 現在のベーステーブルの列とマテリアライズドビューに対応する列の型が一致している場合、フル更新の条件を満たします。一致しない場合は、フル更新を実行することができません。
• あるマテリアライズドビューがフル更新された場合、それに依存するマテリアライズドビュー（ネストされたマテリアライズドビュー）は、その後の増分更新を行う前に必ず一度フル更新を行わなければなりません。そうでない場合、エラーが報告されます。

増分更新

現在、増分更新がサポートされているマテリアライズドビューは、単一テーブルの非集計、単一テーブルの集計、複数テーブルの関連付け、複数テーブルの関連付け集計、および集合クエリ（UNION ALL）のSQL文です。これら5つのシナリオに該当しないSQL文については、現時点では増分更新がサポートされていません。増分更新を行うためのSQL文の要件については、以下の説明を参照してください。

単一テーブルの非集約型増分更新

単一テーブルの非集約型増分更新の例

1. テーブル tbl1 を作成します。

   CREATE TABLE tbl1 (col1 NUMBER PRIMARY KEY, col2 NUMBER, col3 NUMBER, col4 NUMBER);
   

2. tbl1 テーブルにマテリアライズドビューログを作成します。

   CREATE MATERIALIZED VIEW LOG ON tbl1
       WITH SEQUENCE (col2, col3, col4) INCLUDING NEW VALUES;
   

3. テーブル tbl1 に基づいて、増分更新用のマテリアライズドビュー mv_tbl1 を作成します。

   CREATE MATERIALIZED VIEW mv_tbl1
       REFRESH FAST ON DEMAND
       AS SELECT col1, col2
          FROM tbl1;
   

単一テーブルの集計増分更新

単一テーブルの集計増分更新には、基本的に以下の要件があります：

• FROM テーブルは基準テーブルでなければならず、内部ビュー、通常のビューなどでは使用できません。

  説明

  ネストされたマテリアライズドビューはリアルタイムマテリアライズドビューをサポートしていないため、FROM テーブルがマテリアライズドビューの場合、リアルタイムマテリアライズドビューを使用することはできません。

• FROM テーブルには1つのテーブルしか存在しません。

• FROM テーブルにmlogが作成されており、ビューで使用される列はすべてmlogに存在します。

• ビュー定義にサブクエリは含まれません。

• ウィンドウ関数はサポートされていません。

• ビュー定義に ROLLUP、HAVING、DISTINCT、ORDER BY、LIMIT、FETCH などの句は含まれません。

• クエリに DISTINCT が含まれている場合、増分更新可能なマテリアライズドビューの出力列は一意である必要があるため、このような場合は DISTINCT の使用を直接禁止するか、削除する必要があります。

• GROUP BY を伴わないステートメントはスカラーアグリゲーション（Scalar Aggregate）でなければなりません。

• GROUP BY シナリオのマテリアライズドビューでは、SUM および COUNT などの集計関数がサポートされており、集計関数では単純な列のみを使用できます。GROUP BY の要件は以下のとおりです：

  集計関数	SELECT句には必ず依存する列を含める必要があります
  COUNT( expr )	N/A
  SUM ( expr )	COUNT( expr ) または expr が NULLでない
  AVG ( expr )	SUM ( expr ),COUNT( expr )
  STDDEV ( expr )	SUM ( expr ),COUNT( expr ),SUM ( expr * expr )
  VARIANCE ( expr )	SUM ( expr ),COUNT( expr ),SUM ( expr * expr )
  その他、SUMおよびCOUNTに分割可能な集計関数... (計算方法の変更により、精度に影響を与える可能性があります)	SUM (col1),COUNT(col1)
  MAX(expr)/MIN(expr) 説明 V4.3.5バージョンでは、V4.3.5 BP4バージョンから MAX と MIN の集計増分更新がサポートされています。	COUNT(expr)

  1. GROUP BY 句は標準の GROUP BY 構文でなければならず、ROLLUP および HAVING はサポートされていません。
  2. SELECT 句にはすべての GROUP BY 列が含まれていなければなりません。
  3. 集計関数には DISTINCT キーワードが含まれていません。
  4. SELECT 句には集計関数の列に加えて、対応する集計関数の依存列と COUNT(*) 列も含まれていなければなりません。例えば、集計関数 SUM(expr) を使用する場合は、COUNT(*) および COUNT(expr) 列も含める必要があります。

MIN/MAX集計増分更新条件：

上記の単一テーブル集約増分更新の基本要件を満たす場合、MAX および MIN 集約関数を使用する際の要件：マテリアライズド・ビューのベーステーブル上に、GROUP BY 列をプレフィックスとするインデックスが存在すること。

単一テーブルの集計増分更新の例

1. テーブル test_tbl1 を作成します。

   CREATE TABLE test_tbl1 (col1 NUMBER PRIMARY KEY, col2 NUMBER, col3 NUMBER, col4 NUMBER);
   

2. test_tbl1 テーブルにマテリアライズドビューのログを作成します。

   CREATE MATERIALIZED VIEW LOG ON test_tbl1
     WITH SEQUENCE (col2, col3, col4) INCLUDING NEW VALUES;
   

3. 更新方法が増分更新であるマテリアライズドビューを作成します。

   • mv1_test_tbl1 という名前のマテリアライズドビューを作成します。マテリアライズドビューの更新方法を増分更新に指定し、必要に応じて手動で更新操作をトリガーできます。マテリアライズドビューのクエリ部分は、テーブル test_tbl1 から col2 列を選択し、count(*)、count(col3)、sum(col3) の集計結果を計算し、グループ化の基準は col2 列の値です。

     CREATE MATERIALIZED VIEW mv1_test_tbl1
       REFRESH FAST ON DEMAND
       AS SELECT col2, count(*) cnt, count(col3) cnt_col3, sum(col3) sum_col3
          FROM test_tbl1
          GROUP BY col2;
     

   • mv2_test_tbl1 という名前のマテリアライズドビューを作成します。マテリアライズドビューの更新方法を増分更新に指定し、必要に応じて手動で更新操作をトリガーできます。マテリアライズドビューのクエリ部分は、テーブル test_tbl1 から count(*)、count(col3)、sum(col3) の集計結果を計算します。

     CREATE MATERIALIZED VIEW mv2_test_tbl1
       REFRESH FAST ON DEMAND
       AS SELECT count(*) cnt, count(col3) cnt_col3, sum(col3) sum_col3
          FROM test_tbl1;
     

   • mv3_test_tbl1 という名前のマテリアライズドビューを作成します。マテリアライズドビューの更新方法を増分更新に指定し、必要に応じて手動で更新操作をトリガーできます。マテリアライズドビューのクエリ部分は、テーブル test_tbl1 から count(col3) と sum(col3) の結果を計算します。

     CREATE MATERIALIZED VIEW mv3_test_tbl1
       REFRESH FAST ON DEMAND
       AS SELECT count(col3) cnt_col3, sum(col3) sum_col3
          FROM test_tbl1;
     

   • mv4_test_tbl1 という名前のマテリアライズドビューを作成します。マテリアライズドビューの更新方法を増分更新に指定し、必要に応じて手動で更新操作をトリガーできます。マテリアライズドビューのクエリ部分は、テーブル test_tbl1 から col2 と col3 列を選択し、count(*)、count(col3)、sum(col3) の集計結果を計算し、col2 と col3 をグループ化の基準とします。

     CREATE MATERIALIZED VIEW mv4_test_tbl1
       REFRESH FAST ON DEMAND
       AS SELECT col2, col3, count(*) cnt, count(col3) cnt_col3, sum(col3) sum_col3
          FROM test_tbl1
          GROUP BY col2, col3;
     

   • mv5_test_tbl1 という名前のマテリアライズドビューを作成します。マテリアライズドビューの更新方法を増分更新に指定し、必要に応じて手動で更新操作をトリガーできます。マテリアライズドビューのクエリ部分は、テーブル test_tbl1 から col2 列を選択し、count(*)、count(col3)、sum(col3)、avg(col3) などの集計結果を計算すると同時に、カスタム列 calcol1 と calcol2 も計算し、グループ化の基準は col2 列の値です。

     CREATE MATERIALIZED VIEW mv5_test_tbl1
       REFRESH FAST ON DEMAND
       AS SELECT col2, count(*) cnt, count(col3) cnt_col3, sum(col3) sum_col3, avg(col3) avg_col3, avg(col3) * sum(col3)/col2 calcol1, col2+sum(col3) calcol2
          FROM test_tbl1
          GROUP BY col2;
     

   • mv6_test_tbl1 という名前のマテリアライズドビューを作成します。マテリアライズドビューの更新方法を増分更新に指定し、必要に応じて手動で更新操作をトリガーできます。マテリアライズドビューのクエリ部分は、テーブル test_tbl1 から col2 列を選択し、count(*)、count(col3)、sum(col3)、count(col3*col3)、sum(col3*col3)、STDDEV(col3) の集計結果を計算し、グループ化の基準は col2 列の値です。

     CREATE MATERIALIZED VIEW mv6_test_tbl1
       REFRESH FAST ON DEMAND
       AS SELECT col2, count(*) cnt, count(col3) cnt_col3, sum(col3) sum_col3, count(col3*col3) cnt_col3_2, sum(col3*col3) sum_col3_2, STDDEV(col3) stddev_col3
          FROM test_tbl1
          GROUP BY col2;
     

   • 集計関数 MAX と MIN を使用してマテリアライズドビューを作成します。

     1. テーブル test_tbl1 に col1 と col2 列に基づいて idx_test_tbl1 という名前のインデックスを作成します。

        CREATE INDEX idx_test_tbl1 ON test_tbl1(col1, col2);
        

     2. mv7_test_tbl1 という名前のマテリアライズドビューを作成します。マテリアライズドビューの更新方法を増分更新に指定し、必要に応じて手動で更新操作をトリガーできます。マテリアライズドビューのクエリ部分は、テーブル test_tbl1 から col1 と col2 列を選択し、count(*)、各グループ内の col3 の最小値と col4 の最大値の合計を計算し、col1 と col2 の組み合わせに基づいてデータをグループ化します。

        CREATE MATERIALIZED VIEW mv7_test_tbl1
            REFRESH FAST ON DEMAND
            AS SELECT
                col1,
                col2,
                count(*) cnt,
                MIN(col3) + MAX(col4) AS min_max_val
                FROM test_tbl1
                GROUP BY col1, col2;
        

   • GROUP BY で非基本列を使用する場合。

     1. テーブル m_tbl1 を作成する。

        obclient> CREATE TABLE m_tbl1(col1 NUMBER PRIMARY KEY, col2 DATE, col3 NUMBER, col4 NUMBER, col5 NUMBER, col6 NUMBER);
        

     2. テーブル m_tbl1 上にマテリアライズド・ビュー・ログを作成する。

        obclient> CREATE MATERIALIZED VIEW LOG ON m_tbl1
            WITH PRIMARY KEY, ROWID, SEQUENCE (col2, col3, col4, col5, col6)
            INCLUDING NEW VALUES;
        

     3. テーブル m_tbl1 上で、col3 および (ROUND(col2)) 列に基づく idx1_m_tbl1 という名前のインデックスを作成する。

        obclient> CREATE INDEX idx1_m_tbl1 ON m_tbl1(col3, (ROUND(col2)));
        

     4. 単一テーブルの集約増分更新を行うマテリアライズド・ビュー m_tbl1_mv1 を作成する。

        obclient> CREATE MATERIALIZED VIEW m_tbl1_mv1
            REFRESH FAST ON DEMAND
            AS SELECT
                col3,
                ROUND(col2) gby_2,
                COUNT(*) cnt,
                MAX(col4) max_c4,
                MIN(col5 + col6) min_c5_c6
            FROM m_tbl1
            GROUP BY col3, ROUND(col2);
        

複数テーブル結合による増分更新

複数テーブル結合による増分更新の基本的な要件は以下のとおりです：

1. FROM テーブルは内部ビューであってはなりません。

2. FROM テーブルには少なくとも2つのテーブルが含まれていなければなりません。

   説明

   OceanBaseデータベースV4.3.5 BP3以降では、マテリアライズドビューの増分更新機能に、複数テーブル外部結合(LEFT JOIN/RIGHT JOIN)のサポートが追加されました。

   外部結合の使用制限： 接続ツリーは、INNER JOIN が先で LEFT JOIN が後の左深結合ツリーである必要があります。

   注意すべき点として、マテリアライズドビューの増分更新の SELECT 句に LEFT JOIN 演算子が含まれている場合、作成時に主キー(PRIMARY KEY)または一意インデックス(UNIQUE INDEX)を指定することは禁止されています。これは、制約の競合による更新異常を防ぐためです。

3. FROM テーブルにはmlogが作成され、ビューで使用される列はすべてmlogに存在していなければなりません。

4. ビュー定義にサブクエリは存在しません。

5. ビュー定義に ROLLUP、HAVING、WINDOW FUNCTION、DISTINCT、ORDER BY、LIMIT および FETCH などの句は存在しません。

6. ビュー定義では、ROWNUM、RAND および SYSDATE などの不安定な出力値を持つ式を使用することはできません。

複数テーブル結合による増分更新の例

1. ベーステーブル t1 と t2 を作成します。

   CREATE TABLE t1(c1 INT PRIMARY KEY, c2 INT, c3 INT);
   

   CREATE TABLE t2(c1 INT PRIMARY KEY, c4 INT, c5 INT);
   

2. テーブル t1 とテーブル t2 にマテリアライズドビューのログを作成します。

   CREATE MATERIALIZED VIEW LOG ON t1 WITH PRIMARY KEY, ROWID, SEQUENCE (c2) INCLUDING NEW VALUES;
   

   CREATE MATERIALIZED VIEW LOG ON t2 WITH PRIMARY KEY, ROWID, SEQUENCE (c4) INCLUDING NEW VALUES;
   

3. テーブル t1 とテーブル t2 の結合による増分更新用のマテリアライズドビュー mv1_t1_t2 を作成します。

   CREATE MATERIALIZED VIEW mv1_t1_t2
     REFRESH FAST
     AS SELECT t1.c1 t1c1, t1.c2, t2.c1 t2c1, t2.c4
       FROM t1 JOIN t2 ON t1.c1=t2.c1;
   

マテリアライズドビューとその依存するベーステーブルにインデックスを作成する例：

1. (オプション) 以下のステートメントを使用して関連するテストデータを削除します。

   以下のデータベースオブジェクトがない場合は、このステップをスキップできます。

   DROP MATERIALIZED VIEW LOG ON t1;
   DROP TABLE t1;
   DROP MATERIALIZED VIEW LOG ON t2;
   DROP TABLE t2;
   DROP MATERIALIZED VIEW rt_mv1;
   

2. 以下のステートメントを使用して、テーブル t1 とインデックス idx_t1_c2 を作成します。

   CREATE TABLE t1(c1 INT GENERATED BY DEFAULT AS IDENTITY, c2 INT, c3 INT, c4 INT, c5 INT, PRIMARY KEY(c1));
   CREATE INDEX idx_t1_c2 ON t1(c2);
   

3. 以下のステートメントを使用して、テーブル t2 とインデックス idx_t2_c3 を作成します。

   CREATE TABLE t2(c1 INT GENERATED BY DEFAULT AS IDENTITY, c2 INT, c3 INT, c4 INT, c5 INT, PRIMARY KEY(c1));
   CREATE INDEX idx_t2_c3 ON t2(c3);
   

4. 以下のステートメントを使用して、t1 と t2 テーブルにそれぞれマテリアライズドビューのログを作成します。

   CREATE MATERIALIZED VIEW LOG ON t1 WITH PRIMARY KEY, ROWID, SEQUENCE (c2, c3, c4) INCLUDING NEW VALUES;
   CREATE MATERIALIZED VIEW LOG ON t2 WITH PRIMARY KEY, ROWID, SEQUENCE (c2, c3, c4) INCLUDING NEW VALUES;
   

5. 以下のステートメントを使用して、リアルタイムマテリアライズドビュー rt_mv1 を作成します。

   CREATE MATERIALIZED VIEW rt_mv1
     NEVER REFRESH
     ENABLE ON QUERY COMPUTATION
     DISABLE QUERY REWRITE
     AS SELECT t1.c1 AS t1_c1, t2.c1 AS t2_c1, t1.c2 AS t1_c2, t2.c2 AS t2_c2, t1.c3 AS t1_c3, t2.c3 AS t2_c3
         FROM t1, t2
         WHERE t1.c2 = t2.c3;
   

6. 以下のステートメントを使用して、マテリアライズドビュー内の各ベーステーブルの主キー列にインデックスを作成します。

   CREATE INDEX idx_mv_t1_c1 ON rt_mv1(t1_c1);
   CREATE INDEX idx_mv_t2_c1 ON rt_mv1(t2_c1);
   

複数テーブルの集計増分更新

複数テーブルの集計増分更新の基本的な要件は以下のとおりです：

• 複数テーブルの集計増分更新の基本的な要件は、上記の単一テーブルの集計増分更新および複数テーブル結合による増分更新の基本的な要件の和集合です。

• 外部結合を含む集約マテリアライズドビューの増分更新がサポートされています。外部結合に関する制限は非集約外部結合マテリアライズドビューと同じであり、集約部分に関する制限は内部結合を含むマテリアライズドビューと同じです。ただし、外部結合を含む集約マテリアライズドビューはMIN/MAX集計関数やリアルタイムマテリアライズドビューをサポートしていません。

  説明

  V4.3.5バージョンでは、V4.3.5 BP5バージョンから外部結合を含む集約マテリアライズドビューの増分更新がサポートされます。

複数テーブルの集計増分更新の例

1. ベーステーブルt3とt4を作成します。

   CREATE TABLE t3(c1 INT, c2 INT, c3 INT, c4 INT, PRIMARY KEY(c1));
   

   CREATE TABLE t4(c1 INT, c2 INT, c3 INT, c4 INT, PRIMARY KEY(c1));
   

2. テーブルt3とテーブルt4にマテリアライズドビューログを作成します。

   CREATE MATERIALIZED VIEW LOG ON t3 WITH PRIMARY KEY, ROWID, SEQUENCE(c2, c3, c4) INCLUDING NEW VALUES;
   

   CREATE MATERIALIZED VIEW LOG ON t4 WITH PRIMARY KEY, ROWID, SEQUENCE(c2, c3, c4) INCLUDING NEW VALUES;
   

3. テーブルt3とテーブルt4の結合集計増分更新用のリアルタイムマテリアライズドビューmv1_t3_t4を作成します。

   CREATE MATERIALIZED VIEW mv1_t3_t4
     REFRESH FAST
     ENABLE ON QUERY COMPUTATION
     AS SELECT t3.c1,
         COUNT(*) cnt,
         COUNT(t4.c4) cnt_c4,
         SUM(t4.c4) sum_c4,
         AVG(t4.c4) avg_c4
       FROM t3, t4
       WHERE t3.c2 = t4.c3
       GROUP BY t3.c1;
   

セットクエリによる増分更新

集合マテリアライズドビューは、UNION ALL セットクエリを使用した増分更新をサポートします。また、増分更新された集合マテリアライズドビューでは、結合されていないマテリアライズドビューを除き、すべての増分更新可能なマテリアライズドビューをセット内で使用できます。

セットクエリによる増分更新の基本的な要件は以下のとおりです：

• セットクエリを含むマテリアライズドビューはリアルタイムマテリアライズドビューをサポートしません。

• トップレベルのクエリは UNION ALL であり、ビュー定義にはサブクエリが含まれず、ORDER BY/LIMIT/FETCH などの句も存在しません。

• UNION ALL の各ブランチで同じ投影位置の出力列の型は同一でなければならず、サブブランチの列型を CAST によって強制的に統一することはサポートされていません。

  例えば、複数テーブル結合マテリアライズドビューでは、各結合テーブルの主キーが SELECT に含まれている必要があり、これらの SELECT 出力列には UNION ALL によって追加の CAST が加えられてはなりません。

• UNION ALL の各ブランチで同じ投影位置に同じ型/値の異なる定数が存在する場合、定数は識別列として各ブランチを区別します。

セットクエリによる増分更新の例

1. ベーステーブル ua_tbl1 と ua_tbl2 を作成します。

   CREATE TABLE ua_tbl1 (col1 INT PRIMARY KEY, col2 INT, col3 INT, col4 INT);
   

   CREATE TABLE ua_tbl2 (col1 INT PRIMARY KEY, col2 INT, col3 INT, col4 INT);
   

2. テーブル ua_tbl1 と ua_tbl2 にマテリアライズドビューログを作成します。

   CREATE MATERIALIZED VIEW LOG ON ua_tbl1
       WITH PRIMARY KEY, ROWID, SEQUENCE (col2, col3, col4) INCLUDING NEW VALUES;
   

   CREATE MATERIALIZED VIEW LOG ON ua_tbl2
       WITH PRIMARY KEY, ROWID, SEQUENCE (col2, col3, col4) INCLUDING NEW VALUES;
   

3. セットクエリによる増分更新を行うマテリアライズドビュー mv_ua_tbl1_tbl2 を作成します。

   CREATE MATERIALIZED VIEW mv_ua_tbl1_tbl2
       REFRESH FAST ON DEMAND
       AS SELECT
           a.col1 as a_c1,
           b.col1 as b_c1,
           1 marker,
           a.col2 val
       FROM ua_tbl1 a
               INNER JOIN ua_tbl2 b
               ON a.col2 = b.col3
       UNION ALL
       SELECT
           col1 a_c1,
           col2 b_c1,
           2 marker,
           count(*) val
       FROM ua_tbl1
       GROUP BY col1, col2;
   

マテリアライズドビューの更新並列度制御メカニズム

OceanBaseデータベースは、マテリアライズドビューの更新並列度を制御する仕組みを提供しています。ユーザーが明示的に更新操作に並列度を指定した場合、その指定値が優先されます。並列度が明示的に指定されていない場合は、システム変数 mview_refresh_dop を設定することで、セッション上のシステム変数値に基づいてマテリアライズドビューを更新できます。

mview_refresh_dopの設定

mview_refresh_dop は、OceanBaseデータベースにおけるシステム変数であり、マテリアライズドビューの更新操作におけるデフォルトの並列度を制御します。この値を適切に設定することで、更新効率を大幅に向上させ、データベースのパフォーマンスを最適化できます。

mview_refresh_dop を0または1に設定すると、並列更新機能を使用しないことを意味します。システム変数 mview_refresh_dop の詳細については、mview_refresh_dopを参照してください。

例：

• 現在のセッションの並列度を5に設定します。

  SET mview_refresh_dop = 5;
  

• グローバルセッションの並列度を5に設定します。

  SET GLOBAL mview_refresh_dop = 5;
  

  注意

  グローバルレベルの変数の設定は現在のセッションには無効であり、再ログインして新しいセッションを確立した場合にのみ有効になります。

マテリアライズドビューの並列度情報を確認する

• ビューDBA_MVIEWSを使用して、マテリアライズドビューに設定されたバックグラウンド更新の並列度を照会します。

  説明

  ビューDBA_MVIEWSでは、マテリアライズドビューに指定された並列度のみを確認できます。

  • フィールドREFRESH_DOPが0以外の場合、マテリアライズドビューのバックグラウンド更新タスクはREFRESH_DOPに対応する並列度を使用します。
  • REFRESH_DOPが0の場合、グローバル（Global）レベルで設定されたmview_refresh_dopの値が使用されます。

  例：

  1. マテリアライズドビューmv0_t1を作成します。

     CREATE MATERIALIZED VIEW mv0_t1
         REFRESH COMPLETE ON DEMAND
         START WITH current_date
             NEXT current_date + INTERVAL '10' SECOND
         AS SELECT c1, c2
             FROM t1;
     

  2. マテリアライズドビューmv0_t1に設定されたバックグラウンド更新の並列度を確認します。

     SELECT OWNER, MVIEW_NAME,REFRESH_DOP
     FROM SYS.DBA_MVIEWS
     WHERE OWNER = 'SYS'
     AND MVIEW_NAME = 'MV0_T1';
     

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

     +-------+------------+-------------+
     | OWNER | MVIEW_NAME | REFRESH_DOP |
     +-------+------------+-------------+
     | SYS   | MV0_T1     |           0 |
     +-------+------------+-------------+
     1 row in set
     

  3. マテリアライズドビューmv0_t1の並列度を8に変更します。

     ALTER MATERIALIZED VIEW mv0_t1 PARALLEL 8;
     

  4. マテリアライズドビューに設定されたバックグラウンド更新の並列度を確認します。

     SELECT OWNER, MVIEW_NAME,REFRESH_DOP
     FROM SYS.DBA_MVIEWS
     WHERE OWNER = 'SYS'
     AND MVIEW_NAME = 'MV0_T1';
     

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

     +-------+------------+-------------+
     | OWNER | MVIEW_NAME | REFRESH_DOP |
     +-------+------------+-------------+
     | SYS   | MV0_T1     |           8 |
     +-------+------------+-------------+
     1 row in set
     

• ビューDBA_MVREF_RUN_STATSを使用して、マテリアライズドビューの履歴更新並列度を照会します。

  例：

  SELECT REFRESH_ID, MVIEWS, PARALLELISM
  FROM SYS.DBA_MVREF_RUN_STATS
  WHERE MVIEWS = 'SYS.MV0_T1'
  ORDER BY REFRESH_ID;
  

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

  +------------+------------+-------------+
  | REFRESH_ID | MVIEWS     | PARALLELISM |
  +------------+------------+-------------+
  |    6752103 | SYS.MV0_T1 |           5 |
  |    6752733 | SYS.MV0_T1 |           5 |
  |    6753371 | SYS.MV0_T1 |           5 |
  |    6753985 | SYS.MV0_T1 |           8 |
  |    6754618 | SYS.MV0_T1 |           8 |
  |    6755249 | SYS.MV0_T1 |           8 |
  +------------+------------+-------------+
  6 rows in set
  

マテリアライズドビューの手動更新

マテリアライズドビューの更新モードが ON DEMAND の場合、DBMS_MVIEW パッケージを使用して手動で更新できます。増分更新として定義されたマテリアライズドビューについては、手動更新時にフル更新を指定することも可能です。

REFRESHを使用したマテリアライズドビューの更新

DBMS_MVIEW.REFRESH (
   list                   IN     VARCHAR2,                  -- マテリアライズドビュー名。現在は複数のマテリアライズドビューには対応していません
   method                 IN     VARCHAR2       := NULL,    -- 更新オプション
                                                            --   f：クイック更新
                                                            --   ?：強制更新
                                                            --   C|c：完全更新
                                                            --   A|a：常に更新。Cと同じです
   ----------- 以下のパラメータはサポートされておらず、Oracleとの互換性のためにのみ提供されています ----------------
   rollback_seg           IN     VARCHAR2       := NULL,
   push_deferred_rpc      IN     BOOLEAN        := true,
   refresh_after_errors   IN     BOOLEAN        := false,
   purge_option           IN     BINARY_INTEGER := 1,
   parallelism            IN     BINARY_INTEGER := 0,
   heap_size              IN     BINARY_INTEGER := 0,
   atomic_refresh         IN     BOOLEAN        := true,
   nested                 IN     BOOLEAN        := false,
   out_of_place           IN     BOOLEAN        := false,
   skip_ext_data          IN     BOOLEAN        := false,
   ---------------------------------------------------------
   refresh_parallel       IN     BINARY_INTEGER := 0);       -- マテリアライズドビューの更新並列度。OB独自のパラメータ

例：

1. テーブル test_tbl1 に 3 件のデータを挿入します。

   INSERT INTO test_tbl1 VALUES (1, 1, 1, 1),(2, 2, 2, 2),(3, 3, 3, 3);
   

2. マテリアライズドビュー mv1_test_tbl1 の情報を確認します。

   SELECT * FROM mv1_test_tbl1;
   

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

   Empty set
   

3. DBMS_MVIEW.REFRESH を使用して、マテリアライズドビュー mv1_test_tbl1 を手動で更新します。

   • マテリアライズドビュー設定の更新オプションを使用してマテリアライズドビューを更新します：

     CALL DBMS_MVIEW.REFRESH('mv1_test_tbl1');
     

   • 更新オプションを指定してマテリアライズドビューを更新します：

     CALL DBMS_MVIEW.REFRESH('mv1_test_tbl1', 'c');
     

4. 再びマテリアライズドビュー mv1_test_tbl1 の情報を確認します。

   SELECT * FROM mv1_test_tbl1;
   

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

   +------+------+----------+----------+
   | COL2 | CNT  | CNT_COL3 | SUM_COL3 |
   +------+------+----------+----------+
   |    3 |    1 |        1 |        3 |
   |    2 |    1 |        1 |        2 |
   |    1 |    1 |        1 |        1 |
   +------+------+----------+----------+
   3 rows in set
   

マテリアライズドビューの手動更新並列度

マテリアライズドビューを手動で更新する場合、システム変数mview_refresh_dopを設定して、マテリアライズドビューの更新操作に対するデフォルトの並列度を設定できます。

また、DBMS_MVIEW.REFRESH関数を呼び出す際に、refresh_parallelを指定して、今回の更新の並列度を明示的に設定することもできます。

例：

1. 現在のセッションの並列度を5に設定します。

   SET mview_refresh_dop = 5;
   

2. マテリアライズドビューを手動で更新します：

   • 更新の並列度を8に明示的に指定します。今回の更新の並列度は8です。

     CALL DBMS_MVIEW.REFRESH('mv1', 'c', 8);
     

   • 更新の並列度が明示的に指定されていない場合、セッション変数の値に基づき、今回の更新の並列度は5です。

     CALL DBMS_MVIEW.REFRESH('mv1', 'c');
     

マテリアライズドビューの自動更新

マテリアライズドビューを作成する際に、START WITH datetime_expr および NEXT datetime_expr 句を指定した場合、条件が満たされると、システムはマテリアライズドビューに対してバックグラウンドで自動更新タスクを作成します。

マテリアライズドビューの自動更新の並列度

バックグラウンドでマテリアライズドビューを自動更新する際、以下の2つの方法で並列度を指定できます：

1. マテリアライズドビュー作成時に並列度（テーブルDOP）を指定します。

   例：

   CREATE MATERIALIZED VIEW mv_t1
       PARALLEL 8
       REFRESH COMPLETE ON DEMAND
           START WITH current_date
               NEXT current_date + INTERVAL '10' SECOND
           AS SELECT c1, c2
              FROM t1;
   

2. グローバルSession変数 mview_refresh_dop を更新の並列度として設定します。

   自動更新操作は内部Sessionを通じて実行されるため、バックグラウンドSessionに有効にするには、Global（グローバル）レベルの mview_refresh_dop を設定する必要があります。

   注意

   マテリアライズドビュー作成時に明示的に並列度が指定されておらず、かつ mview_refresh_dop 変数が0または1の場合、バックグラウンド更新タスクでは並列更新は有効になりません。

   例：

   1. グローバルSessionの並列度を5に設定します。

      SET GLOBAL mview_refresh_dop = 5;
      

   2. マテリアライズドビューを作成します：

      • マテリアライズドビュー作成時に並列度を8に指定した場合、バックグラウンド更新タスクは8を更新の並列度として使用します。

        CREATE MATERIALIZED VIEW mv1_t1
            PARALLEL 8
            REFRESH COMPLETE ON DEMAND
                 START WITH current_date
                     NEXT current_date + INTERVAL '10' SECOND
            AS SELECT c1, c2
            FROM t1;
        

      • マテリアライズドビュー作成時に並列度が指定されていない場合、バックグラウンド更新タスクは変数 mview_refresh_dop の値である5を更新の並列度として使用します。

        CREATE MATERIALIZED VIEW mv2_t1
            REFRESH COMPLETE ON DEMAND
                 START WITH current_date
                     NEXT current_date + INTERVAL '10' SECOND
            AS SELECT c1, c2
            FROM t1;
        

ネストされたマテリアライズドビューの更新

ネストされたマテリアライズドビューの更新ルール

ネストされたマテリアライズドビューがサポートする更新方式は、非ネストされたマテリアライズドビューと同様に、フル更新と増分更新が含まれます。ネストされたマテリアライズドビューを更新する場合、直接依存するユーザーテーブルとマテリアライズドビュー（およびそれらのmlog）のみを使用しますが、ネストされたマテリアライズドビューは他のマテリアライズドビューに基づいて構築されているため、そのデータの一貫性は他のマテリアライズドビューに依存します。これは、あるネストされたマテリアライズドビューのデータを最新に保つためには、まずその依存する他のマテリアライズドビューのデータを最新にする必要があり、つまりそれらを先に更新する必要があることを意味します。

例えば、以下の図のように、マテリアライズドビューmv1はテーブルtbl1とテーブルtbl2に基づいて構築され、マテリアライズドビューmv2はマテリアライズドビューmv1とテーブルtbl3に基づいて構築され、マテリアライズドビューmv3はマテリアライズドビューmv1とマテリアライズドビューmv2に基づいて構築されています。マテリアライズドビューmv1、マテリアライズドビューmv2、マテリアライズドビューmv3の順序で更新を行う場合、ネストされたマテリアライズドビュー全体のデータの一貫性を保証できます。逆に、まずマテリアライズドビューmv2を更新し、次にマテリアライズドビューmv1を更新すると、マテリアライズドビューmv2のデータは最新ではなく（マテリアライズドビューmv1に遅れる）、同様に、まずマテリアライズドビューmv3を更新し、次にマテリアライズドビューmv2を更新すると、マテリアライズドビューmv3のデータも最新ではなく（マテリアライズドビューmv2に遅れる）ことになります。

OceanBaseデータベースV4.3.5バージョンでは、ネストされたマテリアライズドビューはV4.3.5 BP3バージョンからカスケード更新をサポートしています。カスケード更新には、カスケード非整合性更新とカスケード整合性更新があります。

• カスケード非整合性更新：ネストされたマテリアライズドビューが依存するすべてのマテリアライズドビューをボトムアップで更新します。各マテリアライズドビューの更新ではデータの一貫性は保証されず、依存するベーステーブルから読み取るデータの時点が異なります。カスケード非整合性更新は、業務部門が定期的に上流からデータを同期するような一括同期方式に適しており、データ同期完了後にカスケード非整合性更新を行うことで、マテリアライズドビューの最終的な一貫性を維持できます。

• カスケード整合性更新：スナップショット整合性のカスケード更新であり、カスケード更新全体が完了した後、上位層が参照する依存するすべてのベーステーブルのデータ時点が一致することを保証します。カスケード整合性更新は、リアルタイムでデータを同期するシナリオに適しており、毎回のカスケード更新完了後、マテリアライズドビュー内のデータスナップショットが同一の時点になることを保証します。

ネストされたマテリアライズドビューの更新例

マテリアライズドビューがフル更新された場合、それに依存するマテリアライズドビューは、その後の増分更新を行う前に必ず一度フル更新を行わなければなりません。そうでないとエラーが発生します。

例：

1. テーブル tbl1 を作成し、データを1件挿入します。

   CREATE TABLE tbl1(id INT, name VARCHAR2(30), PRIMARY KEY(id));
   

   INSERT INTO tbl1 VALUES (1, 'jack');
   

2. テーブル tbl2 を作成し、データを1件挿入します。

   CREATE TABLE tbl2(id INT, age INT, PRIMARY KEY(id));
   

   INSERT INTO tbl2 VALUES (1, 21);
   

3. テーブル tbl1 とテーブル tbl2 にマテリアライズドビューログを作成します。

   CREATE MATERIALIZED VIEW LOG ON tbl1 WITH PRIMARY KEY (name) INCLUDING NEW VALUES;
   

   CREATE MATERIALIZED VIEW LOG ON tbl2 WITH PRIMARY KEY (age) INCLUDING NEW VALUES;
   

4. tbl1 と tbl2 を基にマテリアライズドビュー mv1 を作成します。

   CREATE MATERIALIZED VIEW mv1 (PRIMARY KEY (id1, id2))
       REFRESH FAST ON DEMAND
       AS SELECT tbl1.id id1, tbl2.id id2, tbl1.NAME, tbl2.AGE
           FROM tbl1, tbl2
           WHERE tbl1.id = tbl2.id;
   

5. マテリアライズドビュー mv1 にマテリアライズドビューログを作成します。

   CREATE MATERIALIZED VIEW LOG ON mv1 WITH PRIMARY KEY (name, age) INCLUDING NEW VALUES;
   

6. マテリアライズドビュー mv1 を基にマテリアライズドビュー（ネストされたマテリアライズドビュー） mv2 を作成します。

   CREATE MATERIALIZED VIEW mv2
       REFRESH FAST
       AS SELECT COUNT(*) cnt, COUNT(AGE) age_cnt, SUM(AGE) age_sum
           FROM mv1;
   

7. マテリアライズドビュー mv1 のデータを確認します。

   SELECT * FROM mv1;
   

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

   +------+------+------+------+
   | ID1  | ID2  | NAME | AGE  |
   +------+------+------+------+
   |    1 |    1 | jack |   21 |
   +------+------+------+------+
   1 row in set
   

8. マテリアライズドビュー mv2 のデータを確認します。

   SELECT * FROM mv2;
   

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

   +------+---------+---------+
   | CNT  | AGE_CNT | AGE_SUM |
   +------+---------+---------+
   |    1 |       1 |      21 |
   +------+---------+---------+
   1 row in set
   

9. テーブル tbl1 とテーブル tbl2 にそれぞれデータを1件ずつ挿入します。

   INSERT INTO tbl1 VALUES (2, 'rose');
   

   INSERT INTO tbl2 VALUES (2, 19);
   

10. マテリアライズドビュー mv1 を増分更新します。

    CALL dbms_mview.refresh('mv1', 'f');
    

11. マテリアライズドビュー mv1 のデータを確認します。

    SELECT * FROM mv1;
    

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

    +------+------+------+------+
    | ID1  | ID2  | NAME | AGE  |
    +------+------+------+------+
    |    1 |    1 | jack |   21 |
    |    2 |    2 | rose |   19 |
    +------+------+------+------+
    2 rows in set
    

12. マテリアライズドビュー mv2 を増分更新します。

    CALL dbms_mview.refresh('mv2', 'f');
    

13. マテリアライズドビュー mv2 のデータを確認します。

    SELECT * FROM mv2;
    

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

    +------+---------+---------+
    | CNT  | AGE_CNT | AGE_SUM |
    +------+---------+---------+
    |    2 |       2 |      40 |
    +------+---------+---------+
    1 row in set
    

14. 再びテーブル tbl1 とテーブル tbl2 にそれぞれデータを1件ずつ挿入します。

    INSERT INTO tbl1 VALUES (3, 'mary');
    

    INSERT INTO tbl2 VALUES (3, 25);
    

15. マテリアライズドビュー mv1 をフル更新します。

    CALL dbms_mview.refresh('mv1', 'c');
    

16. 再びマテリアライズドビュー mv1 のデータを確認します。

    SELECT * FROM mv1;
    

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

    +------+------+------+------+
    | ID1  | ID2  | NAME | AGE  |
    +------+------+------+------+
    |    1 |    1 | jack |   21 |
    |    2 |    2 | rose |   19 |
    |    3 |    3 | mary |   25 |
    +------+------+------+------+
    3 rows in set
    

17. 再びマテリアライズドビュー mv2 を増分更新します。

    CALL dbms_mview.refresh('mv2', 'f');
    

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

    OBE-12052: cannot fast refresh materialized view
    at package body oceanbase.DBMS_MVIEW.DO_REFRESH , line : 54, col : 1
    at oceanbase.DBMS_MVIEW.REFRESH , line : 72, col : 1
    

    注意

    mv1 はフル更新を経験しているため、mv2 に対して直接増分更新を行うとエラーが発生します。まず一度フル更新を行う必要があります。

18. 再びマテリアライズドビュー mv2 のデータを確認します。

    SELECT * FROM mv2;
    

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

    +------+---------+---------+
    | CNT  | AGE_CNT | AGE_SUM |
    +------+---------+---------+
    |    2 |       2 |      40 |
    +------+---------+---------+
    1 row in set
    

19. マテリアライズドビュー mv2 をフル更新します。

    CALL dbms_mview.refresh('mv2', 'c');
    

20. 再びマテリアライズドビュー mv2 のデータを確認します。

    SELECT * FROM mv2;
    

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

    +------+---------+---------+
    | CNT  | AGE_CNT | AGE_SUM |
    +------+---------+---------+
    |    3 |       3 |      65 |
    +------+---------+---------+
    1 row in set
    

マテリアライズドビューの更新統計情報

OceanBaseシステムは、マテリアライズドビューの更新操作に関する統計情報を収集・保存でき、これらの情報は特定のビューを通じて照会可能です。現在および過去のマテリアライズドビューの更新操作に関する統計情報はデータベース内に格納されます。過去のマテリアライズドビューの更新統計情報を通じて、データベース内のマテリアライズドビューの更新パフォーマンスを把握し分析することができます。

マテリアライズドビューの更新に関する統計情報の役割は以下のとおりです：

• 報告機能：マテリアライズドビューの更新操作に関する現在および過去の統計概要を提供します。これには、更新実行に必要な実際の時間も含まれており、更新パフォーマンスの追跡とモニタリングに役立ちます。

• 診断機能：詳細な現在および過去の統計データを通じて、マテリアライズドビューの更新パフォーマンスを効果的に分析できます。例えば、マテリアライズドビューの更新に時間がかかる場合、統計データはシステム負荷の増加によるものか、それともデータ変更量の増大によるパフォーマンス低下によるものかを特定するのに役立ちます。

マテリアライズドビューによる統計情報の収集

マテリアライズドビューは統計情報を収集します。analyze table または call dbms_stats.gather_table_stats('database_name', 'table_name') を使用して統計情報を収集できます。

• テーブルおよび列の統計情報の収集に関する詳細は、GATHER_TABLE_STATSを参照してください。

• マテリアライズドビューの更新操作に関する統計情報の収集および保持の管理に関する詳細は、DBMS_MVIEW_STATSの概要を参照してください。

マテリアライズドビューの更新情報を表示する

関連ドキュメント

• マテリアライズドビューの概要
• マテリアライズドビューログ
• マテリアライズドビューの作成
• マテリアライズドビューによるクエリの書き換え
• マテリアライズドビューのクエリ
• マテリアライズドビューの削除
• マテリアライズドビューのリソース分離
• マテリアライズドビューの異常診断