是否可以使用非 ACID 数据库模拟分布式事务？

Question

我们有一个系统将 SQL Server 2008 与 MongoDB 结合使用，将后者用于许多临时报告功能。它们的交集很多，但确实有一两个地方确实需要一起工作。

我总是有点担心事务的影响，但我认为如果应用程序首先执行 Mongo 工作并不是什么大问题，而且技术上 如果一个交易偶尔会在中间失败。但是最近出现了一个错误，导致他们始终失败，虽然我已经修复了导致它的错误，但它让我意识到我不能这样做是多么令人讨厌只需在整个工作单元上抛出一个分布式事务。

给定一个支持分布式事务 (SQL Server 2008) 的数据库和另一个不真正支持 任何 ACID 语义 (MongoDB) 的数据库，我有什么方法可以构建应用程序代码，以便两个数据库中的工作单元（“事务”）要么成功，要么回滚？

显然我必须使用一些额外的列/键来跟踪交易的状态 - 但是什么，在什么情况下？

Answer 1

您的一致性要求是什么？如果关于 Mongo 的临时报告并不总是完全最新的，这可以吗？

如果不是，那么我认为你的日子不好过。

如果是，那么我想我会使用一些事务性 MSMQ 以及 SQL Server，然后设置一个（或多个）服务来通过处理来自队列的消息来更新 Mongo。

Answer 2

也许您应该在每个文档中引入一个新字段，例如事务 ID。因此，如果出现问题，这可用于从 mongo 回滚新添加的文档。

伪代码..

Using (var tx=new transaction....){
  try {
    var txID= random id;
    //your sql data insertion
    //Mongo db document insertion with tx id

    if (some problem) {
          rollbackSQL();
          // and delete all the documents with the current tx id
     }
  }
  catch()
  {
          rollbackSQL();
          // and delete all the documents with the current tx id
  }
}

或者您可以在成功的 sql 提交时执行所有 mongodb 插入。

var docList = new List<MongoDocs>();
 Using (var tx=new transaction....){
      try {     
        //your sql data insertion
       docList.add(mongoDoc);
       if (success){
           sqlcommit();
           foreach(var doc in docList )
           {
               mongodb.insert(doc);
           }
       }
      }
      catch()
      {
              rollbackSQL();                 
      }

    }

更新：对 Aaronaught 的评论。

这里的第二个代码sn-p没有 完全可以工作，因为 SQL 事务已经提交 在尝试插入 Mongo 之前， 如果该插入失败（即损坏 连接），滚动它为时已晚 返回 SQL Server。

确实如此，这可以通过在sql commit之前将文档添加到mongo中来解决

 var docList = new List<MongoDocs>();
 Using (var tx=new transaction....)
 {
      try 
      {     
        //your sql data insertion
       docList.add(mongoDoc);
       if (success)
         {             
           foreach(var doc in docList )
           {
               mongodb.insert(doc);
           }

           sqlcommit();
         }
      }
      else {
           rollbackSQL();       

      }
      catch()
      {
              rollbackSQL();                 
              // And delete all newly added mongo documents by looping docList
      }

  }

现在您可以确保只在完成 sql 和 mongo 插入后才会提交。

Answer 3

Ramesh Vel的回答很好，但是还有一点你忘记了。

ACID 是一种容错的范例。您假设您的事务将到达catch 块，然后被回滚，或者到达try 的末尾，然后提交。

一般来说，这不是真的。在某些情况下，DB必须保持一致并且以上条件都不满足，例如：

1. 无限循环。假设您的代码或您的代码调用的方法中存在错误，则事务可能永远不会结束。使用抛出ThreadAbortException 的看门狗计时器进行修复是一种可行的方法。死锁的处理方式相同
2. 硬件故障。假设在执行过程中电源关闭。数据库的safe state 是什么？您必须回滚整个待处理事务，和/或重新执行它们。这是您无法在上面示例中的代码中直接修复的问题。商业 DBMS 有大量事务日志，可帮助恢复正确的 DB 状态

换句话说，就完全容错而言，当使用不是为 ACID 操作而设计的 DBMS 时，如果没有实际实现位于代码和DBMS 仅在code commit 之后执行 SQL 操作，保持已完成事务的稳定日志（在恢复后等待提交）。

这是一个非常复杂的问题。如果您接受您的数据库可能不一致（即您不是银行和/或您有手动在恢复后使用一致性检查器），您可以使用 sn- 模拟 ACIDity p 在另一个答案中显示，我的 +1

Answer 4

我认为您可以通过 IEnlistmentNotification 或 ISinglePhaseNotification 为这种情况创建特殊的资源管理器。