OGG中token的使用

OGG版本&＃xff1a;19.1

RDBMS&＃xff1a;19.15 

测试目的&＃xff1a;
源端表&＃xff1a;bb.t2 
目标端表&＃xff1a; zbb.t4,zbb.t5 .  t4和t5结构不同。t5中相对t4中多余的列为token获取的环境变量
同时将bb.t2同步到zbb.t4和zbb.t5 .

关于token和&＃64;getenv函数&＃xff0c;可以参考官方文档 Oracle® GoldenGate Windows and UNIX Reference Guide 

源端表&＃xff1a;

BB&＃64;orcl>desc t2Name Null? Type----------------------------------------- -------- ----------------------------ID NUMBERNAME VARCHAR2(10)BB&＃64;orcl>


目标端表

conn zbb/oracle
create table t5 (
no number,
firstname varchar2(10), ## token名 &＃61; token值
host varchar2(40), -- TKN-HOST &＃61; &＃64;GETENV (&＃39;GGENVIRONMENT", "HOSTNAME&＃39;),
gg_group varchar2(40), -- TKN-GRP &＃61; &＃64;GETENV (&＃39;GGENVIRONMENT", "GROUPNAME&＃39;),
osuser varchar2(40), -- TKN-USER &＃61; &＃64;GETENV (&＃39;GGENVIRONMENT", "OSUSERNAME&＃39;),
domain varchar2(40), -- TKN-DOMAIN &＃61; &＃64;GETENV (&＃39;GGENVIRONMENT", "DOMAINNAME&＃39;),
UPDATETIME date, -- updatetime&＃61; &＃64;TOKEN (&＃39;GGHEADER&＃39;,&＃39;COMMITTIMESTAMP&＃39;),
tablename varchar2(40), -- TKN-TBNAME &＃61; &＃64;GETENV (&＃39;GGHEADER”, “TABLENAME&＃39;),
optype varchar2(40) -- TKN-OPT &＃61; &＃64;GETENV (&＃39;GGHEADER”, “OPTYPE&＃39;),
)

源端的ext2 ,源端ext进程&＃xff0c;获取的环境变量较多&＃xff0c;虽然针对t4表&＃xff0c;用不了这么多&＃xff0c;但是针对t5表&＃xff0c;可以用到这些。不影响t2和t4&＃xff0c;t2和t5的同时同步

table bb.t2 ,TOKENS & ## 一行写不下&＃xff0c;可以使用符号&换行
(TKN-HOST &＃61; &＃64;GETENV (&＃39;GGENVIRONMENT&＃39;, &＃39;HOSTNAME&＃39;), &
TKN-GRP &＃61; &＃64;GETENV (&＃39;GGENVIRONMENT&＃39;, &＃39;GROUPNAME&＃39;), &
TKN-USER &＃61; &＃64;GETENV (&＃39;GGENVIRONMENT&＃39;, &＃39;OSUSERNAME&＃39;),&
TKN-DOMAIN &＃61; &＃64;GETENV (&＃39;GGENVIRONMENT&＃39;, &＃39;DOMAINNAME&＃39;),&
updatetime&＃61; &＃64;GETENV (&＃39;GGHEADER&＃39;,&＃39;COMMITTIMESTAMP&＃39;),&
TKN-TBNAME &＃61; &＃64;GETENV (&＃39;GGHEADER&＃39;, &＃39;TABLENAME&＃39;),&
TKN-OPT &＃61; &＃64;GETENV (&＃39;GGHEADER&＃39;, &＃39;OPTYPE&＃39;));


源端的pump2进程

table bb.t2 ,TOKENS &
(TKN-HOST &＃61; &＃64;GETENV (&＃39;GGENVIRONMENT&＃39;, &＃39;HOSTNAME&＃39;), &
TKN-GRP &＃61; &＃64;GETENV (&＃39;GGENVIRONMENT&＃39;, &＃39;GROUPNAME&＃39;), &
TKN-USER &＃61; &＃64;GETENV (&＃39;GGENVIRONMENT&＃39;, &＃39;OSUSERNAME&＃39;),&
TKN-DOMAIN &＃61; &＃64;GETENV (&＃39;GGENVIRONMENT&＃39;, &＃39;DOMAINNAME&＃39;),&
updatetime&＃61; &＃64;GETENV (&＃39;GGHEADER&＃39;,&＃39;COMMITTIMESTAMP&＃39;),&
TKN-TBNAME &＃61; &＃64;GETENV (&＃39;GGHEADER&＃39;, &＃39;TABLENAME&＃39;),&
TKN-OPT &＃61; &＃64;GETENV (&＃39;GGHEADER&＃39;, &＃39;OPTYPE&＃39;));


因为源端的表没有变化&＃xff0c;所以不要再次生成defgen file&＃xff0c;只需要在目标端rep2中添加map &＃xff0c;原来的对t4表的map&＃xff0c;也存在 

map bb.t2,target zbb.t4, COLMAP (USEDEFAULTS,no&＃61;id,firstname&＃61;name ,updatetime&＃61; &＃64;TOKEN (&＃39;updatetime&＃39;)),filter (id > 30); -- 仅仅复制id>30map bb.t2,target zbb.t5, COLMAP ( &
USEDEFAULTS, &
no&＃61;id, &
firstname&＃61;name , &
host &＃61; &＃64;token (&＃39;TKN-HOST&＃39;), &
gg_group &＃61; &＃64;token (&＃39;TKN-GRP&＃39;), &
osuser&＃61; &＃64;token (&＃39;TKN-USER&＃39;), &
domain &＃61; &＃64;token(&＃39;TKN-DOMAIN&＃39;),&
updatetime&＃61; &＃64;TOKEN (&＃39;updatetime&＃39;), &
tablename&＃61; &＃64;TOKEN (&＃39;TKN-TBNAME&＃39;), &
optype&＃61; &＃64;TOKEN (&＃39;TKN-OPT&＃39;), &
);

同步成功&＃xff0c;原来的T4&＃xff0c;也可以同步。 T2同时同步到T4&＃xff0c;T5  .

ZBB&＃64;test>select * from t4;NO FIRSTNAME UPDATETIME
---------- ---------- -------------------------41 p 2022-07-13 16:56:2142 ae 2022-07-13 17:10:3743 iwc 2022-07-13 17:13:2247 mmm ## 这里没有结果&＃xff0c;是因为map t2到t4的&＃xff0c;token中&＃xff0c;token名称写错了 &＃xff0c;修改后就可以了。48 ccc 2022-07-14 15:24:1514 c 2022-07-11 14:32:2815 d 2022-07-11 14:34:2311 c 2022-07-09 19:14:2313 c 2022-07-09 19:28:2918 a 2022-07-13 15:37:4319 m 2022-07-13 15:41:25NO FIRSTNAME UPDATETIME
---------- ---------- -------------------------32 c 2022-07-13 16:01:1440 i 2022-07-13 16:04:1341 m 2022-07-13 16:53:059 a 2022-07-08 14:33:0310 aa 2022-07-08 17:13:0717 a 2022-07-13 11:24:5416 a 2022-07-13 10:35:1218 rows selected.ZBB&＃64;test>select * from t5; ## DOmain字段没有结果&＃xff0c;这个字段仅仅针对Windows&＃xff0c;官方文档上有说明 NO FIRSTNAME HOST GG_GROUP OSUSER DOMAIN UPDATETIME TABLENAME OPTYPE
---------- ---------- ---------------- ---------- ---------- ---------- ------------------------- ---------- ----------44 aa redhat762100 PUMP2 oracle BB.T2 INSERT45 mw redhat762100 PUMP2 oracle BB.T2 INSERT46 afdsa redhat762100 PUMP2 oracle 2022-07-14 15:14:32 BB.T2 INSERT47 mmm redhat762100 PUMP2 oracle 2022-07-14 15:22:35 BB.T2 INSERT48 ccc redhat762100 PUMP2 oracle 2022-07-14 15:24:15 BB.T2 INSERTZBB&＃64;test>

END