zoukankan      html  css  js  c++  java
  • 全面学习ORACLE Scheduler特性(9)创建Chains

    五、使用Chains

      今天要来认识一位新同学:CHAIN(注意不要敲成CHINA)。CHAIN可以被视做一组Programs的复合,举个简单的例子:运行PROGRAM:A以及PROGRAM:B,如果成功的话继续运行PROGRAM:C,否则的话运行PROGRAM:D。Programs:A、B、C、D以及执行的逻辑关系就构成了一个最简单的CHAIN。

      关于CHAIN的管理操作比较多,比如创建/删除/修改Chains,添加/修改/删除Chain Steps等等。

    5.1  创建Chains

    5.1.1  创建CHAIN对象

      创建CHAIN使用DBMS_SCHEDULER.CREATE_CHAIN过程,这个过程调用非常简单,因为需要指定的参数极少,该过程的定义如下:

    SQL> desc dbms_scheduler.create_chain;

    Parameter           Type                   Mode Default? 

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

    CHAIN_NAME          VARCHAR2               IN            

    RULE_SET_NAME       VARCHAR2               IN   Y        

    EVALUATION_INTERVAL INTERVAL DAY TO SECOND IN   Y        

      COMMENTS            VARCHAR2               IN   Y        

      在创建时,甚至可以简单到只指定一个CHAIN的名称,其它均为空即可,例如:

    SQL> exec dbms_scheduler.create_chain('my_chain1');

      PL/SQL procedure successfully completed.

      定义好的Chains,可以通过*_SCHEDULER_CHAINS视图查看,例如:

    SQL> select chain_name from user_scheduler_chains;

    CHAIN_NAME

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

      MY_CHAIN1

      注意,不是说创建了CHAIN就齐活,只有一个CHAIN对象ORACLE还是啥也干不了(当然啦,相信从上面执行的创建语句大家也看出来了),CHAIN对象创建之后,要做的工作其实才刚刚开始。其后,还需要定义Chain Steps以及Chain rules。

    5.1.2  创建Chain Step

      Chain Steps 就是用来指定CHAIN执行的操作及执行步骤,创建CHAIN STEP是通过DBMS_SCHEDULER.DEFINE_CHAIN_STEP过程进行,例如,为刚刚创建的my_chain1添加一个step,执行操作如下:

    SQL> begin

      2  DBMS_SCHEDULER.DEFINE_CHAIN_STEP (

      3     chain_name      =>  'my_chain1',

      4     step_name       =>  'my_step1',

      5     program_name    =>  'p_p1');

      6  end;

      7  /

      PL/SQL procedure successfully completed.

      Chain Steps 即可以调用PROGRAM(注意是program,不是procedure,当然program中可以定义执行procedure),也可以调用EVENT,甚至调用其它CHAIN(这就叫嵌套CHAIN)。

      下面接着为my_chain1添加两个step,操作如下:

    SQL> begin

      2  DBMS_SCHEDULER.DEFINE_CHAIN_STEP (

      3     chain_name      =>  'my_chain1',

      4     step_name       =>  'my_step2',

      5     program_name    =>  'p_p2');

      6  DBMS_SCHEDULER.DEFINE_CHAIN_STEP (

      7     chain_name      =>  'my_chain1',

      8     step_name       =>  'my_step3',

      9     program_name    =>  'p_p3');

     10  end;

     11  /

      PL/SQL procedure successfully completed.

      要查询定义的Chain Steps,则是通过*_SCHEDULER_CHAIN_STEPS视图,例如:

    SQL> select chain_name,step_name,program_name from user_scheduler_chain_steps;

    CHAIN_NAME           STEP_NAME            PROGRAM_NAME

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

    MY_CHAIN1            MY_STEP1             P_P1

    MY_CHAIN1            MY_STEP2             P_P2

      MY_CHAIN1            MY_STEP3             P_P3

    5.1.3  创建Chain Rule

      接下来,要为CHAIN的运行定义规则。定义规则是使用DBMS_SCHEDULER.DEFINE_CHAIN_RULE过程,Chain Rules依赖于Chain Steps,每个CHAIN RULE都拥有condition和action属性,当满足condition时则执行action中指定的step。

      DBMS_SCHEDULER.DEFINE_CHAIN_RULE 过程的语法如下:

    SQL> desc dbms_scheduler.define_chain_rule;

    Parameter  Type     Mode Default? 

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

    CHAIN_NAME VARCHAR2 IN            

    CONDITION  VARCHAR2 IN            

    ACTION     VARCHAR2 IN            

    RULE_NAME  VARCHAR2 IN   Y        

      COMMENTS   VARCHAR2 IN   Y        

      CHAIN_NAME 就不说了,需要注意的是CONDITION和ACTION两个参数。在为condition参数指定值时,其语法看起来稍稍复杂一些,或者说是灵活,condition参数值支持下列的语法形式:

    • TRUE
    • FALSE
    • stepname [NOT] SUCCEEDED 
    • stepname [NOT] FAILED 
    • stepname [NOT] STOPPED 
    • stepname [NOT] COMPLETED 
    • stepname ERROR_CODE IN (integer, integer, integer ...)
    • stepname ERROR_CODE NOT IN (integer, integer, integer ...)
    • stepname ERROR_CODE = integer
    • stepname ERROR_CODE != integer
    • stepname ERROR_CODE <> integer
    • stepname ERROR_CODE > integer
    • stepname ERROR_CODE >= integer
    • stepname ERROR_CODE < integer
    • stepname ERROR_CODE <= integer

      甚至于,还可以制定成下列逻辑语法:

    • expression AND expression
    • expression OR expression
    • NOT (expression)

      比如说,我们希望条件为step1成功运行,那么可以指定condition参数值如下:

      'step1 completed'

      Action 参数相对简单一些,这个参数用来指定当满足condition参数时,CHAIN执行的操作。

      例如,创建CHAIN RULE,首先执行my_step1,如果my_step1成功执行的话,就继续执行my_step2,如果my_step2也成功执行的话,则结束该CHAIN,创建脚本如下:

    SQL> BEGIN

      2  DBMS_SCHEDULER.DEFINE_CHAIN_RULE (

      3     chain_name   =>   'my_chain1',

      4     condition    =>   'TRUE',

      5     action       =>   'START my_step1',

      6     rule_name    =>   'my_rule1');

      7  DBMS_SCHEDULER.DEFINE_CHAIN_RULE (

      8     chain_name   =>   'my_chain1',

      9     condition    =>   'my_step1 completed',

     10     action       =>   'START my_step2',

     11     rule_name    =>   'my_rule2');

     12  DBMS_SCHEDULER.DEFINE_CHAIN_RULE (

     13     chain_name   =>   'my_chain1',

     14     condition    =>   'my_step2 completed',

     15     action       =>   'end 0',

     16     rule_name    =>   'my_rule3');

     17  END;

     18  /

      PL/SQL procedure successfully completed.

    5.1.4  运行Chains

      最后,来运行一下创建的my_chain1吧,手动运行CHAIN是通过DBMS_SCHEDULER.RUN_CHAIN过程,例如:

    SQL> BEGIN

      2  DBMS_SCHEDULER.RUN_CHAIN (

      3     chain_name    =>  'my_chain1',

      4     start_steps   =>  'my_step1');

      5  END;

      6  /

      PL/SQL procedure successfully completed.

      语句执行成功,下面需要查看一下执行的结果。我们之前定义的p_p1等program对象,实际上是调用procedure,向一个指定表jss_t2中插入记录,这里直接查询一下该表,就知道执行情况了(在此之前,jss_t2表为空):

    SQL> select * from jss_t2;

    TP                             DT

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

    p_p1 inserted                  03-SEP-09

      p_p2 inserted                  03-SEP-09

      你看,jss_t2表中有了两条记录,对应前面设置的CHAIN RULE,说明my_step1和my_step2均已正确执行。

      提示:Chains在执行前,必须被置于enabled状态,默认情况下刚刚创建的CHAIN都是disabled状态,要修改Chains的状态,还是通过DBMS_SCHEDULER.ENABLE和DBMS_SCHEDULER.DISABLE两过程,这里就不演示了。

      手动执行的CHAIN的话没有系统级的日志记录,因此如果希望看到详细执行情况的话,建议创建job来执行CHAIN,例如:

    SQL> BEGIN

      2  DBMS_SCHEDULER.CREATE_JOB (

      3     job_name        => 'chain_job_1',

      4     job_type        => 'CHAIN',

      5     job_action      => 'my_chain1',

      6     repeat_interval => 'freq=daily;interval=1',

      7     enabled         => TRUE);

      8  END;

      9  /

      PL/SQL procedure successfully completed.

      然后,dba就可以通过定期观察*_scheduler_job_run_details视图来确认chain的执行情况了。

  • 相关阅读:
    centos 安装python3.6 简易安装过程
    包装类型
    剑指offer二叉树中和为某一值的路径
    剑指offer 捡绳子
    按位与的技巧
    SpringBoot 登录拦截功能的实现
    AIO实现简单http服务器
    真题-数的分解
    重建二叉树
    旋转数组的最小数字
  • 原文地址:https://www.cnblogs.com/forestwolf/p/5132259.html
Copyright © 2011-2022 走看看