cursort.execute/cursor.callproc 没有返回错误但没有执行任何操作

zfo*_*fou 5 python postgresql psycopg2 psycopg

当我通过 psql 客户端运行这个 SQL 查询时,它运行了几秒钟(~90 秒,这是正常的,因为它是一个巨大的表)然后它返回,然后我可以检查我的行是否已成功插入。

SELECT merge_data('898989', '111111111', '10000')
Run Code Online (Sandbox Code Playgroud)

它是一个运行 UPDATE 或 INSERT 的存储过程,该过程运行时没有错误,我在表中得到了我的条目。

当尝试从 python 程序执行相同操作时,查询需要 2 秒并且没有返回任何错误,我的表中什么也没有;有关信息,该语句在 postgresqk 支持上成功执行(我可以在 pgsql 日志中看到它),这是我的代码片段:

conn = psycopg2.connect("...")
cursor = conn.cursor()

try:
    cursor.callproc("merge_data", ['898989', '111111111', '10000'])
except:
    print "ERROR !"

cursor.close()
Run Code Online (Sandbox Code Playgroud)

zfo*_*fou 6

解决 !

默认情况下,psycopg2 不会在每个执行的语句上自动提交,因此一旦我关闭连接(最后),所有挂起的事务都将被丢弃,就像执行了 ROLLBACK 一样。

可以在每个 cursor.execute() 或 .callproc 之后调用 conn.commit(),或者只是使用

conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_AUTOCOMMIT)
Run Code Online (Sandbox Code Playgroud)