AnalyticDB:マテリアライズドビューのリフレッシュ

バイナリロギングの有効化

高速リフレッシュを使用するマテリアライズドビューを作成する前に、クラスターおよびそのベーステーブルに対してバイナリロギングを有効にする必要があります。

SET ADB_CONFIG BINLOG_ENABLE=true; -- エンジンバージョン 3.2.0.0 より前のクラスターでは、このコマンドを実行してバイナリロギングを有効にしてください。バージョン 3.2.0.0 以降ではデフォルトで有効になっています。
ALTER TABLE customer binlog=true;
ALTER TABLE sales binlog=true;
ALTER TABLE product binlog=true;

単一テーブルマテリアライズドビュー

• 集約操作なしで高速リフレッシュを使用し、10 秒ごとにリフレッシュされる単一テーブルマテリアライズドビュー fast_mv1 を作成します。

  CREATE MATERIALIZED VIEW fast_mv1
  REFRESH FAST NEXT now() + INTERVAL 10 second
  AS
  SELECT sale_id, sale_date, price
  FROM sales
  WHERE price > 10;

• GROUP BY 集約を使用して高速リフレッシュを行い、5 秒ごとにリフレッシュされる単一テーブルマテリアライズドビュー fast_mv2 を作成します。

  CREATE MATERIALIZED VIEW fast_mv2
  REFRESH FAST NEXT now() + INTERVAL 5 second
  AS
  SELECT
     customer_id, sale_date,                 -- システムは GROUP BY の列をマテリアライズドビューのプライマリキーとして使用します。
     COUNT(sale_id) AS cnt_sale_id,          -- 集計出力列。
     SUM(price * quantity) AS total_revenue, -- 集計出力列。
     customer_id / 100 AS new_customer_id    -- 非集計出力列では任意の式を使用できます。
  FROM sales
  WHERE ifnull(price, 1) > 0                 -- 条件では任意の式を使用できます。
  GROUP BY customer_id, sale_date;

• GROUP BY 集約なしで高速リフレッシュを行い、1 分ごとにリフレッシュされる単一テーブルマテリアライズドビュー fast_mv3 を作成します。

  CREATE MATERIALIZED VIEW fast_mv3
  REFRESH FAST NEXT now() + INTERVAL 1 minute
  AS
  SELECT count(*) AS cnt   -- システムは定数プライマリキーを生成して、マテリアライズドビューに 1 つのレコードのみが含まれるようにします。
  FROM sales;

複数テーブルマテリアライズドビュー

• 集約操作なしで高速リフレッシュを行い、5 秒ごとにリフレッシュされる複数テーブルマテリアライズドビュー fast_mv4 を作成します。

  CREATE MATERIALIZED VIEW fast_mv4
  REFRESH FAST NEXT now() + INTERVAL 5 second
  AS
  SELECT 
      c.customer_id,
      c.customer_name,
      p.product_id,
      s.sale_id,
      (s.price * s.quantity) AS revenue
  FROM 
      sales s
  JOIN 
      customer c ON s.customer_id = c.customer_id
  JOIN 
      product p ON s.product_id = p.product_id;

• GROUP BY 集約を使用して高速リフレッシュを行い、10 秒ごとにリフレッシュされる複数テーブルマテリアライズドビュー fast_mv5 を作成します。

  CREATE MATERIALIZED VIEW fast_mv5
  REFRESH FAST NEXT now() + INTERVAL 10 second
  AS
  SELECT 
      s.sale_id,
      c.customer_name,
      p.product_name,
      COUNT(*) AS cnt,           
      SUM(s.price * s.quantity) AS revenue,         
      SUM(p.unit_price) AS sum_p          
  FROM 
      sales s
  JOIN 
      (SELECT customer_id, customer_name FROM customer) c ON c.customer_id = s.customer_id
  JOIN 
      (SELECT * FROM product WHERE stock_quantity > 0) p ON p.product_id = s.product_id
  GROUP BY 
      s.sale_id, c.customer_name, p.product_name;

注記

ベーステーブルに対して TRUNCATE または INSERT OVERWRITE 操作が実行された場合、またはデータの正確性に影響を与える可能性のある内部アノマリーが発生した場合、増分マテリアライズドビューは自動的に一度だけ完全リフレッシュにフォールバックします。完全リフレッシュが成功すると、その後のリフレッシュは自動的に増分モードで再開されます。

制限事項

高速リフレッシュを使用するマテリアライズドビューには、以下の制限事項が適用されます。

• エンジンバージョンが 3.2.3.0 より前のクラスターでは、パーティションテーブルを高速リフレッシュを使用するマテリアライズドビューのベーステーブルにすることはできません。

• エンジンバージョンが 3.2.3.1 より前のクラスターでは、高速リフレッシュを使用するマテリアライズドビューのベーステーブルに対して INSERT OVERWRITE および TRUNCATE 操作はサポートされていません。これらの操作を実行するとエラーが発生します。

• 高速リフレッシュは、5 秒（s）～5 分（min）の間隔を持つスケジュールリフレッシュのみをサポートしています。

• 高速リフレッシュを使用するマテリアライズドビューの query_body には、以下の制限事項があります。

  • マテリアライズドビューは、その結果がベーステーブルに対する直接クエリと同一であることを保証し、すべての DML 変更をサポートする必要があります。query_body が高速リフレッシュをサポートしていない場合、CREATE MATERIALIZED VIEW 文はエラーを返します。

  • 条件には、now() や rand() などの非決定的式を含めることはできません。

  • サポートされる集計関数は、COUNT、SUM、MAX、MIN、AVG、APPROX_DISTINCT、および COUNT(DISTINCT) のみです。

  • query_body で MAX、MIN、APPROX_DISTINCT、または COUNT(DISTINCT) 集計関数を使用する場合、ベーステーブルに対して INSERT 操作のみが許可されます。DELETE、UPDATE、REPLACE、INSERT ON DUPLICATE KEY UPDATE などのデータ削除操作は禁止されています。

  • DISTINCT キーワードは、COUNT(DISTINCT) 以外の集計関数ではサポートされていません。

  • COUNT(DISTINCT) は INTEGER 型のみをサポートしています。

  • AVG は DECIMAL 型をサポートしていません。

  • 集約操作では HAVING キーワードはサポートされていません。

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

  • ソート操作はサポートされていません。

  • UNION、EXCEPT、INTERSECT などの集合演算はサポートされていません。

• 高速リフレッシュを使用する複数テーブルマテリアライズドビューには、以下の追加の制限事項があります。

  • 複数テーブルマテリアライズドビューは現在、INNER JOIN のみをサポートしています。

  • デフォルトでは、複数テーブルマテリアライズドビューは最大 5 つのテーブルを結合できます。

  • 複数テーブルマテリアライズドビューの結合列は、テーブルの元の列であり、同じデータの型を持ち、各結合列にインデックスが存在している必要があります。