加载中…
个人资料
  • 博客等级:
  • 博客积分:
  • 博客访问:
  • 关注人气:
  • 获赠金笔:0支
  • 赠出金笔:0支
  • 荣誉徽章:
正文 字体大小:

ogg_goldengate实现数据初始化同步

(2013-05-22 21:47:26)
标签:

initial

ogg

oracle

it

分类: goldengate
1.
 如果源端和目标端都是oracle的话,还是建议是用expdp/impdp(scn)进行初始化。
 我这里的环境是MSSQL=>ORACLE

2.
  在目标端创建需要的表(主键必带)
3.
 配置OGG
1.truncate 目标表数据
TRUNCATE TABLE yc_elefile.SUBAPPROVEFLOW;
TRUNCATE TABLE yc_elefile.PASSWORD      ;
TRUNCATE TABLE yc_elefile.MAINDWGDB_DEL ;
TRUNCATE TABLE yc_elefile.MAINDWGDB     ;
TRUNCATE TABLE yc_elefile.GLIBNAME      ;
                                    
                                    
2.
配置OGG初始化进程。


edit params E_INIEP

extract inielep
sourcedb ggsdb userid goldengate,password goldengate

rmthost 10.68.10.15,mgrport 7809
rmttask replicat,group r_iniep

table dbo.SUBAPPROVEFLOW;
table dbo.PASSWORD      ;
table dbo.MAINDWGDB_DEL   ;
table dbo.MAINDWGDB     ;
table dbo.GLIBNAME       ;



===GGSCI
add extract e_iniep, sourceistable  


==目标端

edit params r_iniep


replicat r_iniep
setenv (ORACLE_SID = EPMS1)
SETENV (NLS_LANG=AMERICAN_AMERICA.AL32UTF8)

userid goldengate@epmsprod,password oracle123

sourcedefs ./dirdef/ele_elep.defs

map dbo.SUBAPPROVEFLOW,target YC_ELEFILE.SUBAPPROVEFLOW
colmap(     usedefaults,
ID        = ID        ,
MAINID    = MAINID    ,
FLOWNUM   = FLOWNUM   ,
FLOWNAME  = FLOWNAME  ,
CHKBL     = CHKBL     ,
CHKMAN    = CHKMAN    ,
CHKWKNUM  = CHKWKNUM  ,
CHKSUM    = CHKSUM    ,
CHKNO     = CHKNO     ,
CHKDATE   = CHKDATE   ,
CHKTXT    = CHKTXT    ,
FLOWNUMSTR= FLOWNUMSTR
);

map dbo.password,
target YC_ELEFILE.PASSWORD
colmap(usedefaults,
 ID       = ID       ,
 NAME     = NAME           
 CODENAME = CODENAME ,
 PSEUDOPWD= PSEUDOPWD  
);

map dbo.MAINDWGDB_DEL,
target YC_ELEFILE.MAINDWGDB_DEL
colmap (   usedefaults,
 ID             ID         
 MAINID         MAINID     
 DWGNAME        DWGNAME    
 DWGSORT        DWGSORT    
 DWGPAGENO      DWGPAGENO  
 DWGINFOSUM     DWGINFOSUM ,  
 DWGDRAWDATE    DWGDRAWDATE,  
 MAINCHGDATE    MAINCHGDATE,  
 CHGMAN         CHGMAN     
 CHECKMAN       CHECKMAN   
 ORDERMAN       ORDERMAN   
 MAINNOTE1      MAINNOTE1  
 CMPDATE        CMPDATE    
 CHKDATE        CHKDATE    
 DWGNO          DWGNO      
 DESIGNUNIT     DESIGNUNIT ,  
 DOUNIT         DOUNIT     
 DESIGNUM       DESIGNUM   
 USERUNIT       USERUNIT   
 COPY0          COPY0      
 COMPAREMAN     COMPAREMAN 
 SUBSYS0        SUBSYS0    
 EAMCODE        EAMCODE    
 COMPAREIDX     COMPAREIDX ,  
 CONWRITE       CONWRITE ,    
 CHGBL          CHGBL      
 MAINIDBL       MAINIDBL   
 COPYNUM        COPYNUM    
 COMPAREBL      COMPAREBL  
 CHECKBL        CHECKBL    
 ORDERBL        ORDERBL    
 OFFERMAN       OFFERMAN   
 FILEKIND0      FILEKIND0 ,   
 ALLRIGHTBL     ALLRIGHTBL,   
 MODMANS        MODMANS ,     
 VIEWMANS       VIEWMANS ,    
 ORDDATE        ORDDATE    
 OUTDATE        OUTDATE    
 ROTATE         ROTATE     
 UNSTANDARD     UNSTANDARD 
 RECHKMAN       RECHKMAN   
 RECHKDATE      RECHKDATE  
 RECHKBL        RECHKBL    
 TXTRECHK       TXTRECHK   
 USERWKID_DEL   USERWKID_DEL  ,
 USERWKNO_DEL   USERWKNO_DEL  ,
 USERWKNAME_DEL=   USERWKNAME_DEL,
 FILEDELDATE    FILEDELDATE   ,
 IPADDR         IPADDR       ,
 IPMACADDR      IPMACADDR     ,
 COMPUTERNAME   COMPUTERNAME  ,
 HARDDISKINO    HARDDISKINO   ,
 DELMODE        DELMODE       ,
 SPECIALTYID    SPECIALTYID 
);
map dbo.MAINDWGDB,
target yc_elefile.MAINDWGDB
colmap(  usedefaults,
 MAINID            MAINID   
 DWGNAME           DWGNAME     ,
 DWGSORT           DWGSORT    ,
 DWGPAGENO         DWGPAGENO  ,
 DWGDRAWDATE       DWGDRAWDATE ,
 CHGMAN            CHGMAN   
 CHECKMAN          CHECKMAN 
 ORDERMAN          ORDERMAN 
 CMPDATE           CMPDATE  
 CHKDATE           CHKDATE  
 DESIGNUM          DESIGNUM 
 COPY0             COPY0    
 COMPAREMAN        COMPAREMAN ,
 EAMCODE           EAMCODE  
 MAINIDBL          MAINIDBL ,  
 COPYNUM           COPYNUM  
 COMPAREBL         COMPAREBL   ,
 CHECKBL           CHECKBL  
 ORDERBL           ORDERBL  
 ALLRIGHTBL        ALLRIGHTBL ,
 CHGBL             CHGBL    
 TXTCMP            TXTCMP   
 TXTCHK            TXTCHK  
 TXTORD            TXTORD   
 ORDDATE           ORDDATE  
 KEYWORDS          KEYWORDS ,  
 CHGWKNUM          CHGWKNUM ,  
 CMPWKNUM          CMPWKNUM ,  
 CHKWKNUM          CHKWKNUM 
 RECHKWKNUM        RECHKWKNUM  ,
 ORDWKNUM          ORDWKNUM 
 MULTICHK          MULTICHK   ,
 WORKTICKETBL      WORKTICKETBL

);

map dbo.GLIBNAME,
target yc_elefile.GLIBNAME
colmap(
GLIBID   = GLIBID  ,
GLIBNAME = GLIBNAME,
USERNAME = USERNAME,
CREDATE  = CREDATE
);


add replicat r_iniep, specialrun




start extract e_iniep


error ogg-01192
trying to use rmttask on data  types which may be writes as LOB chunks(TABLE)


由于带LOB或LONG字段,这里的解决办法是修改extract+ normal replicat进行。

extract inielep
sourcedb ggsdb userid goldengate,password goldengate

rmthost 10.68.10.15,mgrport 7809
rmtfile ./dirdat/ii ,maxfiles 999999,megabytes 100

table dbo.SUBAPPROVEFLOW;
table dbo.PASSWORD      ;
table dbo.MAINDWGDB_DEL   ;
table dbo.MAINDWGDB     ;
table dbo.GLIBNAME       ;

然后使用正常的replicat进程读取文件

edit params r_iniep
 add replicat r_iniep, exttrail ./dirdat/ii
 

0

阅读 收藏 喜欢 打印举报/Report
  

新浪BLOG意见反馈留言板 欢迎批评指正

新浪简介 | About Sina | 广告服务 | 联系我们 | 招聘信息 | 网站律师 | SINA English | 产品答疑

新浪公司 版权所有