如何从函数游标返回行并在oracle中循环
Posted
技术标签:
【中文标题】如何从函数游标返回行并在oracle中循环【英文标题】：How to return row from function cursor and loop in oracle 【发布时间】：2020-10-05 23:17:18 【问题描述】：我想使用一个函数/包在 oracle 中运行一个动态查询，该函数/包将返回我可以循环的行。
我有这个功能
create or replace FUNCTION FUNC_CHECK
(
I_SERVICE_ID IN NUMBER,
I_count_id IN NUMBER,
I_SRC_S1 IN NUMBER,
I_SRC_E1 IN NUMBER,
I_SRC_S2 IN NUMBER,
I_SRC_E2 IN NUMBER,
I_SRC_S3 IN NUMBER,
I_SRC_E3 IN NUMBER,
I_SRC_S4 IN NUMBER,
I_SRC_E4 IN NUMBER,
I_SRC_SEC IN VARCHAR2,
I_SRC_NET IN VARCHAR2,
I_SRC_LOC IN VARCHAR2,
I_DST_S1 IN NUMBER,
I_DST_E1 IN NUMBER,
I_DST_S2 IN NUMBER,
I_DST_E2 IN NUMBER,
I_DST_S3 IN NUMBER,
I_DST_E3 IN NUMBER,
I_DST_S4 IN NUMBER,
I_DST_E4 IN NUMBER,
I_DST_SEC IN VARCHAR2,
I_DST_NET IN VARCHAR2,
I_DST_LOC IN VARCHAR2,
I_PROTOCOL IN VARCHAR2,
I_PORTS IN VARCHAR2,
I_S_G IN NUMBER DEFAULT 0
) RETURN SYS_REFCURSOR
IS
l_return SYS_REFCURSOR;
BEGIN
CASE I_S_G
WHEN '0'
THEN
OPEN l_return FOR
SELECT
t1.service_id
,NVL(t1.SERVICE, 'All') SERVICE
,t1.count_id
,t2.table_id
,t2.id AS POLICY_ID
,t2.action
,t1.summary table_name
,t1.updated_by
,t2.s1_1
,t2.s1_2
,t2.s2_1
,t2.s2_2
,t2.s3_1
,t2.s3_2
,t2.s4_1
,t2.s4_2
,t2.s_sec
,t2.s_net
,t2.s_loc
,t2.d1_1
,t2.d1_2
,t2.d2_1
,t2.d2_2
,t2.d3_1
,t2.d3_2
,t2.d4_1
,t2.d4_2
,t2.d_sec
,t2.d_net
,t2.d_loc
,t2.protocol
,t2.ports
,NVL(TO_CHAR(t1.expiry_date), 'Forever') EXPIRY_DATE
,NVL(t2.note, 'Not specified') NOTE
,t2.approved_by
,NVL(
(
SELECT 'yes'
FROM (
SELECT DISTINCT s1.protocol_id, s1.ports
FROM sh.inner_s1 s1
WHERE (s1.type = 'Service')
START WITH s1.name = 'Blacklisted Ports'
CONNECT BY PRIOR id = s1.parent_id
) s1
INNER JOIN sh.sys_list_protocols s2 ON (s1.protocol_id = s2.id)
WHERE (s2.name = t4.name)
AND (s1.ports = t2.ports)
AND (ROWNUM <= 1)
)
, 'no') BLACKLIST,
t2.approved_date,
t2.seq,
CASE WHEN service_id = '0' and count_id = '0' THEN '2'
WHEN service_id != '0' and count_id = '0' THEN '1'
WHEN service_id != '0' and count_id != '0' THEN '0'
END table_authority
FROM sh.v_tables_group t1
INNER JOIN sh.v_table_policies t2 ON (t1.id = t2.table_id)
LEFT JOIN sh.sys_list_protocols t4 ON (t2.protocol_id = t4.id)
WHERE ((t1.service_id = I_SERVICE_ID) OR (t1.service_id IS NULL) OR (t1.service_id = 0 ) )
AND ((t1.count_id = I_count_id) OR (t1.count_id IS NULL) OR t1.count_id = 0)
AND (t1.status = 'Processed')
AND (t2.rejected_date IS NULL)
AND ((t1.expiry_date IS NULL) OR (t1.expiry_date >= SYSTIMESTAMP))
AND (
(
((I_SRC_S1 >= t2.s1_1) AND (I_SRC_E1 <= t2.s1_2))
AND ((I_SRC_S2 >= t2.s2_1) AND (I_SRC_E2 <= t2.s2_2))
AND ((I_SRC_S3 >= t2.s3_1) AND (I_SRC_E3 <= t2.s3_2))
AND ((I_SRC_S4 >= t2.s4_1) AND (I_SRC_E4 <= t2.s4_2))
)
OR (
((I_SRC_SEC = t2.s_sec) OR ( (lower(t2.s_sec) = 'any' ) )) -- AND (t2.s_net IS NULL) AND (t2.s_loc IS NULL) ) )
AND ((I_SRC_NET = t2.s_net) OR (t2.s_net IS NULL))
AND ((I_SRC_LOC = t2.s_loc) AND (t2.s_net IS NOT NULL) OR (t2.s_loc IS NULL))
AND (t2.table_type_src = '')
)
)
AND (
(
((I_DST_S1 >= t2.d1_1) AND (I_DST_E1 <= t2.d1_2))
AND ((I_DST_S2 >= t2.d2_1) AND (I_DST_E2 <= t2.d2_2))
AND ((I_DST_S3 >= t2.d3_1) AND (I_DST_E3 <= t2.d3_2))
AND ((I_DST_S4 >= t2.d4_1) AND (I_DST_E4 <= t2.d4_2))
)
OR (
((I_DST_SEC = t2.d_sec) OR ( (lower(t2.d_sec) = 'any' ) )) -- AND (t2.d_net IS NULL) AND (t2.d_loc IS NULL) ) )
AND ((I_DST_NET = t2.d_net) OR (t2.d_net IS NULL))
AND ((I_DST_LOC = t2.d_loc) AND (t2.d_net IS NOT NULL) OR (t2.d_loc IS NULL))
AND (t2.table_type_dst = '')
)
)
AND (
((t2.protocol = I_PROTOCOL) AND ( (t2.ports = I_PORTS) OR (t2.ports IS NULL) OR (lower(t2.ports) = 'any') ) )
OR
((t2.protocol = 'ICMP') AND ( (t2.ports = I_PORTS) OR (t2.ports IS NULL) OR (t2.ports = 'All') ) )
)
ORDER BY CASE WHEN service_id = '0' and count_id = '0' THEN '2'
WHEN service_id != '0' and count_id = '0' THEN '1'
WHEN service_id != '0' and count_id != '0' THEN '0'
END asc, t2.approved_date desc, t2.seq
FETCH FIRST 1 ROWS ONLY;
WHEN '1' THEN
OPEN l_return FOR
SELECT
t1.service_id
,NVL(t1.SERVICE, 'All') SERVICE
,t1.count_id
,t2.table_id
,t2.id AS POLICY_ID
,t2.action
,t1.summary table_name
,t1.updated_by
,t2.s1_1
,t2.s1_2
,t2.s2_1
,t2.s2_2
,t2.s3_1
,t2.s3_2
,t2.s4_1
,t2.s4_2
,t2.s_sec
,t2.s_net
,t2.s_loc
,t2.d1_1
,t2.d1_2
,t2.d2_1
,t2.d2_2
,t2.d3_1
,t2.d3_2
,t2.d4_1
,t2.d4_2
,t2.d_sec
,t2.d_net
,t2.d_loc
,t2.protocol
,t2.ports
,NVL(TO_CHAR(t1.expiry_date), 'Forever') EXPIRY_DATE
,NVL(t2.note, 'Not specified') NOTE
,t2.approved_by
,NVL(
(
SELECT 'yes'
FROM (
SELECT DISTINCT s1.protocol_id, s1.ports
FROM sh.inner_s1 s1
WHERE (s1.type = 'Service')
START WITH s1.name = 'Blacklisted Ports'
CONNECT BY PRIOR id = s1.parent_id
) s1
INNER JOIN sh.sys_list_protocols s2 ON (s1.protocol_id = s2.id)
WHERE (s2.name = t4.name)
AND (s1.ports = t2.ports)
AND (ROWNUM <= 1)
)
, 'no') BLACKLIST,
t2.approved_date,
t2.seq,
CASE WHEN service_id = '0' THEN '2'
WHEN service_id != '0' THEN '1'
END table_authority
FROM sh.v_t1 t1
INNER JOIN sh.v_table_policies t2 ON (t1.id = t2.table_id)
LEFT JOIN sh.sys_list_protocols t4 ON (t2.protocol_id = t4.id)
WHERE ((t1.service_id = I_SERVICE_ID) OR (t1.service_id IS NULL) OR (t1.service_id = 0 ) )
AND (t1.status = 'Processed')
AND (t2.rejected_date IS NULL)
AND ((t1.expiry_date IS NULL) OR (t1.expiry_date >= SYSTIMESTAMP))
AND (
(
((I_SRC_S1 >= t2.s1_1) AND (I_SRC_E1 <= t2.s1_2))
AND ((I_SRC_S2 >= t2.s2_1) AND (I_SRC_E2 <= t2.s2_2))
AND ((I_SRC_S3 >= t2.s3_1) AND (I_SRC_E3 <= t2.s3_2))
AND ((I_SRC_S4 >= t2.s4_1) AND (I_SRC_E4 <= t2.s4_2))
)
OR (
((I_SRC_SEC = t2.s_sec) OR ( (lower(t2.s_sec) = 'any' ) )) -- AND (t2.s_net IS NULL) AND (t2.s_loc IS NULL) ) )
AND ((I_SRC_NET = t2.s_net) OR (t2.s_net IS NULL))
AND ((I_SRC_LOC = t2.s_loc) AND (t2.s_net IS NOT NULL) OR (t2.s_loc IS NULL))
AND (t2.table_type_src = '')
)
)
AND (
(
((I_DST_S1 >= t2.d1_1) AND (I_DST_E1 <= t2.d1_2))
AND ((I_DST_S2 >= t2.d2_1) AND (I_DST_E2 <= t2.d2_2))
AND ((I_DST_S3 >= t2.d3_1) AND (I_DST_E3 <= t2.d3_2))
AND ((I_DST_S4 >= t2.d4_1) AND (I_DST_E4 <= t2.d4_2))
)
OR (
((I_DST_SEC = t2.d_sec) OR ( (lower(t2.d_sec) = 'any' ) )) -- AND (t2.d_net IS NULL) AND (t2.d_loc IS NULL) ) )
AND ((I_DST_NET = t2.d_net) OR (t2.d_net IS NULL))
AND ((I_DST_LOC = t2.d_loc) AND (t2.d_net IS NOT NULL) OR (t2.d_loc IS NULL))
AND (t2.table_type_dst = '')
)
)
AND (
((t2.protocol = I_PROTOCOL) AND ( (t2.ports = I_PORTS) OR (t2.ports IS NULL) OR (lower(t2.ports) = 'any') ) )
OR
((t2.protocol = 'ICMP') AND ( (t2.ports = I_PORTS) OR (t2.ports IS NULL) OR (t2.ports = 'All') ) )
)
ORDER BY CASE
WHEN service_id = '0' THEN '2'
WHEN service_id != '0' THEN '1'
END asc, t2.approved_date desc, t2.seq
FETCH FIRST 1 ROWS ONLY;
END CASE;
RETURN l_return;
END FUNC_CHECK;
在我的包裹里我正在做
DECLARE
l_tables SYS_REFCURSOR;
l_table VARCHAR2 (32767);
v_emp_id employee.emp_id%type;
BEGIN
DBMS_OUTPUT.put_line ('I_S_G: ' || I_S_G);
l_tables := sh.FUNC_CHECK (I_SERVICE_ID,
I_count_id,
I_SRC_S1,
I_SRC_E1,
I_SRC_S2,
I_SRC_E2,
I_SRC_S3,
I_SRC_E3,
I_SRC_S4,
I_SRC_E4,
I_SRC_SEC,
I_SRC_NET,
I_SRC_LOC,
I_DST_S1,
I_DST_E1,
I_DST_S2,
I_DST_E2,
I_DST_S3,
I_DST_E3,
I_DST_S4,
I_DST_E4,
I_DST_SEC,
I_DST_NET,
I_DST_LOC,
I_PROTOCOL,
I_PORTS,
I_S_G);
LOOP
FETCH l_tables INTO l_table;
DBMS_OUTPUT.put_line ('l_table: ' || l_table);
EXIT WHEN l_tables%NOTFOUND;
END LOOP;
CLOSE l_tables;
--FOR flow_row IN flow_cursor LOOP
/*O_table_ID := tables.table_ID;
O_POLICY_ID := tables.POLICY_ID;
O_ACTION := tables.ACTION;
O_SERVICE := tables.SERVICE;
O_table_NAME := tables.table_NAME;
O_EXPIRY_DATE := tables.EXPIRY_DATE;
O_NOTE := tables.NOTE;
O_APPROVED_BY := tables.APPROVED_BY;
O_BLACKLIST := tables.BLACKLIST;
IF O_ACTION = 'deny' THEN
O_SPA := 'Prevention';
O_SPN := 'Prevention #' || tables.table_ID || '.' || tables.POLICY_ID || ' - Prevented by ' || tables.APPROVED_BY || ' until ' || tables.EXPIRY_DATE;
O_FPA := 'Prevention';
O_FPN := 'Prevention #' || tables.table_ID || '.' || tables.POLICY_ID || ' - Prevented by ' || tables.APPROVED_BY || ' until ' || tables.EXPIRY_DATE;
END IF;
IF O_ACTION = 'permit' THEN
O_SPA := 'table';
O_SPN := 'table #' || tables.table_ID || '.' || tables.POLICY_ID || ' - Approved by ' || tables.APPROVED_BY || ' until ' || tables.EXPIRY_DATE;
O_FPA := 'table';
O_FPN := 'table #' || tables.table_ID || '.' || tables.POLICY_ID || ' - Approved by ' || tables.APPROVED_BY || ' until ' || tables.EXPIRY_DATE;
END IF;*/
END;
我知道我不应该使用SYS_REFCURSOR，但我不确定如何将它实现为行类型并循环遍历结果。
我试图使用来自https://blogs.oracle.com/oraclemagazine/working-with-cursors的示例
我需要将最终结果存储到被注释掉的变量中，以便在包...O_table_ID .. O_...中作为输出返回
更新
这是我现在拥有的，但它不起作用。
PROCEDURE ces (
O_ERRORCODE OUT NUMBER,
O_ERRORTEXT OUT VARCHAR2,
O_EXEMPTION_ID OUT NUMBER,
O_POLICY_ID OUT NUMBER,
O_ACTION OUT VARCHAR2,
O_SERVICE OUT VARCHAR2,
O_EXEMPTION_NAME OUT VARCHAR2,
O_EXPIRY_DATE OUT VARCHAR2,
O_NOTE OUT VARCHAR2,
O_APPROVED_BY OUT VARCHAR2,
O_BLACKLIST OUT VARCHAR2,
O_SPA OUT VARCHAR2,
O_SPN OUT VARCHAR2,
O_FPA OUT VARCHAR2,
O_FPN OUT VARCHAR2,
I_SERVICE_ID IN NUMBER,
I_count_id IN NUMBER,
I_SRC_S1 IN NUMBER,
I_SRC_E1 IN NUMBER,
I_SRC_S2 IN NUMBER,
I_SRC_E2 IN NUMBER,
I_SRC_S3 IN NUMBER,
I_SRC_E3 IN NUMBER,
I_SRC_S4 IN NUMBER,
I_SRC_E4 IN NUMBER,
I_SRC_SEC IN VARCHAR2,
I_SRC_NET IN VARCHAR2,
I_SRC_LOC IN VARCHAR2,
I_DST_S1 IN NUMBER,
I_DST_E1 IN NUMBER,
I_DST_S2 IN NUMBER,
I_DST_E2 IN NUMBER,
I_DST_S3 IN NUMBER,
I_DST_E3 IN NUMBER,
I_DST_S4 IN NUMBER,
I_DST_E4 IN NUMBER,
I_DST_SEC IN VARCHAR2,
I_DST_NET IN VARCHAR2,
I_DST_LOC IN VARCHAR2,
I_PROTOCOL IN VARCHAR2,
I_PORTS IN VARCHAR2,
I_S_G IN NUMBER DEFAULT 0
)
AS
BEGIN
O_EXEMPTION_ID := 0;
O_POLICY_ID := 0;
O_ACTION := '';
O_SERVICE := '';
O_EXEMPTION_NAME := '';
O_EXPIRY_DATE := '';
O_NOTE := '';
O_APPROVED_BY := '';
O_BLACKLIST := '';
O_SPA := '';
O_SPN := '';
O_FPA := '';
O_FPN := '';
DECLARE
l_e SYS_REFCURSOR;
EXEMPTION l_e%ROWTYPE;
BEGIN
DBMS_OUTPUT.put_line ('I_S_G: ' || I_S_G);
l_e := sh.FUNC_c_e (I_SERVICE_ID,
I_count_id,
I_SRC_S1,
I_SRC_E1,
I_SRC_S2,
I_SRC_E2,
I_SRC_S3,
I_SRC_E3,
I_SRC_S4,
I_SRC_E4,
I_SRC_SEC,
I_SRC_NET,
I_SRC_LOC,
I_DST_S1,
I_DST_E1,
I_DST_S2,
I_DST_E2,
I_DST_S3,
I_DST_E3,
I_DST_S4,
I_DST_E4,
I_DST_SEC,
I_DST_NET,
I_DST_LOC,
I_PROTOCOL,
I_PORTS,
I_S_G);
DBMS_OUTPUT.put_line (l_e);
CLOSE l_e;
END;
【问题讨论】：
你的 IDE 是什么？ SQL 开发人员？ PL/SQL 开发人员？相反，您应该使用SYS_REFCURSOR。试试SQL> declare v_rc sys_refcursor; begin :l_tables := CCP.FUNC_CHECK_table(....); end;/ 然后SQL> print l_tables
我使用 Oracle SQL 开发人员
【参考方案1】：
这里有一个例子来说明如何做到这一点。
首先，一个函数（是的，它确实返回 sys_refcursor；为什么不返回？）：
SQL> CREATE OR REPLACE FUNCTION f_test (par_deptno IN dept.deptno%TYPE)
2 RETURN SYS_REFCURSOR
3 IS
4 rc SYS_REFCURSOR;
5 BEGIN
6 OPEN rc FOR SELECT empno, ename
7 FROM emp
8 WHERE deptno = par_deptno;
9
10 RETURN rc;
11 END;
12 /
Function created.
测试：请注意，您必须声明将获取 refcursor 返回的变量的变量。当然，它们匹配函数SELECT 语句中使用的列。
SQL> SET SERVEROUTPUT ON
SQL> DECLARE
2 l_rc SYS_REFCURSOR;
3 l_empno emp.empno%TYPE;
4 l_ename emp.ename%TYPE;
5 BEGIN
6 l_rc := f_test (10);
7
8 LOOP
9 FETCH l_rc INTO l_empno, l_ename;
10
11 EXIT WHEN l_rc%NOTFOUND;
12 DBMS_OUTPUT.put_line (l_empno || ': ' || l_ename);
13 END LOOP;
14 END;
15 /
7782: CLARK
7839: KING
7934: MILLER
PL/SQL procedure successfully completed.
SQL>
【讨论】：
l_empno emp.empno%TYPE; 此错误与不完整或格式错误
它没有，如我的示例所示。因此，你做错了什么。那可能是什么，我不知道，因为我无法调试我看不到的代码。
我将其更改为包而不是函数，并使用 fetch into 返回多个变量。谢谢。我认为在动态游标上你不能设置行类型以上是关于如何从函数游标返回行并在oracle中循环的主要内容，如果未能解决你的问题，请参考以下文章
Oracle 修改 sys refcursor 并在 PL/SQL 中返回修改后的游标
如何从 Oracle 过程返回填充了 NESTED RECORD 类型的游标