如何使用Python的SQLAlchemy刷新Oracle物化视图

你遇到的ORA-00900: invalid SQL statement错误，核心原因是EXEC是Oracle SQL*Plus客户端的专属命令，不属于标准PL/SQL语法，无法通过SQLAlchemy这类程序接口直接识别执行。同时你原有代码直接用f字符串拼接SQL参数，也存在语法错误和SQL注入风险。

按以下规则修正代码即可：

• 把EXEC调用替换为标准PL/SQL匿名块，用BEGIN ... END;包裹存储过程调用
• 用SQLAlchemy提供的text()函数包裹原生SQL/PLSQL语句
• 采用参数绑定的方式传入物化视图名、刷新方法等参数，不要直接拼接进SQL字符串
• SQLAlchemy 2.0+版本需要手动提交事务

修正后可运行代码 #

from sqlalchemy import text

mview = 'mv_test'
# 刷新方法可选值：'C'=完全刷新，'F'=快速刷新，'P'=分区刷新，可按需替换
refresh_method = 'C'
mview_refresh_sql = text("BEGIN DBMS_MVIEW.REFRESH(:mview_name, method => :refresh_method); END;")

try:
    conn.execute(
        mview_refresh_sql,
        {"mview_name": mview, "refresh_method": refresh_method}
    )
    # SQLAlchemy 2.0及以上版本必须加commit，低版本如果开启自动提交可以省略
    conn.commit()
    print(f"物化视图{mview}刷新成功")
except Exception as err:
    print(f"刷新失败：{err}")

如果需要同时刷新多个物化视图，可将多个视图名用逗号拼接后传入mview_name参数即可，无需修改SQL语句结构。

内容的提问来源于stack exchange，提问作者Kishore G