PostgreSQL物化视图不从Python刷新答案

【问题标题】：PostgreSQL materialized view not refreshing from PythonPostgreSQL物化视图不从Python刷新
【发布时间】：2021-01-09 03:38:11
【问题描述】：

我在 TimescaleDB（时间序列数据的 PostgreSQL 扩展）中创建了一个物化视图，当我使用 PGAdmin 的以下代码刷新它时，添加了最新数据并且一切正常：

REFRESH MATERIALIZED VIEW CONCURRENTLY 
    public.time_series_mv
    WITH DATA;

当我在 Python 中使用相同的用户 (postgres) 运行完全相同的代码时，它表示成功（即没有发生错误），但最新的数据实际上并未添加到物化视图中...

因此我尝试创建一个函数来做同样的事情：

CREATE OR REPLACE FUNCTION refresh_time_series_mv()
    RETURNS void
    SECURITY DEFINER
    AS $$
    BEGIN
    REFRESH MATERIALIZED VIEW CONCURRENTLY time_series_mv with data;
    RETURN;
    END;
$$ LANGUAGE plpgsql;

然后我按如下方式运行该函数，它再次在我的浏览器中通过 PGAdmin 运行，但当我在调度应用程序中从 Python 运行相同的 SQL 时却不行。

select refresh_time_series_mv();

这是我的 Python 代码：

import psycopg2

SQL1 = """
    REFRESH MATERIALIZED VIEW CONCURRENTLY 
    public.time_series_mv
    WITH DATA
"""

SQL2 = "select refresh_time_series_mv();"

host = os.getenv("HOST") 
port = int(os.getenv("PORT"))
dbname = os.getenv('DB')
user = os.getenv("USER")
password = os.getenv("PASS")

conn = psycopg2.connect(
    host=host, 
    port=port, 
    dbname=dbname, 
    user=user, 
    password=password, 
    connect_timeout=5
) 
cursor = conn.cursor()
cursor.execute(SQL1)
# cursor.execute(SQL2)
cursor.close()
conn.close()

无论我使用“SQL1”还是“SQL2”，Python 代码都能成功运行（显然，对于 Python），但同样，物化视图中的数据没有刷新......

我使用相同的用户名和密码连接到数据库，无论是在 PGAdmin 还是在 Python 中。

有什么想法吗？谢谢！ -肖恩

【问题讨论】：

Python 默认不自动提交。看起来你也从不手动提交。所以你的动作被回滚了。
@jjanes 我的天哪，这是我犯的一个愚蠢的错误。你是绝对正确的——问题解决了！

标签： python postgresql pgadmin timescaledb

【解决方案1】：

正如@jjanes 在comment 中提到的，我需要在 cursor.execute(SQL) 之后添加以下内容：

conn.commit()

问题解决了。如果 conn.commit() 在那里，我在问题中提到的任何一条 SQL 语句都可以工作。

【讨论】：

感谢您为我节省了一些时间！