使用 BizTalk Server 以增量方式从 SQL 接收查询通知

  • 项目

重要

为简洁起见，本主题仅介绍如何以增量方式接收通知。 在业务方案中，业务流程理想情况下必须包含逻辑，以提取收到的通知消息类型，然后执行任何后续操作。 换句话说，本主题中所述的业务流程必须基于处理通知消息中所述的业务流程，以便使用 BizTalk Server 在 SQL 中完成特定任务。

本主题演示如何将 SQL 适配器配置为从SQL Server数据库接收增量查询通知消息。 若要演示增量通知，请考虑一个表 Employee，其中包含“状态”列。 向此表插入新记录时，“状态”列的值将设置为 0。 可以通过执行以下操作将适配器配置为接收增量通知：

  • 使用 SQL 语句注册通知，该语句检索状态列为 0 的所有记录。 为此，可以为 NotificationStatement 绑定属性指定 SQL 语句。

  • 对于已收到通知消息的行，请将“状态”列更新为 1。

    本主题演示如何创建 BizTalk 业务流程并配置 BizTalk 应用程序来实现此目的。

使用 SQL 适配器绑定属性配置通知

下表汇总了用于配置从 SQL Server 接收通知的 SQL 适配器绑定属性。 在 BizTalk Server 管理控制台中配置接收端口时，必须指定这些绑定属性。

注意

在生成 通知 操作的架构时，可以选择指定这些绑定属性，即使这不是必需的。 如果这样做，则使用适配器服务外接程序在元数据生成过程中生成的端口绑定文件也会包含为绑定属性指定的值。 稍后可以在 BizTalk Server 管理控制台中导入此绑定文件，以使用已设置的绑定属性创建 WCF-custom 或 WCF-SQL 接收端口。 有关使用绑定文件创建端口的详细信息，请参阅 使用端口绑定文件配置物理端口绑定以使用 SQL 适配器。

Binding 属性 说明
InboundOperationType 指定要执行的入站操作。 若要接收通知消息，请将此项设置为 “通知”。
NotificationStatement 指定用于注册查询通知的 SQL 语句 (SELECT 或 EXEC <存储过程>) 。 仅当指定 SQL 语句的结果集发生更改时，适配器才会从SQL Server获取通知消息。
NotifyOnListenerStart 指定在启动侦听器时适配器是否向适配器客户端发送通知。

有关这些属性的更完整说明，请参阅阅读有关 SQL Server 适配器绑定属性的 BizTalk 适配器。 有关如何使用 SQL 适配器接收来自SQL Server通知的完整说明，请进一步阅读。

本主题如何演示接收通知消息

为了演示 SQL 适配器如何支持从SQL Server接收通知消息，本主题将演示如何将适配器配置为接收针对 Employee 表的更改的通知。 假设 Employee 表具有Employee_ID、Name 和 Status 列。 每当添加新员工时，“状态”列的值将设置为 0。

若要演示如何接收通知，请执行以下操作：

  • 为 通知 (入站操作) 生成架构，并在 Employee 表上 选择 (出站操作) 。

  • 创建具有以下项的业务流程：

    • 用于接收通知消息的接收位置。 可以通过将 SELECT 语句指定为来配置通知：

      SELECT Employee_ID, Name FROM dbo.Employee WHERE Status=0

      注意

      必须特别指定语句中的列名称，如此 SELECT 语句所示。 此外，必须始终指定表名称以及架构名称。 例如，dbo.Employee。

    • 用于更新已发送通知的行的发送端口。 为此，可以将“状态”列中的值设置为 1。 可以通过向适配器发送以下消息，作为选择操作的一部分执行此操作。

      <Select xmlns="http://schemas.microsoft.com/Sql/2008/05/TableOp/dbo/Employee">  
  <Columns>Employee_ID,Name,Status</Columns>  
  <Query>where Status=0;UPDATE Employee SET Status=1 WHERE Status=0</Query>  
</Select>

      在此消息中，作为 元素的 <Query> 一部分，指定 UPDATE 语句以更新 Status 列。 请注意，必须在收到通知消息后执行此操作，以便更新已处理的行。 为了摆脱等待获取通知响应，然后手动删除请求消息以更新行的开销，你将生成请求消息来更新业务流程本身中的行。 为此，可以在业务流程中使用 “构造消息” 形状。

如何从SQL Server数据库接收通知消息

使用带BizTalk Server的 SQL 适配器对 SQL Server 数据库执行操作涉及构建基块以使用 SQL 适配器开发 BizTalk 应用程序中所述的过程性任务。 若要将适配器配置为接收通知消息，这些任务包括：

  1. 创建 BizTalk 项目，然后生成 “通知 (入站操作”) 的架构，并在 Employee 表中 选择 (出站操作) 。 （可选）可以为 InboundOperationType 和 NotificationStatement 绑定属性指定值。

  2. 在 BizTalk 项目中创建一条消息，用于从 SQL Server 数据库接收通知。

  3. 在 BizTalk 项目中创建消息，以便对SQL Server数据库执行选择信息并接收响应消息。

  4. 创建执行以下操作的业务流程：

    • 接收来自SQL Server的通知消息。

    • 创建一条消息以选择并更新接收通知的行。

    • 将此消息发送到SQL Server以更新行并接收响应。

  5. 生成并部署 BizTalk 项目。

  6. 通过创建物理发送和接收端口配置 BizTalk 应用程序。

    注意

    对于接收通知消息等入站操作，必须仅配置单向 WCF-Custom 或 WCF-SQL 接收端口。 入站操作不支持双向 WCF-Custom 或 WCF-SQL 接收端口。

  7. 启动 BizTalk 应用程序。

    本主题提供有关执行这些任务的说明。

基于本主题的示例

BizTalk 适配器包提供了基于本主题的示例 IncrementalNotification。 有关详细信息，请参阅 SQL 适配器的示例。

生成架构

必须为 “通知 ”操作和 “对 Employee”表的“选择” 操作生成架构。 有关如何生成架构的详细信息，请参阅使用 SQL 适配器在 Visual Studio 中获取SQL Server操作的元数据。 生成架构时执行以下任务。 如果不想在设计时指定绑定属性，请跳过第一步。

  1. 在生成架构时指定 InboundOperationType 和 NotificationStatement 绑定属性的值。 有关此绑定属性的详细信息，请参阅阅读有关 SQL Server 适配器绑定属性的 BizTalk 适配器。 有关如何指定绑定属性的说明，请参阅 配置 SQL 适配器的绑定属性。

  2. 选择协定类型作为 服务 (入站操作) 。

  3. 为 通知 操作生成架构。

  4. 选择协定类型作为 “客户端 (出站操作) 。

  5. 为 Employee 表的 Select 操作生成架构。

定义消息和消息类型

前面生成的架构描述了业务流程中的消息所需的“类型”。 消息通常是一个变量，其类型由相应的架构定义。 生成架构后，必须将其链接到 BizTalk 项目的业务流程视图中的消息。

对于本主题，必须创建三条消息-一个用于接收来自SQL Server数据库的通知，一个用于执行 Select 操作，一个用于接收 Select 操作的响应。

执行以下步骤来创建消息并将其链接到架构。

  1. 将业务流程添加到 BizTalk 项目。 在解决方案资源管理器，右键单击 BizTalk 项目名称，指向“添加”，然后单击“新建项”。 键入 BizTalk 业务流程的名称，然后单击“ 添加”。

  2. 打开 BizTalk 项目的业务流程视图窗口（如果尚未打开）。 单击“ 视图”，指向 “其他窗口”，然后单击“ 业务流程视图”。

  3. 在 “业务流程视图”中，右键单击“ 消息”，然后单击“ 新建消息”。

  4. 右键单击新创建的消息，然后选择“ 属性窗口”。

  5. 在Message_1的“属性”窗格中，执行以下操作：

    使用此选项 要执行此操作
    标识符 键入 NotifyReceive。
    消息类型 从下拉列表中展开 “架构”，然后选择“ SQLNotify.Notification”，其中 SQLNotify 是 BizTalk 项目的名称。 通知 是为 通知 操作生成的架构。

  6. 重复步骤 3 以创建两条新消息。 在新邮件的“ 属性 ”窗格中，执行以下操作：

    将标识符设置为 将“消息类型”设置为
    Select SQLNotify.TableOperation_dbo_Employee.Select，其中 TableOperation_dbo_Employee 是为 Select 操作生成的架构
    SelectResponse SQLNotify.TableOperation_dbo_Employee.SelectResponse

设置业务流程

必须创建 BizTalk 业务流程才能使用 BizTalk Server 从 SQL Server 数据库接收通知消息，然后更新收到通知的行。 在此业务流程中，适配器根据为 NotificationStatement 绑定属性指定的 SELECT 语句接收通知消息。 在文件位置收到通知消息。 收到响应后，业务流程将构造一条消息，该消息将用于更新接收通知的行。 此消息的响应也在同一 FILE 位置收到。

因此，业务流程必须包含以下项：

  • 用于接收通知消息的单向接收端口。

  • 双向发送端口，用于发送消息以更新行并接收相同行的响应。

  • 构造消息形状，用于构造消息，以在业务流程中执行更新操作。

  • 文件发送端口，用于保存更新操作的响应。

  • 接收和发送形状。

    示例业务流程如下所示。

    用于接收SQL Server通知的业务流程

添加消息形状

请确保为每个邮件形状指定以下属性。 “形状”列中列出的名称是刚才提到的业务流程中显示的消息形状的名称。

形状 形状类型 属性
ReceiveNotification 接收 - 将 Name 设置为 ReceiveNotification

- 将 “激活” 设置为 “True”
SaveNotification 发送 - 将 名称 设置为 SaveNotification
SendSelectMessage 发送 - 将 “名称” 设置为 “SendSelectMessage”
ReceiveSelectResponse 接收 - 将 “名称” 设置为 ReceiveSelectResponse
SaveSelectResponse 发送 - 将 名称 设置为 SaveSelectResponse

添加构造消息形状

可以使用 “构造消息” 形状在操作中生成请求消息，以执行 Select 操作。 为此，必须将 构造消息 形状和消息 分配 形状添加到业务流程中。 在此示例中，“消息分配”形状调用的代码将生成一条消息，该消息发送到SQL Server以执行 Select 操作。 “消息分配”形状还设置要发送到SQL Server的邮件的操作。

对于构造消息形状，将 Message Constructed 属性设置为 Select。

生成响应的代码可能是与 BizTalk 项目相同的 Visual Studio 解决方案的一部分。 生成响应消息的示例代码如下所示。

namespace SampleMessageCreator  
{  
    public class SampleMessageCreator  
    {  
        private static XmlDocument Message;  
        private static string XmlFileLocation;  
        private static string ResponseDoc;  
        public static XmlDocument XMLMessageCreator()  
        {  
            XmlFileLocation = "C:\\TestLocation\\CreateMessage";  
            try  
            {  
                ResponseDoc = (Directory.GetFiles(XmlFileLocation, "*.xml", SearchOption.TopDirectoryOnly))[0];  
            }  
            catch (Exception ex)  
            {  
                Console.WriteLine("Trying to get XML from: " + XmlFileLocation);  
                Console.WriteLine("EXCEPTION: " + ex.ToString());  
                throw ex;  
            }  
            //Create Message From XML  
            Message = new XmlDocument();  
            Message.PreserveWhitespace = true;  
            Message.Load(ResponseDoc);  
            return Message;  
        }   
    }  
}

为使前面的代码摘录能够生成请求消息，您必须在为变量指定的 XmlFileLocation 位置) 对 Employee 表的 Select 操作 (XML 请求消息。

注意

生成项目后，将在项目目录中创建 SampleMessageCreator.dll。 必须将此 DLL 添加到全局程序集缓存 (GAC) 。 此外，必须将 SampleMessageCreator.dll 添加为 BizTalk 项目中的引用。

添加以下表达式以从 “消息分配” 形状调用此代码，并设置消息的操作。 若要添加表达式，请双击“ 消息分配 ”形状以打开“表达式编辑器”。

Select = SampleMessageCreator.SampleMessageCreator.XMLMessageCreator();  
Select(WCF.Action) = "TableOp/Select/dbo/Employee";

添加端口

请确保为每个逻辑端口指定以下属性。 “端口”列中列出的名称是业务流程中显示的端口名称。

端口 属性
SQLNotifyPort - 将 标识符 设置为 SQLNotifyPort

- 将 “类型” 设置为 “SQLNotifyPortType”

- 将 通信模式 设置为 单向

- 将 通信方向 设置为 接收
SaveMessagePort - 将 标识符 设置为 SaveMessagePort

- 将 Type 设置为 SaveMessagePortType

- 将 通信模式 设置为 单向

- 将 “通信方向 ”设置为 “发送”

- 创建操作 通知。 此操作用于通知消息。

- 创建 操作 Select。 此操作用于选择响应消息。
SQLOutboundPort - 将 标识符 设置为 SQLOutboundPort

- 将 Type 设置为 SQLOutboundPortType

- 将 通信模式 设置为 请求-响应

- 将 通信方向 设置为 “发送-接收”

为操作形状指定消息并连接到端口

下表指定了应设置的属性及其值，以便为操作形状指定消息并将消息链接到端口。 “形状”列中列出的名称是前面提到的业务流程中显示的消息形状的名称。

形状 属性
ReceiveNotification - 将 消息 设置为 NotifyReceive

- 将 操作 设置为 SQLNotifyPort.Notify.Request
SaveNotification - 将 消息 设置为 NotifyReceive

- 将 操作 设置为 SaveMessagePort.Notify.Request
SendSelectMessage - 将 “消息 ”设置为 “选择”

- 将 操作 设置为 SQLOutboundPort.Select.Request
ReceiveSelectResponse - 将 消息 设置为 SelectResponse

- 将 操作 设置为 SQLOutboundPort.Select.Response
SaveSelectResponse - 将 消息 设置为 SelectResponse

- 将 操作 设置为 SaveMessagePort.Select.Request

指定这些属性后，将连接消息形状和端口，并且业务流程已完成。

现在必须生成 BizTalk 解决方案并将其部署到BizTalk Server。 有关详细信息，请参阅 生成和运行业务流程。

配置 BizTalk 应用程序

部署 BizTalk 项目后，前面创建的业务流程将列在 BizTalk Server 管理控制台的“业务流程”窗格中。 必须使用 BizTalk Server 管理控制台来配置应用程序。 有关演练，请参阅 演练：部署基本 BizTalk 应用程序。

配置应用程序涉及：

  • 为应用程序选择主机。

  • 将业务流程中创建的端口映射到 BizTalk Server 管理控制台中的物理端口。 对于此业务流程，必须：

    • 定义物理 WCF-Custom 或 WCF-SQL 单向接收端口。 此端口侦听来自 SQL Server 数据库的通知。 有关如何创建端口的信息，请参阅 手动配置到 SQL 适配器的物理端口绑定。 请确保为接收端口指定以下绑定属性。

      重要

      如果在设计时指定了绑定属性，则不需要执行此步骤。 在这种情况下，可以通过导入由使用适配器服务外接程序创建的绑定文件，创建 WCF-custom 或 WCF-SQL 接收端口，并设置所需的绑定属性。 有关详细信息 ，请参阅使用端口绑定文件配置物理端口绑定以使用 SQL 适配器。

      Binding 属性 值
      InboundOperationType 将此项设置为 “通知”。
      NotificationStatement 将此项设置为：

      SELECT Employee_ID, Name FROM dbo.Employee WHERE Status=0

      注意： 必须特别指定语句中的列名称，如此 SELECT 语句所示。 此外，必须始终指定表名称以及架构名称。 例如，dbo.Employee。
      NotifyOnListenerStart 将此项设置为 True。

      有关不同绑定属性的详细信息，请参阅了解适用于 SQL Server 适配器绑定属性的 BizTalk 适配器。

      注意

      建议在使用 SQL 适配器执行入站操作时配置事务隔离级别和事务超时。 为此，可以在配置 WCF-Custom 或 WCF-SQL 接收端口时添加服务行为。 有关如何添加服务行为的说明，请参阅 使用 SQL 配置事务隔离级别和事务超时。

    • 定义物理 WCF-Custom 或 WCF-SQL 发送端口以将消息发送到SQL Server数据库。 还必须在发送端口中指定操作。

    • 在硬盘上定义一个位置和相应的文件端口，BizTalk 业务流程将从SQL Server数据库中删除消息。 这些将是从 SQL Server 接收的通知消息，以及通过 WCF-Custom 或 WCF-SQL 发送端口执行的“选择和更新”操作的消息。

启动应用程序

必须启动 BizTalk 应用程序，以便从SQL Server数据库接收通知消息，并执行后续的选择和更新操作。 有关启动 BizTalk 应用程序的说明，请参阅 如何启动业务流程。

在此阶段，请确保：

  • WCF-Custom 或 WCF-SQL 单向接收端口，用于从正在运行SQL Server数据库接收通知消息。

  • 用于对 Employee 表执行 Select 和 Update 操作的 WCF-Custom 或 WCF-SQL 发送端口正在运行。

  • 从SQL Server接收消息的 FILE 发送端口正在运行。

  • 操作的 BizTalk 业务流程正在运行。

执行操作

若要执行此操作，必须将记录插入 Employee 表中。 假设你插入包含以下详细信息的记录：

Name = John Smith  
Designation = Manager  
Salary = 100000

此外，请确保用于执行 Select 和 Update 操作的 XML 消息在 C：\TestLocation\MessageIn 中可用。 XML 文件应如下所示：

<Select xmlns="http://schemas.microsoft.com/Sql/2008/05/TableOp/dbo/Employee">  
  <Columns>Employee_ID,Name,Status</Columns>  
  <Query>where Status=0;UPDATE Employee SET Status=1 WHERE Status=0</Query>  
</Select>

插入记录后，将按同一顺序执行以下一组操作：

  • 适配器会收到类似于以下内容的通知消息：

    <?xml version="1.0" encoding="utf-8" ?>   
<Notification xmlns="http://schemas.microsoft.com/Sql/2008/05/Notification/">  
  <Info>Insert</Info>   
  <Source>Data</Source>   
  <Type>Change</Type>   
</Notification>

    此消息通知在 Employee 表中插入了一条记录。 请注意，元素的 <Info> 值为“Insert”。

  • 适配器执行 Select 操作。 由于 Select 操作 XML 还包括 Update 语句，因此也会执行 Update 语句。 SQL Server的下一个响应适用于 Select 语句。

    <?xml version="1.0" encoding="utf-8" ?>   
<SelectResponse xmlns="http://schemas.microsoft.com/Sql/2008/05/TableOp/dbo/Employee">  
  <SelectResult>  
    <Employee xmlns="http://schemas.microsoft.com/Sql/2008/05/Types/Tables/dbo">  
      <Employee_ID>10006</Employee_ID>   
      <Name>John</Name>   
      <Status>0</Status>  
    </Employee>  
  </SelectResult>  
</SelectResponse>

    此响应显示已将记录插入 Employee 表，并且该记录的“状态”为 0。

  • 作为 Select 语句的一部分，还将执行 Update 语句，并将新记录的“状态”列更改为 1。 这再次触发来自 SQL Server 的另一个通知，适配器会收到相应的通知消息，如下所示：

    <?xml version="1.0" encoding="utf-8" ?>   
<Notification xmlns="http://schemas.microsoft.com/Sql/2008/05/Notification/">  
  <Info>Update</Info>   
  <Source>Data</Source>   
  <Type>Change</Type>   
</Notification>

    此消息通知 Employee 表中的记录已更新。 请注意，元素的 <Info> 值为“Update”。

  • 第二个通知后，适配器将执行 Select 语句。 但是，由于现在没有状态为 0 的记录，适配器会收到如下所示的空响应。

    <?xml version="1.0" encoding="utf-8" ?>   
<SelectResponse xmlns="http://schemas.microsoft.com/Sql/2008/05/TableOp/dbo/Employee">  
  <SelectResult />   
</SelectResponse>

最佳实践

部署并配置 BizTalk 项目后，可以将配置设置导出到名为绑定文件的 XML 文件。 生成绑定文件后，可以从文件导入配置设置，这样就无需为同一业务流程创建发送端口和接收端口。 有关绑定文件的详细信息，请参阅 重用 SQL 适配器绑定。

另请参阅

使用 BizTalk Server 接收 SQL 查询通知