mysql死锁发生后解决

import mysql.connector
from mysql.connector import Error

def execute_transaction(cursor, sql_statements):
    try:
        for statement in sql_statements:
            cursor.execute(statement)
        cursor.connection.commit()
    except mysql.connector.Error as err:
        if err.errno == 1213:  # 1213是MySQL死锁错误码
            print("Deadlock detected, retrying transaction...")
            execute_transaction(cursor, sql_statements)
        else:
            print(f"Error: {err}")
            cursor.connection.rollback()

# 连接到MySQL数据库
try:
    connection = mysql.connector.connect(host='localhost',
                                         database='testdb',
                                         user='user',
                                         password='password')
    cursor = connection.cursor()
    
    # 定义事务SQL语句
    sql_statements = [
        "UPDATE table1 SET column1 = value1 WHERE condition1",
        "UPDATE table2 SET column2 = value2 WHERE condition2"
    ]
    
    # 执行事务
    execute_transaction(cursor, sql_statements)
    
except Error as e:
    print(f"Error: {e}")
finally:
    if connection.is_connected():
        cursor.close()
        connection.close()