同步需求：

增加生產庫表 t_order_group到目的鏡像庫的ogg同步。
源用戶jyc1到目標庫jyc2，表名不變

源端和目標端：
數據庫版本均oracle 11.2.0.4
ogg版本：
Oracle GoldenGate Command Interpreter for Oracle
Version 12.2.0.1.170919 27731916_FBO
Linux, x64, 64bit (optimized), Oracle 11g on Sep 4 2018 20:23:18

處理思路：(同步多表的思路一致)

1.源端檢查表是否滿足同步要求（主鍵）
2.目標端是否存在該表(不存在)
3.配置步驟：

• 1） 源端附加表日志
• 2） 源端抽取進程增加表，并重新啟動抽取進程
• 3） 源端推送進程增加表，重新啟動推送進程
• 4） 目標端停止復制進程
• 5） 源端獲取scn(確認該表無事務存在)
• 6） 源端exp/expdp根據scn導出表dmp
• 7） 源端dmp拷貝到目標端
• 8） 目標端導入表
• 9） 目標端復制進程增加表帶過濾filter csn
• 10）目標端啟動復制進程,待同步完成后，去掉fiter，重新啟動復制進程
• 11）源端和目標端檢查記錄是否一致

詳細步驟：

1.源端檢查源jyc1用戶下t_order_group表信息，是否有主鍵或唯一索引（無主鍵的表要求加上主鍵，徹底避免性能問題和數據同步不一致的問題）

select a.constraint_name,  a.column_name from user_cons_columns a, user_constraints b where a.constraint_name = b.constraint_name and b.constraint_type = 'P' and a.table_name = 'T_ORDER_GROUP';

CONSTRAINT_NAME    COLUMN_NAME
------------------------
PK_T_ORDER_GROUP     SUBORDERID

SQL> select count(*) from T_ORDER_GROUP;

  COUNT(*)
----------
      1594

SQL> set time on
15:27:09 SQL> /

  COUNT(*)
----------
      1594

15:27:11 SQL> /         

  COUNT(*)
----------
      1595

15:30:38 SQL> /                         

  COUNT(*)
----------
      1597

確認結果：有主鍵并且dml操作數據變化頻繁。由此，我們需要采用scn標準的步驟來配置ogg同步。

2.目標端是否存在該表(不存在)

在目標端conn jyc2/xxx檢查表desc T_ORDER_GROUP提示不存在,后續無需考慮drop表操作

3.配置步驟：

- 1） 源端附加表日志

dblogin userid oggadm,password xxxxxx
add trandata JYC1.T_ORDER_GROUP

- 2） 源端抽取進程增加表，并重新啟動抽取進程

edit param cq
TABLE JYC1.T_ORDER_GROUP;
start cq

- 3） 源端推送進程增加表，重新啟動推送進程

edit param ts
TABLE JYC1.T_ORDER_GROUP;
start cq

- 4） 目標端停止復制進程

stop fz

- 5） 源端獲取scn(確認該表無事務存在)

col current_scn for 9999999999999999
SELECT d.spid,a.sid,e.event,b.status,C.SQL_TEXT,B.USERNAME,B.OSUSER,B.MACHINE,B.PROGRAM
FROM V$SESS_IO A,V$SESSION B,V$SQL C,V$PROCESS D,v$session_wait e
WHERE A.SID=B.SID AND B.SQL_HASH_VALUE=C.HASH_VALUE and B.sid=E.sid and upper(C.sql_text) like '%T_ORDER_GROUP%'
AND B.PADDR=D.ADDR
and b.sid in(
select a.sid
from v$transaction b, v$session a
where b.addr=a.taddr
);
上述SQL的關聯查詢根據網友【秋楓暮霞】建議，改成如下更合適：
select s.sid,t.start_time,osuser o, username u,sa.sql_text
from v$session s, v$transaction t, dba_rollback_segs r, v$sqlarea sa
where s.taddr=t.addr and t.xidusn=r.segment_id(+)
and s.sql_address=sa.address(+) and upper(sa.sql_text) like '%T_ORDER_GROUP%';
select current_scn from v$database;

no rows selected --查詢無事務，則該scn可用，否則重新執行上述語句查詢，直到無記錄為止。

      CURRENT_SCN
-----------------
   17461233119488

SQL> 

- 6） 源端exp/expdp根據scn導出表dmp

注意使用flashback_SCN=17461233119488和排除觸發器trigger（目標端無需觸發器)

[oracle@racj1 ~]$ expdp jyc1/xxx directory=dmp tables=jyc1.T_ORDER_GROUP dumpfile=T_ORDER_GROUP.dmp  parallel=1 logfile=T_ORDER_GROUP.log flashback_SCN=17461233119488 cluster=n exclude=trigger

Export: Release 11.2.0.4.0 - Production on Thu Dec 2 16:19:24 2021

Copyright (c) 1982, 2011, Oracle and/or its affiliates.  All rights reserved.

Connected to: Oracle Database 11g Enterprise Edition Release 11.2.0.4.0 - 64bit Production
With the Partitioning, Real Application Clusters, Automatic Storage Management, OLAP,
Data Mining and Real Application Testing options
FLASHBACK automatically enabled to preserve database integrity.
Starting "jyc1"."SYS_EXPORT_TABLE_01":  jyc1/******** directory=dmp tables=jyc1.T_ORDER_GROUP dumpfile=T_ORDER_GROUP.dmp parallel=1 logfile=T_ORDER_GROUP.log flashback_SCN=17461233119488 cluster=n exclude=trigger 
Estimate in progress using BLOCKS method...
Processing object type TABLE_EXPORT/TABLE/TABLE_DATA
Total estimation using BLOCKS method: 2 MB
Processing object type TABLE_EXPORT/TABLE/PROCACT_INSTANCE
Processing object type TABLE_EXPORT/TABLE/TABLE
Processing object type TABLE_EXPORT/TABLE/COMMENT
Processing object type TABLE_EXPORT/TABLE/INDEX/INDEX
Processing object type TABLE_EXPORT/TABLE/CONSTRAINT/CONSTRAINT
Processing object type TABLE_EXPORT/TABLE/INDEX/STATISTICS/INDEX_STATISTICS
Processing object type TABLE_EXPORT/TABLE/STATISTICS/TABLE_STATISTICS
. . exported "jyc1"."T_ORDER_GROUP"                   1.705 MB    1607 rows
Master table "jyc1"."SYS_EXPORT_TABLE_01" successfully loaded/unloaded
******************************************************************************
Dump file set for jyc1.SYS_EXPORT_TABLE_01 is:
  /bak/dmp/T_ORDER_GROUP.dmp
Job "jyc1"."SYS_EXPORT_TABLE_01" successfully completed at Thu Dec 2 16:21:24 2021 elapsed 0 00:01:49

- 7） 源端dmp拷貝到目標端

[oracle@racj1 ~]$ scp /bak/dmp/T_ORDER_GROUP.dmp 192.168.52.245:/oradata/dmp/
The authenticity of host '192.168.52.245 (192.168.52.245)' can't be established.
ECDSA key fingerprint is SHA256:i68dRBpIH6rfI/vNPpClkLgy4WXuMJJJBhQNyCno83g.
Are you sure you want to continue connecting (yes/no/[fingerprint])? yes
Warning: Permanently added '192.168.52.245' (ECDSA) to the list of known hosts.
oracle@192.168.52.245's password: 
T_ORDER_GROUP.dmp                                                                                                                                     100% 2564KB  62.7MB/s   00:00    

- 8） 目標端導入表

注意檢查dmp路徑及導入到不同用戶參數REMAP_SCHEMA=JYC1:JYC2 tables=JYC1.T_ORDER_GROUP

SQL> set line 132 
SQL> set wrap off
SQL> select * from dba_directories;

OWNER                          DIRECTORY_NAME                 DIRECTORY_PATH
------------------------------ ------------------------------ ----------------------------------------------
SYS                            DMP                            /oradata/dmp

[oracle@zyjxnew dmp]$ impdp jyc2/xxx directory=dmp REMAP_SCHEMA=JYC1:JYC2 tables=JYC1.T_ORDER_GROUP dumpfile=T_ORDER_GROUP.dmp parallel=1 logfile=T_ORDER_GROUP.log cluster=n

Import: Release 11.2.0.4.0 - Production on Thu Dec 2 16:21:36 2021

Copyright (c) 1982, 2011, Oracle and/or its affiliates.  All rights reserved.

Connected to: Oracle Database 11g Enterprise Edition Release 11.2.0.4.0 - 64bit Production
With the Partitioning, OLAP, Data Mining and Real Application Testing options
Master table "JYC2"."SYS_IMPORT_TABLE_01" successfully loaded/unloaded
Starting "JYC2"."SYS_IMPORT_TABLE_01":  JYC2/******** directory=dmp REMAP_SCHEMA=JYC1:JYC2 tables=JYC1.T_ORDER_GROUP dumpfile=T_ORDER_GROUP.dmp parallel=1 logfile=T_ORDER_GROUP.log cluster=n 
Processing object type TABLE_EXPORT/TABLE/PROCACT_INSTANCE
Processing object type TABLE_EXPORT/TABLE/TABLE
Processing object type TABLE_EXPORT/TABLE/TABLE_DATA
. . imported "JYC2"."T_ORDER_GROUP"                    1.705 MB    1607 rows
Processing object type TABLE_EXPORT/TABLE/COMMENT
Processing object type TABLE_EXPORT/TABLE/INDEX/INDEX
Processing object type TABLE_EXPORT/TABLE/CONSTRAINT/CONSTRAINT
Processing object type TABLE_EXPORT/TABLE/INDEX/STATISTICS/INDEX_STATISTICS
Processing object type TABLE_EXPORT/TABLE/STATISTICS/TABLE_STATISTICS
Job "JYC2"."SYS_IMPORT_TABLE_01" successfully completed at Thu Dec 2 16:21:47 2021 elapsed 0 00:00:11

- 9） 目標端復制進程增加表帶過濾filter csn

edit param fz
MAP JYC1.T_ORDER_GROUP TARGET JYC2.T_ORDER_GROUP, filter ( @getenv(‘TRANSACTION’, ‘CSN’) >17461233119488);

提示：如果ogg版本是11.x的，需要使用雙引號"transaction"，“csn”，如果ogg版本>=12.x的使用單引號，如上。

- 10）目標端啟動復制進程,待同步完成后，去掉fiter，重新啟動復制進程

start fz
info fz
info all
edit param fz
MAP JYC1.T_ORDER_GROUP TARGET JYC2.T_ORDER_GROUP;
stop fz
start fz
info all
info fz

- 11）源端和目標端檢查記錄是否一致

源端和目標端同時查詢即可。還可以檢查./dirrpt/fz.dsc日志是否有異常，根據問題處理即可。

SQL> set time on
16:24:52 SQL> select count(*) from T_ORDER_GROUP;

  COUNT(*)
----------
      1609

16:24:54 SQL> /

  COUNT(*)
----------
      1609

16:25:03 SQL> /

  COUNT(*)
----------
      1611

16:26:40 SQL> /

  COUNT(*)
----------
      1611

生產遇到的問題：

1.源端附加日志時卡住，無法取消

2021-12-02 15:55:45  WARNING OGG-00706  Failed to add supplemental log group on table JYC1.T_ORDER_GROUP due to ORA-00054: resource busy and acquire with NOWAIT specified or timeout expired SQL ALTER TABLE "JYC1"."T_ORDER_GROUP" ADD SUPPLEMENTAL LOG GROUP "GGS_2948562" ("SUBORDERID") ALWAYS  /* GOLDENGATE_DDL_REPLICATION */.



^C


^C
^C^C^Z



^C

處理方法：斷開該ssh連接，并檢查處理鎖問題

SQL> select *
  from (select a.inst_id, a.sid, a.serial#,
               a.sql_id,
               a.event,
               a.status,
               connect_by_isleaf as isleaf,
               sys_connect_by_path(a.SID||'@'||a.inst_id, ' <- ') tree,
               level as tree_level
          from gv$session a
         start with a.blocking_session is not null
        connect by (a.sid||'@'||a.inst_id) = prior (a.blocking_session||'@'||a.blocking_instance))
 where isleaf = 1
 order by tree_level asc
rows will be truncated


   INST_ID        SID    SERIAL# SQL_ID        EVENT                                                            STATUS       ISLEAF TREE
---------- ---------- ---------- ------------- ---------------------------------------------------------------- -------- ---------- ------------------------------------------------
         1       7183      54211               SQL*Net message from client                                      INACTIVE          1  <- 7832@1 <- 7183@1
         1       7183      54211               SQL*Net message from client                                      INACTIVE          1  <- 2532@1 <- 7183@1

SQL> 
SQL> 
SQL> 
SQL> alter system kill session '7183,54211,@1' immediate;

System altered.

2.拓展思考：
如果源端表是新表，無記錄，那么就只需要1）2）3）+目標端創建新表+同步測試驗證即可。
如果源端表有記錄，但使用不頻繁，記錄數少（不超過十萬條），比如幾個小時才有數據變化，那么只需要1）2）3）+如下參考方法

• create target table,dblink truncate, insert into
• exp/expdp/imp/impdp
• create target table,ogg initial load
  如果源端的整個數據同步ogg是新搭建，那么處理步驟就又不同了，更簡單些。

總之ogg屬于邏輯同步復制，只要把握好數據變化的時間點即可靈活應對。