GaussDB数据库定时任务主要可以用于实现定期的备份、统计信息采集、数据汇总、数据清理与优化等,它是指在指定的时间间隔内自动执行一次或多次SQL语句的程序。
一、GaussDB数据库定时任务介绍
GaussDB数据库兼容Oracle定时任务功能主要通过DBE_TASK高级功能包提供的二次封装接口实现(另可参见GaussDB提供的基础接口PKG_SERVICE,此接口也可实现定时任务),主要包括创建定时任务、任务到期自动执行、任务删除、修改任务属性(任务id、任务的关闭开启、任务的触发时间、触发时间间隔、任务内容)等。
CALL DBE_TASK.ID_SUBMIT (job_id,task_name,start_time,interval_time)
1)job_id:作业号,指定job_id创建任务,其中job_id可用范围为1~32767。
2)task_name:要执行的SQL语句。支持一个或多个‘DDL’(不支持DB相关操作),‘DML’,‘匿名块’,‘调用存储过程的语句’或4种混合的场景。
3)start_time:任务的开始时间,可以使用 sysdate 表示立即执行。
4)interval_time:任务的执行间隔,例如 'interval ''1 day''' 表示每天执行一次。
需要注意的是,该功能需要在具有相应权限的数据库会话中运行,并且需要替换相应的任务名称和其他参数。此外,该功能只是提交一个定时任务,并不会立即执行任务。任务的执行时间由start_time和interval_time参数控制。
二、创建GaussDB定时任务(场景+示例)
根据GaussDB数据库定时任务应用场景,创建测试表及定时任务。
1、设置应用场景
数据备份和恢复:例如,根据业务需要,按天备份数据库中的一张日销售信息表(累全量)。(Tips:以下是模拟一个简单的业务场景,实际生产环境时,对应的字段、更优的业务逻辑处理方式,请以真实场景为准。)
创建一张日销售信息表(sell_info)和一张销售信息全量表(sell_info_full),其中包含字段有:销售编号、销售日期、商品编号、商品名称、商品数量、商品售价。全量表sell_info_full比表sell_info多一个任务执行日期字段(etl_date)。
,goods_id char(20) not null
,goods_name char(20) not null
,goods_number int not null
,sell_goods_amount int not null
INSERT INTO sell_info(sell_id,sell_date,goods_id,goods_name,goods_number,sell_goods_amount) VALUES (1001,date'2023-06-02','g_001','g_001',10,10);
--销售信息全量表(sell_info_full),
CREATE TABLE sell_info_full
,goods_id char(20) not null
,goods_name char(20) not null
,goods_number int not null
,sell_goods_amount int not null
|
2)创建存储过程,用于定时任务调度
--创建存储过程 sell_info_full_pro
CREATE PROCEDURE sell_info_full_pro()
INSERT INTO sell_info_full(
TRUNCATE TABLE sell_info;
|
任务目标:通过创建定时任务, 每天在销售系统关闭后(22:00)进行累全操作,假设job启动日期是2023-06-02,则提交一个定时任务如下:
call dbe_task.id_submit(1,'call sell_info_full_pro();','2023-06-02 22:00:00','interval ''1 day''')
|
select job,dbname,start_date,last_date,this_date,next_date,broken,status,interval,failures,what from my_jobs;
|
根据业务逻辑,查看相应的结果(此处略)。测试时可将定时“2023-06-02 22:00:00”改成立刻执行“sysdate”,然后查看执行结果。
2、更多适用场景
1)数据清理和优化:例如,定期归档(清理)数据库中的无用数据、过期数据和重复数据,并对数据库进行性能优化,以提高数据库的运行效率和稳定性。
2)数据统计和分析:例如,根据业务需求,定期从数据库中提取数据并进行统计和分析,以便为企业决策提供支持。
3)定时任务通知:例如,通过定时任务向用户发送邮件、短信或其他通知信息,提醒用户关注某些重要的业务活动或事件。
4)定时更新状态:例如,商品定时开售,活动到期自动修改为已结束状态,活动结束商品自动下架,超过三十分钟未支付自动取消订单,到期自动解冻账号。
……
三、管理GaussDB定时任务
1、查看已创建的任务
通过MY_JOBS视图查看当前用户所属的定时任务详情
select job,dbname,start_date,last_date,this_date,next_date,broken,status,interval,failures,what from my_jobs;
|
MY_JOBS视图为当前用户所属定时任务的详细信息,其字段含义参见下表:
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
timestamp without time zone
|
|
|
|
|
|
timestamp without time zone
|
|
|
|
|
|
|
|
|
timestamp without time zone
|
|
|
|
|
|
|
|
|
timestamp without time zone
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
执行状态,取值范围:('r', 's', 'f', 'd'),默认为'r',取值含义:r=running、s=successfully finished、f= job failed、d=aborted
|
|
|
用来计算下次运行时间的时间表达式,如果为null则表示定时任务只执行一次。
|
|
|
|
|
|
|
2、停用/启用任务
call dbe_task.finish(id, broken, next_time);
|
call dbe_task.finish(1,true);
|
2)启用任务,则是将任务正常启动, 按任务设置执行相应的SQL语句或程序
call dbe_task.finish(1,false,'2023-06-02 22:00:00');
|
3、修改任务
1)DBE_TASK.UPDATE——修改定时任务的属性,包括任务内容、下次执行时间、执行间隔。
DBE_TASK.CONTENT ——修改可执行的SQL语句块
DBE_TASK.NEXT_TIME——修改下次执行时间属性
DBE_TASK.INTERVAL——修改执行时间间隔
4、删除任务
DBE_TASK.CANCEL——删除指定的定时任务。
小结:以上所有管理过程,均以任务作业号为唯一键进行操作。
四、总结
GaussDB数据库提供了丰富的定时任务功能。需要注意的是,定时任务的设置和使用需要谨慎,避免误删重要数据或影响业务正常运行。同时,也需要保证定时任务的可靠性和稳定性,避免出现任务漏执行或执行重复的情况。
总之,在使用GaussDB数据库时,创建定时任务可以在很多场景中应用,同时可以帮助我们提高系统的运行效率和方便性等。