查看mysql分布式事务

import mysql.connector
from mysql.connector import errorcode

def two_phase_commit(conn1, conn2, sql1, sql2):
    try:
        # 第一阶段：预提交
        cursor1 = conn1.cursor()
        cursor2 = conn2.cursor()
        cursor1.execute("PREPARE TRANSACTION '%s'" % sql1)
        cursor2.execute("PREPARE TRANSACTION '%s'" % sql2)

        # 第二阶段：提交
        cursor1.execute("COMMIT PREPARED '%s'" % sql1)
        cursor2.execute("COMMIT PREPARED '%s'" % sql2)

        print("Transaction committed successfully.")
    except mysql.connector.Error as err:
        # 回滚
        cursor1.execute("ROLLBACK PREPARED '%s'" % sql1)
        cursor2.execute("ROLLBACK PREPARED '%s'" % sql2)
        print("Transaction rolled back due to error: {}".format(err))
    finally:
        cursor1.close()
        cursor2.close()
        conn1.close()
        conn2.close()

# 示例连接
conn1 = mysql.connector.connect(user='user1', password='password1', host='host1', database='db1')
conn2 = mysql.connector.connect(user='user2', password='password2', host='host2', database='db2')

# 示例SQL
sql1 = "UPDATE table1 SET column1 = 'value1' WHERE id = 1"
sql2 = "UPDATE table2 SET column2 = 'value2' WHERE id = 2"

two_phase_commit(conn1, conn2, sql1, sql2)