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

我的Postgres DB中有一些主表(如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();
    }
}

每个插入命令仅产生一个sql代码执行,而没有任何内部事务.

在执行DoChange之后,出现此错误：

Npgsql.PostgresException (0x80004005): 23503: insert or update on
table “companyaddresses” violates foreign key constraint
“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用于标准设置(将ReadCommitted作为隔离级别,依此类推).另外,我在连接字符串中添加了enlist = true以使事务正常运行.
>我在Insert命令中使用了Npgsql 3.2.5和Dapper 1.50.2

解决方法:

这里没有什么魔术,您会收到错误消息,因为插入CompanyAddress时使用的连接不是您认为的那样.

这是一个新的连接.当运行ComapnyPaymentInfo插入时,您正在使用已经绑定到事务的连接.它正在等待新命令,因为您已经在上一步中等待了.

另一方面,使用Task.WhenAll()会尝试使用多个线程.如果一个连接正在忙于运行一个命令,它将不被使用,并且将产生一个新的命令.

请记住,使用事务时,只有一个连接可用,您不能从并行性中受益.