在多个服务器上批量运行

Question

我有一个批处理应用程序，仅包含以下步骤。

• 从表中选择 update-flag 列为空的所有记录
• 处理所选信息
• 将记录标记为已更新

我正在使用 Oracle 10g，我想要做的是能够在多个服务器上同时执行此应用程序。不过，我担心Oracle的锁机制。 当在第一台服务器上运行的应用程序的第一个实例选择一条记录时，在第二台服务器上运行的另一个实例不应该能够选择它。

是否适合使用“选择更新”来达到这种目的？如果我使用“选择更新跳过锁定”模式，应用程序的第二个实例是否会默默地跳过先前由第一个实例锁定的那些记录并选择其他行？或者，它会等到锁定的行被释放吗？

任何意见和建议将不胜感激

Answer 1

我的同事 Rob 写了一篇关于此的好文章 skip 中的并行性锁定场景
所以是的，它有效，不，它不会帮助你。
FWIW：稍微改变算法可能更聪明，给更新标志一个值，一个增量数字来帮助处理新数据的选择过程，并在准备好时更新为 NULL。这里的优点是

1. 索引大小减少了
2. 两倍，这使得并行性更容易实现，因为进程现在都可以选择它们“自己的”行。

我希望它有帮助。

Answer 2

我使用选择更新跳过锁定并且工作正常。是的，后面的会话会默默地跳过先前会话锁定的记录并选择/锁定其他行。确保并行处理会话没有修改其他常见数据，否则您会陷入另一个瓶颈。

declare 
  my_limit constant number default 1000;
  cursor cRecords is
    select primary_key
    from processed_table t
    where t.update_flag is null
    for update skip locked;
  type t_cRecords is table of cRecords%rowtype;
  tRecords t_cRecords;
begin
  open cRecords;
  while true loop
    -- Select all the records from the table where the update-flag column is null
    fetch cRecords bulk collect into tRecords limit my_limit;
    -- Process the selected information
    -- ...
    -- Mark the record as updated
    forall i in tRecords.first..tRecords.last
      update processed_table
        set update_flag = 'PROCESSED'
      where primary_key = tRecords(i).primary_key;
    --
    exit when tRecords.count < my_limit;
  end loop;
end;

顺便说一句，我不确认 skip 中的并行性锁定场景 - 在我的网站上，使用 rwijk 的脚本，速度加快了 4 到 1 秒。