Deadlock khi hai giao dịch khóa ngược thứ tự

using System;
using System.Data;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Data.SqlClient;

public static class DonHangService
{
    private const int SoLanThuToiDa = 4;

    // 1205: nạn nhân deadlock. 3960: xung đột cập nhật dưới SNAPSHOT.
    // Với cả hai lỗi, SQL Server đã rollback toàn bộ giao dịch trước khi báo về.
    private static bool NenThuLai(SqlException ex) => ex.Number is 1205 or 3960;

    // dong: DataTable với các cột DongSo (short), SanPhamId (int), SoLuong (int),
    // đúng thứ tự cột của dbo.DongDonHang.
    public static async Task TaoDonHangAsync(string chuoiKetNoi, long donHangId, DateTime ngayTao,
        int khachHangId, DataTable dong, CancellationToken ct = default)
    {
        for (int lan = 1; ; lan++)
        {
            try
            {
                using var ketNoi = new SqlConnection(chuoiKetNoi);
                await ketNoi.OpenAsync(ct);

                using var lenh = new SqlCommand("dbo.usp_DonHang_Tao", ketNoi)
                {
                    CommandType = CommandType.StoredProcedure,
                    CommandTimeout = 30
                };
                lenh.Parameters.Add("@DonHangId", SqlDbType.BigInt).Value = donHangId;
                lenh.Parameters.Add("@NgayTao", SqlDbType.DateTime2).Value = ngayTao;
                lenh.Parameters.Add("@KhachHangId", SqlDbType.Int).Value = khachHangId;
                SqlParameter tvp = lenh.Parameters.Add("@Dong", SqlDbType.Structured);
                tvp.TypeName = "dbo.DongDonHang";
                tvp.Value = dong;

                await lenh.ExecuteNonQueryAsync(ct);
                return;
            }
            catch (SqlException ex) when (NenThuLai(ex) && lan < SoLanThuToiDa)
            {
                // Chờ ngẫu nhiên, tăng dần, để hai giao dịch không va lại đúng nhịp cũ.
                await Task.Delay(Random.Shared.Next(50, 250) * lan, ct);
            }
        }
    }
}

#:package Microsoft.Data.SqlClient@7.1.1
// Deadlock lúc 16:40, mỗi kiểu 10 lượt, không thử lại: phiên trả hàng A khóa đơn rồi kho (ngược phiên B),
// rồi A viết lại theo quy ước SanPham trước DonHang. Đếm số lượt có phiên nhận lỗi 1205.
// Chạy: dotnet run ThuTu.cs   (BANHANG_DB: chuỗi kết nối tới database có dbo.SanPham và dbo.DonHang)
using System.Diagnostics;
using Microsoft.Data.SqlClient;

string db = Environment.GetEnvironmentVariable("BANHANG_DB")
    ?? @"Server=(localdb)\MSSQLLocalDB;Database=BanHang_Thu;Integrated Security=true;TrustServerCertificate=true";
const string Don10042 = "DonHangId = 10042 AND NgayTao = '2026-10-02T11:58:00'";
string giamDon = $"UPDATE dbo.DonHang SET TongTien = TongTien - 250000.00 WHERE {Don10042}";
string tangDon = $"UPDATE dbo.DonHang SET TongTien = TongTien + 250000.00 WHERE {Don10042}";
string congKho = "UPDATE dbo.SanPham SET TonKho = TonKho + 1 WHERE SanPhamId = 42";
string truKho = "UPDATE dbo.SanPham SET TonKho = TonKho - 1 WHERE SanPhamId = 42";

await Task.WhenAll(GiaoDich("SELECT 1", "SELECT 1", 0), GiaoDich("SELECT 1", "SELECT 1", 0));   // mở sẵn hai kết nối trong pool

foreach (var (ten, aCau1, aCau2) in new[] { ("A sửa đơn rồi cộng kho, ngược B", giamDon, congKho),
                                            ("A cộng kho rồi sửa đơn, cùng B ", congKho, giamDon) })
{
    int soLuotDeadlock = 0;
    var thoiGian = new List<long>();
    for (int luot = 0; luot < 10; luot++)
    {
        await GiaoDich("UPDATE dbo.SanPham SET TonKho = 7 WHERE SanPhamId = 42",
                       $"UPDATE dbo.DonHang SET TongTien = 1750000.00 WHERE {Don10042}", 0);   // đặt lại dữ liệu mỗi lượt
        var dongHo = Stopwatch.StartNew();
        int[] loi = await Task.WhenAll(GiaoDich(aCau1, aCau2, 0), GiaoDich(truKho, tangDon, 50));   // B: trừ kho rồi tăng đơn
        thoiGian.Add(dongHo.ElapsedMilliseconds);
        if (loi.Contains(1205)) soLuotDeadlock++;
    }
    Console.WriteLine($"{ten}: {soLuotDeadlock}/10 lượt có lỗi 1205; mỗi lượt {thoiGian.Min()} đến {thoiGian.Max()} ms, trung bình {thoiGian.Average():F0} ms");
}

async Task<int> GiaoDich(string cau1, string cau2, int treMs)
{
    await Task.Delay(treMs);
    await using var c = new SqlConnection(db);
    await c.OpenAsync();
    await using var tx = (SqlTransaction)await c.BeginTransactionAsync();
    try
    {
        await new SqlCommand(cau1, c, tx).ExecuteNonQueryAsync();
        await Task.Delay(200);                                  // phần việc giữa hai câu
        await new SqlCommand(cau2, c, tx).ExecuteNonQueryAsync();
        await tx.CommitAsync();
        return 0;
    }
    catch (SqlException ex) { return ex.Number; }
}

#:package Microsoft.EntityFrameworkCore.SqlServer@10.0.12
#:property PublishAot=false
// Deadlock lúc 16:40 và xung đột SNAPSHOT, chạy qua execution strategy của EF Core.
// Chạy: dotnet run Deadlock.cs   (BANHANG_DB: chuỗi kết nối tới database có dbo.SanPham và dbo.DonHang)
using System.Data;
using System.Diagnostics;
using Microsoft.Data.SqlClient;
using Microsoft.EntityFrameworkCore;

string cs = Environment.GetEnvironmentVariable("BANHANG_DB")
    ?? @"Server=(localdb)\MSSQLLocalDB;Database=BanHang_Thu;Integrated Security=true;TrustServerCertificate=true";

await using (var db = new BanHangDb(cs, thuLai: false))
{
    await db.Database.ExecuteSqlRawAsync("ALTER DATABASE CURRENT SET ALLOW_SNAPSHOT_ISOLATION ON");
    await db.Database.ExecuteSqlAsync($"""
        UPDATE dbo.SanPham SET TonKho = 7 WHERE SanPhamId = 42;
        UPDATE dbo.DonHang SET TongTien = 1750000.00
        WHERE DonHangId = 10042 AND NgayTao = '2026-10-02T11:58:00';
        """);
}

// 0. Giao dịch tự mở ngoài execution strategy
try
{
    await using var db = new BanHangDb(cs, thuLai: true);
    await using var tx = await db.Database.BeginTransactionAsync();
    await db.Database.SqlQuery<int>($"SELECT TonKho AS Value FROM dbo.SanPham WHERE SanPhamId = 42").SingleAsync();
}
catch (InvalidOperationException ex) { Console.WriteLine($"0. {ex.Message.Split(". ")[0]}."); }

// 1. Phiên A trả hàng (đơn rồi kho), phiên B thêm hàng (kho rồi đơn): thứ tự ngược nhau.
FormattableString giamDon = $"UPDATE dbo.DonHang SET TongTien = TongTien - 250000.00 WHERE DonHangId = 10042 AND NgayTao = '2026-10-02T11:58:00'";
FormattableString tangDon = $"UPDATE dbo.DonHang SET TongTien = TongTien + 250000.00 WHERE DonHangId = 10042 AND NgayTao = '2026-10-02T11:58:00'";
FormattableString congKho = $"UPDATE dbo.SanPham SET TonKho = TonKho + 1 WHERE SanPhamId = 42";
FormattableString truKho = $"UPDATE dbo.SanPham SET TonKho = TonKho - 1 WHERE SanPhamId = 42";
foreach (bool thuLai in new[] { false, true })
{
    var gap = new Gap(2);
    var dongHo = Stopwatch.StartNew();
    var kq = await Task.WhenAll(
        Task.Run(() => ChayGiaoDich("A", giamDon, congKho, thuLai, gap, dongHo)),
        Task.Run(() => ChayGiaoDich("B", truKho, tangDon, thuLai, gap, dongHo)));
    Console.WriteLine($"1. {(thuLai ? "EnableRetryOnFailure" : "không thử lại")}: {string.Join(" | ", kq)}");
}

// 2. A đọc tồn dưới SNAPSHOT, B trừ kho và commit, rồi A trừ kho: lỗi 3960.
var aDaDoc = new TaskCompletionSource();
var bDaGhi = new TaskCompletionSource();
int lanA = 0;
Console.Write("2. SNAPSHOT, EnableRetryOnFailure mặc định: A ");
var phienA = Task.Run(async () =>
{
    await using var db = new BanHangDb(cs, thuLai: true);
    await db.Database.CreateExecutionStrategy().ExecuteAsync(async () =>
    {
        lanA++;
        await using var tx = await db.Database.BeginTransactionAsync(IsolationLevel.Snapshot);
        int ton = await db.Database.SqlQuery<int>($"SELECT TonKho AS Value FROM dbo.SanPham WHERE SanPhamId = 42").SingleAsync();
        Console.Write($"lần {lanA} đọc {ton}");
        if (lanA == 1) { aDaDoc.SetResult(); await bDaGhi.Task; }
        try { await db.Database.ExecuteSqlAsync($"UPDATE dbo.SanPham SET TonKho = TonKho - 1 WHERE SanPhamId = 42 AND TonKho >= 1"); }
        catch (SqlException ex) { Console.Write($", lỗi {ex.Number}; "); throw; }
        await tx.CommitAsync();
        Console.WriteLine(", commit");
    });
});
await aDaDoc.Task;
await using (var db = new BanHangDb(cs, thuLai: false))
    await db.Database.ExecuteSqlAsync(truKho);
bDaGhi.SetResult();
await phienA;

async Task<string> ChayGiaoDich(string ten, FormattableString cau1, FormattableString cau2, bool thuLai, Gap gap, Stopwatch dongHo)
{
    int lan = 0;
    await using var db = new BanHangDb(cs, thuLai);
    try
    {
        await db.Database.CreateExecutionStrategy().ExecuteAsync(async () =>
        {
            lan++;
            await using var tx = await db.Database.BeginTransactionAsync();
            await db.Database.ExecuteSqlAsync(cau1);
            if (lan == 1) await gap.DenAsync();     // cả hai đã giữ khóa đầu tiên
            await db.Database.ExecuteSqlAsync(cau2);
            await tx.CommitAsync();
        });
        return $"{ten} commit sau {lan} lần chạy, {dongHo.ElapsedMilliseconds} ms";
    }
    catch (Exception ex) when ((ex as SqlException ?? ex.InnerException as SqlException) is { } sql)
    {
        return $"{ten} nhận {ex.GetType().Name} (lỗi {sql.Number}) sau {lan} lần chạy, {dongHo.ElapsedMilliseconds} ms";
    }
}

public class BanHangDb(string cs, bool thuLai) : DbContext
{
    protected override void OnConfiguring(DbContextOptionsBuilder o) =>
        o.UseSqlServer(cs, sql => { if (thuLai) sql.EnableRetryOnFailure(); });
}

sealed class Gap(int soBen)
{
    int _con = soBen;
    readonly TaskCompletionSource _du = new(TaskCreationOptions.RunContinuationsAsynchronously);
    public Task DenAsync() { if (Interlocked.Decrement(ref _con) == 0) _du.SetResult(); return _du.Task; }
}

<deadlock>
  <victim-list><victimProcess id="process1d57e456108" /></victim-list>
  <process-list>
    <process id="process1d57e456108" spid="60" logused="308" lockMode="U" isolationlevel="read committed (2)"
             waitresource="KEY: 27:72057594043432960 (c1ceb6ec8491)" transactionname="user_transaction">
      <inputbuf>UPDATE dbo.SanPham SET TonKho = TonKho + 1 WHERE SanPhamId = 42</inputbuf>
    </process>
    <process id="process1d58ae00108" spid="63" logused="320" lockMode="U" isolationlevel="read committed (2)"
             waitresource="KEY: 27:72057594043301888 (f6019d0d30a0)" transactionname="user_transaction">
      <inputbuf>UPDATE dbo.DonHang SET TongTien = TongTien + 250000.00 WHERE DonHangId = 10042 AND NgayTao = '2026-10-02T11:58:00'</inputbuf>
    </process>
  </process-list>
  <resource-list>
    <keylock objectname="Kumeo_F.dbo.SanPham" indexname="PK_SanPham" mode="X">
      <owner-list><owner id="process1d58ae00108" mode="X" /></owner-list>
      <waiter-list><waiter id="process1d57e456108" mode="U" requestType="wait" /></waiter-list>
    </keylock>
    <keylock objectname="Kumeo_F.dbo.DonHang" indexname="PK_DonHang" mode="X">
      <owner-list><owner id="process1d57e456108" mode="X" /></owner-list>
      <waiter-list><waiter id="process1d58ae00108" mode="U" requestType="wait" /></waiter-list>
    </keylock>
  </resource-list>
</deadlock>

A sửa đơn rồi cộng kho, ngược B: 10/10 lượt có lỗi 1205; mỗi lượt 351 đến 5504 ms, trung bình 1329 ms
A cộng kho rồi sửa đơn, cùng B : 0/10 lượt có lỗi 1205; mỗi lượt 426 đến 723 ms, trung bình 502 ms

0. The configured execution strategy 'SqlServerRetryingExecutionStrategy' does not support user-initiated transactions.
1. không thử lại: A commit sau 1 lần chạy, 1948 ms | B nhận InvalidOperationException (lỗi 1205) sau 1 lần chạy, 1920 ms
1. EnableRetryOnFailure: A commit sau 1 lần chạy, 4968 ms | B commit sau 2 lần chạy, 4976 ms
2. SNAPSHOT, EnableRetryOnFailure mặc định: A lần 1 đọc 8, lỗi 3960; lần 2 đọc 7, commit