多个事务期间的数据库行锁定

Question

你好，新年快乐 :)

我正在使用 Postgresql，我需要一种方法来使工作进程能够锁定特定行，而该进程在该行上运行。它本质上是一个动作表，应该执行一次且只执行一次。每个进程都应该抓取不同的行进行操作。

在这个“操作”期间，工作进程将计算一些值并在一个事务中多次插入数据库（它会在计算和插入数据库之间改变）。

我不知道每个操作需要多长时间（它会有所不同），我需要一种方法来解锁该行，如果该进程死亡/被杀死或系统崩溃（以便其他进程可以抓住该行并完成操作）。

据我所知，Postgresql 的行锁只在一个事务中持续。我正在考虑添加一些标志，这将指示行是否被锁定到表中，但我无法弄清楚如何判断该行是否仍在操作，或者它是否挂起，因为工作进程死了（在后一种情况下，它应该被其他工作进程占用）？ （我在该表中有一个完成标志来表示该行已完成/已完成处理）

Answer 1

您的带有标志的解决方案似乎是可行的，我认为唯一需要做的就是使锁过期。基本上，我构建锁的方式是，我会在获取锁时写一个时间戳并制作它，以便进程必须每隔一段时间（即每 30 秒）更新锁，而它仍然是记录在案。如果进程死亡或无法完成工作，则锁定将过期，并且如果超时时间超过两倍，其他进程可以解锁它。

当进程完成对记录的处理时，它将清除锁定标志并将记录标记为已处理（再次标记另一个标志）。

您可能需要两个字段：一个用于存储时间戳锁定标志，另一个用于指示哪个进程拥有该锁（以防您关心它）。我假设有某种键可用于对表中的记录进行排序，这样“下一步操作”的概念才有意义。

您可以使用这样的查询来获取下一条要处理的记录：

 -- find the next available process and "lock" it by updating it's flag
 UPDATE actions_tabe
    SET LockFlag = @timestamp,
        Process = @processname
  WHERE Id IN (SELECT Id
            FROM actions_table
           WHERE LockFlag IS null
             AND IsComplete = '0'
             AND ScheduledTime < now()
           ORDER BY Scheduledtime ASC, Id ASC
           LIMIT 1);

 -- return the Id and Action of the record that was just marked above
 SELECT Id, Action
   FROM actions_table
  WHERE Process = @processname

这里是小提琴示例：http://sqlfiddle.com/#!11/9c120/26/1