需求:我天天凌晨左右執行任務調度,插入微信用戶關注分析的總數、關注數、取消關注數進行每日初始化。數據庫
一、Job
微信
declare oop
jobChart number;spa
beginit
dbms_job.submit(jobChart, 'PRO_CHART_DATA;', sysdate, 'TRUNC(sysdate) + 1 +1/ (24)');--每晚1點執行date
SYS.DBMS_OUTPUT.PUT_LINE('Job Number is: ' || jobChart );select
COMMIT;循環
end; im
二、存儲過程加遊標循環數據
CREATE OR REPLACE
Procedure PRO_CHART_DATA as
cursor c_job--遊標
is
select * from TBL_WX_MP_CONFIG;
c_count NUMBER;
c_total NUMBER;
Begin
for c_row in c_job loop--(加上循環就出錯)
--邏輯開始
select count(*) into c_count from TBL_WX_MP_USER where WECHAT_ID = c_row.WECHAT_ID AND UNSUBSCRIBE_TIME is NULL;
select count(*) into c_total from TBL_WX_MP_STATISTICS where WECHAT_ID = c_row.WECHAT_ID and YEARS = to_char(sysdate,'yyyy-MM') and "CATEGORY" = to_char(sysdate,'dd');
if(c_total >= 1)
THEN dbms_output.put_line('數據已存在');
else
--進行數據庫操做
insert into HOLLY_WECHAT.TBL_WX_MP_STATISTICS ("LEGEND","CATEGORY","VALUE",YEARS,WECHAT_ID,WECHAT_NAME) values ('新增關注人數',to_char(sysdate,'dd'),'0',to_char(sysdate,'yyyy-MM'),c_row.WECHAT_ID ,c_row.WECHAT_NAME);
insert into HOLLY_WECHAT.TBL_WX_MP_STATISTICS ("LEGEND","CATEGORY","VALUE",YEARS,WECHAT_ID,WECHAT_NAME) values ('累計關注人數',to_char(sysdate,'dd'),c_count,to_char(sysdate,'yyyy-MM'),c_row.WECHAT_ID ,c_row.WECHAT_NAME);
insert into HOLLY_WECHAT.TBL_WX_MP_STATISTICS ("LEGEND","CATEGORY","VALUE",YEARS,WECHAT_ID,WECHAT_NAME) values ('取消關注人數',to_char(sysdate,'dd'),'0',to_char(sysdate,'yyyy-MM'),c_row.WECHAT_ID ,c_row.WECHAT_NAME);
Commit;
end if;
--邏輯結束
end loop;
end PRO_CHART_DATA;