承接上文

01、目标库配置安装ogg

解压 191004_fbo_ggs_Windows_x64_shiphome.zip 然后点击setup.exe 操作步骤见ogg 安装文档，linux/windwos安装选项一致

02、源库配置抽取进程文件

GGSCI (hso32-db-test as ogg@hso32) 86> edit param EXTORA

EXTRACT extora

SETENV (ORACLE_SID="hso32")

SETENV (NLS_LANG="AMERICAN_AMERICA.ZHS16GBK")

userid ogg,password ogg

REPORTCOUNT EVERY 1 MINUTES, RATE

DISCARDFILE ./dirrpt/extya.dsc, APPEND, MEGABYTES 1000

WARNLONGTRANS 2h, CHECKINTERVAL 30m;

EXTTRAIL ./dirdat/oo;

DBOPTIONS  ALLOWUNUSEDCOLUMN;

FETCHOPTIONS NOUSESNAPSHOT;

DDL INCLUDE OBJTYPE 'TABLE',INCLUDE OPTYPE 'ALTER';

DDLOPTIONS  addtrandata REPORT

table test_kingle.oggtest;

table test_ogg.test_ogg;

03、源库配置发送进程文件

GGSCI (hso32-db-test as ogg@hso32) 96> edit param PUORACLE

EXTRACT puoracle

passthru

dynamicresolution

userid ogg,password ogg

RMTHOST 10.118.193.39, MGRPORT 7809

numfiles 5000

RMTTRAIL ./dirdat/oo

table test_kingle.oggtest;

table test_ogg.test_ogg;

04、源库配置进程

GGSCI (hso32-db-test as ogg@hso32) 97> add extract extora,tranlog,begin now

EXTRACT added.

GGSCI (hso32-db-test as ogg@hso32) 98> add exttrail ./dirdat/oo,extract extora

EXTTRAIL added.

GGSCI(hso32-db-testasogg@hso32) 99> add extract puoracle,exttrailsource ./dirdat/oo

EXTRACT added.

GGSCI (hso32-db-test as ogg@hso32) 100> add rmttrail ./dirdat/oo,extract puoracle

RMTTRAIL added.

05、目标库windwos 初始化

01）、操作前

单实例初始化建议: 在CMD 界面sqlplus / as sysdba 测试登入，看是否成功，成功则CMD 页面进入到ogg的安装页面然后./ggsci 执行登入

       多实例初始化：多实例情况下保证CMD使用的环境变量是当前的环境变量，如果不是建议通过windwos SET 配置需要的环境变量，包括PATH 制定的sqlplus 登入命令位置；ORACLE_SID 实例名；ORACLE_HOME 数据库家目录位置。

        综上建议CMD 界面 echo %PATH%、echo %ORACLE_SID% 、echo%ORACLE_HOME%

查看环境是否正确，不正确使用set 调整

02）、配置oracle基础环境

C:\Users\Administrator>set ORACLE_SID=ORCL

C:\Users\Administrator>set ORACLE_HOME=D:\app\Administrator\product\11.2.0\dbhome_1\

06、配置ogg 操作用户

D:\app\Administrator\product\11.2.0\dbhome_1\BIN>sqlplus.exe / as sysdba

SQL*Plus: Release 11.2.0.1.0 Production on 星期五 7月 30 13:28:19 2021

Copyright (c) 1982, 2010, Oracle.  All rights reserved

连接到:

Oracle Database 11g Enterprise Edition Release 11.2.0.1.0 - 64bit Production

With the Partitioning, OLAP, Data Mining and Real Application Testing option

SQL> show parameter name

NAME                                 TYPE        VALUE

------------------------------------ ----------- ------------------------------

db_file_name_convert                 string

db_name                              string      orcl

db_unique_name                       string      orcl

global_names                         boolean     FALSE

instance_name                        string      orcl

lock_name_space                      string

log_file_name_convert                string

service_names                        string      orcl

SQL> create tablespace ogg datafile 'D:\ogg\data\ogg.dbf' size 5000M

表空间已创建。

SQL> create user ogg identified by "ogg" default tablespace ogg temporary tables

pace TEMP;

用户已创建。

S

QL> GRANT CONNECT TO ogg

授权成功。

SQL> GRANT ALTER ANY TABLE TO ogg;

授权成功。

 

SQL> GRANT ALTER SESSION TO ogg;

授权成功。

SQL> GRANT CREATE SESSION TO ogg;

授权成功。

SQL> GRANT FLASHBACK ANY TABLE TO ogg;

授权成功。

SQL> GRANT SELECT ANY DICTIONARY TO ogg;

授权成功。

SQL> GRANT SELECT ANY TABLE TO ogg;

授权成功。

SQL> GRANT RESOURCE TO ogg;

授权成功。

SQL> GRANT SELECT ANY TRANSACTION TO ogg;

授权成功。

SQL> conn ogg

输入口令:

已连接。

SQL> exit

07、初始化ogg

D:\ogg>ggsci.exe

Oracle GoldenGate Command Interpreter for Oracle

Version 19.1.0.0.4 OGGCORE_19.1.0.0.0_PLATFORMS_191017.1054_FBO

Windows x64 (optimized), Oracle 11g on Oct 19 2019 11:09:03

Operating system character set identified as GBK.

Copyright (C) 1995, 2019, Oracle and/or its affiliates. All rights reserved.

GGSCI (yycs) 1> create create subdirs

08、创建源库一致的表结构

 当前为只需要增量数据，所以只需要表结构就行了，如果需要全量数据，建议使用导表结构全量导入。当前就一张表，我就手工创建。

SQL> create user test_ogg identified by test_ogg default tablespace users;

用户已创建。

SQL> grant dba to test_ogg;

授权成功。

SQL> conn test_ogg;

输入口令:

已连接。

SQL> create table test_ogg(id int,name varchar(20),primary key(id));

表已创建。

09、创建MGR进程配置文件

GGSCI (yycs as ogg@orcl) 3> dblogin userid ogg,password ogg

Successfully logged into database.

GGSCI (yycs as ogg@orcl) 12> edit param mgr

PORT 7809

DYNAMICPORTLIST 7800-7850

AUTORESTART EXTRACT *,RETRIES 5,WAITMINUTES 3

--PURGEOLDEXTRACTS ./dirdat/*,usecheckpoints,minkeepdays 3

LAGREPORTHOURS 1

LAGINFOMINUTES 30

LAGCRITICALMINUTES 45

10、创建应用进程配置文件

GGSCI (yycs as ogg@orcl) 22> add checkpointtable test_ogg.checkpoint

Successfully created checkpoint table test_ogg. checkpoint.

GGSCI (yycs as ogg@orcl) 32> edit param ./GLOBALS

checkpointtable test_ogg.checkpoint

GGSCI (yycs as ogg@orcl) 18> edit param reoracle

REPLICAT reoracle

SETENV (ORACLE_SID="ORCL")

setenv (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)

USERID ogg,PASSWORD ogg

REPORT AT 01:59

REPORTCOUNT EVERY 30 MINUTES, RATE

REPERROR DEFAULT, ABEND

DBOPTIONS DEFERREFCONST

assumetargetdefs

DISCARDFILE ./dirrpt/repyaa.dsc, APPEND, MEGABYTES 1000

DISCARDROLLOVER AT 02:30

GETTRUNCATES

ALLOWNOOPUPDATES

MAP test_ogg.test_ogg,TARGET test_ogg.test_ogg;

11、创建应用进程

GGSCI (yycs as ogg@orcl) 29> add replicat reoracle exttrail ./dirdat/oo,checkpoi

nttable test_ogg.checkpoint

REPLICAT added.

12、启动进程

首先启动源库进程ext、pu，然后启动目标库进程re

GSCI (hso32-db-test as ogg@hso32) 89> start EXTORA

Sending START request to MANAGER ...

EXTRACT EXTORA starting

GGSCI (hso32-db-test as ogg@hso32) 90> info all

Program     Status      Group       Lag at Chkpt  Time Since Chkpt

MANAGER     RUNNING                                           

EXTRACT     RUNNING     EXTKAFKA    00:00:00      00:00:00   

EXTRACT     RUNNING     EXTORA      68:09:11      00:00:07   

EXTRACT     RUNNING     PUKAFKA     00:00:00      00:00:00   

EXTRACT     STOPPED     PUORACLE    00:00:00      67:57:50

GGSCI (hso32-db-test as ogg@hso32) 97> start PUORACLE

Sending START request to MANAGER ...

EXTRACT PUORACLE starting

GGSCI (hso32-db-test as ogg@hso32) 98> info all

Program     Status      Group       Lag at Chkpt  Time Since Chkpt

MANAGER     RUNNING                                          

EXTRACT     RUNNING     EXTKAFKA    00:00:00      00:00:06   

EXTRACT     RUNNING     EXTORA      00:00:00      00:00:03   

EXTRACT     RUNNING     PUKAFKA     00:00:00      00:00:03   

EXTRACT     RUNNING     PUORACLE    00:00:00      68:00:43   

GGSCI (hso32-db-test as ogg@hso32) 99>

 

13、测试同步性

测试：源库写入数据/目标库查看

SQL> insert into test_ogg values (23122,22);

1 row created.

SQL> commit;

Commit complete.

SQL>

 目标库查看