OGG目标端配置进程初始化数据

1、添加复制进程
[code]ADD REPLICAT MREP_JJ, EXTTRAIL ./dirdat/va [/code]

2、配置复制进程mrep_jj
[code]GGSCI (twserver) 5> edit params mrep_jj
REPLICAT mrep_jj
SETENV (NLS_LANG=AMERICAN_AMERICA.ZHS16GBK)
ASSUMETARGETDEFS
HANDLECOLLISIONS
USERID ogguser, PASSWORD ogguser
DISCARDFILE ./dirrpt/mrep_jj.dsc, PURGE

MAP LPROMIS.T_JJ_XMAQJCXX, TARGET ODS_YYJC_BUF.T_JJ_XMAQJCXX, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_AQYBZDFX, TARGET ODS_YYJC_BUF.T_JJ_AQYBZDFX, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_ZBXX, TARGET ODS_YYJC_BUF.T_JJ_ZBXX, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_YZXMBRY, TARGET ODS_YYJC_BUF.T_JJ_YZXMBRY, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_YZXMBJBXX, TARGET ODS_YYJC_BUF.T_JJ_YZXMBJBXX, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_XMGC, TARGET ODS_YYJC_BUF.T_JJ_XMGC, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_GCSPQK, TARGET ODS_YYJC_BUF.T_JJ_GCSPQK, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_DTGCJD, TARGET ODS_YYJC_BUF.T_JJ_DTGCJD, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_DTGC, TARGET ODS_YYJC_BUF.T_JJ_DTGC, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_NDJDJHXF, TARGET ODS_YYJC_BUF.T_JJ_NDJDJHXF, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_JSGLDW, TARGET ODS_YYJC_BUF.T_JJ_JSGLDW, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_DMMX, TARGET ODS_YYJC_BUF.T_JJ_DMMX, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_XMJBXX, TARGET ODS_YYJC_BUF.T_JJ_XMJBXX, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_BNS_PRJM_PROJECT, TARGET ODS_YYJC_BUF.T_BNS_PRJM_PROJECT_BASE, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_SXM_SHIGRZ, TARGET ODS_YYJC_BUF.T_SXM_SHIGRZ, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_SXM_WORKSC, TARGET ODS_YYJC_BUF.T_SXM_WORKSC, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_SXM_ZHOUYB, TARGET ODS_YYJC_BUF.T_SXM_ZHOUYB, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP LPROMIS.T_JJ_XMJDZT, TARGET ODS_YYJC_BUF.T_JJ_XMJDZT, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_BNS_PRJM_CONSTRUTUNIT, TARGET ODS_YYJC_BUF.T_BNS_PRJM_CONSTRUTUNIT_BASE, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_BNS_PRJM_PROBASINFOSEND, TARGET ODS_YYJC_BUF.T_BNS_PRJM_PROBASINFOSEND, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_BNS_PRJM_PROBASINFOTRAN, TARGET ODS_YYJC_BUF.T_BNS_PRJM_PROBASINFOTRAN, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_BNS_PRJM_PROBASINFO, TARGET ODS_YYJC_BUF.T_BNS_PRJM_PROBASINFO, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_CTL_DICTIONARY, TARGET ODS_YYJC_BUF.T_CTL_DICTIONARY, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_GATHER_PROJECT_GROUP_DX, TARGET ODS_YYJC_BUF.T_GATHER_PROJECT_GROUP_DX, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_PDC_ORGANIZATION, TARGET ODS_YYJC_BUF.T_PDC_ORGANIZATION_BASE, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_PGC_OF_PROJECT, TARGET ODS_YYJC_BUF.T_PGC_OF_PROJECT, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_PGC_OF_PROJECT_LIST, TARGET ODS_YYJC_BUF.T_PGC_OF_PROJECT_LIST, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());
MAP STDPM.T_STD_YEAR_PLAN, TARGET ODS_YYJC_BUF.T_STD_YEAR_PLAN, COLMAP (USEDEFAULTS, UPDATETIME = @DATENOW());[/code]


3、初始化数据库
1、运行初始化脚本
[code]sqlplus / as sysdba
conn ods_yyjc_buf/ODS_YYJC_BUF
@d:\\基建管控.sql[/code]
2、导入LPROMIS用户下的表
[code]IMP ODS_YYJC_BUF/ODS_YYJC_BUF FILE=D:\\JJ_LP.DUMP BUFFER=65536 FROMUSER=LPROMIS TOUSER=ODS_YYJC_BUF IGNORE=Y[/code]
3、导入STDPM下的表
[code]IMP ODS_YYJC_BUF/ODS_YYJC_BUF FILE=D:\\JJ_ST.DUMP BUFFER=65536 FROMUSER=STDPM TOUSER=ODS_YYJC_BUF IGNORE=Y[/code]

4、处理表名不同的问题
[code]INSERT INTO T_BNS_PRJM_PROJECT_BASE (ID,PROJECT_NAME,PROJECT_SHORTNAME,NAME_JP_SPELL,PROJECT_CODE,SUPER_PROJECTID,PROJECT_LEVEL,PROJECT_TYPE,LEVEL_TYPE,PROJECT_SUB_TYPE,VOLTAGE_LEVEL,PROJ_STATUS,IMPORTANT_PRJ,SORT_NUMBER,ISSHOW,HAVE_SUB_SEG,CREATE_TIME,UPDATE_USER,UPDATE_TIME,DELETE_FLAG,VERSION,CREATE_USER,REMARK,ERP_CODE,CREATE_QUALITY,CREATE_FROM,PLAN_FIN_DATE,START_DATE,FIN_DATE,PLAN_START_DATE,PLAN_COMP_DATE,COMP_DATE,SCOPE,SCREEN_ANQYB,ISAPPRAISE,PROJ_PRTS,IS_MIND,ISDXTC,DXTCSP,SMALLPROJ_FLAG,TCBDRL,TCXLCD,KYBDRL,KYXLCD,CSBDRL,CSXLCD,UPDATETIME) VALUES (SELECT ID,PROJECT_NAME,PROJECT_SHORTNAME,NAME_JP_SPELL,PROJECT_CODE,SUPER_PROJECTID,PROJECT_LEVEL,PROJECT_TYPE,LEVEL_TYPE,PROJECT_SUB_TYPE,VOLTAGE_LEVEL,PROJ_STATUS,IMPORTANT_PRJ,SORT_NUMBER,ISSHOW,HAVE_SUB_SEG,CREATE_TIME,UPDATE_USER,UPDATE_TIME,DELETE_FLAG,VERSION,CREATE_USER,REMARK,ERP_CODE,CREATE_QUALITY,CREATE_FROM,PLAN_FIN_DATE,START_DATE,FIN_DATE,PLAN_START_DATE,PLAN_COMP_DATE,COMP_DATE,SCOPE,SCREEN_ANQYB,ISAPPRAISE,PROJ_PRTS,IS_MIND,ISDXTC,DXTCSP,SMALLPROJ_FLAG,TCBDRL,TCXLCD,KYBDRL,KYXLCD,CSBDRL,CSXLCD,UPDATETIME,SYSDATE FROM T_BNS_PRJM_PROJECT);
INSERT INTO T_BNS_PRJM_CONSTRUTUNIT_BASE (ID,PROJECT_ID,UNIT_TYPE,SUBUNIT_TYPE,UNIT_ID,VERSION,CREATE_USER,CREATE_TIME,UPDATE_USER,UPDATE_TIME,DELETE_FLAG,UPDATETIME) VALUES (SELECT ID,PROJECT_ID,UNIT_TYPE,SUBUNIT_TYPE,UNIT_ID,VERSION,CREATE_USER,CREATE_TIME,UPDATE_USER,UPDATE_TIME,DELETE_FLAG,SYSDATE FROM T_BNS_PRJM_CONSTRUTUNIT);
INSERT INTO T_PDC_ORGANIZATION_BASE (ID,ORGANIZATION_CODE,ORGANIZATION_NAME,ORGANIZATION_SORT,PARENT_ORGANIZATION_ID,VERSION,CREATE_USER,CREATE_TIME,UPDATE_USER,UPDATE_TIME,DELETE_FLAG,PATH,MENU_TEMPLET,SERIAL_NUM,TELEPHONE,POSTCODE,FAXADDRESS,WEBSITE,NOTES,CONTACT,ORGANIZATION_TYPE,UPDATETIME) VALUES (SELECT ID,ORGANIZATION_CODE,ORGANIZATION_NAME,ORGANIZATION_SORT,PARENT_ORGANIZATION_ID,VERSION,CREATE_USER,CREATE_TIME,UPDATE_USER,UPDATE_TIME,DELETE_FLAG,PATH,MENU_TEMPLET,SERIAL_NUM,TELEPHONE,POSTCODE,FAXADDRESS,WEBSITE,NOTES,CONTACT,ORGANIZATION_TYPE,SYSDATE FROM T_PDC_ORGANIZATION);
drop table T_BNS_PRJM_CONSTRUTUNIT cascade constraints;
drop table T_BNS_PRJM_PROJECT cascade constraints;
drop table T_PDC_ORGANIZATION cascade constraints;[/code]
4、开启相关进程
[code]start mgr
START REPLICAT MREP_JJ, AFTERCSN 10144234398385
info all
indo *[/code]

5、测试复制进程
在源端做insert、update、delete操作
在目标端确认