oracle定时器,调用存储过程,定时从n张表中取值新增到本地一张表中

时间:2024-01-05 10:11:56
--创建新增本地数据库的存储过程
create or replace
procedure pro_electric_record as
  begin
    insert into electric_meter_record(id,basestation_id,name,meter_number,createtime,electric_meter_id)
    select sys_guid(),substr(s.sname,0,36),s.sname,s.svalue,sysdate,(select e.id from electric_meter e where e.basestation_id=substr(s.sname,0,36)) from rtdbvs s where s.sname like '%POWER_DQDL%';
    commit;
  end;
--拼接另一张表中的值
select sys_guid(),substr(s.sname,0,36),s.sname,s.svalue,sysdate from rtdbvs s where s.sname like '%POWER_DQDL%';
--查看存储过程
select * from user_source where type='PROCEDURE'
--删除存储过程
drop procedure pro_electric_record

--dbms_scheduler创建job调度
--查询
select * from dba_scheduler_jobs;
--创建job
begin
  dbms_scheduler.create_job(
  job_name=>'electric_meter_record_insert',
  job_type=>'STORED_PROCEDURE',
  job_action=>'pro_electric_record',
  start_date=>sysdate,
  repeat_interval=>'FREQ=MINUTELY;BYSECOND=0',
  comments=>'电表录入表',
  auto_drop=>false
  );
end;
--删除定时器
begin
dbms_scheduler.drop_job(job_name => 'ELECTRIC_METER_RECORD_INSERT',force => TRUE);
end;
--启用定时器
begin
dbms_scheduler.enable('ELECTRIC_METER_RECORD_INSERT');
end;
--运行定时器
begin
dbms_scheduler.run_job('ELECTRIC_METER_RECORD_INSERT',TRUE);
end;

--重点(查询N张表中的数据存储到本地一张表中)
insert into electric_meter_record(id,basestation_id,name,meter_number,createtime)
    select sys_guid(),substr(s.sname,0,36),s.sname,s.svalue,sysdate from rtdbvs s where s.sname like '%POWER_DQDL%';

效果图:

oracle定时器,调用存储过程,定时从n张表中取值新增到本地一张表中