用ogg对mysql的字符字段的最后两位进行分表
1.增量数据配置
GGSCI (wgq-160-17) 12> view param e_test
extract E_TEST
setenv (MYSQL_HOME="/mysql/base")
setenv (NLS_LANG="AMERICAN_AMERICA.UTF8")
tranlogoptions altlogdest /mysql/3306/log/mysql-bin.index
sourcedb ogg@192.168.56.101:3306 ,userid yyy password xxx
exttrail /u03/ogg/ggs/dirdat/qh
--dynamicresolution
table umss01.tc_clearing_record_3,FETCHCOLS(*);
GGSCI (wgq-160-17) 13> view param r_test
REPLICAT R_test
setenv (MYSQL_HOME="/mysql/base")
sourcedefs /u03/ogg/ggs/dirdef/upart.def OVERRIDE
TARGETDB ogg@192.168.56.101:3306 ,userid yyy, password xxx
discardfile ./dirrpt/r_test.dsc,append,megabytes 100
GROUPTRANSOPS 3000
HANDLECOLLISIONS
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_03,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '03');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_13,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '13');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_23,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '23');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_33,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '33');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_43,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '43');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_53,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '53');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_63,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '63');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_73,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '73');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_83,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '83');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_93,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '93');
-----------------------------------------------------------------------
2.全量数据配置
数据不落地的情况下,需要在同一台服务器配置两个mgr,分别使用不同的端口号
[13:43:40 root@wgq-160-17 ggs]# ps -ef|grep mgr
mysql 647 1 0 Mar14 ? 00:02:05 ./mgr PARAMFILE /u03/ogg/ggs/dirprm/mgr.prm REPORTFILE /u03/ogg/ggs/dirrpt/MGR.rpt PROCESSID MGR
mysql 691 1 0 Mar14 ? 00:01:54 ./mgr PARAMFILE /u01/ogg/ggs/dirprm/mgr.prm REPORTFILE /u01/ogg/ggs/dirrpt/MGR.rpt PROCESSID MGR
源端:
[13:45:11 root@wgq-160-17 dirprm]# pwd
/u03/ogg/ggs/dirprm
[13:45:18 root@wgq-160-17 dirprm]# cat initpt.prm
extract initpt
setenv (MYSQL_HOME="/mysql/base")
sourcedb ogg@192.168.56.101:3306 ,userid yyy password xxx
rmthost 192.168.56.101,mgrport 7810
rmttask replicat, group reppt
table umss01.tc_clearing_record_0,FETCHCOLS(*);
table umss01.tc_clearing_record_1,FETCHCOLS(*);
table umss01.tc_clearing_record_2,FETCHCOLS(*);
table umss01.tc_clearing_record_3,FETCHCOLS(*);
目标端
[13:46:37 root@wgq-160-17 dirprm]# pwd
/u01/ogg/ggs/dirprm
[13:46:59 root@wgq-160-17 dirprm]# cat reppt.prm
replicat reppt
setenv (MYSQL_HOME="/mysql/base")
TARGETDB ogg@192.168.56.101:3306 ,userid yyy password xxx
REPERROR DEFAULT, ABEND
ASSUMETARGETDEFS
discardfile ./dirrpt/rpart.dsc,APPEND, MEGABYTES 100
REPORTCOUNT EVERY 1 MINUTES, RATE
map umss01.tc_clearing_record_0, target umss01.tc_clearing_record_00,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '00');
map umss01.tc_clearing_record_0, target umss01.tc_clearing_record_10,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '10');
map umss01.tc_clearing_record_0, target umss01.tc_clearing_record_20,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '20');
map umss01.tc_clearing_record_0, target umss01.tc_clearing_record_30,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '30');
map umss01.tc_clearing_record_0, target umss01.tc_clearing_record_40,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '40');
map umss01.tc_clearing_record_0, target umss01.tc_clearing_record_50,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '50');
map umss01.tc_clearing_record_0, target umss01.tc_clearing_record_60,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '60');
map umss01.tc_clearing_record_0, target umss01.tc_clearing_record_70,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '70');
map umss01.tc_clearing_record_0, target umss01.tc_clearing_record_80,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '80');
map umss01.tc_clearing_record_0, target umss01.tc_clearing_record_90,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '90');
map umss01.tc_clearing_record_1, target umss01.tc_clearing_record_01,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '01');
map umss01.tc_clearing_record_1, target umss01.tc_clearing_record_11,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '11');
map umss01.tc_clearing_record_1, target umss01.tc_clearing_record_21,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '21');
map umss01.tc_clearing_record_1, target umss01.tc_clearing_record_31,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '31');
map umss01.tc_clearing_record_1, target umss01.tc_clearing_record_41,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '41');
map umss01.tc_clearing_record_1, target umss01.tc_clearing_record_51,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '51');
map umss01.tc_clearing_record_1, target umss01.tc_clearing_record_61,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '61');
map umss01.tc_clearing_record_1, target umss01.tc_clearing_record_71,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '71');
map umss01.tc_clearing_record_1, target umss01.tc_clearing_record_81,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '81');
map umss01.tc_clearing_record_1, target umss01.tc_clearing_record_91,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '91');
map umss01.tc_clearing_record_2, target umss01.tc_clearing_record_02,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '02');
map umss01.tc_clearing_record_2, target umss01.tc_clearing_record_12,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '12');
map umss01.tc_clearing_record_2, target umss01.tc_clearing_record_22,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '22');
map umss01.tc_clearing_record_2, target umss01.tc_clearing_record_32,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '32');
map umss01.tc_clearing_record_2, target umss01.tc_clearing_record_42,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '42');
map umss01.tc_clearing_record_2, target umss01.tc_clearing_record_52,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '52');
map umss01.tc_clearing_record_2, target umss01.tc_clearing_record_62,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '62');
map umss01.tc_clearing_record_2, target umss01.tc_clearing_record_72,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '72');
map umss01.tc_clearing_record_2, target umss01.tc_clearing_record_82,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '82');
map umss01.tc_clearing_record_2, target umss01.tc_clearing_record_92,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '92');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_03,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '03');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_13,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '13');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_23,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '23');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_33,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '33');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_43,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '43');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_53,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '53');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_63,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '63');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_73,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '73');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_83,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '83');
map umss01.tc_clearing_record_3, target umss01.tc_clearing_record_93,COLMAP (USEDEFAULTS), filter(@STREXT(MERCHANT_NO, @STRLEN(MERCHANT_NO) - 1, @STRLEN(MERCHANT_NO)) = '93');