插入和删除的Python烧瓶cursors.execute()不起作用

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。

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

我使用pg8000，因为服务器不是我的，已经存在的代码使用这个库。

Answer 1

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