mysql 跨库事物

基础概念

MySQL跨库事务指的是在一个事务中涉及到多个数据库的操作。在MySQL中，默认情况下，事务是针对单个数据库的，即在一个事务中只能对同一个数据库中的表进行操作。然而，在某些场景下，我们可能需要在一个事务中同时操作多个数据库，这就涉及到了跨库事务。

类型

MySQL本身并不直接支持跨库事务，但可以通过以下几种方式实现类似的功能：

分布式事务：通过分布式事务管理器（如XA协议）来协调多个数据库的事务。这种方式可以确保跨库事务的原子性和一致性，但实现复杂且性能开销较大。
两阶段提交（2PC）：在分布式系统中，两阶段提交是一种常用的协议，用于确保跨多个数据库的事务能够同时提交或回滚。
基于消息队列的最终一致性：通过消息队列来传递事务信息，实现多个数据库之间的最终一致性。这种方式适用于对实时性要求不高的场景。

应用场景

跨库事务常用于以下场景：

跨部门业务协同：在企业内部，不同部门可能使用不同的数据库系统，跨库事务可以确保各部门之间的数据一致性。
微服务架构：在微服务架构中，不同的服务可能使用不同的数据库，跨库事务可以确保服务之间的数据一致性。

遇到的问题及解决方法

问题：MySQL不支持跨库事务

原因：MySQL默认情况下只支持单库事务，不直接支持跨库事务。

解决方法：

使用分布式事务管理器：如前所述，可以使用分布式事务管理器（如XA协议）来协调多个数据库的事务。但这种方式实现复杂且性能开销较大。
应用层实现最终一致性：通过在应用层编写逻辑，确保多个数据库之间的数据最终一致。例如，可以使用消息队列来传递事务信息。

示例代码（基于消息队列的最终一致性）

假设我们有两个数据库db1和db2，分别存储用户信息和订单信息。当创建一个新订单时，需要同时更新这两个数据库。

import pika
import pymysql

# 连接数据库
db1_conn = pymysql.connect(host='localhost', user='user1', password='pass1', db='db1')
db2_conn = pymysql.connect(host='localhost', user='user2', password='pass2', db='db2')

# 连接消息队列
rabbitmq_conn = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = rabbitmq_conn.channel()

# 声明队列
channel.queue_declare(queue='order_queue')

def create_order(user_id, product_id):
    try:
        # 开启事务
        db1_conn.begin()
        db2_conn.begin()

        # 插入订单信息到db2
        cursor2 = db2_conn.cursor()
        cursor2.execute("INSERT INTO orders (user_id, product_id) VALUES (%s, %s)", (user_id, product_id))
        db2_conn.commit()

        # 更新用户信息到db1
        cursor1 = db1_conn.cursor()
        cursor1.execute("UPDATE users SET order_count = order_count + 1 WHERE id = %s", (user_id,))
        db1_conn.commit()

        # 发送消息到队列
        channel.basic_publish(exchange='', routing_key='order_queue', body=f'Order created for user {user_id}')

    except Exception as e:
        # 回滚事务
        db1_conn.rollback()
        db2_conn.rollback()
        print(f"Error creating order: {e}")

# 消费消息队列
def callback(ch, method, properties, body):
    print(f"Received message: {body}")

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

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