当我收到PayPal即时付款通知时,我正在开发一个应该创建产品(如运输保险单)的应用程序。不幸的是,PayPal有时会发送重复的通知。此外,还有另一个第三方在从PayPal获取更新时同时执行Web服务更新。
这是所涉及的数据库表的基本图。
// table "package"
// columns packageID, policyID, other data...
//
// table "insurancepolicy"
// columns policyID, coverageAmount, other data...
这是我想要做的基本图表:
using (SqlConnection conn = new SqlConnection(...))
{
sqlTransaction sqlTrans = conn.BeginTransaction(IsolationLevel.RepeatableRead);
// Calls a stored procedure that checks if the foreign key in the transaction table has a value.
if (PackageDB.HasInsurancePolicy(packageID, conn))
{
sqlTrans.Commit();
return false;
}
// Insert row in foreign table.
int policyID = InsurancePolicyDB.Insert(coverageAmount, conn);
if (policyID <= 0)
{
sqlTrans.Rollback();
return false;
}
// Assign foreign key to parent table. If this fails, roll back everything.
bool assigned = PackageDB.AssignPolicyID(packageID, policyID, conn);
if (!assigned)
{
sqlTrans.Rollback();
return false;
}
}
如果有两个(或多个)线程(或进程或应用程序)同时执行此操作,我希望第一个线程在没有policyID的情况下锁定“package”行,直到创建策略并分配policyID为止到包表。然后在将policyID分配给包表后释放锁。我希望调用同一代码的另一个线程在读取包行时会暂停,以确保它首先没有policyID。当第一个事务的锁被释放时,我希望第二个事务将看到policyID存在,因此返回时不会在策略表中插入任何行。
注意:由于CRUD数据库设计,每个存储过程都涉及读取(选择),创建(插入)或更新。
这是否正确使用了RepeatableRead事务隔离?
谢谢。
发布于 2018-09-11 09:11:07
如果insert into Policy
只是在尝试插入重复时遇到一些唯一性表约束,它会更安全和更清晰。提高隔离级别可以降低并发性并导致其他令人讨厌的问题,如死锁。
另一种方法是始终插入Policy行,如果Package已经附加到Policy,则将其回滚:
begin tran (read committed)
/* tentatively insert new Policy */
insert Policy
/* attach Package to Policy if it's still free */
update Package
set Package.policy_id = @policy_id
where Package.package_id = @package_id and Package.policy_id is null
if @@rowcount > 0
commit
else
rollback
当冲突很少发生时,这种方法效果最好,这似乎就是您的情况。
发布于 2018-09-11 10:23:26
我同意aaronjensen的回应中的“消息队列”的想法。如果您担心同时尝试更新同一行数据的多个并发线程,则应该让线程将其数据插入工作队列,然后由单个线程按顺序处理。这显着减少了对数据库的争用,因为目标表仅由一个线程而不是“N”更新,并且工作队列操作仅限于消息传递线程的插入,以及数据处理线程的读取/更新。
https://stackoverflow.com/questions/-100000746
复制相似问题