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

核心提示： 创建队列 : runmqsc QMamanger < mq.in清单 2. 创建 MQ 对象defineqlocal(ADMINQ)defineqlocal(RESTARTQ)defineqlocal(q1)defineqmodel(IBMQREP.SPILL.MODELQ)DEFSOPT

创建队列 : runmqsc QMamanger < mq.in

清单 2. 创建 MQ 对象

　define　qlocal　(ADMINQ)　
　define　qlocal　(RESTARTQ)　
　define　qlocal　(q1)　
　define　qmodel　(IBMQREP.SPILL.MODELQ)　DEFSOPT(shared)　
　MAXDEPTH(500000)　MSGDLVSQ(fifo)　DEFTYPE(permdyn)　
　
　define　channel(CHANNEL1)　chltype(svrconn)　trptype(tcp)　mcauser('mqm')　
　define　listener(listener1)　trptype(tcp)　control(qmgr)　port　(2264)　
　start　listener　(listener1)　
　end　

3. setup Event Publisher

3.1 创建 control tables：asnclp – f cncap.in

清单 3. 创建控制表

　asnclp　session　set　to　q　replication;　
　set　run　script　now　stop　on　sql　error　on;　
　set　qmanager　"　QManager　"　for　capture　schema;　
　set　server　capture　to　db　source;　
　create　control　tables　for　capture　server　
　using　restartq　"RESTARTQ"　adminq　"ADMINQ"　;　
　quit;　

3.2 创建 pubqmap 和 pub：asnclp – f crtqmappub.in

清单 4. 创建 pubqmap 及 pub

　asnclp　session　set　to　Q　replication;　
　set　output　capture　script　"qpubmap.sql"　;　
　set　log　"qpub.log";　
　set　server　capture　to　db　source　;　
　set　run　script　now　stop　on　sql　error　on;　
　set　qmanager　"　QManager　"　for　capture　schema;　
　create　pubqmap　pubqmap1　using　sendq　"q1"　message　
　format　delimited　message　content　type　T;　
　create　pub　using　pubqmap　PUBQMAP1　
　(pubname　eventpub1　"DEMO"."CUSTOMER")　;　
　quit;