以下是一个使用 mysql-connector-python 库的简单事务操作的示例：
首先，确保你已经安装了 mysql-connector-python：
pip install mysql-connector-python
然后，你可以使用以下代码执行事务：
import mysql.connector
# 替换以下信息为你的数据库信息
db_config = {
"host": "your_mysql_host",
"user": "your_mysql_user",
"password": "your_mysql_password",
"database": "your_mysql_database",
}
try:
# 创建数据库连接
connection = mysql.connector.connect(**db_config)
# 创建游标对象
cursor = connection.cursor()
# 启动事务
connection.start_transaction()
# 执行事务操作，这里使用两个示例 SQL 语句
query1 = "UPDATE your_table SET age = age + 1 WHERE name = 'John Doe'"
query2 = "DELETE FROM your_table WHERE age > 50"
cursor.execute(query1)
cursor.execute(query2)
# 提交事务
connection.commit()
except mysql.connector.Error as err:
# 发生错误时回滚事务
print(f"Error: {err}")
connection.rollback()
finally:
# 关闭游标和连接
if cursor:
cursor.close()
if connection.is_connected():
connection.close()
请替换 your_mysql_host、your_mysql_user、your_mysql_password、your_mysql_database 和 your_table 为你的实际数据库信息和表名。上述代码中的 query1 和 query2 是事务中执行的两个 SQL 语句。
在事务中，如果所有操作都成功，调用 connection.commit() 提交事务，否则调用 connection.rollback() 进行回滚，撤销之前的操作。
确保在执行事务的过程中捕获并处理可能发生的错误，以保证程序的稳定性。
转载请注明出处：http://www.zyzy.cn/article/detail/8044/MySQL