python flask cursors.execute() 的 INSERT 和 DELETE 不起作用

Question

我是 python 开发的新手，我正在尝试使用以下函数更新数据库，但遗憾的是它不起作用：

def db_update_favourite(user_id, id_layer,favourite):
    connection = g.db
    cursor = connection.cursor()
    cursor.execute(SCHEMA)
    chiave="favourite_layers";

    if(favourite):
        query = ("""INSERT INTO users_properties (id_user,chiave,index,val_bigint)
                VALUES(%s,%s,(SELECT max(index)+1 from users_properties),%s)
            """)
    else:
        query = ("""DELETE FROM users_properties
                WHERE  id_user=%s AND chiave=%s AND val_bigint=%s
            """)


    print query %(user_id,chiave,id_layer)
    try:
        res= cursor.execute(query, (user_id,chiave,id_layer))
    except Exception as e:
        print e
    print res
    print cursor.rowcount
    return cursor.rowcount>=1

如果我去检查数据库，我发现这个函数根本没有改变数据库。

如果相反，我使用 psql 手动尝试这两个查询，它们按预期工作。

如您所见，我尝试调试但 res 为 None，未触发异常且行数始终为 1。

还有其他方法可以执行类似的查询并且它们都有效，它会是什么？关于如何进一步调试它的任何其他想法，否则？

P.s 我正在使用 pg8000，因为服务器不是我的，并且已经存在的代码使用该库。

Answer 1

在关闭连接之前使用 connection.commit() 或 g.db.commit()。

python flask cursors.execute() 的 INSERT 和 DELETE 不起作用

python flask cursors.execute() of INSERT and DELETE doesn't work

python

database

postgresql

flask

pg8000