您不需要FOR LOOP,只需一个更新即可完成工作:
UPDATE emp
SET comm = extra
WHERE comm IS NULL AND extra IS NOT NULL;
这是一个演示:http://www.sqlfiddle.com/#!4/aacc3/1
--- 编辑 ----
我没有注意到,在预期的输出中,deptno 10 已更新为 20,
更新 deptno 需要另一个查询:
UPDATE emp
SET deptno = 20
WHERE deptno = 10;
---- 编辑 -----
如果要将更改的值插入另一个表,请尝试使用 RETURNING..BULK COLLECT 和 FORALL 的过程:
CREATE OR REPLACE PROCEDURE pro_cedure( p_dept_id number )
IS
TYPE changed_table_type IS TABLE OF changed%ROWTYPE;
changed_buff changed_table_type;
BEGIN
SELECT deptno, comm, extra BULK COLLECT INTO changed_buff
FROM emp
WHERE comm IS NULL AND extra IS NOT NULL AND deptno = p_dept_id
FOR UPDATE;
UPDATE emp
SET comm = extra
WHERE comm IS NULL AND extra IS NOT NULL AND deptno = p_dept_id;
FORALL i IN 1 .. changed_buff.count
INSERT INTO changed VALUES changed_buff( i );
END;
/
如果您不打算在一次调用中处理大量记录(超过 1000 条......或最多几千条),该过程应该可以工作。如果一个dept_id可以包含一万多行,那么这个过程可能会很慢,因为它会消耗大量的PGA内存。在这种情况下,需要另一种以块形式进行批量收集的方法。
-- EDIT --- 如何存储序列值 -------
我假设表 changed 有 4 列,如下所示:
CREATE TABLE "TEST"."CHANGED"
( "DEPTNO" NUMBER,
"OLDVAL" NUMBER,
"NEWVAL" NUMBER,
"SEQ_NEXTVAL" NUMBER
) ;
我们会将序列值存储在seq_nextval 列中。
在这种情况下,过程可能如下所示:
create or replace
PROCEDURE pro_cedure( p_dept_id number )
IS
TYPE changed_table_type IS TABLE OF changed%ROWTYPE;
changed_buff changed_table_type;
BEGIN
SELECT deptno, comm, extra, sequence_name.nextval
BULK COLLECT INTO changed_buff
FROM emp
WHERE comm IS NULL AND extra IS NOT NULL AND deptno = p_dept_id
FOR UPDATE;
UPDATE emp
SET comm = extra
WHERE comm IS NULL AND extra IS NOT NULL AND deptno = p_dept_id;
FORALL i IN 1 .. changed_buff.count
INSERT INTO changed VALUES changed_buff( i );
END;
--- EDIT --- 带有光标的小数据集版本 -----
是的,对于小型数据集,批量收集不会显着提高速度,在这种情况下,带有 for..loop 的普通光标就足够了。
下面是一个如何使用游标和更新的示例,注意FOR UPDATE子句,当我们计划使用WHERE CURRENT OF子句更新从游标中获取的记录时,它是必需的。
这次在 INSERT 语句中计算一个序列值。
create or replace
PROCEDURE pro_cedure( p_dept_id number )
IS
CURSOR mycursor IS
SELECT deptno, comm, extra
FROM emp
WHERE comm IS NULL AND extra IS NOT NULL
AND deptno = p_dept_id
FOR UPDATE;
BEGIN
FOR emp_rec IN mycursor
LOOP
UPDATE emp
SET comm = extra
WHERE CURRENT OF mycursor;
INSERT INTO changed( deptno, oldval, newval, seq_nextval)
VALUES( emp_rec.deptno, emp_rec.comm,
emp_rec.extra, sequence_name.nextval );
END LOOP;
END;