日期:2014-05-16 浏览次数:20618 次
1、先建立一个数组[types]:
?
?
create or replace type p_index_list as varray(35) of number;
2、编写存储过程,循环插入数据:?
?
?
--call jdxxEndingProvinceStock(p_index_list(370000,370200,410000,510000),to_char(sysdate-1,'yyyy-MM-dd')); create or replace procedure jdxxEndingProvinceStock(p_indexs in p_index_list, stock_date IN VARCHAR2) as default_stock_date VARCHAR2(20); p_index_num number; begin default_stock_date := stock_date; for x in 1 .. p_indexs.count loop p_index_num := p_indexs(x); delete JDXX_ENDING_PROVINCE_STOCK where stock_date = to_date(default_stock_date, 'yyyy-MM-dd') and p_index = p_index_num; commit; insert into JDXX_ENDING_PROVINCE_STOCK select p_index_num as p_index, t.pd_type_name, to_date(default_stock_date, 'yyyy-MM-dd') as stock_date, sum(t.count) as stock_count, sum(t.count * t.cur_cost_price) / 10000 as stock_money from jxc_pd t where t.shop_id in (select t.shop_id from entp_shop t where t.p_index in (select t2.P_INDEX from BASE_PROVINCE_LIST t2 where t2.del_mark = 0 start with t2.P_INDEX = p_index_num connect by prior t2.P_INDEX = t2.PAR_INDEX)) and t.own_sys = 1 and t.is_del = 0 group by t.pd_type_name; commit; end loop; end;
?3、编写定时器,定时执行语句
?
?
grant create job to nmswxt_sw; -- 建立job BEGIN dbms_scheduler.create_job(job_name => 'SCHDL_BASE_PD_CLAZZ', job_type => 'STORED_PROCEDURE', job_action => 'P_BASE_PD_CLAZZ', start_date => to_date('10-05-2012 01:10:01', 'dd-mm-yyyy hh24:mi:ss'), repeat_interval => 'sysdate+1', comments => '刷新商网产品类别定时任务'); END; -- 启用job BEGIN dbms_scheduler.enable(NAME => 'SCHDL_BASE_PD_CLAZZ'); END; -- 运行Job BEGIN dbms_scheduler.run_job(job_name => 'SCHDL_BASE_PD_CLAZZ',use_current_session => FALSE); END; -- 停止job BEGIN dbms_scheduler.disable(NAME => 'SCHDL_BASE_PD_CLAZZ'); END; -- 删除job BEGIN dbms_scheduler.drop_job(JOB_NAME => 'SCHDL_BASE_PD_CLAZZ'); END;
?
?
repeat_interval 参数:
???? 1/24 :一小时
???? 1/1440 : 一分钟
???? 1/(3600*24) : 一秒钟
?????sysdate+1 : 每天运行一次
???? sysdate+1/24 : 每一小时运行一次
???? sysdate+1/1440 : 每一分钟运行一次
???? sysdate+1/(3600*24) : 每一秒钟运行一次
???? sysdate+7 : 每星期运行一次
?
以上时间间隔不能保证任务(job)的下一次运行在一个特定的时间,仅仅能够指定一个任务两次运行之间的时间间隔。
特定日期或时间的例子:
trunc(sysdate