--- title: "创建物化视图 - OceanBase 数据库 V4.6.0 | OceanBase 文档中心" description: 创建物化视图 本文将向您介绍如何使用 SQL 语句创建物化视图。 说明 OceanBase 数据库暂时不支持直接修改物化视图的属性，如更新时间、刷新策略等。在这种情况下，可以考虑删除并重新创建物化视图以达到修改物化视图的目的。 权限要求 创建物化视图需要有 CREATE TABLE 权限。更多有关 OceanBase… --- 切换语言 - 中文站 - 简体中文 - International - English - 日本站 - 日本語 文档反馈![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*P8CuR4UJ_FkAAAAAAAAAAAAADiGDAQ/original) OceanBase 数据库分布式版 - V 4.6.0 # 创建物化视图 更新时间：2026-07-15 15:16:39 [编辑](https://github.com/oceanbase/oceanbase-doc/edit/V4.6.0/zh-CN/700.reference/300.database-object-management/100.manage-object-of-mysql-mode/600.manage-views-of-mysql-mode/200.manage-materialized-views-of-mysql-mode/300.create-materialized-views-of-mysql-mode.md) 本文将向您介绍如何使用 SQL 语句创建物化视图。 #### 说明 OceanBase 数据库暂时不支持直接修改物化视图的属性，如更新时间、刷新策略等。在这种情况下，可以考虑删除并重新创建物化视图以达到修改物化视图的目的。 ## 权限要求 创建物化视图需要有 `CREATE TABLE` 权限。更多有关 OceanBase 数据库权限的详细介绍，请参见 [MySQL 模式下的权限分类](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685770)。 ## 语法 创建物化视图的 SQL 语句格式如下： ```sql CREATE MATERIALIZED VIEW view_name [([column_list] [PRIMARY KEY(column_list)])] [table_option_list] [partition_option] [mv_column_group_option] [refresh_clause] [query_rewrite_clause] [on_query_computation_clause] AS view_select_stmt; ``` **参数说明：** - `view_name`：指定待创建的物化视图的名称。 - `column_list`：可选项，指定物化视图的列列表。如果想要为视图列指定明确的名称，可以使用 `column_list` 子句，并在其中使用逗号分隔的列名。 - `PRIMARY KEY(column_list)`：可选项，用于指定物化视图的主键。 - `table_option_list`：可选项，指定物化视图的表选项。 - `partition_option`：可选项，指定物化视图的分区选项。 - `mv_column_group_option`：可选项，指定物化视图的存储格式。不指定时，默认创建行存格式的物化视图。 - `refresh_clause`：可选项，指定物化视图的刷新方式。 - `query_rewrite_clause`：可选项，指定当前物化视图是否开启自动改写。 - `on_query_computation_clause`：可选项，指定当前物化视图是普通物化视图还是实时物化视图。 - `AS view_select_stmt`：用于定义物化视图数据的查询（`SELECT`）语句。该语句用于从基表中检索数据，并将结果存储到物化视图中。 #### 说明 - OceanBase 数据库支持外表作为物化视图的基表来创建全量刷新物化视图。 - OceanBase 数据库支持在创建物化视图时对基表添加 `AS OF PROCTIME()` 子句，若在创建物化视图基表位置之外的地方使用了 `AS OF PROCTIME()` 则会报错。`AS OF PROCTIME()` 用于指定增量刷新时跳过这张表的刷新，并且 `AS OF PROCTIME()` 的表可以不创建 mlog。 - OceanBase 数据库支持普通视图声明为维度表（`AS OF PROCTIME()`）时，可以作为增量刷新物化视图的基表。 有关创建物化视图语法的详细参数说明信息，请参见 [CREATE MATERIALIZED VIEW](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005686108)。 ## 创建物化视图 ### 创建普通物化视图 创建物化视图时，省略或者指定 `DISABLE ON QUERY COMPUTATION` 子句创建普通物化视图。 **示例如下：** 1. 创建表 `tbl1` 作为物化视图的基表。 ```sql CREATE TABLE tbl1 (col1 INT PRIMARY KEY, col2 VARCHAR(20), col3 INT); ``` 2. 基于表 `tbl1` 创建名为 `mv_tbl1` 的物化视图。 ```sql CREATE MATERIALIZED VIEW mv_tbl1 AS SELECT col1, col2 FROM tbl1 WHERE col3 >= 20; ``` 或者 ```sql CREATE MATERIALIZED VIEW mv_tbl1 DISABLE ON QUERY COMPUTATION AS SELECT col1, col2 FROM tbl1 WHERE col3 >= 20; ``` ### 创建嵌套物化视图 嵌套物化视图就是在已有的物化视图上构建的物化视图。例如下图，物化视图 `mv1` 基于表 `tbl1` 和表 `tbl2` 构建，是典型的物化视图。物化视图 `mv2` 则基于物化视图 `mv1` 和表 `tbl3` 构建，属于是嵌套物化视图。同理，物化视图 `mv3` 基于物化视图 `mv1` 和物化视图 `mv2` 构建，也是嵌套物化视图。 ![1](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/observer-enterprise/V4.3.5/700.reference/300.database-object-management/600.manage-views/%E5%B5%8C%E5%A5%97%E7%89%A9%E5%8C%96%E8%A7%86%E5%9B%BE.png) OceanBase 数据库创建嵌套物化视图时支持指定刷新策略，取值如下： - `INDIVIDUAL`：默认值，表示独立刷新。 - `INCONSISTENT`：表示级联非一致性刷。 - `CONSISTENT`：表示级联一致性刷新。 #### 说明 对于非嵌套物化视图来说，不存在级联刷新行为，无论指定为何种刷新策略均无意义，都默认独立刷新。指定的三种刷新策略只在后台任务生效，当手动使用 PL 包（[DBMS_MVIEW.REFRESH](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005686358)）调度刷新，按照指定的 PL 参数执行刷新。 #### 嵌套物化视图功能限制 - 为了支持嵌套物化视图的增量刷新，需要在物化视图（基表）上创建 mlog。 - 如果一个物化视图进行了全量刷新，那么依赖它的物化视图（嵌套物化视图）在后续进行增量刷新前必须先进行一次全量刷新，否则会报错。 - 嵌套物化视图不支持创建为实时物化视图，即创建嵌套物化视图时不支持指定 `ENABLE ON QUERY COMPUTATION` 子句。 **示例如下：** 1. 创建表 `tbl3` 作为物化视图的基表。 ```sql CREATE TABLE tbl3(id INT, name VARCHAR(30), PRIMARY KEY(id)); ``` 2. 创建表 `tbl4` 作为物化视图的基表。 ```sql CREATE TABLE tbl4(id INT, age INT, PRIMARY KEY(id)); ``` 3. 基于表 `tbl3` 和 `tbl4` 创建物化视图 `mv1_tbl3_tbl4`。 ```sql CREATE MATERIALIZED VIEW mv1_tbl3_tbl4 (PRIMARY KEY (id1, id2)) REFRESH COMPLETE AS SELECT tbl3.id id1, tbl4.id id2, tbl3.name, tbl4.age FROM tbl3, tbl4 WHERE tbl3.id = tbl4.id; ``` 4. 基于物化视图 `mv1_tbl3_tbl4` 创建物化视图（嵌套物化视图） `mv_mv1_tbl3_tbl4`。 ```sql CREATE MATERIALIZED VIEW mv_mv1_tbl3_tbl4 REFRESH COMPLETE AS SELECT SUM(AGE) age_sum FROM mv1_tbl3_tbl4; ``` 5. 基于物化视图 `mv1_tbl3_tbl4` 创建物化视图（嵌套物化视图） `mv1_mv1_tbl3_tbl4`，刷新策略为 `INCONSISTENT`。 ```sql CREATE MATERIALIZED VIEW mv1_mv1_tbl3_tbl4 REFRESH COMPLETE INCONSISTENT AS SELECT SUM(AGE) age_sum FROM mv1_tbl3_tbl4; ``` ### 创建实时物化视图 创建物化视图时，指定 `ENABLE ON QUERY COMPUTATION` 子句创建实时物化视图。 #### 实时物化视图注意事项 - 在创建实时物化视图前，物化视图依赖的基表都需要创建物化视图日志。 #### 说明 OceanBase 数据库支持物化视图日志自动管理功能。如果开启自动管理 mlog，那么在创建实时物化视图前，用户无需创建基表的 mlog，OceanBase 数据库会自动创建对应的 mlog 或更新已存在的 mlog 表定义使其包含新建物化视图依赖的列。详细信息，参见 [物化视图日志自动管理](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685863)。 - 只有特定类型的物化视图支持指定为实时物化视图，对于不满足条件的物化视图指定实时物化视图时，会导致报错。实时物化视图的要求与增量刷新的物化视图要求是相同的。详细信息，参见 [刷新物化视图](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685859) 中 **增量刷新基本要求** 内容。 - 使用 `MIN`/`MAX` 函数的物化视图不支持实时物化视图。 - 带有外连接的聚合物化视图不支持实时物化视图。 - 带有集合查询的物化视图不支持实时物化视图。 - 嵌套物化视图不支持创建为实时物化视图。 - 当执行查询的 Session 上的系统变量值和创建物化视图时固化在物化视图中的 Session 变量不一致时，需要将 Session 上的系统变量值修改为实时物化视图中固化的 Session 变量值，否则实时物化视图不可用，即实时物化视图查询改写不生效或直接查询实时物化视图会报错。 **示例如下：** 1. 创建表 `tbl2` 作为物化视图的基表。 ```sql CREATE TABLE tbl2(col1 INT, col2 INT, col3 INT); ``` 2. 在 `tbl2` 表上创建物化视图日志。 ```sql CREATE MATERIALIZED VIEW LOG ON tbl2 WITH PRIMARY KEY, ROWID, SEQUENCE (col1, col2, col3) INCLUDING NEW VALUES; ``` 3. 基于表 `tbl2` 创建实时物化视图 `mv_tbl2`。 ```sql CREATE MATERIALIZED VIEW mv_tbl2 ENABLE ON QUERY COMPUTATION AS SELECT col1, count(*) AS cnt FROM tbl2 GROUP BY col1; ``` 4. 创建实时物化视图后，可以通过视图 [DBA_MVIEWS](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005684704) 查看物化视图的定位是否为实时物化视图。 ```sql SELECT MVIEW_NAME, ON_QUERY_COMPUTATION FROM oceanbase.DBA_MVIEWS WHERE MVIEW_NAME = 'mv_tbl2'; ``` 返回结果如下： ```shell +------------+----------------------+ | MVIEW_NAME | ON_QUERY_COMPUTATION | +------------+----------------------+ | mv_tbl2 | Y | +------------+----------------------+ 1 row in set ``` 5. 查看实时物化视图的执行计划。 ```sql EXPLAIN BASIC SELECT * FROM mv_tbl2; ``` 从下面的执行计划中可以看到，执行期间会同时从物化视图和视图依赖基表的 mlog 读取数据，并对这两部分数据进行计算整合，最终获取实时的物化视图数据。 返回结果如下： ```shell +----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ | Query Plan | +----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ | ============================================== | | |ID|OPERATOR |NAME | | | ---------------------------------------------- | | |0 |HASH GROUP BY | | | | |1 |└─SUBPLAN SCAN |INNER_RT_MV$$| | | |2 | └─UNION ALL | | | | |3 | ├─TABLE FULL SCAN |mv_tbl2 | | | |4 | └─HASH GROUP BY | | | | |5 | └─SUBPLAN SCAN |DLT_T$$ | | | |6 | └─WINDOW FUNCTION | | | | |7 | └─TABLE FULL SCAN|mlog$_tbl2 | | | ============================================== | | Outputs & filters: | | ------------------------------------- | | 0 - output([INNER_RT_MV$$.col1], [cast(T_FUN_SUM(INNER_RT_MV$$.cnt), BIGINT(20, 0))]), filter([T_FUN_SUM(INNER_RT_MV$$.cnt) > cast(0, DECIMAL_INT(64, | | 0))]), rowset=16 | | group([INNER_RT_MV$$.col1]), agg_func([T_FUN_SUM(INNER_RT_MV$$.cnt)]) | | 1 - output([INNER_RT_MV$$.col1], [INNER_RT_MV$$.cnt]), filter(nil), rowset=16 | | access([INNER_RT_MV$$.col1], [INNER_RT_MV$$.cnt]) | | 2 - output([UNION([1])], [UNION([2])]), filter(nil), rowset=16 | | 3 - output([mv_tbl2.col1], [cast(mv_tbl2.cnt, DECIMAL_INT(42, 0))]), filter(nil), rowset=16 | | access([mv_tbl2.col1], [mv_tbl2.cnt]), partitions(p0) | | is_index_back=false, is_global_index=false, | | range_key([mv_tbl2.__pk_increment]), range(MIN ; MAX)always true | | 4 - output([DLT_T$$.col1], [T_FUN_SUM(CASE WHEN DLT_T$$.OLD_NEW$$ = 'N' THEN 1 ELSE -1 END)]), filter(nil), rowset=16 | | group([DLT_T$$.col1]), agg_func([T_FUN_SUM(CASE WHEN DLT_T$$.OLD_NEW$$ = 'N' THEN 1 ELSE -1 END)]) | | 5 - output([DLT_T$$.OLD_NEW$$], [DLT_T$$.col1]), filter([DLT_T$$.OLD_NEW$$ = 'N' AND DLT_T$$.SEQUENCE$$ = DLT_T$$.MAXSEQ$$ OR DLT_T$$.OLD_NEW$$ = 'O' | | AND DLT_T$$.SEQUENCE$$ = DLT_T$$.MINSEQ$$]), rowset=16 | | access([DLT_T$$.OLD_NEW$$], [DLT_T$$.SEQUENCE$$], [DLT_T$$.MAXSEQ$$], [DLT_T$$.MINSEQ$$], [DLT_T$$.col1]) | | 6 - output([mlog$_tbl2.OLD_NEW$$], [mlog$_tbl2.SEQUENCE$$], [T_FUN_MAX(mlog$_tbl2.SEQUENCE$$)], [T_FUN_MIN(mlog$_tbl2.SEQUENCE$$)], [mlog$_tbl2.col1]), filter(nil), rowset=16 | | win_expr(T_FUN_MAX(mlog$_tbl2.SEQUENCE$$)), partition_by([mlog$_tbl2.M_ROW$$]), order_by(nil), window_type(RANGE), upper(UNBOUNDED PRECEDING), lower(UNBOUNDED | | FOLLOWING) | | win_expr(T_FUN_MIN(mlog$_tbl2.SEQUENCE$$)), partition_by([mlog$_tbl2.M_ROW$$]), order_by(nil), window_type(RANGE), upper(UNBOUNDED PRECEDING), lower(UNBOUNDED | | FOLLOWING) | | 7 - output([mlog$_tbl2.M_ROW$$], [mlog$_tbl2.SEQUENCE$$], [mlog$_tbl2.OLD_NEW$$], [mlog$_tbl2.col1], [ORA_ROWSCN]), filter([ORA_ROWSCN > last_refresh_scn(500452)]), rowset=16 | | access([mlog$_tbl2.M_ROW$$], [mlog$_tbl2.SEQUENCE$$], [mlog$_tbl2.OLD_NEW$$], [mlog$_tbl2.col1], [ORA_ROWSCN]), partitions(p0) | | is_index_back=false, is_global_index=false, filter_before_indexback[false], | | range_key([mlog$_tbl2.M_ROW$$], [mlog$_tbl2.SEQUENCE$$]), range(MIN,MIN ; MAX,MAX)always true | +----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ 38 rows in set ``` ### 创建开启查询改写的物化视图 创建物化视图时，指定 `ENABLE QUERY REWRITE` 子句开启当前物化视图的自动改写。更多物化视图改写和改写控制的信息，参见 [物化视图查询改写](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685857)。 #### 注意 对于定义了 `ENABLE QUERY REWRITE` 子句的物化视图并不表示物化视图一定会改写查询。对于不满足查询改写条件的物化视图，不会报错，但不会被用于改写。由于系统变量 `query_rewrite_enabled` 默认值是 `false`，所以默认情况下定义了 `ENABLE QUERY REWRITE` 子句的物化视图并不会被用于改写。 **示例如下：** 1. 基于表 `tbl1` 创建物化视图 `mv_spj_tbl1`，并开启自动改写。 ```sql CREATE MATERIALIZED VIEW mv_spj_tbl1 ENABLE QUERY REWRITE AS SELECT * FROM tbl1; ``` 2. 创建物化视图后，可以通过视图 [DBA_MVIEWS](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005684704) 查看物化视图是否开启自动改写。 ```sql SELECT MVIEW_NAME, REWRITE_ENABLED FROM oceanbase.DBA_MVIEWS WHERE MVIEW_NAME = 'mv_spj_tbl1'; ``` 返回结果如下： ```shell +-------------+-----------------+ | MVIEW_NAME | REWRITE_ENABLED | +-------------+-----------------+ | mv_spj_tbl1 | Y | +-------------+-----------------+ 1 row in set ``` ### 创建列存格式物化视图 OceanBase 数据库支持行存、列存和行存列存冗余格式的物化视图，可以通过指定 `mv_column_group_option` 选项来显示创建列存或者行存列存冗余格式的物化视图。如果物化视图是多表 `JOIN` 形成的一张大宽表，创建列存格式的物化视图可以提高某些查询的性能。通过指定 `WITH COLUMN GROUP(each column)` 创建列存格式的物化视图。 #### 说明 不指定 `mv_column_group_option` 选项时，默认创建行存格式的物化视图。 **示例如下：** 基于表 `tbl1` 创建列存格式的物化视图 `mv_ec_tbl1`。 ```sql CREATE MATERIALIZED VIEW mv_ec_tbl1 WITH COLUMN GROUP(each column) AS SELECT * FROM tbl1; ``` ## 创建物化视图时添加主键 #### 注意 为物化视图指定主键后，维护/更新物化视图数据时，如果数据不满足主键约束，将导致视图维护失败。 **示例如下：** 基于表 `tbl1` 创建名为 `mv_pk_tbl1` 的物化视图，并指定主键。 ```sql CREATE MATERIALIZED VIEW mv_pk_tbl1(v_id, v_name, PRIMARY KEY(v_id)) AS SELECT col1, col2 FROM tbl1 WHERE col3 >= 20; ``` ## 创建物化视图时添加表选项和分区选项 在创建物化视图时，可以设置表选项，并根据数据特征和访问模式来设计和配置适合的分区选项，以提高查询性能和管理效率。 有关表选项和分区选项的详细参数说明信息，请参见 [CREATE TABLE](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005686098)。 **示例如下：** 基于表 `tbl1` 创建名为 `mv_pp_tbl1` 的物化视图，指定物化视图的并行度为 `5`，将物化视图按照 `col1` 列进行 Hash 分区，并分为 `8` 个分区，将 `tbl1` 表中满足条件 `col3 >= 20` 的记录作为基表进行查询，并将查询结果作为物化视图的数据。 ```sql CREATE MATERIALIZED VIEW mv_pp_tbl1 PARALLEL 5 PARTITION BY HASH(col1) PARTITIONS 8 AS SELECT col1, col2 FROM tbl1 WHERE col3 >= 20; ``` ## 物化视图添加索引 在创建物化视图的语句中，不能直接创建索引，但可以使用 [CREATE INDEX](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005686100) 语句或者 [ALTER TABLE](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005686147) 语句为物化视图创建索引。 **示例如下：** - 在物化视图 `mv_tbl1` 的 `col1` 列上创建名为 `idx1_mv_tbl1` 的索引。 ```sql CREATE INDEX idx1_mv_tbl1 ON mv_tbl1(col1); ``` - 在物化视图 `mv_tbl1` 的 `col2` 列上创建名为 `idx2_mv_tbl1` 的索引。 ```sql ALTER TABLE mv_tbl1 ADD INDEX idx2_mv_tbl1(col2); ``` ## 物化视图刷新 OceanBase 数据库物化视图支持全量刷新、增量刷新、混合刷新和永不刷新四种刷新策略。具体如下： - 全量刷新：重新计算整个物化视图的数据，确保视图中的数据与源表完全一致。 - 增量刷新：只刷新与源表变化相关的数据，避免对整个视图进行完全计算。 - 混合刷新：默认选项，首先尝试增量刷新，如果增量刷新失败，则执行全量刷新。 - 永不刷新：物化视图只在创建时进行刷新，并在创建后不允许再次刷新。 更多物化视图刷新的信息，请参见 [刷新物化视图](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685859)。 ### 创建全量刷新物化视图 创建物化视图时，使用 `REFRESH COMPLETE` 子句设置物化视图的刷新策略为全量刷新。 #### 注意 如果一个物化视图进行了全量刷新，那么依赖它的物化视图（嵌套物化视图）在后续进行增量刷新前必须先进行一次全量刷新，否则会报错。 **示例如下：** 基于表 `tbl1` 创建名为 `mv_rc_tbl1` 的物化视图，指定物化视图的刷新策略为全量刷新（`REFRESH COMPLETE`），指定从 `tbl1` 表中选择满足 `col3` 大于等于 `20` 的 `col1` 和 `col2` 列作为物化视图的数据源。 ```sql CREATE MATERIALIZED VIEW mv_rc_tbl1 REFRESH COMPLETE AS SELECT col1, col2 FROM tbl1 WHERE col3 >= 20; ``` #### 基于外表创建全量刷新物化视图 OceanBase 数据库支持外表作为物化视图的基表来创建全量刷新物化视图。 有关外表的介绍信息，参见 [关于外表](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685881)。 **示例如下：** #### 注意 示例中涉及 IP 的命令做了脱敏处理，在验证时应根据自己机器真实 IP 填写。 以下将以外部文件的位置在本地和在 OceanBase 数据库 MySQL 模式中创建外表为例，步骤如下： 1. 准备外部文件。 执行以下命令，在要登录 OBServer 节点所在机器的 `/home/admin` 目录下，创建文件 `ext_tbl1.csv`。 ```shell [admin@xxx /home/admin]# vi ext_tbl1.csv ``` 文件的内容如下： ```shell 1,'A1','2025-01-01' 2,'A2','2025-02-01' 3,'A3','2025-03-01' ``` 2. 设置导入的文件路径。 #### 注意 由于安全原因，设置系统变量 `secure_file_priv` 时，只能通过本地 Socket 连接数据库执行修改该全局变量的 SQL 语句。更多信息，请参见 [secure_file_priv](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685248)。 1. 执行以下命令，登录到 OBServer 节点所在的机器。 ```shell ssh admin@10.10.10.1 ``` 2. 执行以下命令，通过本地 Unix Socket 连接方式连接租户 `mysql001`。 ```shell obclient -S /home/admin/oceanbase/run/sql.sock -uroot@mysql001 -p****** ``` 3. 执行以下 SQL 命令，设置导入路径为 `/home/admin`。 ```sql SET GLOBAL secure_file_priv = "/home/admin"; ``` 3. 重新连接租户 `mysql001`。 示例如下： ```shell obclient -h10.10.10.1 -P2881 -uroot@mysql001 -p****** -A -Ddb_test ``` 4. 创建外表 `ext_tbl1`。 ```sql CREATE EXTERNAL TABLE ext_tbl1 ( id INT, name VARCHAR(50), c_date DATE ) LOCATION = '/home/admin' FORMAT = ( TYPE = 'CSV' FIELD_DELIMITER = ',' FIELD_OPTIONALLY_ENCLOSED_BY ='\'' ) PATTERN = 'ext_tbl1.csv'; ``` 5. 基于外表 `ext_tbl1` 创建全量刷新物化视图 `mv_ext_tbl1`。 ```sql CREATE MATERIALIZED VIEW mv_ext_tbl1 REFRESH COMPLETE AS SELECT * FROM ext_tbl1; ``` 6. 查看物化视图 `mv_ext_tbl1` 数据。 ```sql SELECT * FROM mv_ext_tbl1; ``` 返回结果如下： ```shell +------+------+------------+ | id | name | c_date | +------+------+------------+ | 1 | A1 | 2025-01-01 | | 3 | A3 | 2025-03-01 | | 2 | A2 | 2025-02-01 | +------+------+------------+ 3 rows in set ``` ### 创建增量刷新物化视图 创建物化视图时，使用 `REFRESH FAST` 子句设置物化视图的刷新策略为增量刷新。 #### 创建增量刷新物化视图注意事项 - 增量刷新的物化视图目前支持单表非聚合、单表聚合、多表关联、多表关联聚合、集合查询（`UNION ALL`）的 SQL 语句，对于不满足这五类场景的 SQL 语句，暂不支持增量刷新，增量刷新 SQL 语句要求详见 [刷新物化视图](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685859) 中 **增量刷新** 章节。 - 由于 `REFRESH FAST` 方法利用物化视图日志中的记录信息来确定需要增量刷新的内容，因此在使用增量刷新刷新物化视图时，需要在创建物化视图之前就创建基表的物化视图日志。有关创建物化视图日志的信息，参见 [物化视图日志](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685862)。 #### 说明 OceanBase 数据库支持物化视图日志自动管理功能。如果开启自动管理 mlog，那么在创建增量刷新物化视图前，用户无需创建基表的 mlog，OceanBase 数据库会自动创建对应的 mlog 或更新已存在的 mlog 表定义使其包含新建物化视图依赖的列。详细信息，参见 [物化视图日志自动管理](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685863)。 - 在创建物化视图时，可以对基表添加 `AS OF PROCTIME()` 子句，若在基表位置之外的地方使用了 `AS OF PROCTIME()` 则会报错。 - `AS OF PROCTIME()` 用于指定增量刷新时跳过这张表的刷新，来加速物化视图的增量刷新。并且 `AS OF PROCTIME()` 的表可以不创建 mlog。如果该表需要使用别名，表别名需放在 `AS OF PROCTIME()` 子句后面。 - 使用普通视图声明为维度表（`AS OF PROCTIME()`）作为增量刷新物化视图的基表时，有如下限制： - 与基表的维度表类似，不允许物化视图中使用的所有表都为维度表。 **示例如下：** 1. 创建表 `tbl5` 作为物化视图的基表。 ```sql CREATE TABLE tbl5 (col1 INT PRIMARY KEY, col2 INT, col3 INT); ``` 2. 在 `tbl5` 表上创建物化视图日志，指定物化视图日志的选项为 `SEQUENCE`，用于指示使用序列号来标识变化的数据，列部分指定了要记录的列，其中包括了 `col2` 和 `col3`。 ```sql CREATE MATERIALIZED VIEW LOG ON tbl5 WITH SEQUENCE (col2, col3) INCLUDING NEW VALUES; ``` 3. 基于表 `tbl5` 创建名为 `mv_tbl5` 的物化视图，指定物化视图的刷新策略为增量刷新，在查询部分指定从 `tbl5` 表中按照 `col2` 列进行分组，并计算每个分组中的记录数（`cnt`）、非空 `col3` 列的记录数（`cnt_col3`）和 `col3` 列的总和（`sum_col3`）作为物化视图的结果。 ```sql CREATE MATERIALIZED VIEW mv_tbl5 REFRESH FAST AS SELECT col2, COUNT(*) cnt, COUNT(col3) cnt_col3, SUM(col3) sum_col3 FROM tbl5 GROUP BY col2; ``` 4. 基于表 `tbl5` 和 `tbl1` 创建名为 `mv2_tbl5_tbl1` 的物化视图，指定物化视图的刷新策略为增量刷新，通过 `col1` 字段进行内连接（`INNER JOIN`）。使用 `AS OF PROCTIME()` 指定表 `tbl1` 在物化视图增量刷新时需要跳过此表。 ```sql CREATE MATERIALIZED VIEW mv2_tbl5_tbl1 REFRESH FAST ON DEMAND AS SELECT t5.col1 tbl5_c1, t1.col1 tbl1_c1, t5.col2 tbl5_c2, t1.col2 tbl1_c2 FROM tbl5 t5 INNER JOIN tbl1 AS OF PROCTIME() t1 ON t5.col1 = t1.col1 WHERE t5.col2 = 3; ``` 5. 基于引用声明为 `AS OF PROCTIME()` 的普通视图创建增量刷新物化视图。 1. 基于表 `tbl5` 创建视图 `v1_tbl5`。 ```shell obclient> CREATE VIEW v1_tbl5 AS SELECT * FROM tbl5; ``` 2. 基于表 `tbl5` 和 `v1_tbl5` 创建名为 `mv3_tbl5_v_tbl5` 的物化视图，指定物化视图的刷新策略为增量刷新，通过 `col1` 字段进行连接。使用 `AS OF PROCTIME()` 指定视图 `v1_tbl5` 为维度表。 ```shell obclient> CREATE MATERIALIZED VIEW mv3_tbl5_v_tbl5 AS SELECT a.col1 a_c1, b.col1 b_c1 FROM tbl5 a JOIN v1_tbl5 AS OF PROCTIME() b ON a.col1 = b.col1; ``` ### 创建混合刷新物化视图（默认选项） 创建物化视图时，省略或者指定 `REFRESH FORCE` 子句设置物化视图的刷新策略为混合刷新。 **示例如下：** 基于表 `tbl1` 创建名为 `mv_rf_tbl1` 的物化视图，指定物化视图的刷新策略为混合刷新，指定从 `tbl1` 表中选择满足 `col3` 大于等于 `20` 的 `col1` 和 `col2` 列作为物化视图的数据源。 ```sql CREATE MATERIALIZED VIEW mv_rf_tbl1 REFRESH FORCE AS SELECT col1, col2 FROM tbl1 WHERE col3 >= 20; ``` ### 创建永不刷新物化视图 创建物化视图时，使用 `NEVER REFRESH` 子句设置物化视图不需要刷新。即表示物化视图只在创建时进行刷新，并在创建后不允许再次刷新。 **示例如下：** 基于表 `tbl1` 创建名为 `mv_nr_tbl1` 的物化视图，指定物化视图的刷新策略为永不刷新，指定从 `tbl1` 表中选择满足 `col3` 大于等于 `20` 的 `col1` 和 `col2` 列作为物化视图的数据源。 ```sql CREATE MATERIALIZED VIEW mv_nr_tbl1 NEVER REFRESH AS SELECT col1, col2 FROM tbl1 WHERE col3 >= 20; ``` ## 创建自动刷新物化视图 在创建物化视图时，可以通过指定 `START WITH datetime_expr` 和 `NEXT datetime_expr` 子句来为物化视图创建一个后台自动刷新任务。 #### 注意 如果使用了 `NEXT` 子句，刷新计划的时间表达式必须设定在未来的时间点，否则会引发错误。 **示例如下：** 基于表 `tbl1` 创建名为 `mv_rc_swn_tbl1` 的物化视图，指定物化视图的刷新策略为全量刷新；指定物化视图的刷新计划中初始刷新时间为当前日期，之后每隔 `1` 天刷新一次物化视图。 ```sql CREATE MATERIALIZED VIEW mv_rc_swn_tbl1 REFRESH COMPLETE START WITH sysdate() NEXT sysdate() + interval 1 day AS SELECT col1, col2 FROM tbl1 WHERE col3 >= 20; ``` ## 相关文档 - [DBMS_MVIEW 概述](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005686357) - [物化视图概述](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685864) - [物化视图日志](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685862) - [刷新物化视图](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685859) - [物化视图查询改写](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685857) - [查询物化视图](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685861) - [修改物化视图](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685865) - [删除物化视图](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005685860) 上一篇 下一篇 ![有帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*y6ocSqN8cqsAAAAAAAAAAAAAARQnAQ)![无帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*BG9IQJyLHF8AAAAAAAAAAAAAARQnAQ)![反馈](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*eTWdQKCRKHwAAAAAAAAAAAAAARQnAQ)[AI](https://www.oceanbase.com/obi) 咨询热线