首页 > 数据库 >oracle 存储过程 for loop 定时任务

oracle 存储过程 for loop 定时任务

时间:2023-01-11 13:22:05浏览次数:42  
标签:24 sysdate -- ry 60 oracle 定时 loop TRUNC

记录。

是这么个事,要实现一个需求,当人员表里的数据有更新后需要告知其他系统更新他们自己的人员数据。

我想了一下,表里是有时间戳字段的,那我只要监听这个时间就行,拿到数据后用存储过程把数据插入到中间表,然后其他系统从中间表更新到他自己的系统库里面

 

1.先创建一张所需数据的中间表
create table t_rygx (
ryid varchar(64) primary key not null ,
bm varchar(64),
jh varchar(64),
gh varchar(64),
xm varchar(64),
sfzh varchar(64),
zzjgid varchar(64),
zzjgbm varchar(64),
zzjgmc varchar(200),
zt number , gxsj date DEFAULT CURRENT_TIMESTAMP, cjsj date DEFAULT CURRENT_TIMESTAMP )

 

2.创建存储过程
create or replace procedure insert_ry is
       --让游标变量指向一个动态select查询的结果集
cursor v_rys is 
                select 
                ry.ryid,
                ry.bm,
                ry.xm,
                ry.jh,
                ry.gh,
                ry.sfzh,
                zzjg.zzjgid,
                zzjg.bm as zzjgbm,
                zzjg.mc as zzjgmc
                from t_ry ry 
                left join t_zzjgcy cy on ry.ryid = cy.ryid 
                left join t_zzjg zzjg on cy.zzjgid = zzjg.zzjgid
                where ry.sfyx = 1 and ry.gxsj > sysdate + ( 10 /24 /60); --当前时间减十分钟
extis integer;--声明变量值
begin
       --循环开始
       for e in v_rys loop
                        select count(1) into extis from t_rygx where ryid = e.ryid;
           if extis < 1 then
                            INSERT INTO t_tyqx_rygx ( ryid, xm, bm, jh, gh, sfzh, zzjgid, zzjgbm, zzjgmc, zt, cjsj, gxsj )
                            VALUES
                            (
                            e.ryid,
                            e.xm,
                            e.bm,
                            e.jh,
                            e.gh,
                            e.sfzh,
                            e.zzjgid,
                            e.zzjgbm,
                            e.zzjgmc,
                 0, CURRENT_TIMESTAMP, CURRENT_TIMESTAMP ); else update t_rygx set xm = e.xm, bm = e.bm, jh = e.jh, gh = e.gh, sfzh = e.sfzh, zzjgid = e.zzjgid, zzjgbm = e.zzjgbm, zzjgmc = e.zzjgmc
                 zt = 0 ,
where ryid = e.ryid ;
end if; --if结束
      end loop; --循环结束
end;

 

3.创建job定时任务
declare job number ;
begin 
    dbms_job.submit(
            job,  --返回的定时器id,不用管
            'insert_ry;', -- 要执行的存储过程
            sysdate, --立即生效
            'TRUNC(sysdate,''mi'') + 10/ (24 * 60)' --定时时效 每十分钟执行一次,其他时间自行搜索
    );
    commit;
end;

  

  4.上面三步完成就弄完了 ,然后就可以去看下数据了

select * from t_rygx

 

  定时任务相关

四个参数说明:
    job:输出变量,是此任务在任务队列中的编号;
    what:执行的任务的名称及其输入参数;
    next_date:任务执行的时间;
    interval:任务执行的时间间隔。


-- 查看调度任务
select * from user_jobs;
-- 查看正在执行的调度任务
select * from dba_jobs_running;
-- 查看执行完的调度任务
select * from dba_jobs;


-- 执行定时任务
  BEGIN
    DBMS_JOB.RUN(jobid);
    COMMIT;
  END;

 

-- 停止已启动的定时任务
BEGIN
    DBMS_JOB.BROKEN(25,  TRUE,  SYSDATE);
    COMMIT;
END;

 

-- 删除指定job
BEGIN
    DBMS_JOB.REMOVE(25);
    commit;
END;

 




 

   常用INTERVAL 参数值 


描述 INTERVAL参数值 每天午夜12点 TRUNC(SYSDATE + 1) 每天早上8点30分 TRUNC(SYSDATE + 1) + (8*60+30)/(24*60) 每星期二中午12点 NEXT_DAY(TRUNC(SYSDATE ), ''TUESDAY'' ) + 12/24 每个月第一天的午夜12点 TRUNC(LAST_DAY(SYSDATE ) + 1) 每个季度最后一天的晚上11点 TRUNC(ADD_MONTHS(SYSDATE + 2/24, 3 ), 'Q' ) -1/24 每星期六和日早上6点10分 TRUNC(LEAST(NEXT_DAY(SYSDATE, ''SATURDAY"), NEXT_DAY(SYSDATE, "SUNDAY"))) + (6×60+10)/(24×60) 每秒钟执行次 Interval => sysdate + 1/(24 * 60 * 60) 如果改成sysdate + 10/(24 * 60 * 60)就是10秒钟执行次 每分钟执行 Interval => TRUNC(sysdate,'mi') + 1/ (24*60) 如果改成TRUNC(sysdate,'mi') + 10/ (24*60) 就是每10分钟执行次 每天定时执行 例如:每天的凌晨1点执行 Interval => TRUNC(sysdate) + 1 +1/ (24) 每周定时执行 例如:每周一凌晨1点执行 Interval => TRUNC(next_day(sysdate,'星期一'))+1/24 每月定时执行 例如:每月1日凌晨1点执行 Interval =>TRUNC(LAST_DAY(SYSDATE))+1+1/24 每季度定时执行 例如每季度的第一天凌晨1点执行 Interval => TRUNC(ADD_MONTHS(SYSDATE,3),'Q') + 1/24 每半年定时执行 例如:每年7月1日和1月1日凌晨1点 Interval => ADD_MONTHS(trunc(sysdate,'yyyy'),6)+1/24 每年定时执行 例如:每年1月1日凌晨1点执行 Interval =>ADD_MONTHS(trunc(sysdate,'yyyy'),12)+1/24

 

标签:24,sysdate,--,ry,60,oracle,定时,loop,TRUNC
From: https://www.cnblogs.com/banxia-boke/p/17043440.html

相关文章

  • STM32HAL库定时器中断关闭的方法
    本文可以用于解决这个问题:定时器中断上电后莫名其妙开启,或者首先触发一次。STM32HAL库在定时器初始化并开启以后,也是会默认开启中断。如不需要默认就开启中断可以用一下代......
  • HAL库教程8:通用定时器的使用
    定时器溢出时间的计算  关于定时器溢出的时间计算,有个公式:  定时器本质上是一个不断自加的计数器,只不过在自加的时候,能够自动比较计数值跟某个设定值而已。定时器+1用......
  • HAL库教程11:定时器的缓冲功能与影子寄存器
      在STM32的定时器中,TIMx_PSC、TIM_ARR两个寄存器加上捕捉比较模块中TIMX_CCR寄存器,它们都可以动态修改。不过他们的修改和生效可能不在同一个时刻,或者说,修改过后立即生......
  • HAL库教程10:定时器的PWM模式应用
      本节通过定时器的PWM模式驱动无源蜂鸣器,来演奏一段音乐。本博客在掌机的系列教程中介绍过蜂鸣器的驱动原理,感兴趣的可以参考​​电子琴​​无源蜂鸣器驱动电路  蜂鸣......
  • mysql 备份定时任务
    #!/bin/bashrq=`date+%Y-%m-%d-%H`#日期#数据库信息host=127.0.0.1user=rootpassword=xxxdbname=script#放在这个目录path=/usr/local/backups/sqlmysqldump-h......
  • Oracle分页查询出现重复数据的解决方法
    在使用MybatisPlus分页功能时发现:前端查询第一页是没问题的,但是向后查询的时候数据始终是第一页的查询第一页的时候发现没有任何问题往后查询,比如查询第二页时数据......
  • oracle 多行合并成一行: listagg within group CONNECT BY 可以和递归方法一起使用查
    oracle多行合并成一行:listaggwithingroupCONNECTBY可以和递归方法一起使用查询路径:https://www.bbsmax.com/A/A7zgpjGYJ4/oracle多行合并成一行:listaggwit......
  • oracle的 listagg() WITHIN GROUP () 行转列函数的使用
    oracle的listagg()WITHINGROUP()行转列函数的使用https://blog.csdn.net/sinat_36257389/article/details/81004843如需转载请标明出处1.使用条件查询查询部门为......
  • oracle 情理归档日志
    1.相关日志su-oracle//进入oracle账户sqlplus/assysdba//以操作系统权限认证的oraclesys管理员登陆archiveloglist//查看数据库的归档模式注意:输入arc......
  • oracle merge into与sqlserver merge into 比较
    mergeinto:在两个表之间,根据与源表联接的结果,对目标表执行插入、更新或删除操作。Oracle在9i引入了mergeinto命令,SQLServer2008也引入mergeinto。不多说了,实例对比一......