如何在两个异构数据库之间执行事务以保证数据一致性

你描述的双写跨库场景下的提交一致性问题，是分布式事务领域的经典问题，目前已经有非常成熟的工业界解决方案，按数据库是否支持分布式事务可以分为两大类： #

方案一：两阶段提交（2PC，基于XA协议） #

如果你的两个数据库都支持XA分布式事务规范（MySQL、Postgres均原生支持），可以直接用XA接口实现原子提交，从根本上避免「一个提交成功一个提交失败」的问题，核心逻辑分为两个阶段：

1. 预提交阶段：分别执行两个库的事务逻辑后，向两个库发送PREPARE指令，两个库会预留所有提交需要的资源，校验事务可执行性，只要有一个库返回PREPARE失败，两个库统一执行回滚
2. 正式提交阶段：只有两个库都返回PREPARE成功，才向两个库发送正式COMMIT指令，完成事务提交
   这个方案可以实现强一致性，适合对数据一致性要求极高的场景，但也有两个局限性：一是依赖数据库的XA支持，SQLite等轻量数据库不支持；二是属于阻塞协议，极端情况下协调者宕机可能导致事务长时间卡住。

方案二：最终一致性方案（适用于不支持XA的数据库） #

如果使用的是SQLite这类不支持分布式事务的数据库，无法实现强一致的原子提交，可以用最终一致性方案，保证经过短暂的不一致窗口后，两个库的数据最终完全一致，常用的实现方式有三种：

2.1 补偿事务（TCC模式） #

将整个操作拆分为三个阶段：

• Try阶段：分别在两个库做资源预留，记录变更前的原始数据快照，对操作的数据行加锁避免被其他操作修改
• Confirm阶段：两个库正式执行提交逻辑
• Cancel阶段：如果任意一个库Confirm失败，执行补偿逻辑，将已经提交的库回滚到变更前的原始状态
  注意补偿逻辑必须设计为幂等，避免重复执行补偿导致数据错误。

2.2 本地消息表+重试机制 #

这是生产中最常用的轻量方案，核心逻辑是把本地业务更新和同步任务绑定到同一个本地事务里，保证只要本地更新成功，同步任务一定会被执行：

-- 1. 执行本地事务，同时写入同步任务
BEGIN TRANSACTION 'local';
-- 执行业务更新
UPDATE table SET name='todd' WHERE id=1;
-- 往本地库的消息表写入待同步任务
INSERT INTO sync_task (task_id, target_sql, status, retry_times) 
VALUES (12345, "UPDATE table SET name='todd' WHERE id=1", 'pending', 0);
COMMIT TRANSACTION 'local';

-- 2. 异步轮询任务执行
while True:
    task = get_pending_sync_task()
    if not task:
        time.sleep(1)
        continue
    try:
        execute_remote_sql(task.target_sql)
        update_task_status(task.task_id, 'success')
    except Exception as e:
        if task.retry_times < 10:
            increase_task_retry_times(task.task_id)
        else:
            send_alert_to_admin(task.task_id)

这个方案要求远程库的更新操作必须是幂等的（比如更新时带上版本号校验），避免重试时重复执行导致数据异常。

2.3 CDC增量同步 #

如果对同步实时性要求不高，可以不用双写逻辑，只写本地库，再通过CDC（变更数据捕获）工具抓取本地库的WAL/binlog日志，解析后同步到远程库，同步过程保证幂等即可实现最终一致。 #

内容的提问来源于stack exchange，提问作者David542