SqlConnection 和 Dapper 如何处理 Transactions

Question

我有多个服务器运行同一个应用程序（分布式容器）。该应用程序修改了一个 SQL Server 表，所以它的作用是检查一个表的标志（例如status = open），阻止其中一些（有一个 top(10) 用于性能问题）并处理那些打开的行。完成后，它会相应地设置标志（高度简化）

我现在遇到的问题是，一些服务器随机崩溃

事务在锁定资源上与另一个进程发生死锁，并已被选为死锁牺牲品

我认为这是 SQL Server 错误。所以我的问题： 开始时

using (var connection = new SqlConnection(connectionString))

和小巧玲珑，就像

connection.Query("my Query");

在使用结束之前，是否所有查询都像在一个 SQL 事务中一样处理？这里BeginTransaction 解决了问题还是将所有内容都视为嵌套事务？

真的很难测试，我的猜测是，这个问题每执行 10 次左右就会出现一次。整个过程需要处理对另一台服务器的 HTTP 请求，这些请求可能持续时间更长或更短，因此整个过程可能需要数百毫秒或几秒钟（我对此没有影响）。

更新

所以应用程序（无助于显示真实代码）会执行类似的操作

connection.Query(query1);
doOtherStuff
connection.Query(query2);
doOtherStuff
connection.Query(query3);
doOtherStuff 

其他东西是异步的（有时），但是，每个查询都可以独立执行，不需要处于关闭的事务中。

Answer 1

这真的很棘手，我已经建立了EntityWorker.Core *并且这个问题已经在那里处理了。我想 Dapper 不会处理这些问题。

要首先了解问题，您可以阅读this

现在，在您查看并理解为什么会发生这种情况之后，您可以找到解决方法。

这是我解决这个问题的方法，看看下面的代码，让我知道你的想法和理解。

private static object internalChangeLocker = new object();
// here you should do db changes, this should be a general method only called by external calls.
public static int Save(object someObject) {
  lock(internalChangeLocker) {
    return internalSave(someObject);
  }
}

// this method should only be called from within Save or internalSave
private static int internalSave(object someObject, Transaction tran = null) {
  var tr = tran;
  if (tran == null)
    // then create and begin a new transaction here

    // here do the db operation here
    // you can also call internalSave(newobject, tr); agen and pass on the already created transaction.


    if (tran == null) {
      /// here you should then commit and end the transaction
      // you may ask why the check, this is importend becouse you may calls 
      // internalSave(newobject, tr); within the internalSave and have to use the same old transaction
    }
}