Oracle高级队列(Advanced Queue)初体验

简介: 最简单的高级队列的练习,基本上都使用了默认参数。-- Create Typecreate or replace type note as Object( subject varchar2(100), Content varchar2(2000),...

最简单的高级队列的练习,基本上都使用了默认参数。
-- Create Type
create or replace type note as Object(
 subject varchar2(100),
 Content varchar2(2000),CreateTime date
);

-- Create queue table
begin
  sys.dbms_aqadm.create_queue_table(
    queue_table => 'NOTETAB',
    queue_payload_type => 'TEST.NOTE'
end;

--create queue
begin
  sys.dbms_aqadm.create_queue(
    queue_name => 'NOTEQ',
    queue_table => 'NOTETAB',
    queue_type => sys.dbms_aqadm.normal_queue,
    max_retries => 5,
    retry_delay => 0,
    retention_time => 0);
end;

--enqueue
declare
v_Message note;
v_MsgId RAW(16);
v_options DBMS_AQ.ENQUEUE_OPTIONS_T;
v_properties DBMS_AQ.MESSAGE_PROPERTIES_T;
v_Recipients  DBMS_AQ.AQ$_RECIPIENT_LIST_T;
begin
     v_Message:=note(subject => 'note3',Content => 'content3',createTime => sysdate);

--     v_Recipients(0) := sys.aq$_agent('NOTE','MTQ',0);
--     v_properties.recipient_list := v_Recipients;
     v_options.visibility :=DBMS_AQ.IMMEDIATE;
     dbms_aq.enqueue(queue_name => 'noteq',enqueue_options => v_options,message_properties => v_properties,payload => v_Message,msgid => v_MsgId);
     dbms_output.put_line('encode success,msgid is '||v_MsgId);

end;

--dequeue
declare
v_Message note;
v_MsgId RAW(16);
v_options DBMS_AQ.DEQUEUE_OPTIONS_T;
v_properties DBMS_AQ.MESSAGE_PROPERTIES_T;
v_Recipients  DBMS_AQ.AQ$_RECIPIENT_LIST_T;
begin

--     v_Recipients(0) := sys.aq$_agent('NOTE','MTQ',0);
--     v_properties.recipient_list := v_Recipients;
     v_options.visibility :=DBMS_AQ.IMMEDIATE;
     dbms_aq.dequeue(queue_name => 'noteq',dequeue_options => v_options,message_properties => v_properties,payload => v_Message,msgid => v_MsgId);
     dbms_output.put_line('decode success,msgid is '||v_MsgId);
     dbms_output.put_line('subject is '||v_Message.subject);
     dbms_output.put_line('Content is '||v_Message.Content);
     dbms_output.put_line('createTime is '||to_char(v_Message.createTime,'yyyy-mm-dd hh24:mi:ss'));
end;

目录
相关文章
|
7月前
|
SQL Oracle 关系型数据库
整合Mybatis-Plus高级,Oracle 主键Sequence,Sql 注入器实现自定义全局操作
整合Mybatis-Plus高级,Oracle 主键Sequence,Sql 注入器实现自定义全局操作
150 0
Oracle-高级子查询
Oracle-高级子查询
53 0
|
SQL XML Oracle
整合Mybatis-Plus高级,Oracle 主键Sequence,Sql 注入器实现自定义全局操作(下)
整合Mybatis-Plus高级,Oracle 主键Sequence,Sql 注入器实现自定义全局操作(下)
|
SQL XML Oracle
整合Mybatis-Plus高级,Oracle 主键Sequence,Sql 注入器实现自定义全局操作(中)
整合Mybatis-Plus高级,Oracle 主键Sequence,Sql 注入器实现自定义全局操作(中)
|
SQL Oracle 关系型数据库
整合Mybatis-Plus高级,Oracle 主键Sequence,Sql 注入器实现自定义全局操作(上)
整合Mybatis-Plus高级,Oracle 主键Sequence,Sql 注入器实现自定义全局操作(上)
|
Oracle 关系型数据库 OLAP
Oracle:一篇文章理解model高级语句
Oracle 高级语句model的概念和基本用法,对数据仓库有了解,想要在数据库上实现数据仓库功能的可以看看
553 0
|
Oracle 关系型数据库
oracle学习60-oracle之高级子查询2
oracle学习60-oracle之高级子查询2
97 0
oracle学习60-oracle之高级子查询2
|
Oracle 关系型数据库
oracle学习61-oracle之高级子查询1
oracle学习61-oracle之高级子查询1
80 0
oracle学习61-oracle之高级子查询1
|
Oracle 关系型数据库
oracle学习59-oracle之高级子查询之课后练习
oracle学习59-oracle之高级子查询之课后练习
56 0
oracle学习59-oracle之高级子查询之课后练习