为 InfoSphere Warehouse 提供实时数据的高效解决方案
2010-07-23 00:00:00 来源:WEB开发网4. 启动 capture:
清单 5. 启动 capture
asnqcap capture_server=source capture_schema=ASN
2010-04-22-15.48.28.549339 ASN0600I "Q Capture" : "" :
"Initial" : Program "mqpub 9.7.0" is starting.
2010-04-22-15.48.38.537012 ASN7010I "Q Capture" : "ASN" :
"WorkerThread" : The program successfully activated publication
or Q subscription "EVENTPUB1" (send queue "q1",
publishing or replication queue map "PUBQMAP1")
for source table "DEMO.CUSTOMER".
2010-04-22-15.48.38.641830 ASN7000I "Q Capture" : "ASN" :
"WorkerThread" : "0" subscriptions are active.
"0" subscriptions are inactive. "1" subscriptions that
were new and were successfully activated. "0" subscriptions
that were new could not be activated and are now inactive.
2010-04-22-15.48.38.747328 ASN0572I "Q Capture" : "ASN" :
"WorkerThread" : The "mqpub 9.7.0"
program initialized successfully.
5. 对源表做些插入、删除和更新操作
清单 6. 更新源表
connect to source;
insert into "DEMO"."CUSTOMER" values ('9000', 'F','1960-05-06-00.00.00.000000',
'467897085', 'Boise','Idaho','83701-83733','(71)657-9085','English',
'2006-08-18-21.52.29.000000','IRVING','H','STERN');
insert into "DEMO"."CUSTOMER" values ('9100', 'F','1960-05-06-00.00.00.000000',
'467897085','Boise', 'Idaho','83701-83733','(71)657-9085','English',
'2006-08-18-21.52.29.000000','IRVING','H','STERN');
update "DEMO"."CUSTOMER" set CUSTOMER_ID=5000 where CUSTOMER_ID=2075;
update "DEMO"."CUSTOMER" set FIRST_NAME='meggy' where FIRST_NAME='EILEEN';
update "DEMO"."CUSTOMER" set LAST_NAME='Leee' where LAST_NAME='JOHNSON';
delete from "DEMO"."CUSTOMER" where CUSTOMER_ID=6057;
delete from "DEMO"."CUSTOMER" where CUSTOMER_ID=8354;
connect reset;
Tags:InfoSphere Warehouse 提供
编辑录入:爽爽 [复制链接] [打 印]更多精彩
赞助商链接