/*

　　管道通信的例子程序

　　注意：1要明文给于用户 EXECUTE ANY PROCEDURE 权力可能正常使用DBMS_PIPE

　　2设定：set serveroutput on

　　共有两个过程writepipe和readpipe

　　在sqlplus中通过@writepipe.sql的方式执行，可以创始过程writepipe和readpipe

　　通过 call writepipe('我的测试信息'); 写信息

　　用 call readpipe() 读信息

　　2002年4月12日

　　*/

　　CREATE OR REPLACE PROCEDURE writepipe(msg VARCHAR2) AS

　　n integer;

　　status NUMBER;

　　BEGIN

　　-- DBMS_PIPE.PACK_MESSAGE(LENGTH(msg));

　　DBMS_PIPE.PACK_MESSAGE(msg); --把信息放入缓冲区

　　status := DBMS_PIPE.SEND_MESSAGE('mypipe',1); --信息放入管道mypipe,系统等待时间为1秒

　　--如果status := DBMS_PIPE.SEND_MESSAGE('mypipe');那么就是等待1000天

　　IF status != 0 THEN

　　raise_application_error(-20099, 'Debug error');

　　END IF;

　　END;

　　/

　　CREATE OR REPLACE PROCEDURE readpipe AS

　　info varchar(30);

　　status integer;

　　begin

　　--接受等待时间为1秒,可以为0,立即调用或DBMS_PIPE.RECEIVE_MESSAGE('mypipe') 等待100天

　　status:= DBMS_PIPE.RECEIVE_MESSAGE('mypipe',1);

　　--status:= DBMS_PIPE.RECEIVE_MESSAGE('mypipe');

　　--status为0为成功可以UNPACK_MESSAGE，1为超时没有数据，2为信息太大，3为内部错误

　　IF status <> 0 THEN

　　DBMS_OUTPUT.PUT_LINE('没有信息返回，返回状态为:'||status);

　　return;

　　-- RAISE_APPLICATION_ERROR(-20021,

　　-- 'execute_sql: Error while receiving.

　　-- Status = ' || status);

　　END IF;

　　DBMS_PIPE.UNPACK_MESSAGE(info);

　　DBMS_OUTPUT.PUT_LINE('INFO='|| INFO);

　　end;

　　/