ogg同步表结构不一致

叁歲伎倆 2022-09-23 08:09 197阅读 0赞

事情是因为一次同步的时候，需求需要目标端表需要增加插入更新时间字段

源表

mysql> create table test\_all(name varchar(20),age int);

Query OK, 0 rows affected (0.03 sec)

mysql> desc  test\_all;

\+-------+-------------+------+-----+---------+-------+

\+-------+-------------+------+-----+---------+-------+

| age   | int(11)     | YES  |     | NULL    |       |

\+-------+-------------+------+-----+---------+-------+

2 rows in set (0.00 sec)

mysql> insert into test\_all values('aass',12);

Query OK, 1 row affected (0.00 sec)

mysql> insert into test\_all values('dfa',22);

Query OK, 1 row affected (0.00 sec)

mysql> commit;

Query OK, 0 rows affected (0.00 sec)

目标表

SQL>  create table test\_all(name varchar2(20),age number,INSERTID number,UPDATEID number,CHANGEID number,EITIME date,EUTIME date);

Table created.

加主键

alter table test\_all add primary key(name);

以上方式不推荐

alter table test\_all add constraint pk\_name\_age  primary key(name,age);

一些方式容忍某个字段重复

准备进行表结构不同时的初始化

对于eid字段处理

先建sequence

CREATE SEQUENCE SEQ\_INSERTID     INCREMENT BY 1 START WITH 1000000001 NOMAXvalue NOCYCLE CACHE 10000;

CREATE SEQUENCE SEQ\_CHANGEID  INCREMENT BY 1 START WITH 1000000001 NOMAXvalue NOCYCLE CACHE 10000;

CREATE SEQUENCE SEQ\_UPDATEID   INCREMENT BY 1 START WITH 1000000001 NOMAXvalue NOCYCLE CACHE 10000;

触发器

CREATE OR REPLACE TRIGGER TRG\_TEST\_ALL

BEFORE INSERT OR UPDATE ON TEST\_ALL

FOR EACH ROW

BEGIN

IF INSERTING THEN

SELECT SEQ\_INSERTID.NEXTVAL INTO :NEW.INSERTID FROM DUAL;

SELECT SYSDATE INTO :NEW.EITIME FROM DUAL;

SELECT SYSDATE INTO :NEW.EUTIME FROM DUAL;

SELECT SEQ\_CHANGEID.NEXTVAL INTO :NEW.CHANGEID FROM DUAL;

END IF;

IF UPDATING THEN

SELECT SYSDATE INTO :NEW.EUTIME FROM DUAL;

SELECT SEQ\_UPDATEID.NEXTVAL INTO :NEW.UPDATEID FROM DUAL;

SELECT SEQ\_CHANGEID.NEXTVAL INTO :NEW.CHANGEID FROM DUAL;

END IF;

END;

执行初始化测试

注意初始化rini要加参数

GGSCI (n2) 51> edit params rini

REPLICAT RINI

USERID  [ogg@fafa][ogg_fafa], PASSWORD ogg

SOURCEDEFS /opt/app/OGG\_MYSQL/dirdef/source.def

DISCARDFILE /opt/app/OGG\_MYSQL/dirrpt/RINI.dsc, PURGE

DBOPTIONS NOSUPPRESSTRIGGERS

MAP mydb1.\*, TARGET mysql.\*;

执行操作进行测试

源库

mysql> update test\_all set name='fafa' where age=22;

Query OK, 1 row affected (0.00 sec)

Rows matched: 1  Changed: 1  Warnings: 0

mysql> select \* from test\_all;

\+------+------+

| name | age  |

\+------+------+

| aass |   12 |

| fafa |   22 |

| sss  |   12 |

\+------+------+

3 rows in set (0.00 sec)

目标库

改变前

SQL> select \* from test\_all;

NAME                                    AGE   INSERTID   UPDATEID    CHANGEID EITIME      EUTIME

\------------------------------------------------------------ ---------- ---------- ---------- ---------- --------------- ---------------

aass                                     12 1000000006          1000000009 11-MAY-16     11-MAY-16

dfa                                     22 1000000007          1000000010 11-MAY-16     11-MAY-16

sss                                     12 1000000008          1000000011 11-MAY-16     11-MAY-16

改变后

SQL> /

NAME                                    AGE   INSERTID   UPDATEID    CHANGEID EITIME      EUTIME

\------------------------------------------------------------ ---------- ---------- ---------- ---------- --------------- ---------------

aass                                     12 1000000006          1000000009 11-MAY-16     11-MAY-16

fafa                                     22 1000000007 1000000004 1000000012 11-MAY-16     11-MAY-16

sss                                     12 1000000008          1000000011 11-MAY-16     11-MAY-16

[ogg_fafa]: mailto:ogg@fafa

ogg同步表结构不一致

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关【三】当输入表是输出表从表时，两表主键不一致，如何使用kettle同步

相关【必读】解密Redis主从同步问题，避免数据不一致！

相关 Oracle ogg同步SQL server 问题排查

相关关于OGG单表同步

相关 oracle ogg同步到kafka不抓数据，重启ogg报错

相关 ogg同步表结构不一致

相关 ogg 异步同步，mysql to oracle

相关 OGG同步数据方法

相关 ogg数据同步停止OGG-00446 Could not find archived log for sequence

相关更新mysql表结构，同步数据库表结构