mysql实现分布式事务

-- 启动XA事务
XA START 'transaction_id';

-- 执行SQL操作
INSERT INTO table1 (column1) VALUES ('value1');

-- 准备提交
XA PREPARE 'transaction_id';

-- 提交事务
XA COMMIT 'transaction_id';

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 定义消息队列
channel.queue_declare(queue='transaction_queue')

def callback(ch, method, properties, body):
    # 处理消息并执行SQL操作
    print("Received %r" % body)
    # 执行SQL操作

channel.basic_consume(queue='transaction_queue', on_message_callback=callback, auto_ack=True)

print('Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

-- 本地事务1
START TRANSACTION;
INSERT INTO table1 (column1) VALUES ('value1');
COMMIT;

-- 本地事务2
START TRANSACTION;
UPDATE table2 SET column2 = 'value2' WHERE id = 1;
COMMIT;

-- 补偿操作
START TRANSACTION;
DELETE FROM table1 WHERE column1 = 'value1';
COMMIT;