事务无法通过 Task.WhenAll 处理并行命令

我的 Postgres 数据库中有一些主表（如 Companies）和许多从属表（如 CompanyAddresses、CompanyPaymentInfos 等）：

CREATE TABLE Companies (
Id uuid NOT NULL PRIMARY KEY,
...);

CREATE TABLE CompanyAddresses(
CompanyId uuid NOT NULL PRIMARY KEY REFERENCES Companies(Id),
...);

CREATE TABLE CompanyPaymentInfos(
CompanyId uuid NOT NULL PRIMARY KEY REFERENCES Companies(Id),
...);

我在 C# 代码中使用标准库中的事务：

private TransactionScope GeTransactionScope()
{
    return new TransactionScope(
        TransactionScopeOption.RequiresNew,
        new TransactionOptions
        {
            IsolationLevel = IsolationLevel.ReadCommitted
        },
        TransactionScopeAsyncFlowOption.Enabled);
}

private async Task DoChange(...)
{
    using (var scope = GeTransactionScope())
    {
        await Insert(Company);

        await Task.WhenAll(
            Insert(CompanyPaymentInfo),
            Insert(CompanyAddress),
            Insert(CompanyTags),
            // so on
        );

        scope.Complete();
    }
}

Each Insert命令仅生成 SQL 代码的执行without任何内部交易。

在执行 DoChange 后，我收到此错误：

Npgsql.PostgresException (0x80004005): 23503: 插入或更新 表“companyaddresses”违反外键约束 “companyaddresses_companyid_fkey”

当然，我还有很多问题，比如：

• 为什么我会收到错误消息？
• 为什么我在插入 CompanyAddress 时收到错误，而不是 CompanyPaymentInfo ？

如果我改变DoChange顺序执行一切正常：

private void DoChange()
{
    using (var scope = GeTransactionScope())
    {
        await Insert(Company);
        await Insert(CompanyPaymentInfo);
        await Insert(CompanyAddress);
        await Insert(CompanyTags);
        // ...

        scope.Complete();
    }
}

也许有帮助：

• 我用的是.Net Core 2.0
• 我使用具有标准设置的 Postgres 10.4（ReadCommited 作为隔离级别等）。另外，我还添加了enlist=true到我的连接字符串以使交易正常进行。
• 我在我的内部使用 Npgsql 3.2.5 和 Dapper 1.50.2Insert command

这里没有什么神奇的，你会得到错误，因为插入 CompanyAddress 时使用的连接不是你想象的那样。

这是一个新的连接。当运行 ComapnyPaymentInfo insert 时，您正在使用已经与您的交易绑定的连接。由于您在上一步中已等待，因此它正在等待新命令。

另一方面，使用 Task.WhenAll() 将尝试使用多个线程。如果连接正忙于运行命令，则该连接将不会被使用，并且将生成一个新连接。

请记住，使用事务时，您只有一个可用连接，您无法从并行性中受益。