通知メッセージを処理して、BizTalk Serverを使用して SQL の特定のタスクを完了する

[アーティクル]
05/04/2023

SQL アダプターを使用して、SQL Server データベーステーブルに対する変更に関する通知を受け取ることができます。ただし、アダプターは、一部のレコードが特定のデータベーステーブルに挿入、更新、または削除されたことを示す通知のみを送信します。これらのレコードの後処理は、クライアントアプリケーション自体で処理する必要があります。このトピックでは、SQL Server データベースから受信した通知の種類に基づいて、テーブル内のレコードを処理する方法に関するシナリオベースの説明を示します。

通知を受信した後に後続のアクションを実行するシナリオ

アダプタークライアントが特定の通知後タスクを実行する必要があるいくつかのシナリオを次に示します。

シナリオ 1。アダプタークライアントが、SQL Serverから受信する通知の種類に基づいて特定のタスクを実行する必要があるシナリオを考えてみましょう。たとえば、テーブル "B" にレコードが挿入されている場合、クライアントアプリケーションはテーブル "A" のレコードを更新する必要があります。同様に、テーブル "B" からレコードが削除された場合、クライアントアプリケーションはテーブル "A" からレコードを削除する必要があります。

このシナリオでは、受信した通知メッセージから、アダプタークライアントは通知の種類を抽出して、通知が挿入操作用か削除操作かを決定する必要があります。通知の種類が確認されたら、アダプタークライアントは、関連するテーブルを挿入または更新するために後続のアクションを実行する必要があります。
シナリオ 2。テーブルへの変更に関する通知メッセージを受信する受信場所がダウンするシナリオを考えてみましょう。受信場所がダウンしている間に、一部のレコードがテーブルに追加されます。ただし、これらのレコードの場合、アダプタークライアントは通知を受信しません。受信場所がバックアップされると、アダプターは特定のメッセージを送信してクライアントに通知し、クライアントアプリケーションは、受信場所がダウンしている間にデータベーステーブルに挿入されたすべてのレコードを検索する必要があります。

このシナリオでは、受信した通知メッセージから、アダプタークライアントは、通知がデータベーステーブルに対する変更に対する通知であるか、受信場所が開始されるかに関する情報を抽出する必要があります。通知が受信場所を開始する場合、アダプタークライアントは、受信場所がダウンしている間に挿入、更新、または削除された可能性があるレコードを処理するロジックを実装する必要があります。

Note

これらは、SQL アダプターで通知機能を使用する方法の理解を深めるためにリストされているシナリオの例にすぎません。ただし、受信した通知の種類を抽出するために必要なタスクの基本的なセットは、すべてのシナリオで似ています。このトピックでは、通知メッセージから通知の種類を抽出する方法について説明します。

このトピックでは、通知メッセージの受信と通知の種類の抽出方法について説明します

このトピックでは、通知メッセージを処理して後続のタスクを実行する方法を示すために、アダプタークライアントが BizTalk アプリケーションを使用して Employee テーブルへの変更に関する通知メッセージを受信する基本的なシナリオを検討します。通知を受信した後、クライアントは受信した通知の種類をフィルター処理し、後続のアクションを実行します。非常に基本的なシナリオを示すために、アダプタークライアントが受信した通知の種類に基づいて、通知メッセージを別のフォルダーにコピーすることを検討します。そのために、以下のことにご協力ください。

通知メッセージが挿入操作または更新操作の場合、アダプタークライアントはメッセージを C:\TestLocation\UpsertNotification フォルダーにコピーします。
通知メッセージが他の操作 (Delete など) の場合、アダプタークライアントはメッセージを C:\TestLocation\OtherNotificaiton フォルダーにコピーします。

BizTalk アプリケーションの一部としてこれを実現するには、オーケストレーションに次のものが含まれている必要があります。
通知メッセージを受信する一方向の受信ポート。
受信した通知メッセージの種類に関する情報を抽出する xpath クエリを含む式図形。
オーケストレーションにデシジョンブロックを含める Decide 図形。この決定ブロックでは、アプリケーションは、受信した通知メッセージに基づいて、実行する後続の操作を決定します。
最終的に通知メッセージを受信する 2 つの一方向送信ポート。

SQL アダプターバインドプロパティを使用した通知の構成

次の表は、SQL Serverからの通知の受信を構成するために使用する SQL アダプターバインドプロパティをまとめたものです。 BizTalk Server管理コンソールで受信ポートを構成するときに、これらのバインドプロパティを指定する必要があります。

Note

通知操作のスキーマを生成するときに、必須ではない場合でも、これらのバインドプロパティを指定することもできます。その場合、アダプターサービスアドインを使用してメタデータ生成の一部として生成されるポートバインドファイルには、バインドプロパティに指定した値も含まれます。このバインドファイルは、後で BizTalk Server 管理コンソールにインポートして、バインドプロパティが既に設定されている WCF-custom または WCF-SQL 受信ポートを作成できます。バインドファイルを使用してポートを作成する方法の詳細については、「ポートバインドファイルを使用して SQL アダプターを使用するように物理ポートバインドを構成する」を参照してください。

Binding プロパティ	説明
InboundOperationType	実行する受信操作を指定します。通知メッセージを受信するには、これを [通知] に設定します。
NotificationStatement	クエリ通知の登録に使用する SQL ステートメント (SELECT または EXEC <ストアドプロシージャ>) を指定します。アダプターは、指定した SQL ステートメントの結果セットが変更された場合にのみ、SQL Serverから通知メッセージを取得します。
NotifyOnListenerStart	リスナーの起動時にアダプターがアダプタークライアントに通知を送信するかどうかを指定します。

これらのプロパティの詳細については、「BizTalk Adapter for SQL Server adapter Binding Properties」を参照してください。 SQL アダプターを使用してSQL Serverから通知を受信する方法の詳細については、詳細を参照してください。

SQL Server データベースから通知メッセージを受信する方法

BizTalk Serverで SQL アダプターを使用してSQL Server データベースに対して操作を実行するには、SQL アダプターを使用して BizTalk アプリケーションを開発するための構成要素に関するページで説明されている手続き型タスクが含まれます。通知メッセージを受信するようにアダプターを構成するには、次のタスクを実行します。

BizTalk プロジェクトを作成し、通知受信操作のスキーマを生成します。必要に応じて、 InboundOperationType および NotificationStatement バインドプロパティの値を指定できます。
SQL Server データベースから通知を受信するためのメッセージを BizTalk プロジェクトに作成します。
前のセクションで説明したようにオーケストレーションを作成します。
BizTalk プロジェクトをビルドして展開します。
物理送受信ポートを作成して BizTalk アプリケーションを構成します。

Note

通知メッセージの受信などの受信操作では、一方向の WCF-Custom または WCF-SQL 受信ポートのみを構成する必要があります。双方向 WCF-Custom または WCF-SQL 受信ポートは、受信操作ではサポートされていません。
BizTalk アプリケーションを起動します。

このトピックでは、これらのタスクを実行する手順について説明します。

スキーマの生成

通知受信操作のスキーマを生成する必要があります。スキーマの生成方法の詳細については、「SQL アダプターを使用した Visual Studio でのSQL Server操作のメタデータの取得」を参照してください。スキーマを生成するときは、次のタスクを実行します。デザイン時にバインドプロパティを指定しない場合は、最初の手順をスキップします。

スキーマの生成中に 、InboundOperationType および NotificationStatement バインドプロパティの値を指定します。このバインディングプロパティの詳細については、「BizTalk Adapter for SQL Server adapter Binding Properties」を参照してください。バインドプロパティを指定する方法については、「 SQL アダプターのバインドプロパティを構成する」を参照してください。
コントラクトの種類を [ サービス (受信操作)] として選択します。
通知操作のスキーマを生成します。

メッセージとメッセージの種類の定義

前に生成したスキーマでは、オーケストレーション内のメッセージに必要な "型" について説明します。通常、メッセージは変数であり、対応するスキーマによって定義される型です。スキーマが生成されたら、BizTalk プロジェクトのオーケストレーションビューからメッセージにリンクする必要があります。

このトピックでは、SQL Server データベースから通知を受信するメッセージを 1 つ作成する必要があります。

メッセージを作成してスキーマにリンクするには、次の手順を実行します。

メッセージを作成し、スキーマにリンクするには

BizTalk プロジェクトにオーケストレーションを追加します。ソリューションエクスプローラーから BizTalk プロジェクト名を右クリックし、[追加] をポイントして、[新しい項目] をクリックします。 BizTalk オーケストレーションの名前を入力し、[ 追加] をクリックします。
BizTalk プロジェクトがまだ開いていない場合は、オーケストレーションビューウィンドウを開きます。 [ 表示] をクリックし、[ その他のウィンドウ] をポイントして、[ オーケストレーションビュー] をクリックします。
オーケストレーションビューで、[メッセージ] を右クリックし、[新しいメッセージ] をクリックします。
新しく作成したメッセージを右クリックし、[ プロパティウィンドウ] を選択します。

Message_1の [プロパティ] ウィンドウで、次の操作を行います。

プロパティ	目的
識別子	「`NotifyReceive`.
メッセージ型	ドロップダウンリストから [ スキーマ] を展開し、[ Process_Notification.Notification] を選択します。ここで、Process_Notification は BizTalk プロジェクトの名前です。 Notification は、 Notification 操作用に生成されたスキーマです。

オーケストレーションの設定

SQL Server データベースから通知メッセージを受信し、受信した通知の種類に基づいてタスクを実行するためにBizTalk Serverを使用するには、BizTalk オーケストレーションを作成する必要があります。このオーケストレーションでは、アダプターは NotificationStatement バインディングプロパティに指定された SELECT ステートメントに基づいて通知メッセージを受信します。 Expression 図形内で指定された xpath クエリは、通知の種類 ( NotificationType など) を変数に抽出します。 Decide 図形は、この変数の値を使用して受信した通知の種類を決定し、後続の操作を実行するための適切な "パス" を取得します。前のセクションで説明したように、オーケストレーションは受信した通知メッセージの種類に基づいて次の操作を実行します。

通知メッセージが挿入操作または更新操作の場合、アダプタークライアントはメッセージを C:\TestLocation\UpsertNotification フォルダーにコピーします。
通知メッセージが Delete などの他の操作の場合、アダプタークライアントはメッセージを C:\TestLocation\OtherNotificaiton フォルダーにコピーします。

そのため、オーケストレーションには次のものが含まれている必要があります。
通知メッセージを受信する一方向の受信ポート。
受信した通知の種類を抽出する xpath クエリを含む式図形。
オーケストレーションにデシジョンブロックを含める決定図形。この決定ブロックでは、アプリケーションは、受信した通知メッセージに基づいて、後続の操作を実行する対象を決定します。
最終的に通知メッセージを受信する 2 つの一方向送信ポート。
図形を受け取ります。

サンプルオーケストレーションは次のようになります。

メッセージ図形の追加

メッセージ図形ごとに次のプロパティを指定してください。 [図形] 列に一覧表示される名前は、単一のオーケストレーションに表示されるメッセージ図形の名前です。

図形	図形の種類	プロパティ
ReceiveNotification	受信	- 名前を ReceiveNotification に設定する - Activate をTrue に設定する

式図形の追加

オーケストレーションに式図形を含める目的は、受信した通知メッセージの種類を抽出する xpath クエリを使用することです。 xpath クエリを作成する前に、通知メッセージの形式を見てみましょう。一般的な通知メッセージは次のようになります。

<Notification xmlns="http://schemas.microsoft.com/Sql/2008/05/Notification/">  
  <Info>Insert</Info>   
  <Source>Data</Source>   
  <Type>Change</Type>   
</Notification>

ご覧のように、通知の種類に関する情報は、親<Notification>タグ内の <info> タグ内で使用できます。そのため、この式の図形の一部として、次の操作を行う必要があります。

タグ内の値を含む変数を <Info> 作成し、その型を System.String に設定します。変数の作成の詳細については、「オーケストレーションでの変数の使用」を参照してください。

このトピックでは、変数に NotificationType という名前を 付けます。
xpath クエリを作成して、Info> タグから値を<抽出します。 xpath クエリは次のようになります。
```
NotificationType = xpath(NotifyReceive,"string(/*[local-name()='Notification']/*[local-name()='Info']/text())");  
```
この xpath クエリでは、 NotifyReceive は通知メッセージを受信するために作成したメッセージです。関数内の string 抜粋は、クエリがタグ内 <Info> の値を抽出する必要があることを示しています。これはタグ内 <Notification> にあります。最後に、クエリによって抽出された値が NotificaitonType 変数に割り当てられます。

決定図形の追加

決定図形を追加する目的は、受信した通知メッセージの種類に基づいて後続の操作を実行する決定ブロックをオーケストレーションに含めることです。決定は、 NotificationType 変数の値に基づいて行われます。このトピックでは、オーケストレーションによって、受信した通知メッセージの種類に基づいて決定が行われます。そのため、Rule 図形の条件は次のように指定されます。

NotificationType.Equals("Insert") | NotificationType.Equals("Update")

この条件は、 NotificaitonType 変数の値が Insert または Update の場合、オーケストレーションは 1 つのタスクセットを実行することを示唆しています。 NotificationType 変数の値がそれ以外の場合、オーケストレーションは他の一連のタスクを実行します。

前のセクションで説明したように、簡単な方法を示すために、オーケストレーションは通知メッセージの種類に基づいて異なるフォルダーにメッセージをコピーします。そのため、Rule ブロックと Else ブロック内で、[送信] 図形を追加して、メッセージを別のポートに送信する必要があります。このトピックでは、ルールブロックの Send 図形に SendUpsertNotification 、Else ブロックの Send 図形に SendOtherNotification という名前を付けます。

ポートの追加

次に、次の論理ポートをオーケストレーションに追加する必要があります。

SQL Serverから通知メッセージを受信するための一方向受信ポート。
挿入および更新操作の通知メッセージを特定のフォルダーに送信する一方向送信ポート。
他の操作の通知メッセージを特定のフォルダーに送信するための一方向送信ポート。

論理ポートごとに次のプロパティを指定してください。 [ポート] 列に表示される名前は、オーケストレーションに表示されるポートの名前です。

Port	プロパティ
SQLNotifyPort	- 識別子を SQLNotifyPort に設定する - 型を SQLNotifyPortType に設定する - 通信パターンを一方向に設定する - 受信する通信方向を設定する
NotificationUpsertPort	- 識別子を NotificationUpsertPort に設定する - 型を NotificationUpsertPortType に設定する - 通信パターンを一方向に設定する - [通信の方向] を [送信] に設定する
OtherNotificationPort	- 識別子を OtherNotificationPort に設定する - Type を OtherNotificationPortType に設定する - 通信パターンを一方向に設定する - [通信の方向] を [送信] に設定する

アクション図形のメッセージを指定し、ポートに接続する

次の表では、アクション図形のメッセージを指定し、メッセージをポートにリンクするために設定する必要があるプロパティとその値を指定します。 [図形] 列に表示される名前は、前述のオーケストレーションに表示されるメッセージ図形の名前です。

図形	プロパティ
ReceiveNotification	- Message を NotifyReceive に設定する - 操作を SQLNotifyPort.Notify.Request に設定する
SendUpsertNotification	- Message を NotifyReceive に設定する - 操作を NotificationUpsertPort.Upsert.Request に設定する
SendOtherNotification	- メッセージを選択するように設定する - 操作を OtherNotificationPort.Other.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 に設定します。

さまざまなバインドプロパティの詳細については、「BizTalk Adapter for SQL Server Adapter Binding Properties」を参照してください。

Note

SQL アダプターを使用して受信操作を実行するときに、トランザクション分離レベルとトランザクションタイムアウトを構成することをお勧めします。これを行うには、WCF-Custom または WCF-SQL 受信ポートの構成中にサービスの動作を追加します。サービスの動作を追加する方法については、「SQL を使用してトランザクション分離レベルとトランザクションタイムアウトを構成する」を参照してください。

ハードディスク上の場所と、BizTalk オーケストレーションが挿入および更新操作のためにSQL Server データベースから通知メッセージを削除する対応するファイルポートを定義します。このポートを構成して、C:\TestLocation\UpsertNotification フォルダーに通知メッセージをドロップします。
ハードディスク上の場所と、BizTalk オーケストレーションが他のすべての操作のためにSQL Server データベースから通知メッセージを削除する対応するファイルポートを定義します。このポートを構成して、フォルダー C:\TestLocation\OtherNotification に通知メッセージをドロップします。

アプリケーションの起動

SQL Server データベースから通知メッセージを受信し、後続の Select 操作と Update 操作を実行するには、BizTalk アプリケーションを起動する必要があります。 BizTalk アプリケーションを起動する手順については、「オーケストレーションを開始する方法」を参照してください。

この段階で、次のことを確認します。

WCF-Custom または WCF-SQL の一方向の受信ポート。これは、SQL Server データベースが実行されているから通知メッセージを受信します。
SQL Serverからメッセージを受信する 2 つの FILE 送信ポートが実行されています。
操作の BizTalk オーケストレーションが実行されています。

操作の実行

BizTalk オーケストレーションを開始すると、次の一連のアクションが実行されます。

NotifyOnListenerStart バインドプロパティが True に設定されているため、次のメッセージが表示されます。
```
<?xml version="1.0" encoding="utf-8" ?>  
<Notification xmlns="http://schemas.microsoft.com/Sql/2008/05/Notification/">  
  <Info>ListenerStarted</Info>   
  <Source>SqlBinding</Source>   
  <Type>Startup</Type>   
</Notification>  
```
タグの <Info> 値は "ListnerStarted" であることに注意してください。そのため、このメッセージは C:\TestLocation\OtherNotification フォルダーで受信されます。
Employee テーブルにレコードを挿入します。次のような通知メッセージが表示されます。
```
<?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>  
```
タグの <Info> 値は "Insert" であることに注意してください。そのため、このメッセージは C:\TestLocation\UpsertNotification フォルダーで受信されます。
Employee テーブルのレコードを更新します。次のような通知メッセージが表示されます。
```
<?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>  
```
タグの <Info> 値は "Update" であることに注意してください。そのため、このメッセージは C:\TestLocation\UpsertNotification フォルダーで受信されます。
Employee テーブルからレコードを削除します。次のような通知メッセージが表示されます。
```
<?xml version="1.0" encoding="utf-8" ?>  
<Notification xmlns="http://schemas.microsoft.com/Sql/2008/05/Notification/">  
  <Info>Delete</Info>   
  <Source>Data</Source>   
  <Type>Change</Type>   
</Notification>  
```
タグの <Info> 値は "Delete" であることに注意してください。そのため、このメッセージは C:\TestLocation\OtherNotification フォルダーで受信されます。

ベストプラクティス

BizTalk プロジェクトを展開して構成したら、構成設定をバインドファイルと呼ばれる XML ファイルにエクスポートできます。バインドファイルを生成したら、ファイルから構成設定をインポートして、同じオーケストレーションの送信ポートと受信ポートを作成する必要がないようにすることができます。バインドファイルの詳細については、「アダプターバインドを再利用する」を参照してください。

通知メッセージを受信した後の複雑な操作の実行

わかりやすく、理解を深めるために、このトピックのオーケストレーションでは、通知の種類に基づいて異なるフォルダーにメッセージをコピーします。ただし、実際のシナリオでは、より複雑な操作を実行する必要がある場合があります。このトピックで説明されているように、同様の手順を実行し、それらを基にして必要な操作を実行できます。たとえば、Employee テーブルに対する挿入操作の通知メッセージが表示された場合は、オーケストレーションを変更して別のテーブルにレコードを挿入できます。このような場合は、[決定] 図形内で適切な変更を行うことができます。

このようなシナリオの 1 つは、「チュートリアル 2: 従業員 - SQL アダプターを使用した発注書プロセス」で詳しく説明されています。

参照

BizTalk Serverを使用して SQL クエリ通知を受信する

次の方法で共有

通知メッセージを処理して、BizTalk Serverを使用して SQL の特定のタスクを完了する

通知を受信した後に後続のアクションを実行するシナリオ

このトピックでは、通知メッセージの受信と通知の種類の抽出方法について説明します

SQL アダプターバインドプロパティを使用した通知の構成

SQL Server データベースから通知メッセージを受信する方法

スキーマの生成

メッセージとメッセージの種類の定義

メッセージを作成し、スキーマにリンクするには

オーケストレーションの設定

メッセージ図形の追加

式図形の追加

決定図形の追加

ポートの追加

アクション図形のメッセージを指定し、ポートに接続する

BizTalk アプリケーションの構成

アプリケーションの起動

操作の実行

ベストプラクティス

通知メッセージを受信した後の複雑な操作の実行

参照

フィードバック

その他のリソース

次の方法で共有

通知メッセージを処理して、BizTalk Serverを使用して SQL の特定のタスクを完了する

通知を受信した後に後続のアクションを実行するシナリオ

このトピックでは、通知メッセージの受信と通知の種類の抽出方法について説明します

SQL アダプター バインド プロパティを使用した通知の構成

SQL Server データベースから通知メッセージを受信する方法

スキーマの生成

メッセージとメッセージの種類の定義

メッセージを作成し、スキーマにリンクするには

オーケストレーションの設定

メッセージ図形の追加

式図形の追加

決定図形の追加

ポートの追加

アクション図形のメッセージを指定し、ポートに接続する

BizTalk アプリケーションの構成

アプリケーションの起動

操作の実行

ベスト プラクティス

通知メッセージを受信した後の複雑な操作の実行

参照

フィードバック

その他のリソース

SQL アダプターバインドプロパティを使用した通知の構成

ベストプラクティス