当我通过psql客户端运行此SQL查询时,它将运行几秒钟(〜90秒,这是正常的,因为它的表很大)并返回,然后可以检查是否成功插入了我的行.
SELECT merge_data('898989', '111111111', '10000')
这是一个运行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()
解决方法:
解决 !
默认情况下,psycopg2不会在每个已执行的语句上自动提交,因此一旦我关闭连接(最后),所有待处理的事务都将被丢弃,就像执行了ROLLBACK一样.
可以在每个cursor.execute()或.callproc之后调用conn.commit(),或使用以下命令将其设置为全局范围
conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_AUTOCOMMIT)