Python数据库操作怎样处理事务

在Python中，可以使用sqlite3库来处理SQLite数据库的事务。以下是一个示例代码，展示了如何在Python中使用sqlite3库进行事务处理：

import sqlite3

# 连接到数据库
conn = sqlite3.connect('example.db')
cursor = conn.cursor()

try:
    # 开始事务
    cursor.execute("BEGIN TRANSACTION")

    # 执行SQL语句
    cursor.execute("INSERT INTO test (col1, col2) VALUES (?, ?)", values1)
    cursor.execute("INSERT INTO test (col1, col2) VALUES (?, ?)", values2)

    # 提交事务
    conn.commit()
except:
    # 发生异常，回滚事务
    conn.rollback()
    raise
finally:
    # 关闭游标和连接
    cursor.close()
    conn.close()

在上面的示例代码中，我们首先连接到名为example.db的SQLite数据库。然后，我们使用cursor对象执行SQL语句，并使用BEGIN TRANSACTION开始事务。接下来，我们执行了两个INSERT语句，将数据插入到test表中。最后，我们使用conn.commit()提交事务。

如果在执行SQL语句时发生异常，我们会捕获该异常并使用conn.rollback()回滚事务。这样可以确保数据的一致性，避免因为异常而导致的数据不一致问题。

无论是否发生异常，我们都会在finally块中使用cursor.close()关闭游标，并使用conn.close()关闭数据库连接。这样可以确保资源的正确释放，避免资源泄漏问题。