快捷搜索:  汽车  科技

oracle数据库环境配置变量教程(Oracle基础包之三DBMSPIPE)

oracle数据库环境配置变量教程(Oracle基础包之三DBMSPIPE)sql>grant execute on dbms_pipe to scott;sql>conn sys/oracle as sysdba;用于在同一例程程的不同会话之间进行管道通信.注意事项:如果用户要执行包dbms_pipe中的过程和函数 则必须要为用户授权.

oracle数据库环境配置变量教程(Oracle基础包之三DBMSPIPE)(1)

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

猜您喜欢: