AnalyticDB：增量重新整理物化視圖

全量重新整理適用於T+1類的離線情境。常見的適用情境如下：

• 資料每天批次更新一次，或者小時層級更新一次，更適合全量重新整理。這類SQL通常比較複雜，全量重新整理對SQL文法沒有任何約束。

• 在某些分鐘層級延遲的情境中也可以使用全量重新整理，往往這類SQL即使全量計算成本也不大，通常十幾秒能完成，還可以達到一定的即時效果。

增量重新整理單表物化視圖

1. 建立基表。

   CREATE TABLE tbl0
   (a bigint,
    b tinyint,
    c boolean,
    d decimal(15, 2),
    PRIMARY KEY(a))
   DISTRIBUTED BY HASH (a);

2. 開啟Binlog特性。

   SET ADB_CONFIG BINLOG_ENABLE=true;

   ALTER TABLE tbl0 binlog=true;

3. 建立增量重新整理的物化視圖。

   • 建立無彙總操作的單表增量重新整理的物化視圖，每10秒鐘重新整理一次，樣本如下：

     CREATE MATERIALIZED VIEW mv0
     REFRESH FAST NEXT now() + INTERVAL 10 second
     AS
     SELECT a, b, c   #系統自動輸出基表主鍵作為物化視圖主鍵。
     FROM tbl0
     WHERE d > 1000;

   • 建立分組彙總操作的單表增量重新整理的物化視圖，每5秒鐘重新整理一次，樣本如下：

     CREATE MATERIALIZED VIEW mv1
     REFRESH FAST NEXT now() + INTERVAL 5 second
     AS
     SELECT
        b, c,                # 系統會自動輸出GROUP BY列作為物化視圖主鍵。
        COUNT(a) AS cnt_a,   # 彙總輸出資料行。
        sum(d) AS sum_d,     # 彙總輸出資料行。
        b / 100 AS new_b     # 非彙總輸出資料行可以使用任意運算式。
     FROM tbl0
     WHERE ifnull(d, 1) > 0  # 條件可以使用任何錶達式。
     GROUP BY b, c;

   • 建立無分組彙總操作的單表增量物化視圖，每分鐘重新整理一次，樣本如下：

     CREATE MATERIALIZED VIEW mv2
     REFRESH FAST NEXT now() + INTERVAL 1 minute
     AS
     SELECT count(*) AS cnt   # 系統會自動產生常量主鍵，確保全域只有一條記錄在視圖中。
     FROM tbl0;

增量重新整理多表物化視圖

1. 建立基表，並開啟Binlog特性。

   CREATE TABLE tbl0 (
     a0 bigint,
     b0 varchar,
     c0 int,
     d0 varchar,
     e0 boolean,
     PRIMARY KEY(a0)
   )
   DISTRIBUTED BY HASH (a0) BINLOG=true;
   
   CREATE TABLE tbl1 (
     a1 bigint,
     b1 varchar,
     c1 int,
     d1 varchar,
     e1 boolean,
     PRIMARY KEY(a1)
   )
   DISTRIBUTED BY HASH (a1) BINLOG=true;
   
   CREATE TABLE tbl2 (
     a2 bigint,
     b2 varchar,
     c2 int,
     d2 varchar,
     e2 boolean,
     PRIMARY KEY(a2)
   )
   DISTRIBUTED BY HASH (a2) BINLOG=true;

2. 建立增量重新整理的物化視圖。

   • 建立無彙總操作的多表增量重新整理的物化視圖，每5秒鐘重新整理一次，樣本如下：

     CREATE MATERIALIZED VIEW mv3
     REFRESH FAST NEXT now() + INTERVAL 5 second
     AS
     SELECT a0, a1, a2, (c0 + c1 + c2) AS c
     FROM tbl0
     JOIN tbl1 ON b1 = b0
     JOIN tbl2 ON b2 = b1;

   • 建立分組彙總操作的多表增量重新整理的物化視圖，每10秒鐘重新整理一次，樣本如下：

     CREATE MATERIALIZED VIEW mv4
     REFRESH FAST NEXT now() + INTERVAL 10 second
     AS
     SELECT 
     d0, d1, d2,                
     COUNT(*) AS cnt,           
     sum(c1) AS sum_c1,         
     sum(c2) AS sum_c2          
     FROM tbl0
     JOIN (SELECT b1, c1, d1 FROM tbl1) ON b1 = b0
     JOIN (SELECT * FROM tbl2 WHERE e2 = true) ON b2 = b1
     GROUP BY d0, d1, d2;