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

2019-11-09 01:07:20 阅读：454 来源： 互联网

标签：postgresql dapper transactionscope npgsql c

我的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()会尝试使用多个线程.如果一个连接正在忙于运行一个命令,它将不被使用,并且将产生一个新的命令.

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

标签：postgresql,dapper,transactionscope,npgsql,c
来源： https://codeday.me/bug/20191109/2010632.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

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