详解oracle中通过触发器记录每个语句影响总行数
详解oracle中通过触发器记录每个语句影响总行数需求产生:业务系统中,有一步“抽数”流程,就是把一些数据从其它服务器同步到本库的目标表。这个过程有可能 多人同时抽数,互相影响。有测试人员反应,原来抽过的数,偶尔就无缘无故的 找不到了,有时又会出来重复行。这个问题产生肯定是抽数逻辑问题以及并行的问题了!但他们提了一个简单的需求:想知道什么时候数据被删除了,什么时候插入了,我需要监控“表的每一次变更”!技术选择:第一就想到触发器,这样能在不涉及业务系统的代码情况下,实现监控。触发器分为“语句级触发器”和“行级触发器”。语句级是每一个语句执行前后触发一次操作,如果我在每一个SQL语句执行后,把表名,时间,影响行写到记录表里就行了。 但问题来了,在语句触发器中,无法得到该语句的行数,sql%rowcount 在触发器里报错。只能用行级触发器去统计行数! 代码结构:整个监控数据行的功能包含: 一个日志表,包,序列。 日志表:记录目标表名,SQL执行开始、结束时间,影响行数,监控数据行上的某些列信息。 包:主要是3个存储过程,
序列: 用于生成日志表的主键 代码:日志表和序列: create sequence SEQ_T_CSLOGminvalue 1 maxvalue 99999999999 start with 1 increment by 1 cache 20 cycle; 包代码: --包体create or replace package body pck_cslog is --私有方法,把关联数组中的一条记录写入库里 procedure write_cslog(v_tblname t_cslog.tblname%type) is begin if cslog_tbl.exists(v_tblname) then insert into t_cslog values cslog_tbl (v_tblname); end if; end; --私有方法,清除关联数组中的一条记录 procedure clear_cslog(v_tblname t_cslog.tblname%type) is begin if cslog_tbl.exists(v_tblname) then cslog_tbl.delete(v_tblname); end if; end; --某个SQL语句执行开始。 v_type:语句类型,insert时为 i,update时为u ,delete时为 d procedure onbegin_cs(v_tblname t_cslog.tblname%type,v_type varchar2) is begin --如果关联数组中不存在,初始赋值。 否则表示,同时有insert,delete语句对目标表操作。 if not cslog_tbl.exists(v_tblname) then cslog_tbl(v_tblname).n_id := seq_t_cslog.nextval; cslog_tbl(v_tblname).tblname := v_tblname; cslog_tbl(v_tblname).sj1 := sysdate; cslog_tbl(v_tblname).sj2 := null; cslog_tbl(v_tblname).i_hs := 0; cslog_tbl(v_tblname).u_hs := 0; cslog_tbl(v_tblname).d_hs := 0; cslog_tbl(v_tblname).portcode := ' '; --初始给一个空格 cslog_tbl(v_tblname).startrq := to_date('9999','yyyy'); cslog_tbl(v_tblname).endrq := to_date('1900','yyyy'); cslog_tbl(v_tblname).n := 0; end if; cslog_tbl(v_tblname).bz := cslog_tbl(v_tblname).bz || v_type || ','; ----第一个语句进入,显示1,如果以后并行,则该值递增。 cslog_tbl(v_tblname).n := cslog_tbl(v_tblname).n + 1; end; --每行操作。 procedure oneachrow_cs(v_tblname t_cslog.tblname%type,v_rq date := '') is begin if cslog_tbl.exists(v_tblname) then --行数,代码,起、止时间 if v_type = 'i' then cslog_tbl(v_tblname).i_hs := cslog_tbl(v_tblname).i_hs + 1; elsif v_type = 'u' then cslog_tbl(v_tblname).u_hs := cslog_tbl(v_tblname).u_hs + 1; elsif v_type = 'd' then cslog_tbl(v_tblname).d_hs := cslog_tbl(v_tblname).d_hs + 1; end if; if v_code is not null and if v_rq is not null then begin 绑定触发器:有了以上代码后,想要监控的一个目标表,只需要给它添加三个触发器,调用包里对应的存储过程即可。 假定我要监控 T_A 的表:
三个触发器: --语句结束后create or replace trigger tri_one_t_a after insert or delete or update on t_a declare v_type varchar2(1); begin if inserting then v_type := 'i'; elsif updating then v_type := 'u'; elsif deleting then v_type := 'd'; end if; pck_cslog.onend_cs('t_a',v_type); end; --行级触发器 测试成果:触发器建好了,可以测试插入删除了。先插入100行,再随便删除一些行。 delete from t_a where id > 79;delete from t_a where id < 40; commit; end; clob列,还可以显示监控删除的行: 并行时,在bz列中,可能会有类似信息: i,i,-i,这表示同一时间有2个语句在插入目标表。 i,d,-d,-i 表示在插入时,有一个删除语句也在执行。 当平台多人在用时,避免不了有同时操作同一张表的情况,通过这个列的值,可以观察到数据库的执行情况! 感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!(编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |