创建 SimplifiedDBRouting 消息流

使用以下指示信息创建 SimplifiedDBRouting 消息流。有关更多详细的指示信息,请单击在每个步骤末尾提供的链接。

要创建和配置 SimplifiedDBRouting 消息流:

  1. 创建名为 SimplifiedDBRouting 的新消息流。
    有关指示信息,请参阅 IBM Integration Bus 文档中的创建消息流
  2. 在“消息流”编辑器中,添加并重命名下表中列出的节点。
    有关指示信息,请参阅 IBM Integration Bus 文档中的添加消息流节点
    选用板抽屉 节点类型 节点名(MQ 队列)
    WebSphere MQ MQInput MQInput
    WebSphere MQ MQOutput FailureQ
    WebSphere MQ MQOutput KeyNotFoundQ
    WebSphere MQ MQOutput OrderClockQ
    WebSphere MQ MQOutput SeniorStaffQ
    WebSphere MQ MQOutput DefaultQ
    路由 Route Route
    数据库 DatabaseRetrieve DatabaseRetrieve
    数据库 DatabaseRoute DatabaseRoute
    构造 Trace Trace
  3. 将节点连接在一起,如下表中所示。
    有关指示信息,请参阅 IBM Integration Bus 文档中的连接消息流节点
    要检查您是否已将节点正确连接在一起,请参阅关于 Simplified Database Routing 消息流中的图。
    节点名 终端 连接到此节点
    MQInput Out Route
    Failure Trace
    Catch Trace
    Route Default DatabaseRetrieve
    Failure Trace
    Match DatabaseRoute
    DatabaseRetrieve Out DatabaseRoute
    Failure Trace
    KeyNotFound KeyNotFoundQ
    DatabaseRoute KeyNotFound KeyNotFoundQ
    Failure Trace
    TenYearsService OrderClockQ
    OlderThanMe SeniorStaffQ
    Default DefaultQ
    Trace Out FailureQ
  4. 配置节点属性,如下表中所示。
    除非在表中显示了备用值,否则接受所有属性的缺省值。
    有关指示信息,请参阅 IBM Integration Bus 文档中的配置消息流节点
    节点名 页面 属性
    MQInput 基本 队列名 SIMPLERROUTEDB_IN
    此属性是消息流从中获取消息的本地队列。
    输入消息解析 消息域 XMLNSC:对于 XML 消息
    此属性指示 Integration 节点使用 XMLNSC 解析器,后者可以识别名称空间,支持验证并且内存使用量较低。
    Route 基本 Filter 模式 $Body/EmpRecord/WorkDept
    此属性是一个 XPath 1.0 表达式,在此情况下将输入消息内期望的元素的路径位置指定到此节点。 该节点尝试查找工作部门字段,并在该字段不存在的情况下解析为 false。
    基本 路由输出终端

    匹配
    此属性是动态输出终端的名称,如果过滤表达式解析为 true,将把输入消息传播到此终端。 如果期望的元素位于输入消息中,那么该表达式将解析为 true。
    注意:必须首先通过右键单击该节点然后单击“添加 Output 终端”创建此终端。
    有关指示信息,请参阅 IBM Integration Bus 文档中的使用动态终端

    DatabaseRetrieve 基本 数据源名称

    SIMPLERROUTEDB
    这是用于查找 Integration 节点注册表中存储的 JDBC 提供者详细信息的别名。 此别名用于查找和构建用于连接 DBMS 的 JDBC 连接 URL。

    基本 复制消息
    此属性指示是否因为要更新消息树而需要原始入局消息的副本。
    基本 查询元素
    表名称 列名 运算符 值类型
    EMPLOYEE E LASTNM ASC
    EMPLOYEE E FIRSTNM ASC
    EMPLOYEE E YEARSSERVICE ASC
    EMPLOYEE E AGEINYRS ASC
    EMPLOYEE E WORKDEPT ASC
    EMPLOYEE E EMPNUM = 元素 $InputBody/EmpRecord/EmpNumber
    前一个“查询元素”表的内容在 SQL 语句窗口中生成以下查询:
    SELECT  E.LASTNM,  E.FIRSTNM,  E.YEARSSERVICE,  E.AGEINYRS,  E.WORKDEPT
    FROM EMPLOYEE E
    WHERE  E.EMPNUM = ?
    ORDER BY  E.LASTNM ASC,  E.FIRSTNM ASC,  E.YEARSSERVICE ASC,  E.AGEINYRS ASC,  E.WORKDEPT ASC
    数据元素表 数据元素
    列名 消息元素
    E.FIRSTNM $OutputRoot/XMLNSC/EmpRecord/FirstName
    E.LASTNM $OutputRoot/XMLNSC/EmpRecord/LastName
    E.YEARSSERVICE $OutputRoot/XMLNSC/EmpRecord/YrsInService
    E.AGEINYRS $OutputRoot/XMLNSC/EmpRecord/AgeInYrs
    E.WORKDEPT $OutputRoot/XMLNSC/EmpRecord/WorkDept
    前一个“数据元素”表中的每一行都指定了输出消息中的一个位置,将在该位置先插入检索到的列值然后再从此节点传播消息。
    如果该位置不存在于输出消息(输入消息的副本)中,那么将创建该位置。 因为基本属性“多行”的缺省值设置为“”,那么此节点将仅处理结果集中第一行中返回的值。
    通过运行 SQL 语句窗口中指定的查询获取结果集并通过使用基本“查询元素”表内容配置该结果集。
    DatabaseRoute 基本 数据源名称

    SIMPLERROUTEDB
    这是用于查找 Integration 节点注册表中存储的 JDBC 提供者详细信息的别名。 此别名用于查找和构建用于连接 DBMS 的 JDBC 连接 URL。

    基本 查询元素
    表名称 列名 运算符 值类型
    EMPLOYEE M EMPNUM ASC
    EMPLOYEE M LASTNM ASC
    EMPLOYEE M AGEINYRS ASC
    DEPARTMENT D DEPTNUM = 元素 $Body/EmpRecord/WorkDept
    DEPARTMENT D MGRNUM = (EMPLOYEE) M.EMPNUM
    前一个“查询元素”表的内容在 SQL 语句窗口中生成以下查询:
    SELECT  M.EMPNUM,  M.LASTNM,  M.AGEINYRS
    FROM EMPLOYEE M, DEPARTMENT D
    WHERE  D.DEPTNUM = ?
    AND  D.MGRNUM =  M.EMPNUM
    ORDER BY  M.EMPNUM ASC,  M.LASTNM ASC,  M.AGEINYRS ASC 
    基本 分发方式 All
    当入站消息与多个表达式匹配时,此属性确定此节点的路由行为。 如果“分发方式”设置为“第一个”,那么消息将传播到第一个匹配输出终端。 如果“分发方式”设置为“全部”,那么消息将传播到所有匹配输出终端。 如果没有匹配输出终端,消息将发送到 Default 终端。
    过滤表达式表 过滤器表
    Filter 模式 路由输出终端
    ($Body/EmpRecord/AgeInYears > $M_AGEINYRS) and ($M_LASTNM = 'KWAN') OlderThanMe
    $Body/EmpRecord/YrsInService >= 10 TenYearsService
    前一个“过滤表达式”表中的每一行都指定一个 XPath 1.0 表达式,检索到的列值将在其中以变量引用的格式显示。
    每个表达式都强制转换为布尔值。 如果该表达式解析为 true,那么该节点将把输入消息传播到为行的“路由输出终端”值指定的动态输出终端。
    注意:必须首先通过右键单击此节点然后单击“添加 Output 终端”创建此终端。
    有关指示信息,请参阅 IBM Integration Bus 文档中的使用动态终端
    Trace 基本 目标 本地错误日志
    此属性指示节点将跟踪信息写入本地错误日志中。 在 Windows 上,本地错误日志为事件查看器;在 Linux 上,本地错误日志为系统日志。
    基本 模式
    Root >
    ${Root}
    ExceptionList > ${ExceptionList}
    跟踪模式将抽取整个消息树信息。
    基本 消息号 3051
    FailureQ 基本 队列名 SIMPLERROUTEDB_FAILURE
    此属性是在处理失败时消息流将消息放入的队列。
    KeyNotFoundQ 基本 队列名
    SIMPLERROUTEDB_KEYNOTFOUND
    此属性是消息流将消息放入的本地队列。
    OrderClockQ 基本 队列名
    SIMPLERROUTEDB_ORDERCLOCK
    此属性是消息流将消息放入的本地队列。
    SeniorStaffQ 基本 队列名
    SIMPLERROUTEDB_SNRSTAFF
    此属性是消息流将消息放入的本地队列。
    DefaultQ 基本 队列名
    SIMPLERROUTEDB_DEFAULT
    此属性是消息流将消息放入的本地队列。
  5. 保存消息流。

您现在已创建了 SimplifiedDBRouting 消息流。

返回“构建 Simplified Database Routing 样本”