`

Oracle任务调度之基于事件的任务调度(原创 )

阅读更多

基于事件的Oracle JOB概述

Oracle的任务调度不仅可以基于时间进行调度,也可以根据事件来触发。关于Oracle基于时间的调度管理可以参看http://czmmiao.iteye.com/blog/1003505

在Oracle的调度管理器里,使用高级队列(Advanced Queue)来触发事件。也就是说,可以通过应用程序向某个队列发送一个事件,从而触发某个任务执行。要创建基于事件的队列需要两个额外的信息,事件所在的队列名称以及任务触发的条件。一旦条件为真,则启动任务。在创建基于事件的Oracle JOB中会涉及到一些高级队列的知识,本文不做讨论。有兴趣的朋友可以自行查看资料

实验环境

创建一个测试用表

SQL>conn hr/hr;

Connected.

SQL> create table event_job_test(id number constraint event_job_test_pk primary key,createdate date);
Table created.
创建序列以生成该表的主键
SQL> create sequence event_job_test_seq;
Sequence created.

创建类型以存放队列里的消息格式

SQL> create or replace type event_job_test_t as object(
  2  object_owner varchar2(50),event_name varchar2(50));
  3  /
Type created.

创建队列表,该队列包含刚刚创建的类型 event_job_test_t所包含的属性,也就是object_owner和object_name。

SQL> begin
  2   dbms_aqadm.create_queue_table(
  3     queue_table=>'event_queue_tab',
  4     queue_payload_type=>'event_job_test_t',
  5     multiple_consumers=>true);
  6  end;
  7  /
PL/SQL procedure successfully completed.

创建一个队列,并将该队列于前面创建的队列表关联。
SQL> begin
  2   dbms_aqadm.create_queue(
  3     queue_name=>'event_queue',
  4     queue_table=>'event_queue_tab');
  5  end;
  6  /
PL/SQL procedure successfully completed.

启动该队列
SQL> begin
  2   dbms_aqadm.start_queue(queue_name=>'event_queue');
  3  end;
  4  /
PL/SQL procedure successfully completed.

创建基于事件的任务

1、创建Program


2、创建Schedule

其中 tab.user_data.object_owner=‘’HR‘’和tab.user_data.event_name=‘’give_me_an_event‘' 为两个单引号。表示该任务启动的条件为当队列出现消息,的object_owner属性为HR。event_name属性为give_me_an_event时就启动任务。

该JOB的SQL如下

BEGIN
sys.dbms_scheduler.create_job(
job_name => '"HR"."EVENT_BASED_JOB"',
job_type => 'PLSQL_BLOCK',
job_action => 'begin
   insert into event_job_test
     values(event_job_test_seq.nextval,sysdate);
end;',
event_condition => 'tab.user_data.object_owner=‘’HR‘’and
tab.user_data.event_name=‘’give_me_an_event‘’',
queue_spec => 'HR.EVENT_QUEUE',
start_date => systimestamp at time zone '+8:00',
job_class => 'DEFAULT_JOB_CLASS',
auto_drop => FALSE,
enabled => TRUE);
END;

用如下方式启动任务

declare
  l_enqueue_options dbms_aq.enqueue_options_t
  l_message_properties dbms_aq.message_properties_t
  l_message_handle raw(16)
  l_queue_msg event_job_test_t
 begin
  l_queue_msg := event_job_test_t('HR','give_me_an_event')
  dbms_aq.enqueue(
   queue_name=>'event_queue',
   enqueue_options=>l_enqueue_options,
   message_properties=>l_message_properties,
   payload=>l_queue_msg,
   msgid=>l_message_handle)
 commit
end;
/

执行完毕后在测试表中检查结果如下

SQL> select * from event_job_test ;

        ID CREATEDATE
---------- ------------------
         1 14-APR-11

删除所有创建的高级队列以及相关对象

先删除基于事件的任务

SQL> exec dbms_scheduler.drop_job('event_based_job');
PL/SQL procedure successfully completed.

停止队列
SQL> exec dbms_aqadm.stop_queue(queue_name=>'event_queue');
PL/SQL procedure successfully completed.

删除队列

SQL> exec dbms_aqadm.drop_queue(queue_name=>'event_queue');
PL/SQL procedure successfully completed.

删除队列表

SQL> exec dbms_aqadm.drop_queue_table(queue_table=>'event_queue_tab');
PL/SQL procedure successfully completed.

参考至:《教你成为10g OCP》韩思捷著

本文原创,转载请注明出处、作者

如有错误,欢迎指正

邮箱:czmcj@163.com


0
0
分享到:
评论

相关推荐

    PL/SQL 创建 oracle 任务调度

    Oracle任务调度是数据库管理系统中的一个重要特性,它允许管理员设置定期执行的任务,比如数据备份、清理、统计信息收集等。在PL/SQL环境中,有两种主要的方法来创建Oracle任务调度:可视化创建和通过代码创建。 **...

    分布式任务调度平台XXL-JOB(Oracle版)

    这里分享自己已经跑起来的Oracle版本分布式任务调度平台XXL-JOB资源。 官方只有Mysql版本的DEMO,由于近期单位项目需要,将原来DEMO稍作修改后改成了oracle版本,主要修改工作包括修改配置文件,数据库连接方式,pom...

    oracle调度任务的书写格式

    本文将详细讲解Oracle调度任务的书写格式及其相关知识点。 一、创建调度任务 创建Oracle调度任务主要涉及DBMS_SCHEDULER包中的CREATE_JOB过程。下面是一个基本的创建调度任务的示例: ```sql BEGIN DBMS_...

    oracle执行调度百度

    【标题】"Oracle执行调度百度"涉及到的是Oracle数据库系统中的调度功能,这通常指的是Oracle的Automatic Job Queue(AJQ)或者DBMS_SCHEDULER模块。Oracle数据库允许用户在特定时间或间隔执行任务,如数据备份、统计...

    ORACLE定时任务不能自动执行的检查修复步聚

    Oracle 定时任务不能自动执行的检查修复步聚 Oracle 定时任务是 Oracle 数据库中的一种功能,可以根据设置的计划执行某些任务。但是,在某些情况下,Oracle 定时任务可能不能自动执行。这可能是由于某个版本的 BUG...

    Oracle 10g的任务调度.pdf

    Oracle 10g数据库中的任务调度是数据库管理中的一个重要功能,它允许数据库管理员(DBA)安排和自动执行数据库中的任务。在Oracle 10g版本中,任务调度功能得到了加强,引入了DBMS_SCHEDULER包,它提供了一系列用于...

    利用Quartz实现任务调度的集群

    【Quartz任务调度集群】是Java开发中解决定时任务需求的一种高效方案,它由OpenSymphony团队开发,自2001年以来广泛应用于各种项目。Quartz的核心优势在于其灵活性和简单性,允许开发者自由定义任务触发的时间表,...

    任务调度Quartz框 架

    【Quartz任务调度框架】 Quartz是一个开源的任务调度框架,非常适合初学者入门。它为Java开发者提供了一种高效且可控的方式来实现定时任务的调度。在各种企业应用中,任务调度的需求非常常见,例如定期清理系统垃圾...

    quartznet任务调度和消息调度

    它可以是基于时间的(如每天、每周、每小时等),也可以是事件驱动的。触发器与任务之间是多对多的关系,意味着一个任务可以有多个触发器,反之亦然。 2. **任务和触发器的关联**: - 通过`IScheduler.ScheduleJob...

    oracle job调度存储过程 触发器 定时更新数据库

    总的来说,Oracle Job调度存储过程和触发器是数据库管理中不可或缺的工具,它们允许数据库管理员自动化许多常规任务,提高效率,减少人为错误,并确保数据的一致性和准确性。通过灵活地配置和组合这些功能,可以实现...

    PL/SQL实现Oracle数据库任务调度

    正在看的ORACLE教程是:PL/SQL实现Oracle数据库任务调度。摘要:本文主要就数据库恢复与系统任务的调度,在结合一般性的数据库后台处理的经验上,提出较为实用而新颖的解决方法,拓宽了数据库后台开发的思路。 关键词...

    基于PL_SQL的数据处理任务调度方案.pdf

    作者提出了基于Oracle PL/SQL的任务调度编程方案,该方案主要分为两类任务:建表类和更新类。建表类任务通过执行SQL语句,如“SELECT...FROM...WHERE...GROUP BY...”,从源表下载或汇总数据,生成新表。更新类任务...

    Java使用quartz实现任务调度定时任务

    Java中的任务调度是软件开发中一个重要的组成部分,它允许开发者安排任务在特定时间执行,而无需手动干预。在Java世界里,Quartz是一个强大的、完全开源的作业调度框架,广泛用于构建复杂的时间触发任务。本篇文章将...

    使用PL/SQL Developer图形界面轻松实现oracle定期计划任务

    在Oracle数据库管理中,定期执行任务是不可或缺的一部分,这通常涉及到数据库维护、数据清理、备份等操作。PL/SQL Developer是一款强大的Oracle开发工具,它提供了一个直观的图形用户界面(GUI),使得设置定期计划...

    oracle调度程序

    Oracle调度程序是Oracle数据库系统中的一个强大工具,用于管理和执行数据库中的各种定时任务。自Oracle 11g版本起,Oracle引入了全新的Scheduler特性,这一特性极大地提升了任务调度的灵活性和效率。通过使用...

    Java Oracle JOBS 自动调度

    本话题将聚焦于“Java Oracle JOBS 自动调度”,这是一个关于如何使用Java编程语言与Oracle数据库相结合来实现自动任务调度的知识点。在企业系统中,自动调度功能对于定期执行诸如数据备份、报表生成、系统维护等...

    行业文档-设计装置-基于智能任务调度平台实现异构数据库的数据处理方法.zip

    基于智能任务调度平台,可以统一管理和调度不同类型的数据库,例如SQL Server、Oracle、MySQL、Hadoop HDFS、MongoDB等,实现跨数据库的数据集成。这通常涉及数据抽取(ETL,Extract-Transform-Load)过程,将数据从...

    dolphinScheduler海豚调度器动态传递任务执行参数

    ### dolphinScheduler海豚调度器动态传递任务执行参数 #### 一、重要性及应用场景 **dolphinScheduler**(简称DS)是一款强大的分布式任务调度平台,支持多种类型的作业执行,如Shell、Python、Spark等。它能够...

    关于oracle计划任务设置的实例.rar

    在开始创建计划任务之前,需要确保Oracle调度程序服务已经启用。这可以通过运行以下SQL命令完成: ```sql BEGIN DBMS_SCHEDULER.ENABLE('USER_NAME'); END; / ``` 请将'USER_NAME'替换为实际的用户名。 步骤二:...

Global site tag (gtag.js) - Google Analytics