为 InfoSphere Warehouse 提供实时数据的高效解决方案

核心提示： 查看原图（大图）下面将具体介绍其实现，具体实现所需软件：IBM InfoSphere Replication Server 9.7IBM InfoSphere Information Server 8.1Event Publisher 的配置如果 source 是 Oracle，为 InfoSp

查看原图（大图）

下面将具体介绍其实现。

具体实现

所需软件：

IBM InfoSphere Replication Server 9.7

IBM InfoSphere Information Server 8.1

Event Publisher 的配置

如果 source 是 Oracle，需要通过 Replication Server Oracle capture feature 来完成对变化数据的提取，请参考“参考资料”部分。在本文中，我们 source 以 DB2 为例：

1. 创建 DB2 对象

在本文中创建数据库 SOURCE，和表”DEMO”.”CUSTOMER”，并 import 数据

清单 1. 创建表及导入数据

　CREATE　TABLE　"DEMO"."CUSTOMER"　(　　
　"CUSTOMER_ID"　INTEGER　NOT　NULL　,　
　"SEX"　CHAR(1)　,　
　"BIRTHDAY"　TIMESTAMP　,　
　"SSN"　VARCHAR(30)　,　
　"CITY"　VARCHAR(25)　,　
　"STATE"　VARCHAR(25)　,　
　"ZIP"　VARCHAR(15)　,　
　"PHONE"　VARCHAR(15)　,　
　"PRI_LANGUAGE"　VARCHAR(15)　,　
　"LAST_UPDATE"　TIMESTAMP　,　
　"FIRST_NAME"　VARCHAR(20)　,　
　"MIDDLE_NAME"　VARCHAR(10)　,　
　"LAST_NAME"　VARCHAR(20)　)　;　
　ALTER　TABLE　"DEMO　"."CUSTOMER"　ADD　PRIMARY　KEY　("CUSTOMER_ID");　
　DB2　import　from　customer.ixf　of　ixf　insert　into　”DEMO”.”CUSTOMER”　

2. 创建 MQ 对象

创建 Q manager：crtmqm QManager

启动 Q manager：strmqm QManager