漫步小风 2014-04-24 15:12 采纳率: 0%
浏览 3110

db2 存储过程加了atomic不回滚是什么原因

CREATE PROCEDURE "LOAN".PROCDEALDAILYBAL ( IN V_DATE VARCHAR(10) )
SPECIFIC "PROCDEALDAILYBAL"
DYNAMIC RESULT SETS 1
LANGUAGE SQL
NOT DETERMINISTIC
EXTERNAL ACTION
MODIFIES SQL DATA
CALLED ON NULL INPUT
INHERIT SPECIAL REGISTERS
begin

declare V_DEALED varchar(1) default '1';

declare V_INVALID_YEAR integer;
declare V_INVALID_DAY varchar(5);
declare V_INVALID_DATE varchar(10);
declare V_INVALID_DATE_RN varchar(10);

declare V_CONSUM_SQL varchar(512);

declare USEREXCEPTION CONDITION FOR SQLSTATE '99998';

declare sqlcode INTEGER DEFAULT 0;--

declare sqlstate CHAR(5);--

declare V_MESSAGE CHAR(100);--

declare MESSAGE_TEXT VARCHAR(100);--

declare EXIT HANDLER FOR SQLEXCEPTION
begin

values ('调用失败,SQLCode:' || CHAR(sqlcode) || 'SQLState:' || CHAR(sqlstate)) INTO V_MESSAGE;--
insert into ITG_DATA_UPLOAD(WORKDATE,DATATIME,PACKETERR,PACKETFLAG) values (to_char(current timestamp ,'yyyyMMddHH24miss'),V_DATE,V_MESSAGE,'0');--

SIGNAL SQLSTATE '99999';--
SET MESSAGE_TEXT = V_DATE || ' 日数据更新失败!';--

end;--

declare GLOBAL TEMPORARY TABLE session.USER_CONSUM (

CUSTOMID VARCHAR(32),
CONSUM DECIMAL(18,8)
) NOT LOGGED WITH REPLACE;--

declare GLOBAL TEMPORARY TABLE session.DAILY_BAL (

CUSTOMID VARCHAR(32),
CUSTOMNAME VARCHAR(64),
BALANCE DECIMAL(18,8)
) NOT LOGGED WITH REPLACE;--

set V_INVALID_YEAR = integer(to_char(to_date(V_DATE,'yyyy-MM-dd') -1 years,'yyyy'));
set V_INVALID_DAY = substr(V_DATE,6);
set V_INVALID_DATE = to_char(to_date(V_DATE,'yyyy-MM-dd') -1 years,'yyyy') || substr(V_DATE,5);
set V_INVALID_DATE_RN = to_char(to_date(V_INVALID_DATE,'yyyy-MM-dd') -1 days,'yyyy-MM-dd');

select count(1) into V_DEALED from ITG_DATA_UPLOAD where DATATIME = V_DATE AND PACKETFLAG = '1';--
if V_DEALED <> '0' then
SIGNAL USEREXCEPTION;--
end if;

if ((mod(V_INVALID_YEAR,400) = 0 ) or ( mod(V_INVALID_YEAR , 4) = 0 and mod(V_INVALID_YEAR , 100) != 0 )) and (V_INVALID_DAY = '03-01') then
set V_CONSUM_SQL = 'insert into session.USER_CONSUM select customid,COALESCE(sum(COALESCE(integraldec,0)),0) - COALESCE(sum(COALESCE(integraladd,0)),0) from itg_details where trandate >=''' || V_INVALID_DATE_RN || ''' group by customid';
else
set V_CONSUM_SQL = 'insert into session.USER_CONSUM select customid,COALESCE(sum(COALESCE(integraldec,0)),0) - COALESCE(sum(COALESCE(integraladd,0)),0) from itg_details where trandate >=''' || V_INVALID_DATE || ''' group by customid';
end if;--

EXECUTE IMMEDIATE V_CONSUM_SQL;--

--事物开始

p1: begin atomic
insert into session.DAILY_BAL
select a.acustomid,a.acustomname,
case when COALESCE(a.ALSTYEAR,0) >= COALESCE(b.CONSUM,0) then COALESCE(a.AYEAR,0) - ( COALESCE(a.ALSTYEAR,0) - COALESCE(b.CONSUM,0) ) else COALESCE(a.AYEAR,0) end
from ITG_BALANCE_DAILY a left join session.USER_CONSUM b
on a.acustomid = b.customid;--

 merge into ITG_BALANCE a USING (select * from session.DAILY_BAL) b
 on (a.customid=b.customid) when matched then update set a.balance = a.balance + b.balance
 when not matched then insert (a.customid,a.customname,a.balance) values (b.customid,b.customname,b.balance);--

 --插入日志表
 insert into ITG_DATA_UPLOAD(WORKDATE,DATATIME,PACKETERR,PACKETFLAG) values(to_char(current timestamp ,'yyyyMMddHH24miss')||'1111111111111111',V_DATE,'数据更新成功','1');--

end p1;

end

在p1 模块加了atomic 我在插入日志表这块故意让他出错 但是merge into 这部分却没有回滚,不知道为什么 求解

  • 写回答

1条回答

  • wocuolelaoda 2021-01-28 14:06
    关注

    declare EXIT HANDLER FOR SQLEXCEPTION

    评论

报告相同问题?

悬赏问题

  • ¥15 如何在3D高斯飞溅的渲染的场景中获得一个可控的旋转物体
  • ¥88 实在没有想法,需要个思路
  • ¥15 MATLAB报错输入参数太多
  • ¥15 python中合并修改日期相同的CSV文件并按照修改日期的名字命名文件
  • ¥15 有赏,i卡绘世画不出
  • ¥15 如何用stata画出文献中常见的安慰剂检验图
  • ¥15 c语言链表结构体数据插入
  • ¥40 使用MATLAB解答线性代数问题
  • ¥15 COCOS的问题COCOS的问题
  • ¥15 FPGA-SRIO初始化失败