数据同步之各站点同步表触发器创建

create or replace
TRIGGER "ADMIN"."TRIGGER_ITEM_REC"
 after insert or update or delete
 on ITEM_REC FOR EACH ROW

/** HEAD
 * @name 项目记录表触发器
 * @description 变更事件，形成ddl语句插入同步表中
 * @version 1.0.0
 * @author Tang
 * @create-date 2014-07-01
 */
declare
 v_sql nvarchar2(3000); --临时存放sql
 v_zdcode varchar2(30):='08052'; --站点代码
 v_exception varchar2(500);
begin
 v_sql := null;
 case when inserting then--插入数据
 v_sql := 'insert into ITEM_REC('||
 'ID,PROTEAMNAME,PY,PROID,'||
 'JCTYPE,WORKFLAG,ZXFLAG,JWDCODE)'||
 'values('''||
 :new.ID||''','''||replace(:new.PROTEAMNAME,'''','')||''','''||:new.PY||''','''||:new.PROID||''','''||
 :new.JCTYPE||''','''||:new.WORKFLAG||''','''||:new.ZXFLAG||''','''||v_jwdcode||''')';
 when updating then--更新数据
 v_sql := 'update ITEM_REC set '||
 'PROTEAMNAME='''||replace(:new.PROTEAMNAME,'''','')||''''||
 ',PY='''||:new.PY||''''||
 ',PROID='''||:new.PROID||''''||
 ',JCTYPE='''||:new.JCTYPE||''''||
 ',WORKFLAG='''||:new.WORKFLAG||''''||
 ',ZXFLAG='''||:new.ZXFLAG||''''||
 ' where '||
 'ID='||:old.ID||' and JWDCODE='''||v_jwdcode||'''';
 when deleting then--删除数据
 v_sql := 'delete from ITEM_REC t where t.ID='||:old.ID||' and t.JWDCODE='''||v_jwdcode||'''';
 end case;
 if v_sql is not null then--如果v_sql不为空，则将相应信息插入到synchro_tb_operate_log表中
 insert into
 synchro_tb_operate_log(sd_record_id,sd_record_sql,sd_flag,create_time)
 values(SEQ_SYNCHRO_DATA.NEXTVAL,v_sql,0,to_char(sysdate,'YYYY-MM-DD HH24:MI:SS'));
 end if;
exception
 when others then--如果执行过程中出现异常，则将异常信息插入到SYNCHRO_DATA_EXCEP_LOG表中
 v_exception := substr(sqlcode||'---'||sqlerrm, 1, 500);
 insert into SYNCHRO_DATA_EXCEP_LOG
 (ID,TRIGGER_NAME,EXCEPTION_INFO,EXCEPTION_TIME)
 values
 (sys_guid(),'Trigger_DICT_PROTEAM',v_exception,to_char(sysdate,'YYYY-MM-DD HH24:MI:SS'));
end TRIGGER_ITEM_REC;