小例子，方便以后查阅.
包头需要声明： type C_CURSOR is ref cursor;
procedure visitcount(in_date number,
out_code out number,
out_desc out varchar2
) is
t_date number(8);
t_datepre number(8);
t_sql varchar2(2000);
t_tempcount number(8);
c_data C_CURSOR; v_cityname varchar(20);
v_visittime number(8);
v_visitcount number(8);
v_counttype number(8);
begin
if(in_date<=0) then
t_date:=to_number(trunc(sysdate)-1,'yyyymmdd');
t_datepre:=to_number(trunc(sysdate)-2,'yyyymmdd');
else
t_date:=in_date;
t_datepre:=to_number(to_char(to_date(in_date,'yyyy-mm-dd')-1,'yyyymmdd'));
end if;
--删除之前的数据
--select count(1) into t_tempcount from cn_visitcount
-- where visittime=t_date;
--if t_tempcount>0 then
delete from cn_visitcount
where visittime=t_date;
--end if; t_sql:='
select * from (
select cityname,'||t_date||' visittime,count(1) visitcount,1 counttype from
(
select
(
case
when cityid=68 then ''深圳''
when cityid=56 then ''广州''
end
)cityname,mobile,count(1) from cn_visitanalysis
where to_number(to_char(visittime,''yyyymmdd''))='||t_date||
' and (cityid=68 or cityid=56)
group by cityid,mobile
)
group by cityname';
t_sql:=t_sql||'
union all
select cityname,'||t_date||' visittime,count(1) visitcount,2 counttype from
(
select
(
case
when cityid=68 then ''深圳''
when cityid=56 then ''广州''
end
)cityname,mobile,count(1) from cn_visitanalysis
where to_number(to_char(visittime,''yyyymmdd''))='||t_date||
' and (cityid=68 or cityid=56)
and mobile not in (
select mobile from cn_visitanalysis
where to_number(to_char(visittime,''yyyymmdd''))<='||t_datepre||'
and (cityid=68 or cityid=56)
)
group by cityid,mobile
)
group by cityname)
order by cityname,visitcount desc';
--插入查询的数据
open c_data for t_sql;
loop
fetch c_data into v_cityname,v_visittime,v_visitcount,v_counttype ;
exit when c_data%notfound;
insert into cn_visitcount
(visitcountid, cityname, visitcount, visittime, counttype)
values
(seq_cn_visitcountid.nextval,v_cityname, v_visitcount, v_visittime, v_counttype);
end loop;
--备份每日的手机号
delete from cn_visitmobile where visittime=t_date;
insert into cn_visitmobile
select seq_cn_visitmobileid.nextval,mobile,cityid,visittime from
(
select mobile,cityid,to_number(to_char(visittime,'yyyymmdd')) visittime
from cn_visitanalysis
where to_number(to_char(visittime,'yyyymmdd'))=t_date
and (cityid=68 or cityid=56)
group by cityid,mobile,to_number(to_char(visittime,'yyyymmdd'))
)
commit; exception
when others then
out_desc:='sqlcode:'||sqlcode ||' err_message:' || sqlerrm;
begin
out_code:= -;
--out_description := '系统繁忙，请稍后再试!';
rollback;
--raise;
--错误日志
insert into cn_joblog(joblogid,procname,starttime,endtime,logtype,remark)
values(seq_cn_joblogid.Nextval,'fx114v01_cn_job.visitcount',sysdate,sysdate,'error',out_desc);
commit;
end;
end visitcount;
