ogg程序replicat进程部署文档-USB迷|专注于互联网分享

2024年3月9日发(作者：祖芷烟)

OGG程序replicat进程部署文档

一、准备工作 ........................................................................................................................... 2

1、检查ogg程序运行情况，停止replicat进程 ........................................................... 2

2、检查ogg程序配置文件 ............................................................................................. 2

二、配置replicat进程............................................................................................................. 2

1、配置replicat进程参数文件 ....................................................................................... 2

2、重新添加replicat进程 ............................................................................................... 6

三、初始化数据 ....................................................................................................................... 6

1、在数据库服务器上创建新的用户名存放数据 ......................................................... 6

2、以oracle用户登录服务器，导入初始化数据 ......................................................... 7

3、数据导入完成后，检查数据 ..................................................................................... 7

四、开启replicat进程............................................................................................................. 9

五、比对数据 ........................................................................................................................... 9

一、准备工作

需求：现需要在oracle数据库服务器上重新配置新的ogg的replicat进程接收源端传输的数据文件。

1、检查ogg程序运行情况，停止replicat进程

停止所有replicat进程stop RQF_WP*

mgr程序保持开启，源端传输数据文件过来能够接收文件。

2、检查ogg程序配置文件

检查ogg全局变量参数文件

view params ./GLOBAL

GGSCHEMA ogg

CHECKPOINTTABLE

检查mgr配置文件

view params mgr

port 7809

dynamicportlist 7815-8000

autorestart er *, retries 5, waitminutes 3

purgeoldextracts ./dirdat/*,usecheckpoints, minkeepdays 5

LAGREPORTHOURS 1

LAGINFOMINUTES 30

LAGCRITICALMINUTES 45

检查没有问题后配置replicat进程和初始化数据

二、配置replicat进程

1、配置replicat进程参数文件

由于这次同步的表比较多，所以总共部署了5个replicat进程

配置RQF_WP1进程：

replicat RQF_WP1

SETENV (ORACLE_SID="wpracdb1")

SETENV (NLS_LANG=AMERICAN_32UTF8)

USERID ogg , PASSWORD AACAAAAAAAAAAAOABHCDPGBEKGVDABKFLGLIRCUJZDMANIIG,

BLOWFISH, ENCRYPTKEY DEFAULT

REPORT AT 01:59

REPORTROLLOVER AT 02:00

CACHEMGR, CACHESIZE 256MB

REPERROR DEFAULT,ABEND

DISCARDFILE ./dirrpt/RQF_,APPEND,MEGABYTES 100

DISCARDROLLOVER AT 06:00

GETTRUNCATES

NUMFILES 3000

EOFDELAYCSECS 30

ASSUMETARGETDEFS

ALLOWNOOPUPDATES

DYNAMICRESOLUTION

GETUPDATEBEFORES

NOCOMPRESSDELETES

map GS__ZRR,target _ZRR;

map HX_CS__ZS_SWJGGKDZB,target _ZS_SWJGGKDZB;

map HX__NSRCKZHZHXX,target _NSRCKZHZHXX;

map HX__NSRCKZHZHXX_YGZ,target _NSRCKZHZHXX_YGZ;

map HX__NSRXX,target _NSRXX;

map HX__NSRXX_KZ,target _NSRXX_KZ;

map HX__NSRXX_KZ_LS,target _NSRXX_KZ_LS;

map HX__NSRXX_KZ_YGZ,target _NSRXX_KZ_YGZ;

map HX__NSRXX_YGZ,target _NSRXX_YGZ;

map HX__PZJGXX,target _PZJGXX;

配置RQF_WP2进程：

replicat RQF_WP2

SETENV (ORACLE_SID="wpracdb1")

SETENV (NLS_LANG=AMERICAN_32UTF8)

USERID ogg , PASSWORD AACAAAAAAAAAAAOABHCDPGBEKGVDABKFLGLIRCUJZDMANIIG,

BLOWFISH, ENCRYPTKEY DEFAULT

REPORT AT 01:59

REPORTROLLOVER AT 02:00

CACHEMGR, CACHESIZE 256MB

REPERROR DEFAULT,ABEND

DISCARDFILE ./dirrpt/RQF_,APPEND,MEGABYTES 100

DISCARDROLLOVER AT 06:00

GETTRUNCATES

NUMFILES 3000

EOFDELAYCSECS 30

ASSUMETARGETDEFS

ALLOWNOOPUPDATES

DYNAMICRESOLUTION

GETUPDATEBEFORES

NOCOMPRESSDELETES

map HX__WTXYS_BWTDZNSRXX,target _WTXYS_BWTDZNSRXX;

map HX__WTXYSXX,target _WTXYSXX;

map HX_DM__FP_FPLB,target _FP_FPLB;

map HX_DM__FP_FPZL,target _FP_FPZL;

map HX_DM__GY_HY,target _GY_HY;

map HX_DM__GY_NSRZT,target _GY_NSRZT;

map HX_DM__GY_ZSPM,target _GY_ZSPM;

map HX_DM__FP_FP,target _FP_FP;

map HX_DM__GY_SWJG,target _GY_SWJG;

map HX_DM__GY_SWRY,target _GY_SWRY;

配置RQF_WP3进程：

replicat RQF_WP3

SETENV (ORACLE_SID="wpracdb1")

SETENV (NLS_LANG=AMERICAN_32UTF8)

USERID ogg , PASSWORD AACAAAAAAAAAAAOABHCDPGBEKGVDABKFLGLIRCUJZDMANIIG,

BLOWFISH, ENCRYPTKEY DEFAULT

REPORT AT 01:59

REPORTROLLOVER AT 02:00

CACHEMGR, CACHESIZE 256MB

REPERROR DEFAULT,ABEND

DISCARDFILE ./dirrpt/RQF_,APPEND,MEGABYTES 100

DISCARDROLLOVER AT 06:00

GETTRUNCATES

NUMFILES 3000

EOFDELAYCSECS 30

ASSUMETARGETDEFS

ALLOWNOOPUPDATES

DYNAMICRESOLUTION

GETUPDATEBEFORES

NOCOMPRESSDELETES

map HX_DM__GY_YHYYWD,target _GY_YHYYWD;

map HX__DBCKD_MX,target _DBCKD_MX;

map HX__DK_FPKJXX,target _DK_FPKJXX;

map HX__DK_SQ,target _DK_SQ;

map HX__DK_TYJDFP,target _DK_TYJDFP;

map HX__DK_YSYSKMX,target _DK_YSYSKMX;

map HX__DK_ZZSFP,target _DK_ZZSFP;

map HX__DK_ZZSFP_HLMX,target _DK_ZZSFP_HLMX;

map HX__DK_ZZS_GHFNSRXX,target _DK_ZZS_GHFNSRXX;

map HX__FPKF,target _FPKF;

map HX__LY,target _LY;

配置RQF_WP4进程：

replicat RQF_WP4

SETENV (ORACLE_SID="wpracdb1")

SETENV (NLS_LANG=AMERICAN_32UTF8)

USERID ogg , PASSWORD AACAAAAAAAAAAAOABHCDPGBEKGVDABKFLGLIRCUJZDMANIIG,

BLOWFISH, ENCRYPTKEY DEFAULT

REPORT AT 01:59

REPORTROLLOVER AT 02:00

CACHEMGR, CACHESIZE 256MB

REPERROR DEFAULT,ABEND

DISCARDFILE ./dirrpt/RQF_,APPEND,MEGABYTES 100

DISCARDROLLOVER AT 06:00

GETTRUNCATES

NUMFILES 3000

EOFDELAYCSECS 30

ASSUMETARGETDEFS

ALLOWNOOPUPDATES

DYNAMICRESOLUTION

GETUPDATEBEFORES

NOCOMPRESSDELETES

map HX__LY_MX,target _LY_MX;

map HX__NSRFPJC,target _NSRFPJC;

map HX__PZHDXX,target _PZHDXX;

map HX__PZHDXXZB,target _PZHDXXZB;

map HX__SWJGKFKC,target _SWJGKFKC;

map HX__TP,target _TP;

map HX__TP_MX,target _TP_MX;

map HX__WLFP_KJXX,target _WLFP_KJXX;

map HX__WLFP_PZHDXX,target _WLFP_PZHDXX;

map HX__WLFP_SFZRDXXB,target _WLFP_SFZRDXXB;

配置RQF_WP5进程：

replicat RQF_WP5

SETENV (ORACLE_SID="wpracdb1")

SETENV (NLS_LANG=AMERICAN_32UTF8)

USERID ogg , PASSWORD AACAAAAAAAAAAAOABHCDPGBEKGVDABKFLGLIRCUJZDMANIIG,

BLOWFISH, ENCRYPTKEY DEFAULT

REPORT AT 01:59

REPORTROLLOVER AT 02:00

CACHEMGR, CACHESIZE 256MB

REPERROR DEFAULT,ABEND

DISCARDFILE ./dirrpt/RQF_,APPEND,MEGABYTES 100

DISCARDROLLOVER AT 06:00

GETTRUNCATES

NUMFILES 3000

EOFDELAYCSECS 30

ASSUMETARGETDEFS

ALLOWNOOPUPDATES

DYNAMICRESOLUTION

GETUPDATEBEFORES

NOCOMPRESSDELETES

map HX__YZJH,target _YZJH;

map HX__YZJHFP,target _YZJHFP;

map HX__YZJHFP_MX,target _YZJHFP_MX;

map HX__YZRKXX,target _YZRKXX;

map HX__YZYBDWMCFPBAXX,target _YZYBDWMCFPBAXX;

map HX__QX_SWRYSF,target _QX_SWRYSF;

map HX__NSRZGXX_JGB,target _NSRZGXX_JGB;

map HX__NSRZGXX_JGB_YGZ,target _NSRZGXX_JGB_YGZ;

map HX__SFZRDXXB,target _SFZRDXXB;

map HX__SFZRDXXB_YGZ,target _SFZRDXXB_YGZ;

map HX__SBXX,target _SBXX;

map HX__HD_DQDEHD_JG,target _HD_DQDEHD_JG;

map HX__HD_DQDEHD_JG_YGZ,target _HD_DQDEHD_JG_YGZ;

map HX__YJSF,target _YJSF;

注：在配置replicat进程时ogg用户密码是加密了，加密的方法如下：

encrypt password AACAAAAAAAAAAA,encryptkey default

在ggsci上运行，其中AACAAAAAAAAAAA为ogg用户的密码

2、重新添加replicat进程

由于传送数据文件名的格式发生了变化，故需要删除以前进程，重新创建进程

登录数据库

dblogin userid ogg,password AACAAAAAAAAAAA

删除历史进程

delete replicat RQF_WP1

delete replicat RQF_WP2

delete replicat RQF_WP3

delete replicat RQF_WP4

添加新进程（新的数据文件名格式为zt开头）

add replicat RQF_WP1,exttrail /app/ogg/dirdat/zt,checkpointtable

add replicat RQF_WP2,exttrail /app/ogg/dirdat/zt,checkpointtable

add replicat RQF_WP3,exttrail /app/ogg/dirdat/zt,checkpointtable

add replicat RQF_WP4,exttrail /app/ogg/dirdat/zt,checkpointtable

历史进程只有4个，现部署了5个进程，所以还需添加一个进程

add replicat RQF_WP5,exttrail /app/ogg/dirdat/zt,checkpointtable

三、初始化数据

1、在数据库服务器上创建新的用户名存放数据

创建表空间文件，导入的数据量比较大，故需要多创建几个表空间文件

Create tablespace OGGSJJG_DATA

‘+ORA_DATA/wpracdb/datafile/oggsjjg_data_ ' size 20G

autoextend on next 500M maxsize 31G;

alter tablespaceOGGSJJG_DATA add datafile

‘+ORA_DATA/wpracdb/datafile/oggsjjg_data_ ' size 20G

autoextend on next 500M maxsize 31G;

alter tablespaceOGGSJJG_DATA add datafile

‘+ORA_DATA/wpracdb/datafile/oggsjjg_data_ ' size 20G

autoextend on next 500M maxsize 31G;

datafile

创建新用户

create user oggsjjg identified by oggsjjg tablespace OGGSJJG_DATA；

创建目录及授权

create directory DP_DATA as '/app/ogg/dirdat/';

grant read,write on directory DP_DATA to oggsjjg;

2、以oracle用户登录服务器，导入初始化数据

impdp oggsjjg/oggsjjg directory=DP_DATA dumpfile=

logfile=impdp_`date +%Y%m%d%H`.log

remap_schema=GS_CXTJ:OGGSJJG,HX_CS_ZDY:OGGSJJG,HX_DJ:OGGSJJG,HX_DM_QG:OGGSJJG,HX_DM_ZDY:OGGSJJG,HX_FP:OGGSJJG,HX_QX:OGGSJJG,HX_RD:OGGSJJG,HX_SB:OGGSJJG,HX_ZS:OGGSJJG

remap_tablespace=TS_GS_CXTJ_DATA:OGGSJJG_DATA,TS_HX_DJ_DATA:OGGSJJG_DATA,TS_HX_DM_DATA:OGGSJJG_DATA,TS_HX_FPFX_DATA:OGGSJJG_DATA,TS_HX_SB_DATA:OGGSJJG_DATA,TS_HX_ZS_DATA:OGGSJJG_DATA,TS_HX_DJ_IDX:OGGSJJG_DATA,TS_HX_DM_IDX:OGGSJJG_DATA,TS_HX_FPFX_IDX:OGGSJJG_DATA,TS_HX_SB_IDX:OGGSJJG_DATA,TS_HX_ZS_IDX:OGGSJJG_DATA

table_exists_action=replace cluster=no parallel=16;

3、数据导入完成后，检查数据

统计oggsjjg用户下导入表的条数和源库中表的条数进行比对

统计源库的表名如下

HX__NSRCKZHZHXX

HX__NSRXX_KZ

HX__NSRXX_KZ_LS

HX__NSRXX

HX__PZJGXX

HX__WTXYSXX

HX__QX_SWRYSF

HX__DK_FPKJXX

HX__DK_YSYSKMX

HX__DK_SQ

HX__DK_ZZSFP

HX__FPKF

HX__LY

HX__LY_MX

HX__PZHDXXZB

HX__SFZRDXXB

HX__SBXX

HX__YJSF

HX_DM__FP_FP

HX_DM__FP_FPLB

HX_DM__FP_FPZL

HX_DM__GY_HY

HX_DM__GY_NSRZT

HX_DM__GY_SWJG

HX_DM__GY_SWRY

HX_DM__GY_YHYYWD

HX_DM__GY_ZSPM

HX__DK_TYJDFP

HX__DK_ZZS_GHFNSRXX

HX__DK_ZZSFP_HLMX

HX__NSRFPJC

HX__PZHDXX

HX__SWJGKFKC

HX__TP

HX__TP_MX

HX__NSRZGXX_JGB

HX__HD_DQDEHD_JG

HX__SFZRDXXB_YGZ

HX__NSRZGXX_JGB_YGZ

HX_DM__FP_FPZL

HX_DM__FP_FP

HX__WLFP_KJXX

HX__NSRCKZHZHXX_YGZ

HX__NSRXX_KZ_YGZ

HX__NSRXX_YGZ

HX__HD_DQDEHD_JG_YGZ

HX__DBCKD_MX

HX__SWJGKFKC

HX__YZJHFP

HX__YZJHFP_MX

HX__YZJH

HX__YZRKXX

HX__YZYBDWMCFPBAXX

HX__WLFP_PZHDXX

HX__WLFP_SFZRDXXB

HX__WTXYS_BWTDZNSRXX

HX_CS__ZS_SWJGGKDZB

四、开启replicat进程

因源端忘记修改目标端IP地址导致ogg数据文件传送到其他主机，故需要将文件手工复制到本机来：

scp oracle@98.12.10.215:/app/oracle/ogg/dirdat/zt00028* /app/ogg/dirdat

scp oracle@98.12.10.215:/app/oracle/ogg/dirdat/zt000290 /app/ogg/dirdat

修改replicat进程复制的起始文件

alter replicat RQF_WP1,extseqno 000284,extrba 0

alter replicat RQF_WP2,extseqno 000284,extrba 0

alter replicat RQF_WP3,extseqno 000284,extrba 0

alter replicat RQF_WP4,extseqno 000284,extrba 0

alter replicat RQF_WP5,extseqno 000284,extrba 0

开启replicat进程，注意需要加上scn号

start RQF_WP1, aftercsn 184

start RQF_WP2, aftercsn 184

start RQF_WP3, aftercsn 184

start RQF_WP4, aftercsn 184

start RQF_WP5, aftercsn 184

源端后续传输过来数据文件序号与手工复制过来的文件序号不连续，需要等复制完手工复制的文件后再次手工修改replicat进程复制的起始文件序号

查看确认手工传送的文件复制完成

Info RQF_WP1,detail

（根据log read checkpoint中的详细时间确认数据文件是否全部同步完成）

停止复制进程

Stop RQF_WP1

修改replicat进程的起始文件

alter replicat RQF_WP1,extseqno 000293,extrba 0

开启复制进程

Start RQF_WP1

其它四个replicat进程进行同样操作

五、比对数据

手动复制过来的数据文件序号和ogg传输过来的文件序号不连续，故需要手工比对源库表和目标端表的数据是否一致。条目数比对，需根据情况确认是进行补数据或者重新进行数据初始化。

经比对数据，发现有两个表需要手工补入数据。重新补入数据后比对表的条目数正常。