融会贯通学习trigger(r2笔记第4天)
很多的东西在工作中用到的时候才能理解深刻,有些东西停留在理论层面而不去实践,就不会真正理解。
昨天写了一个很简单的trigger,但是中间也费了一些周折。
系统中碰到一个很严重的问题,一个数据处理引擎是基于表驱动设计的,里面的一个表中已经pending了很多的事务信息,对系统造成了严重的影响,为了第一时间排查这个问题,同事为了避免对目前的事务处理的进一步影响。讨论最后决定,我们需要修改一个字段的值,把它改为一个不被系统设别的值,这样新的事务信息就不会对目前的问题排查工作所影响。
这个时候需要dba要做的就是每一个新增的事务都需要修改那个字段的值,比如我们设定字段为source_comp_id,这个字段的值为2003的时候就被系统设别,能够进一步处理,如果设定为203,系统就不舍别,就不会处理,我们现在要做的就是把每一个新增的事务的source_comp_id值都去掉一位。
这个用trigger实现还是很自然的,但是因为这个表是生产的一个很大的分区表,自己分析和考虑的时候就走了一些弯路。
这个过程中也对trigger有了进一步的学习。发现自己很多以前的东西都忘记了。
首先从性能的角度考虑,能不能从字段的级别进行触发,类似下面的样子。
CREATE TRIGGER pub_source_code_chg_trg
before insert of source_comp_id
ON test_number for each row
begin
.....
end
/
马上得到了错误,所以基于列的修改,insert还是不支持的。还有delete也是同样的问题,update就可以。
before INSERT of SOURCE_COMP_ID
*
ERROR at line 2:
ORA-04073: column list not valid for this trigger type
好了继续学习。
接着我写了如下的trigger:
create or replace trigger pub_source_code_chg_trg
after insert
on trb1_pub_log
for each row
begin
if (:new.source_comp_id =2003) then
update pub_log set source_comp_id = 203,buffer_id=-1 where source_comp_id=:new.SOURCE_COMP_ID and PUB_TRX_ID=:new.PUB_TRX_ID and BUFFER_ID=:new.BUFFER_ID;
commit;
end if;
end;
/
看似很简单,已经完成了。
做了一个简单的Insert操作。就报了如下的错误。看来创建好了只是开始,还不能用。
insert into app_tmp.pub_log select *from test_pub_log where source_comp_id=2003 and rownum<2
*
ERROR at line 1:
ORA-04091: table APP_TMP.PUB_LOG is mutating, trigger/function may not see
it
ORA-06512: at "APP_TMP.PUB_SOURCE_CODE_CHG_TRG", line 3
ORA-04088: error during execution of trigger
'APP_TMP.PUB_SOURCE_CODE_CHG_TRG'
最后发现是同一个表insert的同时做update会有问题,果断加了自治事务的部分。
create or replace trigger pub_source_code_chg_trg
after insert
on trb1_pub_log
for each row
declare
pragma autonomous_transaction;
begin
if (:new.source_comp_id =2003) then
update pub_log set source_comp_id = 203,buffer_id=-1 where source_comp_id=:new.SOURCE_COMP_ID and PUB_TRX_ID=:new.PUB_TRX_ID and BUFFER_ID=:new.BUFFER_ID;
commit;
end if;
end;
/
又做了简单的Insert,看似就没有问题了,但是数据有问题。
-->做insert操作前。有9条记录都是2003.
SQL> select source_comp_id from trb1_pub_log;
SOURCE_COMP_ID
--------------
2003
2003
2003
2003
2003
2003
2003
2003
2003
9 rows selected.
insert into app_tmp.pub_log select *from test_pub_log where source_comp_id=2003 and rownum<3
2 rows created.
没有提交,结果source_comp_id就自动改变了。
SQL> select source_comp_id from trb1_pub_log;
SOURCE_COMP_ID
--------------
203
203
203
2003
2003
2003
2003
2003
2003
2003
2003
最后发现还是这个自治事务的问题,在insert的过程中,所做的Update修改的数据不是insert的数据。
这个也是自治事务不是很常用的原因。
还是先来实现目标才考虑其他的因素吧。
下面的这个triggr就实现了新增事务的字段值修改。
CREATE OR REPLACE TRIGGER trb_pub_source_code_chg_trg
before INSERT
ON trb1_pub_log for each row
begin
if (:new.source_comp_id =2003)
then
:new.source_comp_id := 203;
:new.buffer_id:=-1 ;
end if;
end;
/
但是还有一个问题。报了ora-14402的问题,这个时候可以启用row movement就可以了。
insert into app_tmp.pub_log select *from test where source_comp_id=2003 and rownum<3
*
ERROR at line 1:
ORA-14402: updating partition key column would cause a partition change
ORA-06512: at "APP_TMP.PUB_SOURCE_CODE_CHG_TRG", line 5
ORA-04088: error during execution of trigger
'APP_TMP.PUB_SOURCE_CODE_CHG_TRG'
做了好几轮测试,考虑了很多的因素,都没有发现问题。
所以大道至简,这也给自己好好上了一课。
- iOS多线程——RunLoop与GCD、AutoreleasePool你要知道的iOS多线程NSThread、GCD、NSOperation、RunLoop都在这里
- iOS多线程——你要知道的RunLoop都在这里你要知道的iOS多线程NSThread、GCD、NSOperation、RunLoop都在这里
- iOS网络——AFNetworking AFHttpSessionManager源码解析
- iOS网络——SDWebImage SDImageDownloader源码解析你要知道的NSURLSession都在这里
- iOS缓存 NSCache详解及SDWebImage缓存策略源码分析你要知道的NSCache都在这里
- freeRTOS信号量学习
- 微信扫码支付+Asp.Net MVC
- Linq中连接主要有组连接、内连接、左外连接、交叉连接四种
- 深入源码理解YYCache 、SDWebImage、AFNetworking、NSCache 缓存方式与对比
- Linq Like的操作
- iOS网络——AFNetworking AFURLSessionManager源码解析
- 1692: [Usaco2007 Dec]队列变换(BZOJ1640强化版)
- 1620: [Usaco2008 Nov]Time Management 时间管理
- 手把手教你树莓派linux内核如何编译
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 「高并发通信框架Netty4 源码解读(七)」NIO通道之Selector选择器
- Python与seo工具脚本,360/搜狗相关搜索词采集源码参考
- 逐行阅读Spring5.X源码(八)Mybatis是如何利用MapperScan完成扫描的?
- KEDA|Kubernetes中基于事件驱动的自动伸缩
- 「高并发通信框架Netty4 源码解读(八)」NIO应用——聊天案例及Reactor线程模式
- 「kafka」kafka-clients,java编写生产者客户端及原理剖析
- 「kafka」kafka-clients,java编写消费者客户端及原理剖析
- Kubernetes:如何自动检测和处理弃用的API
- 逐行阅读Spring5.X源码(九)spring利用CGLIB实现动态代理原理剖析
- 逐行阅读Spring5.X源码(十)spring如何解决循环引用,bean实例化过程源码详解
- 逐行阅读Spring5.X源码(十一)AOP概念、应用、原理
- java当中的线程和操作系统的线程是什么关系?
- 基于OpenCV 的车牌识别
- Redis入坟(六)分布式集群,概念、原理、实操
- Redis入坟(一)redis的前世今生、redis基础及存储结构源码讲解