Oracle 更新跳过锁定并依赖于其他行

Question

对于我们应用程序中的多线程环境，我们实现了 oracle 跳过锁定，其中没有两个线程在数据库中获取相同的记录进行处理（我们将“等待”添加到“工作”标志）。

现在，我们有一个修改，如果数据库中排队等待处理的两条记录具有相同的 ID(workid)，则不应同时获取。（即，如果其他记录状态不应更新为 WORKING已经有一条记录有一个标志是“正在工作” 有人可以帮忙看看如何实现吗？

以下是相同的过程，其中单个记录被锁定而不进行比较。

create or replace PROCEDURE DEQUEUE_MANAGER(
    v_managerName IN Queue.manager%TYPE,
    v_workid IN VARCHAR2,
    v_key OUT NUMBER,
    v_datatablekey OUT Queue.DATA_TABLE_KEY%TYPE,
    v_tasktype OUT Queue.TASK_TYPE%TYPE,
    v_no_of_attempts OUT Queue.ATTEMPT%TYPE,
    v_result OUT NUMBER,
    v_error_desc OUT VARCHAR2)
IS
    v_recordrow Queue%ROWTYPE;
    v_qeuuestatus  VARCHAR2(255);
    v_updatedstaus VARCHAR2(255);
    CURSOR c IS 
        select * 
        from QUEUE  
        WHERE MANAGER =v_managerName 
        AND STATUS =v_qeuuestatus 
        AND workid=v_workid 
        AND DATE_RELEASE<=SYSDATE 
    FOR UPDATE SKIP LOCKED;
BEGIN
    v_result      := -1;
    v_qeuuestatus :='WAITING';
    v_updatedstaus:='WORKING';
    v_tasktype :='';
    v_datatablekey:=-1;
    v_key:=-1;
    v_error_desc:='No Data Found';
    v_no_of_attempts:=0;
    OPEN c;
    FOR i IN 1..1 LOOP
        FETCH c INTO v_recordrow;
        EXIT WHEN c%NOTFOUND;
        select v_recordrow.key into v_key 
        from QUEUE 
        where key = v_recordrow.key 
        for update;

        UPDATE Queue 
        SET STATUS=v_updatedstaus 
        WHERE KEY=v_recordrow.key;
        COMMIT;
        v_datatablekey:=v_recordrow.data_table_key;
        v_tasktype    := v_recordrow.task_type;
        v_no_of_attempts := v_recordrow.attempt;
        v_result      := 0;
        IF (v_no_of_attempts IS NULL) THEN
            v_no_of_attempts:=0;
        END IF;
    END LOOP;
    CLOSE c;
EXCEPTION
    WHEN NO_DATA_FOUND THEN
            v_datatablekey:=-1;
            v_tasktype:='';
            v_key:=-1;
            v_no_of_attempts:=0;
            v_result    :=-1;
            v_error_desc:='No Rows Found';      
    WHEN OTHERS THEN
              DBMS_OUTPUT.put_line ('Exception Occurred');
              v_datatablekey:=0;
              v_tasktype:='';
              v_key:=0;
              v_no_of_attempts:=0;
              v_result     := -2;
              v_error_desc := SQLERRM;
              ROLLBACK;
END;

Answer 1

FOR UPDATE 语法的目的是锁定我们希望在未来某个时间更新的记录。我们现在想获取记录，这样我们就可以确保我们的后续更新不会因为另一个会话锁定记录而失败。

这不是您的代码所做的。相反，它选择记录，更新它，然后发出提交。提交结束事务，释放锁。如果没有 FOR UPDATE，您的流程也可以正常工作。

现在我们有您的额外要求：如果正在处理给定 workid 的排队记录，则另一个会话不能处理同一 workid 的其他记录。您说workid 的所有实例都具有相同的queue status 或manager 值。这意味着最初的 SELECT FOR UPDATE 会抓取您想要锁定的所有记录。问题是 SKIP LOCK 允许其他会话更新该workid 的任何其他记录（实际上只有第一条记录被锁定，因为这是您唯一更新的记录）。 sd 提交释放这些锁并不重要。

最简单的解决方案是删除 SKIP LOCKED 和 COMMIT。这将使所有相关记录保持锁定，直到您的处理事务提交。但这可能会在其他地方造成更多问题。

并发编程真的很难做到。这是一个架构问题；您无法在单个程序单元的级别上解决它。