融会贯通学习trigger

简介: 很多的东西在工作中用到的时候才能理解深刻,有些东西停留在理论层面而不去实践,就不会真正理解。 昨天写了一个很简单的trigger,但是中间也费了一些周折。 系统中碰到一个很严重的问题,一个数据处理引擎是基于表驱动设计的,里面的一个表中已经pending了很多的事务信息,对系统造成了严重的影响,为了第一时间排查这个问题,同事为了避免对目前的事务处理的进一步影响。
很多的东西在工作中用到的时候才能理解深刻,有些东西停留在理论层面而不去实践,就不会真正理解。
昨天写了一个很简单的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                   *
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
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                     *
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'

做了好几轮测试,考虑了很多的因素,都没有发现问题。
所以大道至简,这也给自己好好上了一课。

目录
相关文章
|
4天前
|
弹性计算 关系型数据库 微服务
基于 Docker 与 Kubernetes(K3s)的微服务:阿里云生产环境扩容实践
在微服务架构中,如何实现“稳定扩容”与“成本可控”是企业面临的核心挑战。本文结合 Python FastAPI 微服务实战,详解如何基于阿里云基础设施,利用 Docker 封装服务、K3s 实现容器编排,构建生产级微服务架构。内容涵盖容器构建、集群部署、自动扩缩容、可观测性等关键环节,适配阿里云资源特性与服务生态,助力企业打造低成本、高可靠、易扩展的微服务解决方案。
1106 0
|
3天前
|
机器学习/深度学习 人工智能 前端开发
通义DeepResearch全面开源!同步分享可落地的高阶Agent构建方法论
通义研究团队开源发布通义 DeepResearch —— 首个在性能上可与 OpenAI DeepResearch 相媲美、并在多项权威基准测试中取得领先表现的全开源 Web Agent。
527 10
|
13天前
|
人工智能 运维 安全
|
12天前
|
人工智能 测试技术 API
智能体(AI Agent)搭建全攻略:从概念到实践的终极指南
在人工智能浪潮中,智能体(AI Agent)正成为变革性技术。它们具备自主决策、环境感知、任务执行等能力,广泛应用于日常任务与商业流程。本文详解智能体概念、架构及七步搭建指南,助你打造专属智能体,迎接智能自动化新时代。
|
4天前
|
弹性计算 Kubernetes jenkins
如何在 ECS/EKS 集群中有效使用 Jenkins
本文探讨了如何将 Jenkins 与 AWS ECS 和 EKS 集群集成,以构建高效、灵活且具备自动扩缩容能力的 CI/CD 流水线,提升软件交付效率并优化资源成本。
301 0
|
11天前
|
人工智能 异构计算
敬请锁定《C位面对面》,洞察通用计算如何在AI时代持续赋能企业创新,助力业务发展!
敬请锁定《C位面对面》,洞察通用计算如何在AI时代持续赋能企业创新,助力业务发展!
|
12天前
|
机器学习/深度学习 人工智能 自然语言处理
B站开源IndexTTS2,用极致表现力颠覆听觉体验
在语音合成技术不断演进的背景下,早期版本的IndexTTS虽然在多场景应用中展现出良好的表现,但在情感表达的细腻度与时长控制的精准性方面仍存在提升空间。为了解决这些问题,并进一步推动零样本语音合成在实际场景中的落地能力,B站语音团队对模型架构与训练策略进行了深度优化,推出了全新一代语音合成模型——IndexTTS2 。
807 23
|
4天前
|
缓存 供应链 监控
VVIC seller_search 排行榜搜索接口深度分析及 Python 实现
VVIC搜款网seller_search接口提供服装批发市场的商品及商家排行榜数据,涵盖热销榜、销量排名、类目趋势等,支持多维度筛选与数据分析,助力选品决策、竞品分析与市场预测,为服装供应链提供有力数据支撑。
|
4天前
|
缓存 监控 API
Amazon item_review 商品评论接口深度分析及 Python 实现
亚马逊商品评论接口(item_review)可获取用户评分、评论内容及时间等数据,支持多维度筛选与分页调用,结合Python实现情感分析、关键词提取与可视化,助力竞品分析、产品优化与市场决策。