1、说明
重新将系统A(源库)用户的数据将导入到系统B(目标库)的用户下
系统A：UCCBIZ.T_HW_AGENT_SIGN_RECORD、UCCBIZ.T_HW_AGENT_CONSULTED
系统B：UCCBIZ.T_HW_AGENT_SIGN_RECORD、UCCBIZ.T_HW_AGENT_CONSULTED
2、查看系统A的OGG状态
GGSCI (A) 4> info all
Program Status Group Lag at Chkpt Time Since Chkpt
MANAGER RUNNING
EXTRACT RUNNING E_SH 00:00:02 00:00:03
EXTRACT RUNNING P_SH 00:00:00 00:00:06
3、系统A抽取进程E_SH修改参数文件
3.1、停止进程进行参数文件修改
GGSCI (A)1> stop E_SH
3.2、编辑参数文件新增如下
GGSCI (A)2> edit param E_SH
--20210918 add
TABLE UCCBIZ.T_HW_AGENT_SIGN_RECORD;
如果当前配置存在TABLE UCCBIZ.*; 就不用增加了。
4、登录数据库goldengate用户，打开表级附加日志
这里因为之前添加过，所以先删除再添加
GGSCI (A) 3> dblogin useridalias shoggadmin_alias
GGSCI (A) 4> delete TRANDATA UCCBIZ.T_HW_AGENT_SIGN_RECORD
GGSCI (A) 5> ADD TRANDATA UCCBIZ.T_HW_AGENT_SIGN_RECORD
GGSCI (A) 6> delete TRANDATA UCCBIZ.T_HW_AGENT_CONSULTED
GGSCI (A) 7> ADD TRANDATA UCCBIZ.T_HW_AGENT_CONSULTED
5、启动抽取进程
GGSCI (A) 6> start E_SH
6、系统A投递进程P_SH修改参数文件
GGSCI (A) 7> stop P_SH
GGSCI (A) 8> edit param P_SH
--20210918 add
TABLE UCCBIZ.*;
注意这里不要 start P_SH
7、停止系统B复制进程R_SH
系统B：
GGSCI (B) 1> stop R_SH
8、系统A基于SCN号抽取数据
系统A:
预估数据大小
SQL> select sum(BYTES/1024/1024) MB from dba_segments where owner =‘UCCBIZ‘ and SEGMENT_NAME=‘T_HW_AGENT_SIGN_RECORD‘;
MB
----------
472
SQL>
9、系统A中定义导出文件存放的目录
系统A:
mkdir /bak
chown oracle:oinstall /bak
SQL> create directory OGG_EXPDP as ‘/bak‘;
10、查询系统A数据库scn号
col current_scn for 9999999999999999
select current_scn from v$database;
CURRENT_SCN
-----------------
14670064687177
SQL>
11、通过数据泵导出系统A指定的表结构及数据
expdp \‘/ as sysdba\‘ directory=OGG_EXPDP tables=UCCBIZ.T_HW_AGENT_SIGN_RECORD,UCCBIZ.T_HW_AGENT_CONSULTED dumpfile =TB0918.dmp logfile=TB0918.log flashback_scn=14670064687177 compression=all cluster=N
--flashback_scn 限定对应的scn号之前的数据
--参数介绍：compression=all 文件压缩
--cluster=N RAC环境导出需要该参数
12、在B库创建dmp存放目录
mkdir /bak
chown oracle:oinstall /bak
SQL> create directory OGG_EXPDP as ‘/bak‘;
13、scp将dmp文件从系统A传至系统B
系统A:
$scp TB0918.dmp oracle@系统B的IP:传至的目录
scp TB0918.dmp oracle@B:/bak
14、在系统B导入数据
impdp \‘/ as sysdba\‘ directory=OGG_EXPDP dumpfile=TB0918.dmp logfile=TB0918.log table_exists_action=truncate transform=oid:n cluster=N
--参数介绍：
--table_exists_action=truncate 导入之前，如果表存在就truncate
--cluster=N RAC环境备份需要该参数
15、系统B复制进程R_SH参数文件修改
GGSCI (B) 2> edit param R_SH
--20210918 add
个性化表都放到map *之前，因为遇到重复定义会优先第一次遇到的规则
所以需要在MAP UCCBIZ.*, TARGET UCCBIZ.*;这一行之前增加：
--系统A基于SCN号导出，系统B基于CSN号开启应用
Version 11的OGG对应：
MAP UCCBIZ.T_HW_AGENT_SIGN_RECORD, TARGET UCCBIZ.T_HW_AGENT_SIGN_RECORD,FILTER(@GETENV("TRANSACTION","CSN")>14670064687177);
Version 12 的OGG对应：
MAP UCCBIZ.T_HW_AGENT_SIGN_RECORD, TARGET UCCBIZ.T_HW_AGENT_SIGN_RECORD,FILTER(@GETENV(‘TRANSACTION‘,‘CSN‘)>14670064687177);
区别：版本11的ogg需要使用双引号"TRANSACTION","CSN"，如果使用的是版本12的ogg要使用单引号.
16、开启系统A的投递进程P_SH
GGSCI (A) 11> start P_SH
17、开启系统B的应用进程R_SH
GGSCI (B) 3> start R_SH
18、数据对比
下查看相关统计数据
系统A：
GGSCI (A) 11> stats P_SH,daily
系统B：
GGSCI (B) 4> stats R_SH,daily
19、验证数据
多查几次，看数据变化情况
select count(*) from UCCBIZ.T_HW_AGENT_SIGN_RECORD;
select count(*) from UCCBIZ.T_HW_AGENT_CONSULTED;