使用规则或通知自动刷新物化视图

Question

我有一个很少更改（大约一天两次）的 PostgreSQL 9.3 数据库的物化视图。但是当它发生时，我想及时更新它的数据。

到目前为止，这是我的想法：

有一个物化视图mat_view，它使用一些连接语句从表table1 和table2 中获取数据。

每当table1 或table2 中的某些内容发生变化时，我已经有一个触发器来更新一个小配置表config，其中包含

table_name | mat_view_name | need_update
-----------+---------------+------------
table1     | mat_view      | TRUE/FALSE
table2     | mat_view      | TRUE/FALSE

因此，如果table1 中的任何内容发生变化（每个语句的 UPDATE 和 DELETE 触发器都有一个触发器），则第一行中的字段 need_update 将设置为 TRUE。 table2 和第二行也是如此。

显然，如果need_update 为TRUE，则必须刷新物化视图。

更新： 由于物化视图不支持规则（正如@pozs 在下面的评论中提到的那样），我会更进一步。我会用定义“SELECT * FROM mat_view”创建一个虚拟视图v_mat_view。当用户在此视图上执行 SELECT 时，我需要在 SELECT 上创建一个规则，它执行以下操作：

• 检查mat_view是否应该更新（SELECT 1 FROM config WHERE mat_view_name='mat_view' AND need_update=TRUE）
• 用UPDATE config SET need_update=FALSE where mat_view_name='mat_view' 重置need_update 标志
• REFRESH MATERIALIZED VIEW mat_view
• 最后以mat_view 为目标执行原始SELECT 语句。

更新2： 我尝试创建上述步骤：

创建一个处理上述四点的函数：

CREATE OR REPLACE FUNCTION mat_view_selector()
RETURNS SETOF mat_view AS $body$
BEGIN
  -- here is checking whether to refresh the mat_view
  -- then return the select:
  RETURN QUERY SELECT * FROM mat_view;
END;
$body$ LANGUAGE plpgsql;

创建真正从函数mat_view_selector中选择的视图v_mat_view：

CREATE TABLE v_mat_view AS SELECT * from mat_view LIMIT 1;
DELETE FROM v_mat_view;

CREATE RULE "_RETURN" AS
    ON SELECT TO v_mat_view
    DO INSTEAD 
        SELECT * FROM mat_view_selector();
    -- this also converts the empty table 'v_mat_view' into a view.

结果不满意：

# explain analyze select field1 from v_mat_view where field2 = 44;
QUERY PLAN
Function Scan on mat_view_selector (cost=0.25..12.75 rows=5 width=4)
(actual time=15.457..18.048 rows=1 loops=1)
Filter: (field2 = 44)
Rows Removed by Filter: 20021
Total runtime: 31.753 ms

与从 mat_view 本身进行选择相比：

# explain analyze select field1 from mat_view where field2 = 44;
QUERY PLAN
Index Scan using mat_view_field2 on mat_view (cost=0.29..8.30 rows=1 width=4)
  (actual time=0.015..0.016 rows=1 loops=1)
Index Cond: (field2 = 44)
Total runtime: 0.036 ms

所以基本上它确实有效，但性能可能是个问题。

有人有更好的主意吗？ 如果没有，那么我将不得不在应用程序逻辑中以某种方式实现它，或者更糟：运行一个每分钟左右运行的简单 cronjob。

Answer 1

您应该在 table1 和 table2 上的每个语句的插入/更新/删除/截断之后刷新触发器中的视图。

create or replace function refresh_mat_view()
returns trigger language plpgsql
as $$
begin
    refresh materialized view mat_view;
    return null;
end $$;

create trigger refresh_mat_view
after insert or update or delete or truncate
on table1 for each statement 
execute procedure refresh_mat_view();

create trigger refresh_mat_view
after insert or update or delete or truncate
on table2 for each statement 
execute procedure refresh_mat_view();

通过这种方式，您的物化视图始终是最新的。这种简单的解决方案可能难以接受频繁的插入/更新和零星的选择。 就您而言（很少一天更换两次），它非常适合您的需求。

---

要实现物化视图的延迟刷新，您需要以下功能之一：

• 异步触发
• 选择前触发
• 选择之前的规则

Postgres 一个都没有，所以好像没有clear postgres 解决方案。

考虑到这一点，我会考虑在 mat_view 上选择一个包装函数，例如

CREATE OR REPLACE FUNCTION select_from_mat_view(where_clause text)
RETURNS SETOF mat_view AS $body$
BEGIN
  -- here is checking whether to refresh the mat_view
  -- then return the select:
  RETURN QUERY EXECUTE FORMAT ('SELECT * FROM mat_view %s', where_clause);
END;
$body$ LANGUAGE plpgsql;

在实践中是否可以接受取决于我不知道的细节。

Answer 2

PostgreSQL 9.4 将 REFRESH CONCURRENTLY 添加到物化视图中。

当您描述尝试设置物化视图的异步更新时，这可能是您正在寻找的内容。

在刷新完成之前，从物化视图中选择的用户将看到不正确的数据，但在许多使用物化视图的场景中，这是一个可以接受的折衷方案。

使用语句级触发器来监视基础表的任何更改，然后同时刷新实体化视图。