为什么我的 UPDATE 存储过程执行了多次？

Question

我使用存储过程来管理仓库。 PDA 扫描仪扫描添加的库存并将其批量（插入后）发送到 SQL 数据库 (SQL Server 2016)。

SQL 数据库相当偏远（其他国家/地区），因此某些查询有时会出现延迟，但这个特定的查询是有问题的：即使 stock 表没问题，我在 更新仓库地点。 PDA 将每个点中添加的项目作为 SMALLINT 进行跟踪，然后将此值发送回下面的存储过程。

PDA“send_spots”查询：

SELECT spot, added_items FROM spots WHERE change=1

存储过程：

CREATE PROCEDURE [dbo].[update_spots]
@spot VARCHAR(10),
@added_items SMALLINT
AS
BEGIN
    BEGIN TRAN
    UPDATE storage_spots
    SET remaining_capacity = remaining_capacity - @added_items
    WHERE storage_spot=@spot
    IF @@ROWCOUNT <> 1
    BEGIN
        ROLLBACK TRAN
        RETURN - 1
    END
    ELSE
    BEGIN
        COMMIT TRAN
        RETURN 0
    END
END
GO

如果remaining_capacity 的值为0，则PDA 无法在下一轮向其添加更多项目。但是在这个过程中，我得到了负值，因为据称查询运行了两次（因此减去了两次 @added_items）。

有没有办法做到这一点？我该如何解决？据我了解，如果受影响的行是！= 1，则事务应该被取消（回滚），但也许那是别的东西。

编辑：在@Zero 的帮助下的当前解决方案：

CREATE PROCEDURE [dbo].[update_spots]
    @spot VARCHAR(10),
    @added_racks SMALLINT
AS
BEGIN
    -- Recover current capacity of the spot
    DECLARE @orig_capacity SMALLINT
    SELECT TOP 1
        @orig_capacity = remaining_capacity
    FROM storage_spots
    WHERE storage_spot=@spot

    -- Test if double is present in logs by comparing dates (last 10 seconds)
    DECLARE @is_double BIT = 0
    SELECT @is_double = CASE WHEN EXISTS(SELECT *
    FROM spot_logs
    WHERE log_timestamp >= dateadd(second, -10, getdate()) AND storage_spot=@spot AND delta=@added_racks)
    THEN 1 ELSE 0 END

    BEGIN
        BEGIN TRAN
        UPDATE storage_spots
        SET remaining_capacity= @orig_capacity - @added_racks
        WHERE storage_spot=@spot

        IF @@ROWCOUNT <> 1 OR @is_double <> 0
            -- If double, rollback UPDATE
            ROLLBACK TRAN
        ELSE
            -- If no double, commit UPDATE
            COMMIT TRAN

        -- write log
        INSERT INTO spot_logs
            (storage_spot, former_capacity, new_capacity, delta, log_timestamp, double_detected)
        VALUES 
            (@spot, @orig_capacity, @orig_capacity-@added_racks, @added_racks, getdate(), @is_double)
    END
END
GO

Answer 1

我正在考虑可能的原因（以及追踪它们的方法），然后它击中了我 - 你没有价值验证！

这里有一个简单的例子来说明问题：

 Spot | capacity 
 ---------------
  x1  |     1

Update spots set capacity = capacity - 2 where spot = 'X1'

您的扫描仪很可能给您提供的数量超出了您的承受能力。 我不确定您的业务逻辑是如何进行的，但是您需要按照

行执行某些操作

Update spots set capacity = capacity - @added_items where spot = 'X1' and capacity  >= @added_items
if @@rowcount <> 1;
   rollback;

---

编辑：在不实施验证的情况下跟踪问题的几种方法： 创建一个日志表（带有timestamp、user id（连接到数据库的用户）、session id、old value、new value、delta value（添加的项目）。

---

选项 1： 记录所有将值从正变为负的更新（至少在您找出问题之前）。 此选项的缺点是它不会注册不会导致负容量的双重调用。

---

选项 2：（记录相同的更新）： 创建一个脚本，该脚本创建一个全局临时表并从该表中删除记录，时间戳早于...假设每分钟 10 分钟左右一次（玩弄数字）。

这个临时表应该保存传递给你的更新语句的数据，所以'spot'，' added_items' + 'timestamp'（用于跟踪）。 现在是关键部分：当您调用更新语句时，检查临时表中是否存在类似的记录（相同的位置和 added_items 以及当前时间戳为between timestamp and [timestamp + 1 second] - 再次使用数字）。如果存在这样的记录，则记录该更新，否则将其添加到临时表中。

这将注册在 1 秒内（或您选择的任何时间范围）进行的相同更新。

Answer 2

我找到了here 一个替代 SQL 查询，它按照我需要的方式进行更新，但使用 DECLARE 提供了一个临时值。在我的情况下会更好吗，还是我的初始查询正确？

初始查询：

UPDATE storage_spots
    SET remaining_capacity = remaining_capacity - @added_items
    WHERE storage_spot=@spot

替代查询：

DECLARE @orig_capacity SMALLINT
SELECT TOP 1 @orig_capacity = remaining_capacity 
    FROM storage_spots 
    WHERE spot=@spot
UPDATE Products 
    SET remaining_capacity = @orig_capacity - @added_items 
    WHERE spot=@spot

另外，我应该去掉 ROLLBACK/COMMIT 指令吗？