五、使用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 

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的执行情况了。