数据的同步为每个站点创建触发器同步表

数据的同步为每个站点创建触发器同步表

大家好,又见面了,我是全栈君,今天给大家准备了Idea注册码。

     在数据同步时提到以前的博客,在每个站点都会有创建触发器对于每个工作表,当运行CRUD。触发器的任务就是对其进行操作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):='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;

版权声明:本文博客原创文章,博客,未经同意,不得转载。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/117142.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号