Oracle定时任务的创建与禁用/删除

在开始操作之前,先从三W开始,即我常说的what 是什么;why 为什么使用;how 如何使用。

一、Oracle定时器是什么

Oracle定时器是一种用于在特定时间执行任务或存储过程的工具,可以根据需求设置不同的时间段和频率来执行相应的操作。

二、为什么使用Oracle定时器

使用Oracle定时器的好处在于可以自动化执行重复性的任务,比如每天、每周或每月执行一次数据库维护、数据备份等操作,从而减轻了人工操作的负担,提高了工作效率。

三、如何使用Oracle定时器

使用Oracle定时器的方法包括编写存储过程来定义需要执行的任务,然后创建一个定时器Job来调度这个存储过程。可以根据具体需求设置定时器的执行时间、频率和其他参数,以实现自动化执行任务的目的。

四、目前有哪些主流Oracle定时器?有何区别?

目前主流的Oracle定时器有两种:DBMS_SCHEDULER和DBMS_JOB。它们之间有以下区别:
1. DBMS_SCHEDULER:DBMS_SCHEDULER是Oracle 10g及以上版本引入的定时器。它提供了更强大和灵活的功能,可以创建和管理复杂的作业调度。DBMS_SCHEDULER使用了面向对象的方式来定义作业和调度器,并且支持多种类型的作业,如PL/SQL块、存储过程、外部脚本等。它还支持更多的调度选项,如基于时间、日期、事件等触发器,以及更灵活的重复调度设置。

2. DBMS_JOB:DBMS_JOB是Oracle 9i及以下版本中使用的定时器。它相对简单,只能调度PL/SQL块作业。DBMS_JOB使用了过程式的方式来定义作业和调度器,调度选项相对较少,只能基于时间间隔来触发作业。此外,DBMS_JOB的调度信息存储在数据库中的JOB表中。

总的来说,DBMS_SCHEDULER比DBMS_JOB更强大和灵活,适用于复杂的作业调度需求。而DBMS_JOB则更简单,适用于简单的定时任务。

介绍了概念,接下来是实际使用,参考自蒋老师的文章,感谢蒋老师的分享和归纳——

oracle 定时任务 (yuque.com)icon-default.png?t=N7T8https://www.yuque.com/ernanbei/fh8sgs/fn20rxtaosmfdfnq?singleDoc#最常见的定时场景就是周期性统计动态变化的数据,以我为例,我需要在项目中加入一个Oracel定时器,每三分钟统计一次数据,那首先得写一个函数用于操作数据的读取和存储,其次是设置定时器,通过定时器定时周期性调度执行该函数,从而实现数据的周期性的获取。

1、函数的编写

create PROCEDURE SYNCHRONIZE_HONORING_HISTORY
ASV_ERR_MSG NVARCHAR2(1000);V_COUNT_1 NUMBER(1);V_COUNT_2 NUMBER(5) :=0;--查询当天的数据cursor c_job is select APPLY_RECORD_ID,COMMENDATION_ID,COMMENDATION_NAME,USER_NAMES,UPDATE_DATE,COMMENDATION_SOURCE,COMMENDATION_SOURCE_NAME,COMPETENCE_DIMENSION,COMPETENCE_DIMENSION_NAME,SUM_SCORE,BASE_DEPT_IDfrom (select APPLY_RECORD_ID,COMMENDATION_ID,COMMENDATION_NAME,substr(USER_NAME, 0, instr(USER_NAME, ',', -1) - 1) USER_NAMES,UPDATE_DATE,COMMENDATION_SOURCE,COMMENDATION_SOURCE_NAME,COMPETENCE_DIMENSION,COMPETENCE_DIMENSION_NAME,SUM_SCORE,BASE_DEPT_IDfrom (select A.APPLY_RECORD_ID,A.COMMENDATION_ID,C.COMMENDATION_NAME,xmlagg(xmlelement(e, d.name, ',').extract('//text()')).getclobval() USER_NAME,A.UPDATE_DATE,C.COMMENDATION_SOURCE,E.DICT_VALUE                                                        COMMENDATION_SOURCE_NAME,c.COMPETENCE_DIMENSION,F.DICT_VALUE                                                        COMPETENCE_DIMENSION_NAME,sum(B.SCORE)                                                        SUM_SCORE,A.BASE_DEPT_IDfrom (select APPLY_RECORD_ID,COMMENDATION_ID,UPDATE_DATE,BASE_DEPT_IDfrom DIAN_COMMENDATION_APPLY_RECORD Awhere APPLY_STATUS = 'APPROVED'and UPDATE_DATE >= trunc(sysdate)and UPDATE_DATE <= trunc(sysdate+ 1)) Aleft join (select SOURCE_ID, USER_ID, SCORE,USER_ACCOUNT_IDfrom DIAN_COMMENDATION_DISTRIBUTE_RECORD DRwhere DR.CREATION_DATE >= trunc(sysdate)and DR.CREATION_DATE <=  trunc(sysdate+ 1)) Bon a.APPLY_RECORD_ID = B.SOURCE_IDleft join DIAN_COMMENDATION Con A.COMMENDATION_ID = c.COMMENDATION_IDleft join (select A.USER_ID,A.NAME,B.USER_ACCOUNT_IDfrom DIAN_USER_EXPAND Aleft join DIAN_USER_ACCOUNT bon a.USER_ID=b.USER_ID) Don B.USER_ID = D.USER_IDand B.USER_ACCOUNT_ID = D.USER_ACCOUNT_IDleft join (select DICT_VALUE, DICT_KEYfrom DIAN_DICTIONARY_MAPwhere DICT_TYPE = 'COMMENDATION_SOURCE'and IS_ENABLE = 1) Eon E.DICT_KEY = c.COMMENDATION_SOURCEleft join (select DICT_VALUE, DICT_KEYfrom DIAN_DICTIONARY_MAPwhere DICT_TYPE = 'COMPETENCE_DIMENSION'and IS_ENABLE = 1) Fon F.DICT_KEY = c.COMPETENCE_DIMENSIONgroup by A.APPLY_RECORD_ID,A.COMMENDATION_ID,C.COMMENDATION_NAME,A.UPDATE_DATE,C.COMMENDATION_SOURCE,E.DICT_VALUE,c.COMPETENCE_DIMENSION,F.DICT_VALUE,A.BASE_DEPT_ID));/*** create by: lcb* create date:2023-10-30* modify by:wxx* modify date:2023-12-8 加入基地ID BASE_DEPT_ID* describe:同步当天表彰历史数据 (每3分钟同步一次)*/
BEGIN--循环FOR ITEM IN C_JOBLOOP--  判断数据是否存在SELECT COUNT(1) INTO V_COUNT_1 FROM DIAN_HONORING_HISTORY WHERE APPLY_RECORD_ID = ITEM.APPLY_RECORD_ID;IF V_COUNT_1 = 0 THEN-- 不存在则添加数据INSERT INTO DIAN_HONORING_HISTORY(APPLY_RECORD_ID,COMMENDATION_ID,COMMENDATION_NAME,USER_NAMES,UPDATE_DATE,COMMENDATION_SOURCE,COMMENDATION_SOURCE_NAME,COMPETENCE_DIMENSION,COMPETENCE_DIMENSION_NAME,SUM_SCORE,BASE_DEPT_ID)VALUES (ITEM.APPLY_RECORD_ID,ITEM.COMMENDATION_ID,ITEM.COMMENDATION_NAME,ITEM.USER_NAMES,ITEM.UPDATE_DATE,ITEM.COMMENDATION_SOURCE,ITEM.COMMENDATION_SOURCE_NAME,ITEM.COMPETENCE_DIMENSION,ITEM.COMPETENCE_DIMENSION_NAME,ITEM.SUM_SCORE,ITEM.BASE_DEPT_ID);IF V_COUNT_2 < 100 THENV_COUNT_2 := V_COUNT_2 + 1;ELSEV_COUNT_2 := 0;COMMIT;END IF;END IF;END LOOP;COMMIT;
EXCEPTIONWHEN OTHERS THENROLLBACK;V_ERR_MSG := SQLERRM || CHR(13) || DBMS_UTILITY.FORMAT_ERROR_BACKTRACE;JA_WRITE_LOG(JA_UTILS_PKG.GET_FN_NAME(), 'ERROR', V_ERR_MSG, -1, 1);
END;
/

2、设置Oralcle定时器

-- 表彰历史
BEGIN
DBMS_SCHEDULER.CREATE_JOB(JOB_NAME => 'SYNCHRONIZE_HONORING_HISTORY2',JOB_TYPE => 'PLSQL_BLOCK',JOB_ACTION => 'SYNCHRONIZE_HONORING_HISTORY;',START_DATE => to_date('18-10-2022 00:00:00', 'dd-mm-yyyy hh24:mi:ss'),--开始时间ENABLED => TRUE, --创建完成后激活REPEAT_INTERVAL => 'TRUNC(SYSDATE,''MI'')+3/(24*60)',  --每3分钟执行一次
--       REPEAT_INTERVAL => 'TRUNC(SYSDATE + 1) + (8*60 + 30)/(24*60)', --每天8:30执行COMMENTS => '每三分钟统计表彰历史');
END;

注意:

如果是第一次使用定时器,需要手动将先前数据同步,如果数据量少可以从开始时间直接同步至当前时间对应数据,但是数据量较大则不建议这么做,会加剧数据库查询和存储的的负担,因此可能需要分时间对其切片,设置开始时间和结束时间并且跨度不宜过大,一点点同步到当前时间,后面就由定时器自动同步就好。

3.定时器的禁用与删除

也会遇到不再使用该定时器的情况,这时候提供了两种操作——禁用或删除。

操作步骤如下:

先查询数据库中的定时任务,查到相关信息如任务名,通过对查询到的任务名执行禁用/删除。

查看当前用户的定时任务指令

--查看当前用户的定时任务
select * from USER_SCHEDULER_JOBS;
-- 测试环境定时任务名
-- SYNCHRONIZE_HONORING_HISTORY_TASK   表彰历史同步
-- SYNCHRONIZE_JINGDIAN_STATISTICS_TASK  表彰项

禁用指令

--禁用
DBMS_SCHEDULER.DISABLE('TEST_JOB');  --暂时停止某个SCHEDULER JOB
--禁用定时任务
begin
DBMS_SCHEDULER.DISABLE('SYNCHRONIZE_HONORING_HISTORY_TASK');
DBMS_SCHEDULER.DISABLE('SYNCHRONIZE_JINGDIAN_STATISTICS_TASK');
end;

删除指令

--删除
DBMS_SCHEDULER.DROP_JOB(JOB_NAME => 'TEST_USER_INSERT',FORCE => TRUE);
-- 删除定时任务
begin
DBMS_SCHEDULER.DROP_JOB(JOB_NAME => 'SYNCHRONIZE_HONORING_HISTORY_TASK',FORCE => TRUE);
DBMS_SCHEDULER.DROP_JOB(JOB_NAME => 'SYNCHRONIZE_JINGDIAN_STATISTICS_TASK',FORCE => TRUE);
end;

这里我用的是禁用,状态可以在查询中查看,再次执行代码

--查看当前用户的定时任务
select * from USER_SCHEDULER_JOBS;

可以看到使用情况变成了False,状态变成了Disabled,应用成功啦!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/221245.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

PostgresSQL数据库中分区和分表的区别以及PostgresSQL创建表分区分表示例

1.分区分表理解 数据库分区和分表都是数据库中常用的数据分散存储技术&#xff0c;但它们的实现方式和应用场景有所不同。 分表&#xff1a;将一个大的表拆分成多个小的表&#xff0c;每个子表存储一部分数据。分表可以减轻单个表的数据量&#xff0c;提高查询效率&#xff0c…

【计算机四级(网络工程师)笔记】操作系统概论

目录 一、OS的概念 1.1OS的定义 1.2OS的特征 1.2.1并发性 1.2.2共享性 1.2.3随机性 1.3研究OS的观点 1.3.1软件的观点 1.3.2资源管理器的观点 1.3.3进程的观点 1.3.4虚拟机的观点 1.3.5服务提供者的观点 二、OS的分类 2.1批处理操作系统 2.2分时操作系统 2.3实时操作系统 2.4嵌…

0基础学java-day21(网络编程)

一、网络的相关概念 1 网络通信 2 网络 3 ip 地址 4.ipv4 地址分类 5.域名 6 网络通信协议 7.网络通信协议 8.TCP 和 UDP 二、InetAddress 类 &Socket 1 相关方法 package com.hspedu.api;import java.net.InetAddress; import java.net.UnknownHostException;/*** …

Azure Machine Learning - 提示工程高级技术

本指南将指导你提示设计和提示工程方面的一些高级技术。 关注TechLead&#xff0c;分享AI全维度知识。作者拥有10年互联网服务架构、AI产品研发经验、团队管理经验&#xff0c;同济本复旦硕&#xff0c;复旦机器人智能实验室成员&#xff0c;阿里云认证的资深架构师&#xff0c…

分布式链路追踪 —— 基于Dubbo的traceId追踪传递

文章目录 **原文链接&#xff0c;点击跳转**RpcContext 上下文对象Dubbo 过滤器&#xff08;Filter&#xff09;对象基于Dubbo的traceId追踪传递实现 原文链接&#xff0c;点击跳转 RpcContext 上下文对象 在实现 Dubbo 调用之间的链路跟踪之前&#xff0c;先简单了解 RpcCon…

【开源项目】WPF 扩展 -- 多画面视频渲染组件

目录 1、项目介绍 2、组件集成 2.1 下载地址 2.2 添加依赖 3、使用示例 3.1 启动动画 3.2 视频渲染 3.3 效果展示 4、项目地址 1、项目介绍 Com.Gitusme.Net.Extensiones.Wpf 是一款 Wpf 扩展组件。基于.Net Core 3.1 开发&#xff0c;当前是第一个发布版本 1.0.0&am…

node.js mongoose

目录 官方文档 mongoose Schema Model Query document 关系 官方文档 Mongoose v8.0.3: Getting Started mongoose Mongoose 是一个 Node.js 环境下 MongoDB 的对象建模工具。它提供了一种在应用程序中与 MongoDB 数据库进行交互的方式&#xff0c;使得开发者能够使用…

超结MOS/低压MOS在5G基站电源上的应用-REASUNOS瑞森半导体

一、前言 5G基站是5G网络的核心设备&#xff0c;实现有线通信网络与无线终端之间的无线信号传输&#xff0c;5G基站主要分为宏基站和小基站。5G基站由于通信设备功耗大&#xff0c;采用由电源插座、交直流配电、防雷器、整流模块和监控模块组成的电气柜。所以顾名思义&#xf…

石器时代H5小游戏架设教程

本文讲解石器时代 H5 之恐龙宝贝架设教程&#xff0c;想研究 H5 游戏如何实现&#xff0c;那请跟着此次教程学习在拥有小游戏源码的情况下该如何搭建起来 开始架设 1. 架设条件 石器时代架设需要准备&#xff1a; 一台linux 服务器&#xff0c;建议 CentOs 7.6 版本&#xf…

【ranger】CDP环境 更新 ranger 权限策略会发生低概率丢失权限策略的解决方法

一、问题描述&#xff1a; 我们的 kafka 服务在更新&#xff08;添加&#xff09; ranger 权限时&#xff0c;会有极低的概率导致 MM2 同步服务报错&#xff0c;报错内容 Not Authorized。但是查看 ranger 权限是赋予的&#xff0c;并且很早配置的权限策略也会报错。 相关组件…

JDK bug:ciObjectFactory::create_new_metadata:原因完全解析

文章目录 1、问题2.详细日志2.关键日志3.结论4.JDK&#xff1a;bug最终bug链接&#xff1a; 京东遇到过类似bug各位大佬如果有更详细的解答可以留言。 1、问题 服务不通&#xff0c;接口404&#xff0c;查看日志有一下截图&#xff0c;还有一个更详细的日志 2.详细日志 # #…

RPC(3):HttpClient实现RPC之GET请求

1HttpClient简介 在JDK中java.net包下提供了用户HTTP访问的基本功能&#xff0c;但是它缺少灵活性或许多应用所需要的功能。 HttpClient起初是Apache Jakarta Common 的子项目。用来提供高效的、最新的、功能丰富的支持 HTTP 协议的客户端编程工具包&#xff0c;并且它支持 H…

文件操作入门指南

目录 一、为什么使用文件 二、什么是文件 2.1 程序文件 2.2 数据文件 2.3 文件名 三、文件的打开和关闭 3.1 文件指针 3.2 文件的打开和关闭 四、文件的顺序读写 ​编辑 &#x1f33b;深入理解 “流”&#xff1a; &#x1f342;文件的顺序读写函数介绍&#xff1a; …

VM安装Sonoma【笔记】

VMware Workstation安装MacOS Sonoma 1、配置虚拟机&#xff0c;根据系统性能调整参数&#xff1b; 2、先不焦急启动虚拟机&#xff0c;打开虚拟机存储目录&#xff0c;以文本方式打开.vmx文件&#xff08;这里以Sonoma.vmx为例&#xff09;&#xff1b; 这里只针对Inter CP…

Ansible自动化运维以及模块使用

ansible的作用 远程操作主机功能 自动化运维(playbook剧本基于yaml格式书写) ansible是基于python开发的配置管理和应用部署工具。在自动化运维中&#xff0c;现在是异军突起 ansible能够批量配置、部署、管理上千台主机。类似于Xshell的一键输入工具。不需要每次都切换主机…

监控k8s controller和scheduler,创建serviceMonitor以及Rules

目录 一、修改kube-controller和kube-schduler的yaml文件 二、创建service、endpoint、serviceMonitor 三、Prometheus验证 四、创建PrometheusRule资源 五、Prometheus验证 直接上干货 一、修改kube-controller和kube-schduler的yaml文件 注意&#xff1a;修改时要一个节…

MATLAB - 最优控制(Optimal Control)

系列文章目录 前言 - 什么是最优控制&#xff1f; 最优控制是动态系统满足设计目标的条件。最优控制是通过执行以下定义的最优性标准的控制律来实现的。一些广泛使用的最优控制方法有&#xff1a; 线性二次调节器 (LQR)/线性二次高斯 (LQG) 控制 模型预测控制 强化学习 极值…

K8s攻击案例:RBAC配置不当导致集群接管

01、概述 Service Account本质是服务账号&#xff0c;是Pod连接K8s集群的凭证。在默认情况下&#xff0c;系统会为创建的Pod提供一个默认的Service Account&#xff0c;用户也可以自定义Service Account&#xff0c;与Service Account关联的凭证会自动挂载到Pod的文件系统中。 …

Golang(壹)

爱情不需要华丽的言语&#xff0c;只需要默默的行动。 简介 应用领域&#xff1a; 下载vscode 使用vscode Go下载 - Go语言中文网 - Golang中文社区 下载sdk 解压到文件中&#xff0c;打开sdk解压文件 穿插dos操作系统知识点&#xff1a; 测试go语言环境 看到vscode 的目录结…

urllib2 HTTP头部注入

文章目录 注入原理例题 [SWPU 2016]web7 注入原理 参考文章 应用场景是具有SSRF漏洞&#xff0c;结合CRLF注入 我们以redis数据库为例&#xff0c;当存在SSRF时我们伪造以下请求 http://127.0.0.1%0d%0aCONFIG%20SET%20dir%20%2ftmp%0d%0aCONFIG%20SET%20dbfilename%20evil%…