主题:[Oracle]触发器被触发时向远程数据库插入数据
环境:
数据库:Oracle 12c;数据库A(本地),数据库B(远程),在A中创建DBLink连接到B
工具:sqldevloper
问题:
数据库A中的Change表中创建了触发器T,After insert,当T被触发时,查询I表和B表,并将查到的数据插入到数据库B中对应的表中,Change表中一条记录可对应0或多条I表中的数据,I表中的一条记录可对应0或多条B表中的数据,通过创建游标来实现。
简而言之,触发器被触发,先查询再向远程数据库插入数据。
会出现下面的错误:
java.sql.SQLException:ORA-00604:递归SQL级别1出现错误
ORA-02067:要求事务处理或保存点回退
原因:
?
解决方案:
?
触发器代码:
create or replace trigger plm_mapping_mid_trg after insert on change for each row declare -- 通用变量 trg_ato_number change.ato_number%type; -- mfr游标 cursor vrows_mfr(trg_pid in item.pid%type) is select mfr_name trg_imak002 -- into trg_flag_mfr, trg_mfr_name from mfr where pid = trg_pid; -- item游标 cursor vrows_item(ato_number in change.ato_number%type) is select pid trg_pid, item_number trg_imat001, item_type trg_imat002, substr(item_number, 1, 2) trg_imat003, item_description trg_imat004, unit trg_imat005, lifecycle_phase trg_imat007, business_unit trg_imat026 from jx_itf_item where ato_number = trg_ato_number; -- BOM游标 cursor vrows_bom(trg_pid in item.pid%type) is select assembly_item trg_bmat001, component_item trg_bmat002, unit_consumption trg_bmat003 from jx_itf_bom where pid = trg_pid; -- assembly游标 cursor vrows_assembly(trg_pid in item.pid%type) is select assembly_item from jx_itf_bom_assembly_header where pid = trg_pid; begin trg_ato_number := :new.ato_number; -- 根据ato_number查询item for r_item in vrows_item(trg_ato_number) loop -- 插入远程数据库的item表 insert into plm_imatuc_t@plm_mapping_mid_dblink(plm_pk, imat001, imat002, imat003,imat004,imat005,imat007, imat026) values(r_item.trg_pid, r_item.trg_imat001, r_item.trg_imat002, r_item.trg_imat003,r_item.trg_imat004,r_item.trg_imat005,r_item.trg_imat007, r_item.trg_imat026); -- 根据pid查询mgr表中的对应的信息 for r_mfr in vrows_mfr(r_item.trg_pid) loop -- 插入远程数据库的mfr表 insert into plm_imakuc_t@plm_mapping_mid_dblink(plm_pk, imak001, imak002) values(r_item.trg_pid, r_item.trg_imat001, r_mfr.trg_imak002); end loop; -- 根据pid查询Assembly表中的对应的信息 for r_assembly in vrows_assembly(r_item.trg_pid) loop -- 根据pid查询BOM表 for r_bom in vrows_bom(r_item.trg_pid) loop -- 插入远程数据库的bom表 insert into plm_bmatuc_t@plm_mapping_mid_dblink(plm_pk, bmat001, bmat002, bmat003) values(r_item.trg_pid, r_bom.trg_bmat001, r_bom.trg_bmat002, r_bom.trg_bmat003); end loop; end loop; end loop; end;