为什么这个存储过程有时不能正常工作？

Question

我有一个名为“Schedule”的表，它充当多个进程/计算机频繁访问该表的队列机制。 该过程的目标是拾取不超过@count行的行，这些行有资格被拾取（它们的LastCompletedProcessingId和LastStartedProcessingId必须匹配）并将它们标记为已拾取（将LastStartedProcessingId更改为NEWID（）），这样下一个进程就不会尝试选取已经标记的行。

我的问题是，在极少数情况下，当多个客户端在非常接近的时间调用该过程时，多个客户端最终会得到相同的行。这怎么可能？我该如何避免呢？桌子本身并不大。 @timeout 不是问题，因为这些事情的处理时间不会超过 300 秒，而且我有一个日志，在进程获取多个记录之前，它们运行的​​时间不会超过 300 秒。这是在 SQL Azure 中运行的

你知道这是如何实现的吗？ 谢谢

CREATE PROCEDURE X
    @count int,
    @timeout int = 300
AS
BEGIN
    SET NOCOUNT ON;

    DECLARE @batchId uniqueidentifier
    SELECT @batchId = NEWID()

    BEGIN TRAN

    -- Update rows
    UPDATE Schedule 
    WITH (ROWLOCK)
    SET 
        LastBatchId = @batchId, 
        LastStartedProcessingId = NEWID(), 
        LastStartedProcessingTime = GETDATE()
    WHERE 
        AccountId IN (
            SELECT TOP (@count) AccountId 
            FROM Schedule 
            WHERE 
                (LastStartedProcessingId = LastCompletedProcessingId OR LastCompletedProcessingId IS NULL OR DATEDIFF(SECOND, LastStartedProcessingTime, GETDATE()) > @timeout) AND 
                (LastStartedProcessingTime IS NULL OR DATEDIFF(SECOND, LastStartedProcessingTime, GETDATE()) > Frequency)
            ORDER BY (DATEDIFF(SECOND, LastStartedProcessingTime, GETDATE()) - Frequency) DESC
        )

    -- Return the changed rows
    SELECT AccountId, LastStartedProcessingId, Frequency, LastProcessTime, LastConfigChangeTime
    FROM Schedule 
    WHERE LastBatchId = @batchId

    COMMIT TRAN
END

Answer 1

不要使用 ROWLOCK 提示，而是将isolation_level 设置为 SERIALIZABLE 来运行更新。

此外，如果在更新中使用 OUTPUT 子句，则更新完成后即可获得受影响行的列表。这意味着您可以更快地结束事务 1 DML 语句并保持 ACIDity。

Answer 2

也许这是你的问题？

在交易中指定时
在快照隔离下运行
级别，不会采取行锁，除非
ROWLOCK与其他表组合
需要锁的提示，例如
UPDLOCK 和 HOLDLOCK。

来源