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后赋权:
GRANT EXECUTE ON DBMS_PIPE TO scott;
创建管道CREATE_PIPE
基本语法如下:
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类型的过程。基本语法如下:
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
语法如下:
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会在指定的管道不存在时,隐式地创建管道,并且等待接收信息。如果在指定的时间内没有接收到消息,调用会返回同时管道自动删除。
基本语法如下:
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
基本语法如下:
DBMS_PIPE.NEXT_ITEM_TYPE RETURN INTEGER;
返回值的含义:
- 返回0:表示无数据项。
- 返回6:表示NUMBER。
- 返回9:表示VARCHAR2。
- 返回11:表示ROWID。
- 返回12:表示DATE。
- 返回23:表示RAW。
读取缓冲区数据UNPACK_MESSAGE
语法如下:
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
删除管道后,管道中还未被提取的信息在管道被删除前统一会被删除,语法如下:
DBMS_PIPE.REMOVE_PIPE(pipename IN VARCHAR2) RETURN INTEGER;
返回0表示管道被成功删除,如果用户没有删除这个管道的权限,则会抛出ORA-23322。
清除管道内容PURGE
用于清除命名管道中的所有信息,对于隐式创建的管道,会根据最近最少使用的算法将此管道从全局共享内存区中清除,实际上就是释放了管道所占用的内存。PURGE会自动调用RECEIVE_MESSAGEG,将私有数据缓冲区重写覆盖,语法如下:
DBMS_PIPE.PURGE(pipename IN VARCHAR2);
复位管道缓冲区RESET_BUFFER
该过程将重置PACK_MESSAGE和UNPACK_MESSAGE指针的位置,使之指到私有数据缓冲区的头部,语法如下:
DBMS_PIPE.RESET_BUFFER;
返回会话名称UNIQUE_SESSION_NAME
该函数用来为特定会话返回唯一的名称,名称的最大长度为30个字节,对于同一会话来说,其值不会改变,语法如下:
DBMS_PIPE.UNIQUE_SESSION_NAME RETURN VARCHAR2;
使用管道的例子
由于管道用于在多个会话之间传递数据,因此需要一个会话发送消息,另一个会话接收消息,基本实现过程如下:
1. 一个会话发哦少年宫消息到管道时,需要首先将消息写入本地消息缓冲区中,然后将本地消息缓冲区内容发送到管道。
2. 当接收管道消息时,需要首先使用本地消息缓冲区接收管道消息,然后从消息缓冲区取得具体消息。
代码如下:
--发送管道消息
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进行了简单介绍,然后按照大多数用户的使用习惯,对各种操作和相关命令进行了分类介绍。对相关命令的介绍都力求通俗易懂,都给...
你 发表评论:
欢迎- 一周热门
- 最近发表
- 标签列表
-
- maven镜像 (69)
- undefined reference to (60)
- zip格式 (63)
- oracle over (62)
- date_format函数用法 (67)
- 在线代理服务器 (60)
- shell 字符串比较 (74)
- x509证书 (61)
- localhost (65)
- java.awt.headless (66)
- syn_sent (64)
- settings.xml (59)
- 弹出窗口 (56)
- applicationcontextaware (72)
- my.cnf (73)
- httpsession (62)
- pkcs7 (62)
- session cookie (63)
- java 生成uuid (58)
- could not initialize class (58)
- beanpropertyrowmapper (58)
- word空格下划线不显示 (73)
- jar文件 (60)
- jsp内置对象 (58)
- makefile编写规则 (58)