我看到很多人要sql的存储过程的例子，所以我就把我以前写的发出来，和大家一起探讨！
下面是我在苏州的时候写的代码，，是把oracle上的移植过来的，如果大家要oracle的代码，可以告诉我一声，我发
这段代码很全，有出错处理，游标动态定义，联合体用户的使用，分支和循环语句都有，，
到 /sqllib/下面去找，很多例子的代码的
我献丑了！！！
CREATE PROCEDURE IPD.st_inter_PROF ( IN in_Transfer_id dec(6,0),
IN in_TRANS_TYPE_id dec(2,0),
IN in_begin_date timestamp,
IN in_TRANSFER_name varchar(1024),
OUT o_err_no int,
OUT o_err_msg varchar(1024) )
LANGUAGE SQL
------------------------------------------------------------------------
-- SQL 存储过程
------------------------------------------------------------------
-- --
-- --
-- 抽取acct_item_billingday,acct_item表 --
-- author :zsk 2002/06/27 --
-- update by zsk at 2002/11/25 as SZ --
-- move from oracle to db2 by dengl 2002-12-8 as sz --
-- 返回值结果：0：执行通过 --
-- 1：执行不通过 --
-- -1：调用本过程时异常出错 --
-- 联合体用户是 ADMINISTRATOR BILL.BILL.* /BILL.CAL.* --
-------------------------------------------------------------------
------------------------------------------------------------------------
P1: BEGIN
--临时变量出错变量
declare rec integer default 0;
declare SQLCODE integer default 0;
declare stmt varchar(1024);
declare at_end integer default 0;
declare r_code integer default 0;
declare state varchar(1024) default 'AAA';--记录程序当前所作工作
declare temp_int integer default 0;
--声明变量
declare v_cycle_str varchar(1000);
declare v_sql_str varchar(2000);
declare n_num bigint;
declare n_rows bigint;
declare n_rows_all bigint;
--声明放游标的值
--声明动态游标存储变量
declare c_bill_task_id integer;
declare bill_task cursor for s1;
--声明出错处理
DECLARE EXIT HANDLER FOR SQLEXCEPTION
begin
set r_code=SQLCODE;
set o_err_no=1;
set o_err_msg='处理'||state||'出错 '||'错误代码SQLCODE:'||CHAR(r_code);
end;
DECLARE continue HANDLER for not found
begin
SET at_end = 1;
set o_err_no=100;
end;
--开始拉
select deal_cycle
into v_cycle_str
from ipd.transfer_task
where transfer_id=in_transfer_Id;
--v_cycle_str:='%'||v_cycle_str;
if in_trans_type_id=7
then
set n_num=1;
---将汇总数据写入任务表
update ipd.transfer_task
set rows_cnt=0
where transfer_id=in_transfer_id;
--声明动态游标
set stmt=' select distinct bill_task_id from ADMINISTRATOR.bill_task_cycle a , ADMINISTRATOR.billing_cycle b where substr(char(b.CYCLE_BEGIN_DATE),1,4)||substr(char(b.CYCLE_BEGIN_DATE),6,2)='||char((integer(v_cycle_str)-1))||' and a.billing_cycle_id=b.billing_cycle_id';
prepare s1 from stmt;
-- execute s1;
open bill_task; --using v_cycle_str;
--声明完毕
fetch_loop1:
loop
fetch bill_task into c_bill_task_id ;
--由于db2和oracle的不同,db2必须先创建一个oracle相连的别名ADMINISTRATOR.*,而不像oracle直接用@to_jif 下面是oracl的源码
-- v_sql_str:=' update transfer_task
-- set rows_cnt=rows_cnt+(select count(*)
-- from cal.acct_item_billingday_'||rec.bill_task_id||'@to_jf)
-- where transfer_id='||in_transfer_id;
--update by dengl 2002-12-08
set stmt='create nickname ADMINISTRATOR.ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id)||' for bill.cal.acct_item_billingday_'||char(c_bill_task_id);
--记录
set state='创建别名'||'ADMINISTRATOR.ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id);
call ipd.sp_exec_dsql(stmt,o_err_no);
--o_err_no 是返回的SQLCODE
if o_err_no<>;0
then
update ipd.transfer_task
set deal_flag=-1
where transfer_id=in_transfer_id;
set o_err_msg='处理'||state||'出错 '||'错误代码SQLCODE:'||CHAR(o_err_no);
set o_err_no=1;
return 0;
end if;
set v_sql_str=' update ipd.transfer_task set rows_cnt=rows_cnt+(select count(*) from '||'ADMINISTRATOR.ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id)||' where transfer_id='||char(in_transfer_id);
call ipd.sp_exec_dsql(v_sql_str,o_err_no);
if o_err_no <>; 0
then
update ipd.transfer_task
set deal_flag=-1
where transfer_id=in_transfer_id;
set o_err_msg=char(in_TRANS_TYPE_id)||'传送出错！SQLCODE:'||char(o_err_no);
set o_err_no=1;
return 0;
end if ;
commit;
end loop fetch_loop1;
close bill_task;
--汇总数据写入完毕
--建立接口表并插入数据
---整理表空间。
call ipd.bi_settle_tablespace(in_Transfer_id,
o_err_no,
o_err_msg);--调用此过程，检测表空间
--返回值不为0，则不执行返回
set state='整理表空间';
if o_err_no<>;0
then
update ipd.TRANSFER_TASK
set DEAL_FLAG=-1
where Transfer_id=in_Transfer_id;
commit;
set o_err_msg='处理'||state||'出错 '||'错误代码SQLCODE:'||CHAR(o_err_no);
set o_err_no=1;
return 0;
end if;
--创建任务需要的接口表 并把多个表的数据整合到一个表中去,如果是oracle就要使用零时表而db2用别名就代替了
set stmt='create table ipd.'||in_TRANSFER_name;
call ipd.sp_exec_dsql(stmt,o_err_no);
set state='创建接口表ipd.'||in_TRANSFER_name;
if o_err_no<>;0
then
update ipd.TRANSFER_TASK
set DEAL_FLAG=-1
where Transfer_id=in_Transfer_id;
commit;
set o_err_msg='处理'||state||'出错 '||'错误代码SQLCODE:'||CHAR(o_err_no);
set o_err_no=1;
return 0;
end if;
--建表完毕开始组合sql语句
open bill_task using v_cycle_str;
fetch_loop2:
loop
fetch bill_task into c_bill_task_id;
if n_num=1
then
set v_sql_str='inter into ipd.'||in_TRANSFER_name||' select * from ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id);
else
set v_sql_str=v_sql_str||' union select * from ADMINISTRATOR.ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id);
end if;
set n_num=n_num+1;
end loop fetch_loop2;
--组合完毕
-- set v_sql_str:=v_sql_str||' )';
set state='向接口表ipd.'||in_TRANSFER_name||'插入数据';
call ipd.sp_exec_dsql(v_sql_str,o_err_no);
if o_err_no<>;0
then
update ipd.TRANSFER_TASK
set DEAL_FLAG=-1
where Transfer_id=in_Transfer_id;
commit;
set o_err_msg='处理'||state||'出错 '||'错误代码SQLCODE:'||CHAR(o_err_no);
set o_err_no=1;
return 0;
else
update transfer_task
set deal_flag=2
where transfer_id=in_transfer_id;
set o_err_no=0;
set o_err_msg=o_err_msg||'任务号为'||char(in_TRANSFER_id)||'抽取成功！';
end if;
commit;
--数据插入完毕
--删除联合体的别名
open bill_task using v_cycle_str;
fetch_loop3:
loop
set stmt='drop nickname ADMINISTRATOR.ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id)||' for bill.cal.acct_item_billingday_'||char(c_bill_task_id);
--记录
set state='删除别名'||'ADMINISTRATOR.ACCT_ITEM_BILLINGDAY_'||char(c_bill_task_id);
call ipd.sp_exec_dsql(stmt,o_err_no);
--o_err_no 是返回的SQLCODE
if o_err_no<>;0
then
update ipd.transfer_task
set deal_flag=-1
where transfer_id=in_transfer_id;
set o_err_msg='处理'||state||'出错 '||'错误代码SQLCODE:'||CHAR(o_err_no);
set o_err_no=1;
return 0;
end if;
end loop fetch_loop3;
-----下账数据接口
else if in_trans_type_id =8
then
--帐务表的联合体别名已经建好了
set v_sql_str='update ipd.transfer_task set rows_cnt=(select count(*) from ADMINISTRATOR.acct_item a , ADMINISTRATOR.billing_cycle b where a.billing_cycle_id=b.billing_cycle_id and substr(char(b.CYCLE_BEGIN_DATE),1,4)||substr(char(b.CYCLE_BEGIN_DATE),6,2)= '''||upper(char(v_cycle_str))||''' ) where Transfer_id='||char(in_Transfer_id);
set state='汇总acct_item数据 ';
call ipd.sp_exec_dsql(v_sql_str,o_err_no);
if o_err_no <>; 0
then
update ipd.transfer_task
set deal_flag=-1
where transfer_id=in_transfer_id;
set o_err_no=1;
set o_err_msg=state||char(in_TRANS_TYPE_id)||'传送出错！';
return 0;
end if;
--整理表空间。
call ipd.bi_settle_tablespace(in_Transfer_id,
o_err_no,
o_err_msg);--调用此过程，检测表空间
--返回值不为0，则不执行返回
set state='为acct_item整理表空间';
if o_err_no<>;0
then
update ipd.TRANSFER_TASK
set DEAL_FLAG=-1
where Transfer_id=in_Transfer_id;
set o_err_msg=state||'任务号'||char(in_TRANS_TYPE_id)||'传送出错！SQLCODE:'||char(o_err_no);
set o_err_no=1;
commit;
return 0;
end if;
--在任务表中将状态改为1，准备传送数据.
update ipd.TRANSFER_TASK
set DEAL_FLAG=1
where Transfer_id=in_Transfer_id;
commit;
set v_sql_str='create table ipd.'||in_TRANSFER_name||' like ADMINISTRATOR.ACCT_item)';
call ipd.sp_exec_dsql(v_sql_str,o_err_no);
set stmt='inset into ipd.'||in_TRANSFER_name||' select ACCT_ITEM_ID,SERV_ID,SERV_SEQ_NBR,EXT_SERV_ID, ACCT_ID,ACCT_SEQ_NBR,ACCT_ITEM_TYPE_ID,CHARGE,BILLING_CYCLE_ID,CREATED_DATE,PARTNER_ID,BILL_SERIAL_NBR,STATE,STATE_DATE, EXCHANGE_ID, PAYMENT_METHOD from ADMINISTRATOR.acct_item where billing_cycle_id like '''||upper(v_cycle_str)||'''';
call ipd.sp_exec_dsql(stmt,o_err_no);
set state='插入数据到ipd.'||in_TRANSFER_name;
if o_err_no = 0
then
update transfer_task
set deal_flag=2
where transfer_id=in_transfer_id;
set o_err_no=0;
else
update transfer_task
set deal_flag=-1
where transfer_id=in_transfer_id;
set o_err_msg=state||'任务号'||char(in_TRANS_TYPE_id)||'传送出错！SQLCODE:'||char(o_err_no);
set o_err_no=1;
end if ;
commit;
end if;--下帐数据完毕
end if;
set temp_int=0;
call ipd.bi_check(in_transfer_id,
in_transfer_name,
temp_int,
o_err_no,
o_err_msg);
END P1
myralete 回复于：2003-07-17 08:42:35
law是个大好人！！！
intelcpu 回复于：2003-07-17 08:48:59
谢谢，一直在关注你的留言，对我帮助很大！
Law 回复于：2003-07-17 15:00:56
本来在我的机器上格式好好的，可是发上来就乱了！请大家将就将就了！！
大家这么说我都不好意思拉！！
大家写sql的存储过程要记住，db2还是把他翻译成了c的代码！
大家需要的话，我可以写一个用c写的存储过程！！
艾，，工作上也不开心啊！！现在想做技术也不行，郁闷啊！！这就是中国啊！
vlife 回复于：2003-07-17 16:27:14
引用：原帖由 "Law" 发表：
本来在我的机器上格式好好的，可是发上来就乱了！请大家将就将就了！！
大家这么说我都不好意思拉！！
大家写sql的存储过程要记住，db2还是把他翻译成了c的代码！
大家需要的话，我可以写一个用c写的存储过..........
我一直觉得用宿主语言写的存储过程才更灵活，sql的从来没写很复杂，看来sql的也可以写的足够的灵活啊 :oops:
做技术还会有人反对吗？不是很理解，呵呵~~~~~~~~
我想技术追求的最终开发上就是做一个好的架构师，或者数据库，操作系统，和各种中间件都精通的系统工程师吧？
Law 回复于：2003-07-17 17:29:24
用sql写存储过程很快，可是用db2产生的c代码冗余度非常大，就代码行数来说，是sql代码的5，6倍，运行效率可知了！！而且db2的api是c接口的，纯sql也不能使用cli的接口，所以sql还是有限制的！ibm的人都不推荐使用sql的！
艾，，大家不了解啊，现在我们干活很是烦恼啊！！现在就像进了政府单位了，等级森严的，话都不能说了！艾，，，，，！
vlife 回复于：2003-07-18 21:38:04
其实工作有很多是不很顺心的，我现在干的也很郁闷，虽然有很多不好的事情干扰，但是对工作还的好好做，总感觉做不好自己心里更不舒服。真不知道自己还能在这单位干多长时间。
调节自己的心态真的是很必要的 ：），明天应该会更好的。
IKULADESGA 回复于：2003-07-19 07:29:52
樓上兩位不順心就跳吧
vlife 回复于：2003-07-19 09:08:44
引用：原帖由 "IKULADESGA"]樓上兩位不順心就跳吧
发表：
:cry:
Law 回复于：2003-07-21 19:28:26
哈，现在竞争那么激烈，，那里容易找啊！想回家摆地摊算了！
intelcpu 回复于：2003-07-24 10:15:04
能用C写一段存储过程吗？谢谢！
gaoxiandong_123 回复于：2003-07-31 14:49:13
用C写一段存储过程吗？谢谢！
是不是 回复于：2003-08-26 17:03:25
我是菜菜鸟，问一个菜菜的问题。怎么执行这个.sql的文件啊？谢谢。
人世间 回复于：2003-08-28 15:18:32
再问一下：
你的DB2数据库是AS400的吗？
Law 回复于：2003-08-29 08:46:33
不是的
用的很杂，H85，V880，都在用
现在正式的机器是SUN 12K
人世间 回复于：2003-09-01 11:49:11
噢！
那这个存储过程我用不了了，可否劳驾再写一个C的。
我的DB2是AS400的。
xuguopeng 回复于：2003-09-01 11:57:38
我的也是400的DB2，能写个例子吗？先谢了
Law 回复于：2003-09-03 09:17:16
对不起,,我c的也不是很了解啊,,写不出这么复扎的了,,,有时间大家再讨论讨论哦!
pujing 回复于：2004-11-22 14:07:10
请问：
1。db2 7 和 db2 8 差别有什么？
2。在DB2 7上能用SQL而不用JAVA/C建存储过程吗？
wangli886 回复于：2004-11-22 14:54:14
顶上面回复，我现在也有这方面的困惑！望解决！！
Law 回复于：2004-11-23 16:16:20
8版本改进了很多，比如load啊，什么的，你们去看把，叫做db2 8的新增功能。
在db2 7上，可以使用c sql，java ，coblo，构建存储过程，其实所有sql的存储过程db2都会翻译成c的，
daliwa 回复于：2004-11-23 21:01:49
为什么要翻译成C呢？不明白！
Law 回复于：2004-11-24 10:13:50
他要编译成可执行代码，所以他先弄成c的，然后编译！
pujing 回复于：2004-11-24 13:34:23
law,
db2 7和db2 8 的差异今天刚从网上找了份中文资料，有时间慢慢看。
在db2 7上用SQL建存储过程，装上数据库后就可以建吗？
我建的时候老报错。
引用：原帖由 "Law" 发表：
8版本改进了很多，比如load啊，什么的，你们去看把，叫做db2 8的新增功能。
在db2 7上，可以使用c sql，java ，coblo，构建存储过程，其实所有sql的存储过程db2都会翻译成c的，
pujing 回复于：2004-11-24 13:38:19
借此贴问个别的问题
db2 7。2数据库连上后，过上不到10分钟就断了，还要重新连接。反复出现这种情况 。是什么原因呢？
谢谢答复！
Law 回复于：2004-11-25 18:26:33
你看看db2diag.log没有报错，然后看看客户端把数据库给出的返回代码是什么
呵呵，如果你是有源代码的话，你可以从新构建了，你也可以使用db2自带的命令把存储过程迁移过去！
zero_dot 回复于：2004-11-28 10:32:26
好东东。。
加精华。。
呵呵
石三一 回复于：2004-12-01 12:45:05
引用：原帖由 "Law" 发表：
1。你看看db2diag.log没有报错，然后看看客户端把数据库给出的返回代码是什么？
客户端返回代码，怎么和db2diag.log联系。
2。引用：呵呵，如果你是有源代码的话，你可以从新构建了，你也可以使用db2自带的命令把存储过程迁移过去！
有什么源码，可以重新构建？
db2自带的什么命令？
怎么把存储过程迁移过去？
hardis 回复于：2004-12-24 09:44:44
有些问题，可以参考db2的帮助文档，中英结合的，写的比较详细,网址如下：http://publib.boulder.ibm.com/infocenter/db2help/index.jsp?topic=/com.ibm.db2.udb.doc/core/c0008278.htm
SmileFace 回复于：2004-12-26 01:29:21
1. DB2下C嵌入SQL的例子可以看看SQLLIB\samples\c下的例子，写的很详细。
2. v8.2以后的版本纯SQL的存储过程可以脱离C编译器
markmahw 回复于：2005-07-25 03:03:47
顶一下，v8.2.2中已经可以支持了
|
