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

在前一个博客中提到了在数据同步的时候，在各站点需要建立各操作表的触发器，在执行增删改的时候，触发器的任务是将其中操作的sql语句拼接成字符串，并保存在表synchro_tb_operate_log中，如果触发器执行出现异常，则将其异常信息保存在另一个表中：SYNCHRO_

在前一个博客中提到了在数据同步的时候，在各站点需要建立各操作表的触发器，在执行增删改的时候，触发器的任务是将其中操作的sql语句拼接成字符串，并保存在表synchro_tb_operate_log中，如果触发器执行出现异常，则将其异常信息保存在另一个表中：SYNCHRO_DATA_EXCEP_LOG，其中

synchro_tb_operate_log字段信息：主键ID、拼接的sql语句(其中包含主键ID和地区代码)、是否完成同步(默认为0未完成)、创建时间

SYNCHRO_DATA_EXCEP_LOG字段信息：主键ID、触发器异常名称、触发器异常信息、触发器异常出现的时间

下面是创建item_rec代码，也可以让我们来学习一下创建触发器相关的语法和知识：

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):=&＃39;08052&＃39;;    --站点代码
  v_exception varchar2(500);
begin
  v_sql := null;
  case when inserting then--插入数据
          v_sql := &＃39;insert into ITEM_REC(&＃39;||
          &＃39;ID,PROTEAMNAME,PY,PROID,&＃39;||
          &＃39;JCTYPE,WORKFLAG,ZXFLAG,JWDCODE)&＃39;||
          &＃39;values(&＃39;&＃39;&＃39;||
          :new.ID||&＃39;&＃39;&＃39;,&＃39;&＃39;&＃39;||replace(:new.PROTEAMNAME,&＃39;&＃39;&＃39;&＃39;,&＃39;&＃39;)||&＃39;&＃39;&＃39;,&＃39;&＃39;&＃39;||:new.PY||&＃39;&＃39;&＃39;,&＃39;&＃39;&＃39;||:new.PROID||&＃39;&＃39;&＃39;,&＃39;&＃39;&＃39;||
          :new.JCTYPE||&＃39;&＃39;&＃39;,&＃39;&＃39;&＃39;||:new.WORKFLAG||&＃39;&＃39;&＃39;,&＃39;&＃39;&＃39;||:new.ZXFLAG||&＃39;&＃39;&＃39;,&＃39;&＃39;&＃39;||v_jwdcode||&＃39;&＃39;&＃39;)&＃39;;
       when updating then--更新数据
          v_sql := &＃39;update ITEM_REC set &＃39;||
                       &＃39;PROTEAMNAME=&＃39;&＃39;&＃39;||replace(:new.PROTEAMNAME,&＃39;&＃39;&＃39;&＃39;,&＃39;&＃39;)||&＃39;&＃39;&＃39;&＃39;||
                       &＃39;,PY=&＃39;&＃39;&＃39;||:new.PY||&＃39;&＃39;&＃39;&＃39;||
                       &＃39;,PROID=&＃39;&＃39;&＃39;||:new.PROID||&＃39;&＃39;&＃39;&＃39;||
                       &＃39;,JCTYPE=&＃39;&＃39;&＃39;||:new.JCTYPE||&＃39;&＃39;&＃39;&＃39;||
                       &＃39;,WORKFLAG=&＃39;&＃39;&＃39;||:new.WORKFLAG||&＃39;&＃39;&＃39;&＃39;||
                       &＃39;,ZXFLAG=&＃39;&＃39;&＃39;||:new.ZXFLAG||&＃39;&＃39;&＃39;&＃39;||
                    &＃39; where &＃39;||
                       &＃39;ID=&＃39;||:old.ID||&＃39; and JWDCODE=&＃39;&＃39;&＃39;||v_jwdcode||&＃39;&＃39;&＃39;&＃39;;
       when deleting then--删除数据
          v_sql := &＃39;delete from ITEM_REC t where t.ID=&＃39;||:old.ID||&＃39; and t.JWDCODE=&＃39;&＃39;&＃39;||v_jwdcode||&＃39;&＃39;&＃39;&＃39;;
  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,&＃39;YYYY-MM-DD HH24:MI:SS&＃39;));
  end if;
exception
  when others then--如果执行过程中出现异常，则将异常信息插入到SYNCHRO_DATA_EXCEP_LOG表中
       v_exception := substr(sqlcode||&＃39;---&＃39;||sqlerrm, 1, 500);
      insert into SYNCHRO_DATA_EXCEP_LOG
             (ID,TRIGGER_NAME,EXCEPTION_INFO,EXCEPTION_TIME)
      values
             (sys_guid(),&＃39;Trigger_DICT_PROTEAM&＃39;,v_exception,to_char(sysdate,&＃39;YYYY-MM-DD HH24:MI:SS&＃39;));
end TRIGGER_ITEM_REC;