如果游标只返回单个计数（*）行，我可以锁定游标中的行吗？

Question

我想限制用户在我的FOO表中插入color = 'Red'以上的3条记录。我的意图是：A）检索当前计数，以便我可以确定是否允许另一个记录，以及B）防止任何其他进程插入任何红色记录，同时处理此记录，因此为for update of。

我想这样做：

cursor cur_cnt is 
select count(*) cnt from foo 
where foo.color = 'Red' 
for update of foo.id; 

这是否会同时满足我的要求还是会不会谁了foo.color = 'Red'的COUNT（*）仅锁定行？

Answer 1

这只会阻止用户更新选定的行，而不是添加新的行。可靠地执行此规则的唯一方法是在“主”表上检查约束和“foo”表上触发器的组合，以更新主表。像这样（使用EMP和DEPT对于熟悉）：

alter table dept add (manager_count integer default 0 not null, 
    constraint manager_count_chk check (manager_count <= 3)); 

create trigger emp_trg 
before insert or update or delete on emp 
for each row 
begin 
    if inserting or updating then 
     if :new.job = 'MANAGER' then 
      update dept 
      set manager_count = manager_count+1 
      where deptno = :new.deptno; 
     end if; 
    end if; 
    if updating or deleting then 
     if :old.job = 'MANAGER' then 
      update dept 
      set manager_count = manager_count-1 
      where deptno = :new.deptno; 
     end if; 
    end if; 
end; 

这实现防止多于一个的用户从插入，更新或一次删除的经理的员工所期望的锁定。

Answer 2

你运行的是哪个数据库？在DB2中，您可以通过附加'WITH [locking-level]'来控制锁定行为，而锁定级别是4个预定义锁定级别之一。但是，一般情况下，我不会认为数据库会按照您缩进的方式锁定事物 - 还有锁升级等事情。如果您想阻止将任何数据插入到表中，那么可以在DB2中执行'LOCK TABLE table IN EXCLUSIVE MODE'。

Answer 3

您可以使用Oracle CONTEXT来存储试图在FOO表中插入/更新/删除的Oracle用户的名称。当Oracle用户提交或回滚时，通过使用我的存储过程USER_LOCK和USER_UNLOCK清空（手动）Oracle CONTEXT。通过这种方式，您可以避免多个Oracle用户同时访问/更新和删除操作，因为您一次只能向一个Oracle用户授予访问权限。

通过USER_LOCK（name_of_the_user）过程，您可以在Oracle上下文中添加Oracle用户的名称。使用USER_UNLOCK（name_of_the_user）过程，您可以在Oracle上下文中删除Oracle用户的名称。使用视图locked_users，您可以确定Oracle用户是否被锁定，因为如果它被锁定，其名称将出现在视图中。以下代码创建所有Oracle结构以实现所有目标：

CREATE OR REPLACE PACKAGE my_pkg 
IS 
    PROCEDURE set_session_id (p_session_id NUMBER); 

    PROCEDURE set_ctx (p_name VARCHAR2, p_value VARCHAR2); 

    PROCEDURE close_session (p_session_id NUMBER); 
END; 
/

CREATE OR REPLACE PACKAGE BODY my_pkg 
IS 
    g_session_id NUMBER; 

    PROCEDURE set_session_id (p_session_id NUMBER) 
    IS 
    BEGIN 
     g_session_id := p_session_id; 
     DBMS_SESSION.set_identifier (p_session_id); 
    END set_session_id; 

    --=============================================== 
    PROCEDURE set_ctx (p_name VARCHAR2, p_value VARCHAR2) 
    IS 
    BEGIN 
     DBMS_SESSION.set_context ('App_Ctx', 
           p_name, 
           p_value, 
           USER, 
           g_session_id); 
    END set_ctx; 

    --=============================================== 
    PROCEDURE close_session (p_session_id NUMBER) 
    IS 
    BEGIN 
     DBMS_SESSION.set_identifier (p_session_id); 
     DBMS_SESSION.clear_identifier; 
    END close_session; 
--=============================================== 
END; 
/

    CREATE OR REPLACE CONTEXT APP_CTX 
    USING MY_PKG 
    ACCESSED GLOBALLY 
/


CREATE OR REPLACE TYPE test_type AS TABLE OF VARCHAR2 (30); 
/



CREATE OR REPLACE FUNCTION f_convert2 (p_list IN VARCHAR2) 
    RETURN test_type 
    PIPELINED 
AS 
    --l_string  LONG  := p_list || ','; 
    l_string  VARCHAR2 (4000) := p_list || ','; 
    l_comma_index PLS_INTEGER; 
    l_index   PLS_INTEGER := 1; 
BEGIN 
    LOOP 
     l_comma_index := INSTR (l_string, ',', l_index); 
     EXIT WHEN l_comma_index = 0; 
     PIPE ROW (SUBSTR (l_string, l_index, l_comma_index - l_index)); 
     l_index := l_comma_index + 1; 
    END LOOP; 

    RETURN; 
END f_convert2; 
/



CREATE OR REPLACE FORCE VIEW locked_users (utente) 
AS 
    SELECT COLUMN_VALUE utente 
     FROM TABLE (
       f_convert2 (
        REPLACE (
        LTRIM (RTRIM (SYS_CONTEXT ('app_ctx', 'Var1', 4000), '*'), 
          '*'), 
        '**', 
        ','))) 
    ORDER BY 1 ASC 
/



CREATE OR REPLACE PROCEDURE user_lock (ne_user IN VARCHAR2) 
IS 
BEGIN 
    DECLARE 
     indice    NUMBER; 
     appoggio_variabile1 VARCHAR2 (250); 
    BEGIN 
     -- my_pkg.close_session(1234); 
     my_pkg.set_session_id (1234); 
     appoggio_variabile1 := SYS_CONTEXT ('app_ctx', 'var1'); 
     DBMS_OUTPUT.put_line (appoggio_variabile1); 

     IF INSTR (appoggio_variabile1, ne_user) >= 1 
     THEN 
     BEGIN 
      DBMS_OUTPUT. 
      put_line ('The user ' || ne_user || ' is already locked!'); 
     END; 
     ELSE 
     BEGIN 
      my_pkg. 
      set_ctx ('Var1', appoggio_variabile1 || '*' || ne_user || '*'); 
      DBMS_OUTPUT. 
      put_line ('The user ' || ne_user || ' is now locked.'); 
     END; 
     END IF; 
    END; 
END user_lock; 
/



CREATE OR REPLACE PROCEDURE user_unlock (ne_user IN VARCHAR2) 
IS 
BEGIN 
    DECLARE 
     indice    NUMBER; 
     appoggio_variabile1 VARCHAR2 (250); 
    BEGIN 
     -- my_pkg.close_session(1234); 
     my_pkg.set_session_id (1234); 
     appoggio_variabile1 := SYS_CONTEXT ('app_ctx', 'var1'); 
     DBMS_OUTPUT.put_line (appoggio_variabile1); 

     IF INSTR (appoggio_variabile1, ne_user) = 0 
     OR appoggio_variabile1 IS NULL 
     THEN 
     BEGIN 
      DBMS_OUTPUT. 
      put_line ('The user ' || ne_user || ' is already unlocked!'); 
     END; 
     ELSE 
     BEGIN 
      my_pkg. 
      set_ctx ('Var1', 
         REPLACE (appoggio_variabile1, '*' || ne_user || '*')); 
      DBMS_OUTPUT. 
      put_line ('The user ' || ne_user || ' is now unlocked.'); 
     END; 
     END IF; 
    END; 
END user_unlock; 
/

Answer 4

锁定现有行无法阻止其他会话插入新行。

一种可能的方法是有一个列出可能颜色的COLORS表格。 （您的FOO.COLOR可以拥有COLORS.COLOR的外键引用。）然后在插入和更新之前，在COLORS中锁定相应的行。这将序列化处理相同颜色的所有访问。