1、概述

说明：

Oracle管道类似UNIX系统的管道，但不采用OS机制实现，管道信息被缓存到SGA中，当关闭例程时会丢失管道信息，建立公用管道所有数据库用户都可访问，私有管道只能由建立者访问。

作用：

用于在同一例程程的不同会话之间进行管道通信.

注意事项：

如果用户要执行包dbms_pipe中的过程和函数,则必须要为用户授权.

sql>conn sys/oracle as sysdba;

sql>grant execute on dbms_pipe to scott;

2、包的组成

2.1、create_pipe

作用：

该函数用于建立公用管道或私有管道.如果将参数private设置为TRUE,则建立私有管道;如果设置为FALSE,则建立公用管道.

语法：

dbms_pipe.create_pipe(pipename in varchar2,

maxpipesize in integer default 8192,

private in boolean default true)

return integer;

-- 其中，pepename指定管道名称，maxpipesize指定管道消息的最大尺寸，private指定管道类型，函数返回0则成功，反之失败。

2.2、pack_message

作用：

该过程用于将变量写入到本地消息缓冲区。

说明：

为了给管道发消息，首先使用过程pack_message将消息写入本地消息缓冲区，然后使用send_message将消息发送到管道。

语法：

dbns_pipe.pack_message(item in varchar2/nchar2/number/date);

dbns_pipe.pack_message_raw(item in raw);

dbns_pipe.pack_message_rowid(item in rowid);

2.3、send_message

作用：

该函数用于将本地消息缓冲区中的内容发送到管道。

语法：

dbms_pipe.send_message(pipename in varchar2,

timeout in integer defalut maxwait,

maxpipesize in integer default 8192)

return integer;

-- 其中，timeout指定发送消息的超时时间，0成功1超时3中断。

2.4、receive_message

说明：

该函数用于接收管道消息，并将接收到的消息写入到本地消息缓冲区。当接收完管道信息之后，会删除管道消息，管道消息只能被接收一次。

语法：

dbms_pipe.receive_message(pepename in varchar2,

timeout in integer default maxwait)

return integer;

--其中，返回0接受成功，返回1超时，返回2本地缓冲区不能容纳管道消息，返回3发生中断。

2.5、next_item_type

说明：

该函数用于确定本地消息缓冲区下一项的数据类型。在调用receive_message之后调用。

语法：

dbms_pipe.next_item_type

return integer;

-- 其中，如果该函数返回0,则表示管道没有任何消息;如果返回6,则表示下一项的数据类型为number;如果返回9,则表示下一项的数据类型为varchar2;

--如果返回11,则表示下一项的数据类型为rowid;如果返回12,则表示下一项的数据类型为date;如果返回23,则表示下一项的数据类型为raw.

2.6、unpack_message

作用：

该过程用于将消息缓冲区的内容取出来写入到变量中，每次只能取一条，需要取出多条需要多次调用。

说明：

在使用函数receive_message接收到管道消息之后，应该使用过程unpack_message取得消息缓冲区的消息。

语法：

dbms_pipe.unpack_message(item out varchar2\nchar\number\date);

dbms_pipe.unpack_message_raw(item out raw);

dbms_pipe.unpack_message_rowid(item out rowid);、

2.7、remove_pipe

作用：

该函数用于删除已经建立的管道

语法：

dbms_pipe.remove_pipe(pepename in varchar2) return integer;

--其中，函数返回0表示成功，否则会显示错误信息。

2.8、purge

说明：

该过程用于清除管道中的内容。

语法：

dbms_pipe.purge(pipename in varchar2);

2.9、reset_buffer

说明：

该过程用于复位管道缓冲区，因为所有管道都共享单个管道缓冲区，所以在使用新管道之前应该复位管道缓冲区。

语法：

dbms_pipe.reset_buffer;

2.10、unique_session_name

说明：

该函数用于为特定会话返回唯一的名称,并且名称的最长度为30字节，对同一会话其值不变。

语法：

dbms_pipe.unique_session_name

回到顶部

3、包的应用

1）、综合例子1

declare

falg int;

v_ename emp.ename%type;

v_sal emp.sal%type;

v_rowid rowid;

item_no int;

message varchar2(100);

v_session varchar2(200);

begin

flag := dbms_pipe.create_pipe('public_pipe', 8192, false);

if flag = 0 then

dbms_output.put_line('建立公用管道成功');

end if;

select ename,sal,rowid into v_ename,v_sal,v_rowid from emp where empno=7788;

dbns_pipe.pack_message(v_ename||','||v_sal||','||v_rowid);

flag :dbms_pipe.send_message('PUBLIC_PIPE');

if flag = 0 then

dbms_output.put_line('发送成功');

end if;

flag := dbms_pipe.receive_message('PUBLIC_PIPE');

if flag = 0 then

dbms_output.put_line('成功');

end if;

item_no := dbms_pipe.next_item_type;

dbms_output.put_line(item_no);

dbms_pipe.unpack_message(message);

dbms_output.put_line(message);

--remove_pipe

flag:=dbms_pipe.remove_pipe('PUBLIC_PIPE');

if flag = 0 then

dbms_output.put_line('删除成功');

end if;

--unique_session_name

v_session:=dbms_pipe.unique_session_name;

dbms_output.put_line(v_session);

end;

2）、综合例子2

使用管道时，一个会话需要将消息发送到管道中，另一个会话则需要接收管道消息。

发送消息到管道需要先将消息写入本地消息缓冲区，然后再发送到管道；

接收消息需要先使用本地消息缓冲区接收管道消息，然后从消息缓冲区取得具体消息。

create or replace procedure send_message(pepename varchar2,message varchar2) is

flag int;

begin

flag:=dbms_pipe.create_pipe(pipename);

if flag=0 then

dbms_pipe.pack_message(message);

flag:=dbms_pipe.send_message(pipename);

end if;

end send_message;

create or replace procedure receive_message(pipename varchar2,message out varchar2) is

flag int;

begin

flag:=dbms_pipe.receive_message(pipename);

if flag=0 then

dbms_pipe.unpack_message(message);

flag:=dbms_pipe.remove_pipe(pipename);

end if;

end receive_message;

会话一:exec send_message('pipe1','你好');

会话二：

var message varchar2(100)

exec scorr.receive_message('pipe1',:message)

print message