很好的理解 job chain window

时间  2019-11-25
标签 很好 理解 job chain window 栏目 Windows 繁體版
原文   原文链接 
今天和你们分享一下

1.     做业(job)，2.调度(scheduler)，3.程序(program)，4.链(chain)，4.做业类(job_class)，5.窗口(window)，6.窗口组(window_group)
完全揭开他们神秘的面纱。

在oracle 8i,9i中使用dbms_job方式留做业。其限制有二。
一是调度的时间很差控制，不太灵活，对时间的间隔难于把握。
二是不能调度操做系统的脚本，只能调度数据库内的程序或者语句。
随着技术的发展，oracle在10g，11g 中推出了新的一代调度程序dbms_scheduler，这个程序克服了上面的两个缺点。
下面咱们介绍如何使用调度程序dbms_scheduler。

咱们首先了解一下时间间隔的问题。
repeat_interval => 'FREQ=MINUTELY; INTERVAL=30'  
这句话的含义为：每30分钟运行重复运行一次！
repeat_interval => 'FREQ=YEARLY; BYMONTH=MAR,JUN,SEP,DEC; BYMONTHDAY=30' 　
这句话的含义为：每一年的3,6,9,12月的30号运行job
一眼看上去格式有点乱，没有章法，不如之前的时间间隔明白。由于咱们不知道格式的含义。
日历表达式基本分为三部分:
第一部分是频率，也就是"FREQ"这个关键字，它是必须指定的;
第二部分是时间间隔，也就是"INTERVAL"这个关键字，取值范围是1-999. 它是可选的参数;
最后一部分是附加的参数,可用于精确地指定日期和时间,它也是可选的参数,例以下面这些值都是合法的:
BYMONTH,BYWEEKNO,BYYEARDAY,BYMONTHDAY,BYDAY,BYHOUR,BYMINUTE,BYSECOND
repeat_interval => 'FREQ=HOURLY; INTERVAL=2' 每隔2小时运行一次job
repeat_interval => 'FREQ=DAILY'　　天天运行一次job
repeat_interval => 'FREQ=WEEKLY; BYDAY=MON,WED,FRI"　　每周的1,3,5运行job
既然说到了repeat_interval,你可能要问:"有没有一种简便的方法来得出，或者说是评估出job的每次运行时间，以及下一次的运行时间呢?"
dbms_scheduler包提供了一个过程evaluate_calendar_string,能够很方便地完成这个需求. 来看下面的例子:
set serveroutput on size 999999
declare
L_start_date TIMESTAMP;    --声明须要的变量
l_next_date TIMESTAMP;
l_return_date TIMESTAMP;
begin
l_start_date := trunc(SYSTIMESTAMP); --取当前的时间
l_return_date := l_start_date;
for ctr in 1..10 loop      --循环10次
dbms_scheduler.evaluate_calendar_string(
'FREQ=DAILY; BYDAY=MON,TUE,WED,THU,FRI; BYHOUR=7,15',
l_start_date, l_return_date, l_next_date);
dbms_output.put_line('Next Run on: ' ||
to_char(l_next_date,'mm/dd/yyyy hh24:mi:ss')); --打印下次运行的时间
l_return_date := l_next_date;
end loop;
end;
/
结果以下：
Next Run on: 08/08/2014 07:00:00
Next Run on: 08/08/2014 15:00:00
Next Run on: 08/11/2014 07:00:00
Next Run on: 08/11/2014 15:00:00
Next Run on: 08/12/2014 07:00:00
Next Run on: 08/12/2014 15:00:00 
Next Run on: 08/13/2014 07:00:00
Next Run on: 08/13/2014 15:00:00
Next Run on: 08/14/2014 07:00:00
Next Run on: 08/14/2014 15:00:00
 
咱们看一下数据库本身带的调度的时间间隔。
col REPEAT_INTERVAL for a45
SQL>select job_name,repeat_interval from dba_scheduler_jobs;
JOB_NAME                       REPEAT_INTERVAL
------------------------------ ------------------------------------------
AUTO_SPACE_ADVISOR_JOB
GATHER_STATS_JOB
FGR$AUTOPURGE_JOB              freq=daily;byhour=0;byminute=0;bysecond=0
PURGE_LOG
RLM$SCHDNEGACTION              FREQ=MINUTELY;INTERVAL=60
RLM$EVTCLEANUP                 FREQ = HOURLY; INTERVAL = 1
 
已选择6行。
咱们发现有6个做业存在，但只有3个有时间的间隔。
很好理解，天天0点运行，其它的为间隔1小时运行，但为何有3个没有时间间隔呢？
col JOB_NAME for a23
col SCHEDULE_NAME for a25
SQL> select JOB_NAME,REPEAT_INTERVAL,SCHEDULE_NAME from DBA_SCHEDULER_JOBS;
 
JOB_NAME                REPEAT_INTERVAL                               SCHEDULE_NAME
----------------------- --------------------------------------------- ------------------------
AUTO_SPACE_ADVISOR_JOB                                                MAINTENANCE_WINDOW_GROUP
GATHER_STATS_JOB                                                      MAINTENANCE_WINDOW_GROUP
FGR$AUTOPURGE_JOB       freq=daily;byhour=0;byminute=0;bysecond=0
PURGE_LOG                                                             DAILY_PURGE_SCHEDULE
RLM$SCHDNEGACTION       FREQ=MINUTELY;INTERVAL=60
RLM$EVTCLEANUP          FREQ = HOURLY; INTERVAL = 1
 
已选择6行。
咱们看到一个现象，有时间间隔的没有调度的名称，有调度名称的就没有时间间隔。
那什么是调度呢？数据库为经常使用的时间间隔编写一个程序策略。叫作调度(scheduler)。
例如：
一个任务计划执行的时间策略.好比咱们想要建立一个晚上3点执行的任务计划,就能够建立一个调度,凡是符合这个调度要求的,均可以调用这个咱们预先建立好的调度.能够用dbms_scheduler.create_schedule来建立一个调度.
 
好比我建立一个名字叫MYTEST_SCHEDULE的调度,天天4:00执行.
Begin
　　dbms_scheduler.create_schedule(
　　 repeat_interval => 'FREQ=DAILY;BYHOUR=4;BYMINUTE=0;BYSECOND=0',
　　start_date => systimestamp at time zone 'PRC',
　　 comments => '---this is my test schedule---',
　　schedule_name => 'MYTEST_SCHEDULE');
END;
/
 
上面咱们看到PURGE_LOG的做业调度为DAILY_PURGE_SCHEDULE。
SQL> select REPEAT_INTERVAL from DBA_SCHEDULER_SCHEDULES where
 2 SCHEDULE_NAME='DAILY_PURGE_SCHEDULE';
 
REPEAT_INTERVAL
---------------------------------------------
freq=daily;byhour=3;byminute=0;bysecond=0
咱们看到了该策略为天天3点运行。
但GATHER_STATS_JOB的调度为MAINTENANCE_WINDOW_GROUP，这又是什么呢？
这是窗口组！
SQL> select * from DBA_SCHEDULER_WINGROUP_MEMBERS;
 
WINDOW_GROUP_NAME              WINDOW_NAME
------------------------------ -------------------
MAINTENANCE_WINDOW_GROUP       WEEKNIGHT_WINDOW
MAINTENANCE_WINDOW_GROUP       WEEKEND_WINDOW
咱们看到维护窗口组MAINTENANCE_WINDOW_GROUP中有两个窗口。
窗口又是什么呢？
SQL> COL WINDOW_NAME FOR A20
SQL> COL REPEAT_INTERVAL FOR A79
SQL> SELECT WINDOW_NAME,REPEAT_INTERVAL FROM DBA_SCHEDULER_WINDOWS;
WINDOW_NAME          REPEAT_INTERVAL
-------------------- ---------------------------------------------------------------------
WEEKNIGHT_WINDOW     freq=daily;byday=MON,TUE,WED,THU,FRI;byhour=22;byminute=0; bysecond=0
WEEKEND_WINDOW       freq=daily;byday=SAT;byhour=0;byminute=0;bysecond=0
平时天天晚上10点运行，周六0点运行！
 
窗口(window):
 
　　能够当作是一个更高功能的调度,窗口能够调用系统中存在的调度(也能够自行定义执行时间),并且,具备资源计划限制功能,窗口能够归属于某个窗口组.
 
　　可使用DBMS_SCHEDULER.CREATE_WINDOW来建立一个窗口.
 
　　例如我建立了一个名为mytest_windows_1的窗口,采用DAILY_PURGE_SCHEDULE的调度方式,资源计划限制方案为 SYSTEM_PLAN,持续时间为4小时.
 
BEGIN
　　DBMS_SCHEDULER.CREATE_WINDOW(
　　 window_name=>'mytest_windows_1',
　　 resource_plan=>'SYSTEM_PLAN',
　　 schedule_name=>'SYS.DAILY_PURGE_SCHEDULE',
　　 duration=>numtodsinterval(240, 'minute'),
　　 window_priority=>'LOW',
　　comments=>'');
　　END;
/
 
窗口组(window_group):
 
　　一个/几个窗口的集合.10g默认的自动采集统计信息的调度就是一个窗口组的形式,譬如,设置两个窗口,窗口一指定任务周日-----周五,晚上12点执行,而窗口二设定周六凌晨3点执行,这两个窗口组成了一个窗口组,造成了这个job的执行调度策略.
 
　　可使用DBMS_SCHEDULER.CREATE_WINDOW_GROUP来建立一个窗口组.
BEGIN
　　DBMS_SCHEDULER.CREATE_WINDOW_GROUP(
　　 group_name=>'mytest_window_group',
　　 window_list=>'MYTEST_WINDOWS_1,WEEKEND_WINDOW');
　　END;
/
关于调度时间的问题咱们搞清楚了，如今咱们看一下调度的内容问题！
SQL> col PROGRAM_NAME for a40
SQL> select JOB_NAME,PROGRAM_NAME from DBA_SCHEDULER_JOBS;
 
JOB_NAME                PROGRAM_NAME
----------------------- --------------------------------------
AUTO_SPACE_ADVISOR_JOB AUTO_SPACE_ADVISOR_PROG
GATHER_STATS_JOB        GATHER_STATS_PROG
FGR$AUTOPURGE_JOB
PURGE_LOG               PURGE_LOG_PROG
RLM$SCHDNEGACTION
RLM$EVTCLEANUP
 
已选择6行。
咱们还研究GATHER_STATS_JOB这个做业，这个做业作什么？是一个程序，叫作GATHER_STATS_PROG，GATHER_STATS_PROG内容是什么呢？
SQL> select PROGRAM_ACTION from DBA_SCHEDULER_PROGRAMS
where PROGRAM_NAME='GATHER_STATS_PROG';
 
PROGRAM_ACTION
---------------------------------------------------------------------
dbms_stats.gather_database_stats_job_proc
啊，原来就是一个存储过程。咱们一步步的把调度的神秘面纱剥掉了！
如今我总结一下：有个程序GATHER_STATS_PROG，该程序调用了一个存储过程。
有个窗口组MAINTENANCE_WINDOW_GROUP，其内含有平时和周末两个策略。
咱们的做业GATHER_STATS_JOB就是在MAINTENANCE_WINDOW_GROUP窗口组的时间内运行程序GATHER_STATS_PROG。搞的挺复杂，其实不难！
调度中还有两个概念咱们没有讲到。一个为链(chain)，一个为做业类(job_class)。
链(chain):
　　链能够看做是一个/几个program/event scheduler的集合,为了维护须要,咱们可能须要将不少不一样的program放到一块儿依次执行,按照之前的模式,要么将这几个program能整合成一个大的总体,要么分开几个job来单独执行,这无疑加剧了维护负担,而chain的出现,能够优化这个问题,咱们将实现定义好的program集合到一块儿,而后统一制定一个job来执行,可使用dbms_scheduler.create_chain来建立一个chain.
 
　　好比,在个人系统中,我分别建立了一个EXECUTABLE类型的和一个STORED PROCEDURE类型的program,我须要他们顺次执行,因而我能够这么作:
 
BEGIN
　　dbms_scheduler.create_chain( chain_name =>'MYTEST_CHAIN');
　　dbms_scheduler.define_chain_step(chain_name =>'MYTEST_CHAIN', step_name =>'mytest_chain_1',program_name =>'P_1');
　　 dbms_scheduler.alter_chain(chain_name =>'MYTEST_CHAIN', step_name =>'mytest_chain_1',attribute=>'skip',value=>FALSE);
　　 dbms_scheduler.define_chain_step(chain_name =>'MYTEST_CHAIN',step_name =>'mytest_chain_2',program_name =>'P_2');
　　 dbms_scheduler.alter_chain(chain_name =>'MYTEST_CHAIN',step_name =>'mytest_chain_2',attribute=>'skip', value=>FALSE);
　　dbms_scheduler.enable('MYTEST_CHAIN');
　　 END;
/
 
做业类(job_class):
 
　　定义了运行做业的资源使用者组.经过使用窗口中的资源计划,咱们能够在不一样资源组和不一样做业类之间分配资源.可使用 dbms_scheduler.create_job_class建立一个做业类.
BEGIN
　　dbms_scheduler.create_job_class(
　　 logging_level => DBMS_SCHEDULER.LOGGING_RUNS,
　　 log_history => 100,
　　 resource_consumer_group => 'AUTO_TASK_CONSUMER_GROUP',
　　 job_class_name => 'MYTEST_JOB_CLASS');
　　END;
/
调度的概念都讲解完了，咱们总结一下：
1.     做业(job)，2.调度(scheduler)，3.程序(program)，4.链(chain)，4.做业类(job_class)，5.窗口(window)，6.窗口组(window_group)
这些不是必须的。咱们能够直接留做业，和之前dbms_job同样，并且能够运行操做系统的脚本。
begin
　　dbms_scheduler.create_job
　　(
　　job_name => 'ARC_MOVE',
 repeat_interval => 'FREQ=MINUTELY; INTERVAL=30',
　　job_type => 'EXECUTABLE',
　　job_action => '/home/dbtools/move_arcs.sh',
　　enabled => true,
　　comments => 'Move Archived Logs to a Different Directory'
　　);
　　end;
/
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程