刷新物化视图

更新基表的数据可能会导致物化视图的数据与基表的数据不一致，为了维护物化视图的数据，OceanBase 数据库会通过刷新物化视图来实现。

OceanBase 数据库支持的物化视图刷新策略支持全量刷新和增量刷新，并且支持手动调度刷新和自动调度刷新。

说明

刷新物化视图也会自动更新其所有索引。

全量刷新

OceanBase 数据库使用异地刷新的方式进行全量刷新，即创建一个隐藏表，在隐藏表上执行刷新语句，然后切换原表和隐藏表。因此，全量刷新操作需要额外的空间，并且会全量重建索引（如果有的话）。

全量刷新注意事项

全量刷新可能是一个非常耗时的过程，尤其是在需要读取和处理大量数据的情况下。因此，在执行全量刷新之前，您应该始终考虑处理全量刷新所需的时间。
当前基表的列与物化视图对应的列类型匹配，就符合全量刷新的条件。如果不匹配，将无法进行全量刷新。
如果一个物化视图进行了全量刷新，那么依赖它的物化视图（嵌套物化视图）在后续进行增量刷新前必须先进行一次全量刷新，否则会报错。

增量刷新

增量刷新的物化视图目前支持单表非聚合、单表聚合、多表关联、多表关联聚合、集合查询（UNION ALL）的 SQL 语句，对于不满足这五类场景的 SQL 语句，暂不支持增量刷新，增量刷新 SQL 语句要求详见下述介绍。

注意

由于 REFRESH FAST 方法利用物化视图日志中的记录信息来确定需要增量刷新的内容，因此在使用增量刷新刷新物化视图时，需要在创建物化视图之前就创建基表的物化视图日志（mlog）。
- 有关创建物化视图日志的信息，请参见物化视图日志。
- 对于 V4.3.5 版本，从 V4.3.5 BP4 版本开始支持物化视图日志自动管理功能。如果开启自动管理 mlog，那么在创建增量刷新物化视图前，用户无需创建基表的 mlog，OceanBase 数据库会自动创建对应的 mlog 或更新已存在的 mlog 表定义使其包含新建物化视图依赖的列。详细信息，参见物化视图日志自动管理。
增量刷新物化视图中使用的列都必须在 mlog 里。

单表非聚合增量刷新

说明

对于 OceanBase 数据库 V4.3.5 版本，物化视图增量刷新从 V4.3.5 BP3 版本开始支持单表非聚合场景。

单表非聚合增量刷新示例

创建表 tbl1。

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

在 tbl1 表上创建物化视图日志。

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

基于表 tbl1 创建增量刷新的物化视图 mv_tbl1。

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

单表聚合增量刷新

单表聚合增量刷新基本要求如下：

FROM 表必须为基表，不能为内联视图、普通视图等。

说明

由于嵌套物化视图不支持实时物化视图，所以在 FROM 表为物化视图时，无法使用实时物化视图。
FROM 表仅存在一张表。
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)

GROUP BY 子句必须是标准的 GROUP BY 语法，不支持 ROLLUP 和 HAVING。
SELECT 子句中必须包含所有的 GROUP BY 列。
聚合函数不包含 DISTINCT 关键字。
SELECT 子句中除了包含聚合函数列外，还必须包含对应聚合函数的依赖列和 COUNT(*) 列，如使用聚合函数 SUM(expr)，还需要包含 COUNT(*) 以及 COUNT(expr) 列。

MIN/MAX 聚合增量刷新条件：

注意

使用 MIN/MAX 函数的物化视图不支持实时物化视图。

满足以上单表聚合增量刷新基本要求时，使用聚合函数 MAX 和 MIN 的要求：在物化视图基表上存在以 GROUP BY 列为前缀的索引。

说明

对于 OceanBase 数据库 V4.3.5 版本，从 V4.3.5 BP5 版本开始 MIN/MAX 聚合函数参数支持非基本列，GROUP BY 列中支持使用非基本列。

单表聚合增量刷新示例

创建表 test_tbl1。

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

在 test_tbl1 表上创建物化视图日志。

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

创建刷新方法是增量刷新的物化视图。
- 创建名为 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 和 (DATE(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);
```

多表连接增量刷新

多表连接增量刷新基本要求如下：

FROM 表不能为内联视图。
FROM 表至少包含两张表。

说明

在 OceanBase 数据库 V4.3.5 BP3 及以上版本中，物化视图的增量刷新功能新增支持多表外连接（LEFT JOIN/RIGHT JOIN）。

外连接使用限制： 连接树需要是等价于 INNER JOIN 在先，LEFT JOIN 在后的左深连接树。

需要注意的是，若增量刷新物化视图的 SELECT 子句包含 LEFT JOIN 算子，则禁止在创建时指定主键（PRIMARY KEY）或唯一索引（UNIQUE INDEX），以避免因约束冲突引发的刷新异常。
FROM 表均创建 mlog，且使视图中使用列均在 mlog 中存在。
视图定义中不存在子查询。
视图定义中不存在 ROLLUP、HAVING、WINDOW FUNCTION、DISTINCT、ORDER BY、LIMIT 和 FETCH 等子句。
视图定义中不能使用 ROWNUM、RAND 和 SYSDATE 等不稳定输出值的表达式。

注意

对于 OceanBase 数据库 V4.3.5 版本：

在 V4.3.5 BP5 之前版本 FROM 表均需存在主键，且主键在 SELECT 中输出。
从 V4.3.5 BP5 版本开始删除对多表连接增量刷新物化视图要求基表上有主键的要求。
带有外连接的聚合物化视图不支持实时物化视图。

多表连接增量刷新示例

创建基表 t1 和 t2。

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

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

在表 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;

创建表 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. 为每张表的连接键创建索引，用于提升增量更新和实时物化视图中表的连接性能。
2. 为物化视图中各基表主键列创建索引。
随着物化视图中 JOIN 表数量的增加，物化视图的增量刷新性能和实时物化视图查询性能通常会有所下降。

为物化视图及其依赖基表创建索引示例如下：

（可选）使用以下语句删除相关测试数据。

如果没有以下数据库对象可以跳过此步骤。

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

使用以下语句创建表 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);

使用以下语句创建表 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);

使用以下语句在 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;

使用以下语句创建实时物化视图 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;

使用以下语句为物化视图中各基表主键列创建索引。

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 版本开始支持带有外连接的聚合物化视图的增量刷新。

多表聚合增量刷新示例

创建基表 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));

在表 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;

创建表 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;

集合查询增量刷新

说明

对于 OceanBase 数据库 V4.3.5 版本，物化视图增量刷新从 V4.3.5 BP3 版本开始支持集合查询场景。

集合物化视图支持物化视图使用 UNION ALL 集合查询，并可以进行增量刷新。增量刷新的集合物化视图允许集合分支中使用除外连接物化视图外的所有可以增量刷新的物化视图。

集合查询增量刷新基本要求如下：

带有集合查询的物化视图不支持实时物化视图。
顶层查询为 UNION ALL，视图定义中不包含子查询，不存在 ORDER BY/LIMIT/FETCH 等子句。
UNION ALL 各分支相同投影位置的输出列类型需相同，不支持强行通过 CAST 将子分支的列类型转换为一致的类型。

例如，多表连接物化视图要求各连接表主键出现在 SELECT 中，这些 SELECT 输出列不能由于 UNION ALL 而添加额外 CAST。
UNION ALL 各分支相同投影位置存在相同类型/值不同的常量，常量作为标识列区分各分支。

集合查询增量刷新示例

创建基表 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);

在表 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;

创建集合查询增量刷新的物化视图 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，以 Session（会话）上的系统变量值为准刷新物化视图。

说明

对于 OceanBase 数据库 V4.3.5 版本，变量 mview_refresh_dop 从 V4.3.5 BP1 版本开始引入。

设置 mview_refresh_dop

mview_refresh_dop 是 OceanBase 数据库中的一个系统变量，用于控制物化视图刷新操作的默认并行度。通过合理设置其值，可以显著提升刷新效率，优化数据库性能。

当设置 mview_refresh_dop 为 0 或 1 时，表示不使用并行刷新能力。有关系统变量 mview_refresh_dop 的详细介绍信息，参见 mview_refresh_dop。

示例如下：

将当前 Session 并行度设置为 5。
```
SET mview_refresh_dop = 5;
```
将全局 Session 并行度设置为 5。
```
SET GLOBAL mview_refresh_dop = 5;
```
注意

设置 Global 级别的变量对当前 Session 无效，需要重新登录建立新的 Session 才会生效。

查看物化视图并行度信息

使用视图 DBA_MVIEWS 查询为物化视图设定的后台刷新并行度。

说明

视图 DBA_MVIEWS 查看物化视图并行度只能查看针对物化视图指定的的并行度。

字段 REFRESH_DOP 为非 0 时，物化视图后台刷新任务将使用 REFRESH_DOP 对应的并行度。
当 REFRESH_DOP 为 0 时，将使用设置 Global（全局）级别的 mview_refresh_dop 的值。

示例如下：

创建物化视图 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;

查看物化视图 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

修改物化视图 mv0_t1 并行度为 8。

ALTER MATERIALIZED VIEW mv0_t1 PARALLEL 8;

查看物化视图设定的后台刷新并行度。

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独有的参数

示例如下：

向表 test_tbl1 中插入 3 条数据。

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

查看物化视图 mv1_test_tbl1 信息。
```
SELECT * FROM mv1_test_tbl1;
```
返回结果如下：
```
Empty set
```
使用 DBMS_MVIEW.REFRESH 手动刷新物化视图 mv1_test_tbl1。
- 使用物化视图设置的刷新选项刷新物化视图：
```
CALL DBMS_MVIEW.REFRESH('mv1_test_tbl1');
```
- 指定刷新选项刷新物化视图：
```
CALL DBMS_MVIEW.REFRESH('mv1_test_tbl1', 'c');
```

再次查看物化视图 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 显式设置本次刷新的并行度。

注意

如果未显式指定并行度，且 mview_refresh_dop 变量为 0 或 1 时，不开启并行刷新。

示例如下：

将当前 Session 并行度设置为 5。
```
SET mview_refresh_dop = 5;
```
手动刷新物化视图：
- 显式指定刷新并行度为 8，本次刷新并行度为 8。
```
CALL DBMS_MVIEW.REFRESH('mv1', 'c', 8);
```
- 未显式指定刷新并行度，以 Session 变量值为准，本次刷新并行度为 5。
```
CALL DBMS_MVIEW.REFRESH('mv1', 'c');
```

自动刷新物化视图

创建物化视图的时候，如果指定了START WITH datetime_expr 和 NEXT datetime_expr 子句，当满足要求时，系统会为物化视图创建后台自动刷新任务。

自动刷新物化视图刷新并行度

在后台自动刷新物化视图时，可以通过以下两种方式来指定并行度：

说明

下述并行度优先级依次降低。

创建物化视图时指定并行度（Table 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;

设置全局 Session 变量 mview_refresh_dop 作为刷新并行度。

自动刷新操作通过内部 Session 进行刷新，需要设置 Global（全局）级别的 mview_refresh_dop 才能对后台 Session 生效。

注意

如果创建物化视图时未显式指定并行度，且 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;
```

嵌套物化视图刷新

说明

对于 OceanBase 数据库 V4.3.5 版本，从 V4.3.5 BP5 版本开始支持基于无主键的物化视图创建嵌套物化视图。

注意

嵌套物化视图不支持创建为实时物化视图，即创建嵌套物化视图时不支持指定 ENABLE ON QUERY COMPUTATION 子句。

嵌套物化视图的刷新规则

嵌套物化视图所支持的刷新方式和非嵌套物化视图一样，都包括全量与增量刷新。虽然刷新一个嵌套物化视图只需要用到其所直接依赖的用户表与物化视图（以及它们的 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 版本开始支持级联刷新。级联刷新分为级联非一致性刷新和级联一致性刷新。

级联非一致性刷新：自底向上刷新嵌套物化视图依赖的所有物化视图，每个物化视图的刷新没有数据一致性的保证，依赖的基表读取的数据位点不一致。级联非一致刷新适用于批量同步的方式，比如业务方定时从上游同步数据，数据同步完成后通过级联非一致刷新即可保持物化视图的最终一致性。
级联一致性刷新：快照一致性级联刷新，保证整个级联刷新完成后，上层看到的所依赖的所有基表的数据位点都是一致的。级联一致刷新适用于实时同步数据的场景，我们保证了每次级联刷新完成后，物化视图中的数据快照处于相同位点。

嵌套物化视图刷新示例

如果一个物化视图进行了全量刷新，那么依赖它的物化视图在后续进行增量刷新前必须先进行一次全量刷新，否则会报错。

示例如下：

创建表 tbl1 并插入一条数据。

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

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

创建表 tbl2 并插入一条数据。

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

INSERT INTO tbl2 VALUES (1, 21);

在表 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;

基于 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;

在物化视图 mv1上创建物化视图日志。

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

基于物化视图 mv1 创建物化视图（嵌套物化视图） mv2。

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

查看物化视图 mv1 的数据。

SELECT * FROM mv1;

返回结果如下：

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

查看物化视图 mv2 的数据。

SELECT * FROM mv2;

返回结果如下：

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

向表 tbl1 和表 tbl2 中各插入一条数据。

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

INSERT INTO tbl2 VALUES (2, 19);

增量刷新物化视图 mv1。
```
CALL dbms_mview.refresh('mv1', 'f');
```

查看物化视图 mv1 的数据。

SELECT * FROM mv1;

返回结果如下：

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

增量刷新物化视图 mv2。
```
CALL dbms_mview.refresh('mv2', 'f');
```

查看物化视图 mv2 的数据。

SELECT * FROM mv2;

返回结果如下：

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

再次向表 tbl1 和表 tbl2 中各插入一条数据。

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

INSERT INTO tbl2 VALUES (3, 25);

全量刷新物化视图 mv1。
```
CALL dbms_mview.refresh('mv1', 'c');
```

再次查看物化视图 mv1 的数据。

SELECT * FROM mv1;

返回结果如下：

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

再次增量刷新物化视图 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 进行增量刷新会报错，必须先进行一次全量刷新。

再次查看物化视图 mv2 的数据。

SELECT * FROM mv2;

返回结果如下：

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

全量刷新物化视图 mv2。
```
CALL dbms_mview.refresh('mv2', 'c');
```

再次查看物化视图 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 概述。

展示物化视图刷新信息

视图名	功能描述
ALL_MVIEWS	展示物化视图信息。
DBA_MVREF_STATS_SYS_DEFAULTS	物化视图刷新历史统计属性的系统范围默认值。
DBA_MVREF_STATS_PARAMS	展示与每个物化视图关联的刷新统计信息属性。
DBA_MVREF_RUN_STATS	展示物化视图的每次刷新运行的信息，每次运行均由 REFRESH_ID 标识。
DBA_MVREF_STATS	展示物化视图刷新的基本计时统计信息。
DBA_MVREF_CHANGE_STATS	展示物化视图刷新相关的统计信息。
DBA_MVREF_STMT_STATS	展示刷新语句关联的信息。
DBA_SCHEDULER_JOBS	展示数据库中所有调度程序作业的信息。

说明

全量刷新

全量刷新注意事项

增量刷新

注意

单表非聚合增量刷新

说明

单表非聚合增量刷新示例

单表聚合增量刷新

说明

说明

注意

说明

单表聚合增量刷新示例

多表连接增量刷新

说明

注意

多表连接增量刷新示例

说明

多表聚合增量刷新

说明

多表聚合增量刷新示例

集合查询增量刷新

说明

集合查询增量刷新示例

物化视图刷新并行度控制机制

说明

设置 mview_refresh_dop

注意

查看物化视图并行度信息

说明

手动刷新物化视图

说明

使用 REFRESH 刷新物化视图

手动刷新物化视图刷新并行度

注意

自动刷新物化视图

自动刷新物化视图刷新并行度

说明

注意

嵌套物化视图刷新

说明

注意

嵌套物化视图的刷新规则

嵌套物化视图刷新示例

注意

物化视图刷新统计信息

物化视图收集统计信息

展示物化视图刷新信息

相关文档