Oracle（三）之任务调度

Oracle任务调度概述 

在Oracle中任务调度指某一执行程序在特定的时间被周期性的执行。Oracle把任务调度称为job。而一个基本的job由两方面组成program和schedule。其中program指周期性执行的可执行程序，其中可包括PL\SQL匿名块，存储过程、函数、包以及操作系统的可执行脚本和外部程序等等。schedule指的是，调度program执行的周期。该周期既可以基于特定时间被调度，也可以基于某一事件被调度。因而JOB总体上可分为两大类，基于时间的JOB和基于事件的JOB。在Oracle 10g之前，采用dbms_job程序包来完成任务调度的相关工作。在Oracle 10g之后，Oracle推出了功能更加强大的dbms_schedule来完成任务调度工作，主要是由于dbms_schedule能够基于事件进行任务调度而dbms_job无法基于事件进行调度（笔者个人浅见，待验证）！ 基于时间的JOB 创建Program截图 

Administration->Programs->Create

BEGIN 

DBMS_SCHEDULER.CREATE_PROGRAM( 

program_name=>'HR.INSERT_SYSDATE', program_action=>'begin 

insert into hr.job_test values(sysdate); commit; end', 

program_type=>'PLSQL_BLOCK', number_of_arguments=>0, 

comments=>'insert sysdate into table', enabled=>TRUE); END;

其中program类型里有3个选项分别代表 

PLSQL_BLOCK:表示该程序为可执行的PL\SQL匿名块 STORED_PORCEDURE:表示程序为存储过程、函数或程序包 EXECUTABLE：表示程序为位于操作系统上的可执行脚本或程序

在Repeating部分，我们指定启动的频率，在指定启动频率时应采用日历表达式。起格式由3部分组成：频率、间隔、特定时间点。每隔2天：FREQ=DAYLY；INTERVAL=2 每隔30妙：FREQ=SECONDLY;INTERVAL=30 每周的第一天：FREQ=WEEKLY;BYMONTHDAY=1 每月的最后一天：FREQ=MONTHLY;BYMONTHDAY=-1

创建Schedule截图 

Administration->Schedules->Create 

创建Schedule的SQL如下 

BEGIN 

sys.dbms_scheduler.create_schedule( 

repeat_interval => 'FREQ=MINUTELY;INTERVAL=5', start_date => systimestamp at time zone '+8:00', comments => 'Start Every 5 minutes', schedule_name => '"HR"."INSERT_SCHE"'); END;

 

其中Schedule Type中可选择Schedule的类型

Standard：为标准的Schedule类型，需要用户自行定义Schedule的时间

Use Pre-defined Schedule:使用之前定义过的Schedule

Standard Using PL\SQL for repeated interval:使用PL\SQL编写Schedule的时间

Use Pre-defined Window:使用之前定义的Window

Event:使用基于时间的Schedule

JOB里的Options选项

<!--[if gte vml 1]><v:shapetype id="_x0000_t75" coordsize="21600,21600" o:spt="75" o:preferrelative="t" path="m@4@5l@4@11@9@11@9@5xe" filled="f" stroked="f"> <v:stroke joinstyle="miter"/> <v:formulas> <v:f eqn="if lineDrawn pixelLineWidth 0"/> <v:f eqn="sum @0 1 0"/> <v:f eqn="sum 0 0 @1"/> <v:f eqn="prod @2 1 2"/> <v:f eqn="prod @3 21600 pixelWidth"/> <v:f eqn="prod @3 21600 pixelHeight"/> <v:f eqn="sum @0 0 1"/> <v:f eqn="prod @6 1 2"/> <v:f eqn="prod @7 21600 pixelWidth"/> <v:f eqn="sum @8 21600 0"/> <v:f eqn="prod @7 21600 pixelHeight"/> <v:f eqn="sum @10 21600 0"/> </v:formulas> <v:path o:extrusionok="f" gradientshapeok="t" o:connecttype="rect"/> <o:lock v:ext="edit" aspectratio="t"/> </v:shapetype><v:shape id="Picture_x0020_1" o:spid="_x0000_i1025" type="#_x0000_t75" alt="http://img181.poco.cn/mypoco/myphoto/20110414/21/5616035720110414211905010.jpg" style='width:525.75pt;height:148.5pt;visibility:visible;mso-wrap-style:square'> <v:imagedata src="file:///C:\Users\lidao\AppData\Local\Temp\msohtmlclip1\01\clip_image001.jpg" o:title="5616035720110414211905010"/> </v:shape><![endif]--><!--[if !vml]--><!--[endif]-->

 

Priority:在相同的JOB CLASS中分配资源的等级。

Schedule Limit(minutes):计划执行的任务如果在计划时间内没有被执行则在Schedule Limit规定的时间内重新执行。该选项只对重复执行的任务有效。

Maximum Runs:任务执行成功次数达到Maximum Runs指定的次数后任务则不再执行

Maximum Failures:持续执行的任务可失败的最大次数，达到Maximum Failures指定的值后该任务自动失效

Job Weight:该JOB所支持的最大并行查询

Instance Stickiness:应用在RAC环境中。如果设置为TRUE，那么该JOB将在负载最轻的实例上运行。如果设置为FLASE，将在第一个有效的节点上运行嗯该JOB。

 

创建JOB的SQL如下 

BEGIN 

sys.dbms_scheduler.create_job( job_name => '"HR"."INSERT_JOB"', 

program_name => 'HR.INSERT_SYSDATE', schedule_name => 'HR.INSERT_SCHE', job_class => 'DEFAULT_JOB_CLASS', 

comments => 'insert sysdate into table', auto_drop => FALSE, enabled => FALSE); 

sys.dbms_scheduler.set_attribute( name => '"HR"."INSERT_JOB"', 

attribute => 'schedule_limit', value => numtodsinterval(1, 'minute')); 

sys.dbms_scheduler.set_attribute( name => '"HR"."INSERT_JOB"', attribute => 'job_priority', value => 2); 

sys.dbms_scheduler.set_attribute( name => '"HR"."INSERT_JOB"', attribute => 'max_runs', value => 10); 

sys.dbms_scheduler.set_attribute( name => '"HR"."INSERT_JOB"', attribute => 'max_failures', value => 3); 

sys.dbms_scheduler.set_attribute( name => '"HR"."INSERT_JOB"', attribute => 'job_weight', value => 4); 

sys.dbms_scheduler.set_attribute( name => '"HR"."INSERT_JOB"', attribute => 'instance_stickiness', value => TRUE);

 

END;