python flask cursors.execute() of 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，异常没有触发，rowcount总是1。

有其他的方法执行类似的查询，他们都工作，它可以是什么?还有其他关于如何进一步调试它的想法吗?

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

Answer 1

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