事务无法通过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()会尝试使用多个线程.如果一个连接正在忙于运行一个命令,它将不被使用,并且将产生一个新的命令.
请记住,使用事务时,只有一个连接可用,您不能从并行性中受益.
标签:postgresql,dapper,transactionscope,npgsql,c 来源: https://codeday.me/bug/20191109/2010632.html