百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术资源 > 正文

Oracle PL/SQL进阶编程(第七弹:使用系统包:DBMS_PIPE)

lipiwang 2024-12-04 13:41 6 浏览 0 评论

DBMS_PIPE包用于在同一个Oracle的Instance,即例程的不同会话之间进行通信。管道非常类似于UNIX操作系统中的管道,但是Oracle管道并不是使用像在UNIX中那样的操作系统调用的机制,其管道信息被缓存在系统全局区(SGA)中,当关闭Oracle例程时,就会丢失管道信息。管道又可以分为如下两种类型:

- 公用管道:指所有数据库用户都可以访问的管道。

- 私有管道:只能由建立管道的数据库用户访问。

要能访问和执行DBMS_PIPE包中的过程,当前会话的用户需要具有对DBMS_PIPE包的执行权限,可以以DBA用户登录Oracle后赋权:

Bash
GRANT EXECUTE ON DBMS_PIPE TO scott;

创建管道CREATE_PIPE

基本语法如下:

Bash
DBMS_PIPE.CREATE_PIPE(pipename IN VARCHAR2,

 maxpipesize IN INTEGER DEFAULT 8192,

 private IN BOOLEAN DEFAULT True) RETURN INTEGER;

pipename:用于指定管道的名称,在调用SEND_MESSAGE和RECEIVE_MESSAGE时使用此参数,这个名称在应用的数据库实例中必须唯一。管道名不能以ORA$开头,不能超过128个字节,不区分大小写,不能是中文。

maxpipesize:用于指定管道消息的最大尺寸,以字节为单位,不能超过8192个字节,如果超过此值会发生阻塞。

private:用于指定管道的类型,True表示建立私有管道,False表示建立公用管道。

该函数返回INTEGER类型的 值,如果返回0,表示管道建立成功,否则表示失败,会抛出ORA-23322命名冲突错误,表示另一个用户创建了同名的管道。

缓存消息PACK_MESSAGE

为了给管道发送消息,必须要先使用PACK_MESSAGE将消息写入本地消息缓冲区,然后使用SEND_MESSAGEG将本地消息缓冲区中的消息发送到管道。PACK_MESSAGE的功能就是讲消息存到私有的信息缓冲区中,该过程具有多个重载,分别接受类型为VARCHAR2、NUMBER或DATE类型的数据项,还有两个专门用来存储RAW和ROWID类型的过程。基本语法如下:

Bash
DBMS_PIPE.PACK_MESSAGE(item IN VARCHAR2);

DBMS_PIPE.PACK_MESSAGE(item IN NCHAR);

DBMS_PIPE.PACK_MESSAGE(item IN NUMBER);

DBMS_PIPE.PACK_MESSAGE(item IN DATE);

DBMS_PIPE.PACK_MESSAGE_RAW(item IN RAW);

DBMS_PIPE.PACK_MESSAGE_ROWID(item IN ROWID);

在缓冲区中只能存放4096字节的数据,如果超过的限制,Oracle将抛出ORA-06558的异常。

发送消息SEND_MESSAGE

语法如下:

Bash
DBMS_PIPE.SEND_MESSAGE(pipename IN VARCHAR2,
timeout IN INTEGER DEFAULT MAXWAIT,
maxpipesize IN INTEGER DEFAULT 8192) RETURN INTEGER;

pipename:已经存在的管道的名称,如果管道不存在,则在SEND_MESSAGE执行后,Oracle将创建该管道。

timeout:尝试将信息放到管道中的时间,默认值是常量值MAXWAI,以秒为单位,为86400000秒,即1000天。

maxpipesize:管道容量的最大值,传入管道的大小不能超过这个值。

返回值的含义:
- 返回0:表示发送成功。
- 返回1:表示超时,是由于不能获取对管道的锁控制,或者管道已满,等待RECEIVE_MESSAGE从管道中清理空间超过了最长等待时间。
- 返回3:表示发送信息中断,因为在隐式创建管道时,如果管道内无信息,则管道会被自动删除。

接受消息RECEIVE_MESSAGE

ECEIVE_MESSAGE用于接收管道消息,将接收到的消息写入本地消息缓冲区,然后删除管道中的消息,因此要特别注意,管道消息只能被接收一次。

RECEIVE_MESSAGE会在指定的管道不存在时,隐式地创建管道,并且等待接收信息。如果在指定的时间内没有接收到消息,调用会返回同时管道自动删除。

基本语法如下:

Bash
DBMS_PIPE.RECEIVE_MESSAGE(pipename IN VARCHAR2,

timeout IN INTEGER DEFAULT MAXWAIT) RETURN INTEGER;

返回值的含义:

- 返回1:表示成功接收消息。

- 返回2:表示超时。

- 返回3:表示正在接收的消息被中断。

如果抛出ORA-23322,表示用户无权读取管道。

在接收到消息后,还需要调用UNPACK_MESSAGE访问私有数据缓冲区,以获取信息。如果不能确认缓冲区中的数据项的类型,可以使用NEXT_ITEM_TYPE确认数据类型后,再调用UNPACK_MESSAGE获取信息。

确定数据类型NEXT_ITEM_TYPE

基本语法如下:

Bash
DBMS_PIPE.NEXT_ITEM_TYPE RETURN INTEGER;

返回值的含义:
- 返回0:表示无数据项。
- 返回6:表示NUMBER。
- 返回9:表示VARCHAR2。
- 返回11:表示ROWID。
- 返回12:表示DATE。
- 返回23:表示RAW。

读取缓冲区数据UNPACK_MESSAGE

语法如下:

Bash
DBMS_PIPE.UNPACK_MESSAGE(item OUT VARCHAR2);

DBMS_PIPE.UNPACK_MESSAGE(item OUT NCHAR);

DBMS_PIPE.UNPACK_MESSAGE(item OUT NUMBER);

DBMS_PIPE.UNPACK_MESSAGE(item OUT DATE);

DBMS_PIPE.UNPACK_MESSAGE_RAW(item OUT RAW);

DBMS_PIPE.UNPACK_MESSAGE_ROWID(item OUT ROWID);

如果缓冲区中没有数据或类型不匹配,则会触发ORA-06556或ORA-06559,因此最好在接收之前,使用NEXT_ITEM_TYPE确定缓冲区中下一个项目的数据类型。

UNPACK_MESSAGE每次只能取出一条消息,如果要取出多条消息,需要多次调用UNPACK_MESSAGE。

删除管道REMOVE_PIPE

删除管道后,管道中还未被提取的信息在管道被删除前统一会被删除,语法如下:

Bash
DBMS_PIPE.REMOVE_PIPE(pipename IN VARCHAR2) RETURN INTEGER;

返回0表示管道被成功删除,如果用户没有删除这个管道的权限,则会抛出ORA-23322。

清除管道内容PURGE

用于清除命名管道中的所有信息,对于隐式创建的管道,会根据最近最少使用的算法将此管道从全局共享内存区中清除,实际上就是释放了管道所占用的内存。PURGE会自动调用RECEIVE_MESSAGEG,将私有数据缓冲区重写覆盖,语法如下:

Bash
DBMS_PIPE.PURGE(pipename IN VARCHAR2);

复位管道缓冲区RESET_BUFFER

该过程将重置PACK_MESSAGE和UNPACK_MESSAGE指针的位置,使之指到私有数据缓冲区的头部,语法如下:

Bash
DBMS_PIPE.RESET_BUFFER;

返回会话名称UNIQUE_SESSION_NAME

该函数用来为特定会话返回唯一的名称,名称的最大长度为30个字节,对于同一会话来说,其值不会改变,语法如下:

Bash
DBMS_PIPE.UNIQUE_SESSION_NAME RETURN VARCHAR2;

使用管道的例子

由于管道用于在多个会话之间传递数据,因此需要一个会话发送消息,另一个会话接收消息,基本实现过程如下:

1. 一个会话发哦少年宫消息到管道时,需要首先将消息写入本地消息缓冲区中,然后将本地消息缓冲区内容发送到管道。

2. 当接收管道消息时,需要首先使用本地消息缓冲区接收管道消息,然后从消息缓冲区取得具体消息。

代码如下:

Bash
--发送管道消息
CREATE OR REPLACE PROCEDURE send_pipe_message(pipename 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;

--从管道中接收消息
CREATE OR REPLACE PROCEDURE receive_pipe_message(pipename VARCHAR2,message VARCHAR2)
IS
 flag INT;
BEGIN
 falg:=DBMS_PIPE.receive_message(pipename); --从管道中获取消息,保存到缓冲区
 IF flag=0 THEN
 DBMS_PIPE.unpack_message(message); --从缓冲区读取消息
 flag:=DBMS_PIPE.remove_pipe(pipename); --移除管道
 END IF;
END;


可以使用usera登录,调用send_pipe_message向管道发送一条消息,然后用userb登录,调用receive_pipe_message获取消息。

相关推荐

linux实例之设置时区的方式有哪些

linux系统下的时间管理是一个复杂但精细的功能,而时区又是时间管理非常重要的一个辅助功能。时区解决了本地时间和UTC时间的差异,从而确保了linux系统下时间戳和时间的准确性和一致性。比如文件的时间...

Linux set命令用法(linux cp命令的用法)

Linux中的set命令用于设置或显示系统环境变量。1.设置环境变量:-setVAR=value:设置环境变量VAR的值为value。-exportVAR:将已设置的环境变量VAR导出,使其...

python环境怎么搭建?小白看完就会!简简单单

很多小伙伴安装了python不会搭建环境,看完这个你就会了Python可应用于多平台包括Linux和MacOSX。你可以通过终端窗口输入"python"命令来查看本地是否...

Linux环境下如何设置多个交叉编译工具链?

常见的Linux操作系统都可以通过包管理器安装交叉编译工具链,比如Ubuntu环境下使用如下命令安装gcc交叉编译器:sudoapt-getinstallgcc-arm-linux-gnueab...

JMeter环境变量配置技巧与注意事项

通过给JMeter配置环境变量,可以快捷的打开JMeter:打开终端。执行jmeter。配置环境变量的方法如下。Mac和Linux系统在~/.bashrc中加如下内容:export...

C/C++|头文件、源文件分开写的源起及作用

1C/C++编译模式通常,在一个C++程序中,只包含两类文件——.cpp文件和.h文件。其中,.cpp文件被称作C++源文件,里面放的都是C++的源代码;而.h文件则被称...

linux中内部变量,环境变量,用户变量的区别

unixshell的变量分类在Shell中有三种变量:内部变量,环境变量,用户变量。内部变量:系统提供,不用定义,不能修改环境变量:系统提供,不用定义,可以修改,可以利用export将用户变量转为环...

在Linux中输入一行命令后究竟发生了什么?

Linux,这个开源的操作系统巨人,以其强大的命令行界面而闻名。无论你是初学者还是经验丰富的系统管理员,理解在Linux终端输入一条命令并按下回车后发生的事情,都是掌握Linux核心的关键。从表面上看...

Nodejs安装、配置与快速入门(node. js安装)

Nodejs是现代JavaScript语言产生革命性变化的一个主要框架,它使得JavaScript从一门浏览器语言成为可以在服务器端运行、开发各种各样应用的通用语言。在不同的平台下,Nodejs的安装...

Ollama使用指南【超全版】(olaplex使用方法图解)

一、Ollama快速入门Ollama是一个用于在本地运行大型语言模型的工具,下面将介绍如何在不同操作系统上安装和使用Ollama。官网:https://ollama.comGithub:http...

linux移植(linux移植lvgl)

1uboot移植l移植linux之前需要先移植一个bootlader代码,主要用于启动linux内核,lLinux系统包括u-boot、内核、根文件系统(rootfs)l引导程序的主要作用将...

Linux日常小技巧参数优化(linux参数调优)

Linux系统参数优化可以让系统更加稳定、高效、安全,提高系统的性能和使用体验。下面列出一些常见的Linux系统参数优化示例,包括修改默认配置、网络等多方面。1.修改默认配置1.1修改默认编辑器默...

Linux系统编程—条件变量(linux 条件变量开销)

条件变量是用来等待线程而不是上锁的,条件变量通常和互斥锁一起使用。条件变量之所以要和互斥锁一起使用,主要是因为互斥锁的一个明显的特点就是它只有两种状态:锁定和非锁定,而条件变量可以通过允许线程阻塞和等...

面试题-Linux系统优化进阶学习(linux系统的优化)

一.基础必备优化:1.关闭SElinux2.FirewalldCenetOS7Iptables(C6)安全组(阿里云)3.网络管理服务||NetworkManager|network...

嵌入式Linux开发教程:Linux Shell

本章重点介绍Linux的常用操作和命令。在介绍命令之前,先对Linux的Shell进行了简单介绍,然后按照大多数用户的使用习惯,对各种操作和相关命令进行了分类介绍。对相关命令的介绍都力求通俗易懂,都给...

取消回复欢迎 发表评论: