练习4_计算节点_数据库访问.doc

练习 在计算节点中访问数据库练习 在计算节点中访问数据库 练习背景 练习背景 在下面的练习中 我们将设计一个消息流 其从队列中读取 XML 消息 并 通过计算节点 过滤节点的处理 然后路由至正确的目标队列中 本练习学习使用在计算节点访问数据库 利用数据库中的内容 丰富 XML 消息的内容 XML 输入消息格式如下 100001100001 南京市南京市 560 00560 00 300 00300 00 通过本练习中的数据库访问操作 输出 XML 消息格式为 100001100001 江苏省电力公司江苏省电力公司 南京市南京市 560 00560 00 300 00300 00 1 目标 目标 学习使用计算节点进行数据库访问操作 并利用 ESQL 语句重新构造 XML 消息 加入新的字段 2 步骤 步骤 1 在开始下面步骤之前请确保 IBM WebSphere Message Broker CFG 和 IBM WebSphere Message Broker BROKER 两个服务处于 已启动 状 态 如未启动 请使用服务面板 或命令行命令 mqsistart MBCFG 和 mqsistart BROKER 命令启动它们 2 依此选中 开始 程序 IBM 软件开发平台 IBM Websphere Message Broker Toolkit 6 1 WebSphere Message Broker Toolkit 6 1 打开 WebSphere Message Brokers Toolkit 3 单击中左上角的 打开透视图 按钮 选中 代理应用程序开发 切换 到 代理应用程序开发透视图 4 我们下面利用前面练习的消息流继续工作 在此需要复制它 5 在 代理开发 窗口中选中消息流 Exe3 Compute msgflow 右键单击 在弹出菜单中选择 复制 6 在 代理开发 窗口中选中消息流项目 WMB6 右键单击在弹出菜单中 选择 粘贴 7 在 名称冲突 对话框中输入 Exe4 Compute DB msgflow 并单击 确 定 8 在本练习中 我们不需要增加新的节点 只需要在 Compute 节点中修改 ESQL 语句即可 9 此外 为了访问数据库 我们需要在 DB2 数据库中创建一个表 Oracle 的表结构一样 其结构与样本内容如下 表名 CUSTOMER 字段 CUST IDCHAR 6 CUST NAMECHAR 40 样本内容 CUST IDCUST IDCUST NAMECUST NAME 100001 江苏省电力公司 100002 IBM 上海分公司 100003 上海移动通信有限公司 10 在 CMD 命令窗口中执行如下 DB2 命令创建表 CUSTOMER 并插入三条样本内 容 C db2cmd C db2 CONNECT TO MBDB CREATE TABLE CUSTOMER CUST ID CHAR 6 CUST NAME CHAR 40 INSERT INTO CUSTOMER CUST ID CUST NAME VALUES 100001 江苏省电力公司 INSERT INTO CUSTOMER CUST ID CUST NAME VALUES 100002 IBM 上海分公司 INSERT INTO CUSTOMER CUST ID CUST NAME VALUES 100003 上海移动通信有限公司 如果用的是 Oracle 数据库 例如 选择在 system 用户下建 CUSTOMER 表 然后 需要执行 mqsistop BROKER 停止 BROKER 然后执行 mqsisetdbparms BROKER n DataSourceName u system p password 重新启动 BROKER mqsistart BROKER 即可 11 参照下表设置这些节点的属性 红色为与原有值不同的属性 节点类型节点类型节点名称节点名称属性属性值值 基本 队列名 EXE4 IN MQInput 节点读取 XML 消息 缺省 消息域 XML Compute 节点转换 XML 消息 Filter 节点判断目的地 基本 队列名 SHANGHAI MQOutput 节点上海市 基本 队列管理器名 ESBQM 基本 队列名 NANJING MQOutput1 节点南京市 基本 队列管理器名 ESBQM 基本 队列名 FAILURE MQOutput2 节点错误队列 基本 队列管理器名 ESBQM 12 本练习中的节点连接不需要变动 13 右键单击 转换 XML 消息 节点 在弹出菜单中选择 属性 14 在对话框中的 基本 页面中的 数据源 字段输入 MBDB 如果是 Oracle 设置你在 ODBC 中配置的数据源名称 将 ESQL 模块 字段内 容改为 Exe4 Compute Compute 单击 确定 15 下面需要在 转换 XML 消息 节点内写入 ESQL 语句 右键单击 转换 XML 消息 节点 在弹出菜单中选择 打开 ESQL 16 在打开的 ESQL 编辑窗口中 输入下列 ESQL 语句 如下图 并用 Ctrl S 保存 注意看是否出现如下所示红色错误标记或黄色的警告标记 本 练习中会出现一个警告信息 该信息是由于数据库不能静态解析的缘故 在此我们忽略它 首先复制消息头 CALL CopyMessageHeaders CALL CopyEntireMessage 访问数据库表格CUSTOMER得到与XML字段id对应的用户名称 并去掉空格 DECLARE TEMP CHARACTER SET TEMP THE SELECT ITEM T CUST NAME FROM Database CUSTOMER AS T WHERE T CUST ID InputRoot XML record id SET TEMP TRIM BOTH FROM TEMP 构造输出XML消息 SET OutputRoot XML record id InputRoot XML record id SET OutputRoot XML record name CAST TEMP AS CHARACTER CCSID 1381 SET OutputRoot XML record address CAST InputRoot XML record address AS CHARACTER CCSID 1381 SET OutputRoot XML record amount1 InputRoot XML record amount1 SET OutputRoot XML record amount2 InputRoot XML record amount2 17 至此 消息流已设计完成 请使用 Ctrl S 保存你的消息流 下面将我们设计的消息流 Exe4 Compute DB 发布到 WMB 代理 BROKER 上 18 在 代理开发 窗口中展开服务器项目 选中 WMB6 下的 Message Broker 代理归档 EXE2 bar 双击打开该文件的 准备 界面 19 在消息流 Exe4 Compute DB msgflow 前面的复选框中打勾 以选中该消 息流 20 在 管理 窗口中单击 构建 构建完成点击 确定 使用 Ctrl S 保存该 BAR 文件 注意 内容 窗口列出了当前压缩文件中 的消息流 你也可以使用 配置 窗口查看各个消息流的细节配置 21 下面我们把该代理压缩文件 EXE2 bar 部署到代理上去 单击左上角的 打开透视图 快捷按钮 选择 代理管理 则自动打开 代理管理透 视图 注意下部的 域 窗口中 代理拓扑 是否连接到配置管理器 22 使用鼠标将代理压缩文件 EXE2 bar 拖拽到 域 窗口中的代理 BROKER 下的执行组 缺省 中 23 在弹出的 代理管理 对话框中显示部署状态 确保已成功发布该代理 压缩文件 单击 确定 关闭该对话框 24 你也可以双击 域 窗口中的 事件日志 在右边的日志窗口中查看具 体日志信息 请确保最新日志为蓝色的成功标记 而不是红色的失败标 记 25 你也可以查看左下角的 域 窗口中该消息流是否存在 好了 到现在为止 你已经成功创建了该消息流 生成了代理压缩文件 EXE2 bar 并发布到了代理 BROKER 上 26 打开一个 CMD 窗口 输入下面的命令创建队列 runmqsc ESBQM DEF QL EXE4 IN END 27 下面执行目录 MQ Tools IH03 下的 rfhutil exe 启动测试工具 在 Queue Manage Name 字段输入 WBRK QM 在 Queue Name 字段中 输入 EXE4 IN 再单击 Read File 按钮选择 Exercises 目录下的文 件 record1 xml 该文件的内容为下图所示 28 在 MQMD 窗口中的 Code Page 字段中输入 1381 该代码页为中文 代码页 29 如下图单击 Main 窗口中的 Write Q 按钮将该 XML 消息发送到队列 EXE4 IN 中 注意最下面的状态栏显示消息已发送到 EXE4 IN 长度为 121 个字节 30 如果消息流执行正确 通过 转换 XML 消息 与 判断目的地 过滤节 点的处理 该 XML 消息将路由到队列 NANJING 而不是队列 SHANGHAI 中 31 在 Queue Name 字段中输入 SHANGHAI 单击 Read Q 按钮读取该 文件 注意状态栏中显示 2033 No me