时间戳

首页 > 解决方案 > 事务无法通过 Task.WhenAll 处理并行命令

c# - 事务无法通过 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();
    }
}

每个Insert命令仅生成 SQL 代码的执行，没有任何内部事务。

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

Npgsql.PostgresException（0x80004005）：23503：在表“companyaddresses”上插入或更新违反外键约束“companyaddresses_companyid_fkey”

当然，我有很多问题，例如：

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

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

        scope.Complete();
    }
}

也许它有帮助：

标签： c#postgresqldappernpgsqltransactionscope

解决方案

这里没有什么神奇之处，您会收到错误消息，因为您在插入 CompanyAddress 时使用的连接不是您认为的那个。

这是一个新的连接。运行 ComapnyPaymentInfo 插入时，您正在使用已绑定到您的交易的连接。它正在等待新命令，因为您已在上一步中等待。

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

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

推荐阅读