4.2 Application抛出的Events

  首先要说明,这里所说的Application是个代词,即可以表示ORACLE数据库之外的应用程序,也可以是ORACLE数据库中的PROCEDURE等对象,总之你就将其理解成用户自己创建的对象就好了。

  Scheduler 能够抛出Events让外部应用处理,外部的应用也可以抛出Events让Scheduler启动job处理,不过并不是任何job都能够对外部应用抛出的Events做出响应,必须在创建jobs时明确指定响应的事件。那么如何指定呢?依靠下列两个附加的参数:

  • queue_spec :指定外部应用抛出的events消息入队的队列名;
  • event_condition :指定触发job启动的条件,这一参数的参数值在设置时应当基于事件消息的自身属性,因为事件消息在入队时,消息的属性都是由application定义的,因此在设置触发条件时,也应该根据这些属性值就行设置。

  下面,我们就演示创建一个由event触发启动的job,在此之前,首先需要进行一些准备工具,比如创建队列,由于队列需要基于一个队列表,因此在创建队列之前,首先要创建一个队列表,考虑到队列表需要依赖一个对象类型,因此在创建队列表之前,先得创建一个type.......复杂,具体的操作步骤如下,客官可要看仔细了:

    SQL> create or replace type jss_type 1  as object

      2  (

      3    event_type         VARCHAR2( 1 0),

      4    object_owner       VARCHAR2( 30 ),

      5    object_name        VARCHAR2( 3 0)

      6  );

      7  /

    Type created.

    SQL> begin

      2    dbms_aqadm.create_queue_table(

      3      queue_table        => ¨my_queue_tbl1¨,

      4      queue_payload_type => ¨JSS_TYPE1¨,

      5      multiple_consumers => true);

      6  end;

      7  /

    PL/SQL procedure successfully completed.

    SQL> begin

      2    dbms_aqadm.create_queue(

      3      queue_name  => ¨event_t1¨,

      4      queue_table => ¨my_queue_tbl1¨);

      5  end;

      6  /

    PL/SQL procedure successfully completed.

  OK, 准备工作完成,下面就来创建一个event触发启动的job,创建脚本如下:

    SQL> BEGIN

      2  DBMS_SCHEDULER.CREATE_JOB (

      3     job_name            =>  ¨EVENT_JOB_T1¨,

      4     job_type            =>  ¨STORED_PROCEDURE¨,

      5     job_action          =>  ¨P_INSERTINTOTEST¨,

      6     event_condition     =>  ¨tab.user_data.event_type = ¨¨OP_INSERT¨¨¨,

      7     queue_spec          =>  ¨EVENT_T1¨,

      8     enabled             =>  TRUE);

      9  END;

     10  /

    PL/SQL procedure successfully completed.

  上述脚本仅做演示,因此创建的job仍然执行P_INSERTINTOTEST过程。

  三思并不准备再编写一套外部的应用来触发,这里仅为了演示application触发job启动的示例,因此三思决定通过pl/sql直接向event_t1队列中添加消息的方式,触发job的启动,具体操作如下。

  首先要执行DBMS_AQADM.START_QUEUE过程,将event_t1置于允许入队和出队状态(默认情况下创建的队列是不允许出队和入队操作的),脚本如下:

    SQL> exec dbms_aqadm.start_queue(queue_name => ¨event_t1¨,enqueue => true,dequeue => true);

    PL/SQL procedure successfully completed.

  执行入队操作:

    SQL> declare

      2    v_Message           jss_type1;

      3    v_EnqueueOptions    dbms_aq.enqueue_options_t;

      4    v_MessageProperties dbms_aq.message_properties_t;

      5    v_msg_handle        raw(16);

      6  begin

      7    v_message := jss_type1(¨OP_ SELECT ¨, user, ¨tmpObj¨);

      8

      9    dbms_aq.enqueue(queue_name         => ¨event_t1¨,

     10                    enqueue_options    => v_enqueueOptions,

     11                    message_properties => v_messageproperties,

     12                    payload            => v_message,

     13                    msgid              => v_msg_handle);

     14    commit;

     15

     16  end;

     17  /

    PL/SQL procedure successfully completed.

  查询队列表中的数据:

    SQL> select user_data from my_queue_tbl1;

    USER_DATA(EVENT_TYPE, OBJECT_OWNER, OBJECT_NAME)

    ---------------------------------------------------------

    JSS_TYPE1(¨OP_SELECT¨, ¨TEST¨, ¨tmpObj¨)

  然后查询job

    SQL> select to_char(created,¨yyyy-mm-dd hh24:mi:ss¨) from jss_1;

    TO_CHAR(CREATED,¨YY

    -------------------

    2009-08-25 12:49:29

  看起来jss_1表中并未有新增加记录,似乎job没有执行啊。这很正常,还记得咱们创建job时指定的 event_condition 条件吗:

      6     event_condition     =>  ¨tab.user_data.event_type = ¨¨OP_INSERT¨¨¨,

  没错,只有当event_type为¨OP_INSERT¨时才会触发job的执行,前面入队时指定的是 OP_ SELECT ,当然没有触发job中指定的procedure啦,下面再次执行入队操作:

    SQL> declare

      2    v_Message           jss_type1;

      3    v_EnqueueOptions    dbms_aq.enqueue_options_t;

      4    v_MessageProperties dbms_aq.message_properties_t;

      5    v_msg_handle        raw(16);

      6  begin

      7    v_message := jss_type1(¨OP_INSERT¨, user, ¨tmpObj¨);

      8

      9    dbms_aq.enqueue(queue_name         => ¨event_t1¨,

     10                    enqueue_options    => v_enqueueOptions,

     11                    message_properties => v_messageproperties,

     12                    payload            => v_message,

     13                    msgid              => v_msg_handle);

     14    commit;

     15

     16  end;

      17  /

  再次查看jss_1表看看:

    SQL> select to_char(created,¨yyyy-mm-dd hh24:mi:ss¨) from jss_1;

    TO_CHAR(CREATED,¨YY

    -------------------

    2009-08-25 12:49:29

    2009-08-25 13:21:21

  多了一条记录,说明job已经被自动触发。

  最后再补充一句,基于event的job不能通过DBMS_SCHEDULER.RUN_JOB过程执行,否则会触发ORA-00942: table or view does not exist错误。