1

我有一个项目正在尝试应用 DDD（域驱动设计）。目前，我们有这样的东西：

begin tran
 try
  _manager.CreateNewEmployee(newEmployeeCmd);
  tran.Commit();
 catch
  rollback tran

在内部，CreateNewEmployee 方法使用域服务来检查是否已经存在具有 memberId 的员工。这是一些伪代码：

void CreateNewEmployee(NewEmployeeCmd cmd)
  if(_duplicateMember.AlreadyRegistered(cmd.MemberId) )
    throw duplicate
  // extra stuff
  saveNewEmployee()
end

现在，最后，就好像我们执行了以下 SQL 指令（再次伪代码）：

begin sql tran
 select count(*) from table where memberId=@memberId and status=1 -- active
 --some time goes by
 insert into table ...
end

现在，当我开始查看代码时，我注意到它使用的是默认的 SQL Server 锁定级别。在实践中，这意味着可能会发生这样的事情：

--thread 1
(1)select ... --assume it returns 0
--thread 2
(2)select ... ---nothing found
(3)insert recordA
--thread 1
(4)insert record --some as before
(5) commit tran
--thread 1
(6) commit tran

因此，我们最终可能会重复记录。我尝试过使用事务级别，但我设法使其按预期工作的唯一方法是更改​​用于检查表中是否已有记录的选择。我最终使用了一个表锁定提示，它指示 sql 保持锁定直到事务结束。这是我在选择开始时设法获得锁定的唯一方法（更改其他隔离级别仍然不能满足我的需要，因为它们都允许选择运行）

所以，我最终使用了一个表锁，它从事务的开始一直保持到结束。实际上，这意味着步骤 (2) 将阻塞，直到线程 1 结束其工作。

对于这种情况（不依赖于使用，比如说，索引）有更好的选择吗？

谢谢。

路易斯

4

1 回答 1

1

您需要在初始值上获得正确的锁定select，这可以通过锁定提示来完成with (updlock, serializable)。一旦你这样做了，线程 2 将等待线程 1 完成，如果线程 2 在其where.

您可以使用Sam Saffron upsert 方法。

例如：

create procedure dbo.Employee_getset_byName (@Name nvarchar(50), @MemberId int output) as
begin
  set nocount, xact_abort on;
  begin tran;
    select  @MemberId = Id
      from  dbo.Employee with (updlock, serializable) /* hold key range for @Name */
      where Name = @Name;
    if @@rowcount = 0 /* if we still do not have an Id for @Name */
    begin;
    /* for a sequence */
      set @MemberId = next value for dbo.IdSequence; /* get next sequence value */
      insert into dbo.Employee (Name, Id)
        values (@Name, @MemberId);
    /* for identity */
      insert into dbo.Employee (Name)
        values (@Name);
      set @MemberId = scope_identity();
    end;
  commit tran;
end;
go
于 2017-03-26T16:40:02.380 回答