BIZTALK SERVERを使用して SQL から FOR XML 句で SELECT ステートメントを使用してポーリングメッセージを受信する

[アーティクル]
07/21/2023

SQL アダプターは、FOR XML 句を含む SELECT ステートメントまたはストアドプロシージャを使用して、SQL Serverテーブルまたはビューの定期的なデータ変更メッセージを受信するように構成できます。これらのステートメントは、アダプターがデータベースをポーリングするために実行するポーリングステートメントとして指定できます。ポーリングステートメントには、SELECT ステートメント、または結果セットを返すストアドプロシージャを指定できます。

アダプターがポーリングをサポートする方法の詳細については、「ポーリングのサポート」を参照してください。ポーリング操作用の SOAP メッセージの構造については、「ポーリング操作と TypedPolling 操作のメッセージスキーマ」を参照してください。 SQL FOR XML 句では、詳細が提供されます。

Note

このトピックでは、 XmlPolling 受信操作を使用してポーリングメッセージを受信する方法について説明します。 XmlPolling 操作は、SELECT ステートメントまたは FOR XML 句を含むストアドプロシージャを使用して、SQL Server データベースをポーリングするために使用されます。 XmlPolling 操作のメッセージには、select ステートメントまたはストアドプロシージャを実行して受信した xml メッセージがSQL Server Management Studio。

アダプターを使用して、さまざまな種類のポーリングメッセージを受信することもできます。

弱く型指定されたポーリングメッセージを取得する場合は、ポーリング操作を使用する必要があります。詳細については、「BizTalk Serverを使用してSQL Serverからポーリングベースのデータ変更メッセージを受信する」を参照してください。
- 厳密に型指定されたポーリングメッセージを取得する場合は、 TypedPolling 操作を使用する必要があります。 1 つの BizTalk アプリケーションで複数のポーリング操作を行うには、 TypedPolling 操作も使用する必要があります。 TypedPolling 操作を実行する方法については、「BizTalk Serverを使用してSQL Serverから厳密に型指定されたポーリングベースのデータ変更メッセージを受信する」を参照してください。

重要

1 つの BizTalk アプリケーションで複数のポーリング操作を行う場合は、接続 URI の一部として InboundID 接続プロパティを指定して一意にする必要があります。一意の接続 URI を使用すると、同じデータベース、またはデータベース内の同じテーブルをポーリングする複数の受信ポートを作成できます。詳細については、「BizTalk Serverを使用して SQL から複数の受信ポート間でポーリングメッセージを受信する」を参照してください。

このトピックでポーリングを示す方法

このトピックでは、SQL アダプターがデータ変更メッセージの受信をサポートする方法を示すために、FOR XML 句と共に SELECT ステートメントを使用して、SQL Server データベースをポーリングします。 SQL Server Management Studioでこのようなステートメントを呼び出すと、出力は xml メッセージの形式になります。このようなステートメントを使用してSQL Server データベースをポーリングするには、応答 xml メッセージのスキーマが必要です。 SQL アダプターでは、FOR XML 句を使用して SELECT ステートメントを実行した後、このスキーマでポーリングメッセージを受信する必要があります。そのため、SELECT ステートメントと FOR XML 句を使用してSQL Server データベースをポーリングするには、次の一連のタスクを実行する必要があります。

FOR XML 句を使用して SELECT ステートメントの XML 応答メッセージのスキーマを生成します。
BizTalk プロジェクトを作成し、生成されたスキーマをプロジェクトに追加します。
SQL Server データベースから XML 応答メッセージを受信するためのメッセージを BizTalk プロジェクトに作成します。
SQL Server データベースからメッセージを受信し、フォルダーに保存するオーケストレーションを作成します。
BizTalk プロジェクトをビルドして展開します。
物理送受信ポートを作成して BizTalk アプリケーションを構成します。

重要

受信ポーリングのシナリオでは、常に一方向の WCF-Custom または WCF-SQL 受信ポートを構成する必要があります。双方向 WCF-Custom または WCF-SQL 受信ポートは、受信操作ではサポートされていません。
BizTalk アプリケーションを起動します。

SELECT ステートメントの応答メッセージのスキーマの生成

句を句と共に含めることで、SELECT ステートメントの応答メッセージの xmlschema スキーマを for xml 生成できます。このトピックでは、SELECT ステートメントを使用して、特定の従業員 ID の従業員の詳細を取得します。 SELECT ステートメントを実行してスキーマを取得するには、SELECT ステートメントを次のように記述する必要があります。

SELECT Employee_ID ,Name ,Designation FROM Employee for xml auto, xmlschema

この SELECT ステートメントを実行して、応答メッセージのスキーマを取得します。スキーマを保存します。次に、Visual Studio で BizTalk プロジェクトを作成し、このスキーマをプロジェクトに追加する必要があります。この例では、このスキーマに PollingResponse.xsd という名前を付けることができます。

重要

SELECT ステートメントを実行してスキーマを xmlschema 生成した後で、句を削除してください。これを行わない場合、XmlPolling 操作の一部として BizTalk を介して SELECT ステートメントを最後に実行すると、応答メッセージでスキーマが再度生成されます。そのため、応答メッセージを xml として取得するには、句を削除する xmlschema 必要があります。

BizTalk プロジェクトにスキーマを追加するには

Visual Studio で BizTalk プロジェクトを作成します。
ストアドプロシージャ用に生成した応答スキーマを BizTalk プロジェクトに追加します。ソリューションエクスプローラーで BizTalk プロジェクトを右クリックし、[追加] をポイントして、[既存の項目] をクリックします。 [既存の項目の追加] ダイアログボックスで、スキーマを保存した場所に移動し、[ 追加] をクリックします。
Visual Studio でスキーマを開き、次の変更を行います。
1. スキーマにノードを追加し、この新しく追加されたノードの下に既存のルートノードを移動します。ルートノードに名前を付けます。このトピックでは、ルートノードの名前を Root に変更します。
2. SELECT ステートメント用に生成された応答スキーマは、sqltypes.xsd を参照します。 sqltypes.xsd スキーマはから https://go.microsoft.com/fwlink/?linkid=31850取得できます。 sqltypes.xsd スキーマを BizTalk プロジェクトに追加します。このスキーマの詳細については、次のページを参照してください。
  - 2.2.5.2 sqlTypes
  - 組み込みの XML スキーマコレクションを参照する (sys)
3. SELECT ステートメント用に生成されたスキーマで、の import schemaLocation 値を次のように変更します。
```
import schemaLocation=”sqltypes.xsd”
```
  これは、既に sqltypes.xsd スキーマを BizTalk プロジェクトに追加しているためです。
4. スキーマのターゲット名前空間を指定します。 [スキーマ>] ノードを<クリックし、プロパティペインで [ターゲット名前空間] プロパティに名前空間を指定します。このトピックでは、名前空間をとして http://ForXmlPolling/namespace指定します。

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

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

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

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

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

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

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

プロパティ	目的
識別子	「 PollingMessage」と入力します。
メッセージ型	ドロップダウンリストから [ スキーマ] を展開し、[ ForXMLPolling.PollingResponse] ( ForXMLPolling は BizTalk プロジェクトの名前) を選択します。 PollingResponse は、「BIZTALK SERVERを使用して SQL から FOR XML 句を使用して SELECT ステートメントを使用してポーリングメッセージを受信する」で説明されているように、SELECT ステートメントを実行して生成される応答スキーマの名前です。

プロパティ

目的

識別子

「 PollingMessage」と入力します。

メッセージ型

ドロップダウンリストから [ スキーマ] を展開し、[ ForXMLPolling.PollingResponse] ( ForXMLPolling は BizTalk プロジェクトの名前) を選択します。 PollingResponse は、「BIZTALK SERVERを使用して SQL から FOR XML 句を使用して SELECT ステートメントを使用してポーリングメッセージを受信する」で説明されているように、SELECT ステートメントを実行して生成される応答スキーマの名前です。

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

SQL Server データベースからポーリングベースのデータ変更メッセージを受信するためにBizTalk Serverを使用するには、BizTalk オーケストレーションを作成する必要があります。このオーケストレーションでは、アダプターは PollingStatement バインディングプロパティに指定された select ステートメントの応答を受け取ります。 SELECT ステートメントの応答は FILE の場所に保存されます。 SQL Server データベースをポーリングするための一般的なオーケストレーションには、次のものが含まれます。

SQL Serverからメッセージを受信し、それぞれ FILE ポートに送信する図形を受信および送信します。
SQL Serverからメッセージを受信する一方向の受信ポート。

重要

受信ポーリングシナリオでは、常に一方向の受信ポートを構成する必要があります。双方向の受信ポートは、受信操作ではサポートされていません。
SQL Server データベースからフォルダーにポーリング応答を送信する一方向送信ポート。

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

SQL Server データベースを

メッセージ図形の追加

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

図形	図形の種類	プロパティ
ReceiveMessage	受信	- 名前を ReceiveMessage に設定する - アクティブ化を True に設定する
SaveMessage	Send	- 名前を SaveMessage に設定する

ポートの追加

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

Port	プロパティ
SQLReceivePort	- 識別子を SQLReceivePort に設定する - 型を SQLReceivePortType に設定する - 通信パターンを一方向に設定する - 通信方向を受信に設定する
SaveMessagePort	- 識別子を SaveMessagePort に設定する - Type を SaveMessagePortType に設定する - 通信パターンを一方向に設定する - [通信の方向] を [送信] に設定する

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

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

図形	プロパティ
ReceiveMessage	- メッセージを受信に設定する - 操作を SQLReceivePort.XmlPolling.Request に設定する
SaveMessage	- メッセージを受信に設定する - 操作を SaveMessagePort.XmlPolling.Request に設定する

これらのプロパティを指定すると、メッセージの図形とポートが接続され、オーケストレーションが完了します。

BizTalk ソリューションをビルドし、BizTalk Serverに展開する必要があります。詳細については、「オーケストレーションのビルドと実行」を参照してください。

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

BizTalk プロジェクトを展開すると、先ほど作成したオーケストレーションが、BizTalk Server管理コンソールの [オーケストレーション] ウィンドウの下に一覧表示されます。アプリケーションを構成するには、BizTalk Server管理コンソールを使用する必要があります。チュートリアルについては、「チュートリアル: 基本的な BizTalk アプリケーションの展開」を参照してください。

アプリケーションの構成には、次の作業が含まれます。

アプリケーションのホストの選択。

オーケストレーションで作成したポートを、BizTalk Server管理コンソールの物理ポートにマッピングします。このオーケストレーションでは、次の操作を行う必要があります。

ハードディスク上の場所と、BizTalk オーケストレーションがSQL Server データベースからメッセージを削除する対応するファイルポートを定義します。これらのメッセージは、受信ポートに指定したポーリングステートメントに応答します。

物理 WCF-Custom または WCF-SQL 一方向の受信ポートを定義します。このポートは、ポートに指定したポーリングステートメントを使用して、SQL Server データベースをポーリングします。ポートを作成する方法については、「 SQL アダプターへの物理ポートバインドを手動で構成する」を参照してください。受信ポートには、次のバインドプロパティを指定してください。

重要

デザイン時にバインドプロパティを指定した場合は、この手順を実行する必要はありません。このような場合は、アダプターサービスアドインを使用して作成されたバインドファイルをインポートすることで、必要なバインドプロパティを設定して、WCF-custom または WCF-SQL 受信ポートを作成できます。詳細については、「 SQL アダプターを使用するようにポートバインドファイルを使用して物理ポートバインドを構成する」を参照してください。

Binding プロパティ	値
InboundOperationType	これを XmlPolling に設定してください。
PolledDataAvailableStatement	SQL ステートメントを指定してください。このトピックでは、次を指定します。 `SELECT COUNT(*) FROM Employee`
PollingStatement	「BIZTALK SERVERを使用して SQL から FOR XML 句を使用して SELECT ステートメントを使用してポーリングメッセージを受信する」の説明に従って、スキーマの生成中に指定したのと同じステートメントを句なしで`xmlschema`指定してください。 `SELECT Employee_ID ,Name ,Designation FROM Employee for xml auto` メモ： SELECT ステートメントには句が含 `xmlschema` まれていないことに注意してください。
XmlStoredProcedureRootNodeName	SELECT ステートメントの応答メッセージのスキーマの生成に関するページで説明されているように、SELECT ステートメント用に生成した応答スキーマに追加したルートノードの名前を指定します。このトピックでは、これを [ルート] に設定します。
XmlStoredProcedureRootNodeNamespace	SELECT ステートメントの応答メッセージのスキーマの生成に関するページで説明されているように、SELECT ステートメント用に生成した応答スキーマのターゲット名前空間を指定します。このトピックでは、これをに設定します `http://ForXmlPolling/namespace`。

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

Note

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

アプリケーションの起動

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

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

WCF-Custom または WCF-SQL の一方向の受信ポートは、PollingStatement バインディングプロパティに指定されたステートメントを使用してSQL Server データベースをポーリングします。
SQL Serverからメッセージを受信する FILE 送信ポートが実行されています。
操作の BizTalk オーケストレーションが実行されています。

操作の実行

アプリケーションを実行すると、次の一連のアクションが同じ順序で実行されます。

アダプターは、Employee テーブルで PolledDataAvailableStatement を実行し、テーブルにポーリング用のレコードがあることを判断します。
アダプターはポーリングステートメントを実行し、SQL Server データベースからポーリングメッセージを受信します。ポーリングステートメントは FOR XML 句を含む SELECT ステートメントで構成されるため、アダプターによって受信されるポーリングメッセージは次のようになります。
```
<?xml version="1.0" encoding="utf-8" ?>
<Root xmlns="http://ForXmlPolling/namespace">
  <Employee Employee_ID="10765" Name="John" Designation="Tester" xmlns="" />
  <Employee Employee_ID="10766" Name="Sam" Designation="Manager" xmlns="" />
  .....
  .....
</Root>
```
ポーリングメッセージは、 xmlschema 句を使用して SELECT ステートメントを実行して生成されたのと同じスキーマで受信されます。また、ルートノードと名前空間は、 それぞれ XmlStoredProcedureRootNodeName および XmlStoredProcedureRootNodeNamespace バインドプロパティの値として指定したのと同じであることに注意してください。

Note

SQL アダプターは、BizTalk Server管理コンソールから受信ポートを明示的に無効にするまでポーリングを続行します。

ベストプラクティス

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

参照

BizTalk Serverで SQL アダプターを使用してSQL Serverをポーリングする

次の方法で共有

BIZTALK SERVERを使用して SQL から FOR XML 句で SELECT ステートメントを使用してポーリングメッセージを受信する

このトピックでポーリングを示す方法

SELECT ステートメントの応答メッセージのスキーマの生成

BizTalk プロジェクトにスキーマを追加するには

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

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

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

メッセージ図形の追加

ポートの追加

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

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

アプリケーションの起動

操作の実行

ベストプラクティス

参照

フィードバック

フィードバック

その他のリソース

次の方法で共有

BIZTALK SERVERを使用して SQL から FOR XML 句で SELECT ステートメントを使用してポーリング メッセージを受信する

このトピックでポーリングを示す方法

SELECT ステートメントの応答メッセージのスキーマの生成

BizTalk プロジェクトにスキーマを追加するには

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

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

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

メッセージ図形の追加

ポートの追加

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

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

アプリケーションの起動

操作の実行

ベスト プラクティス

参照

フィードバック

フィードバック

その他のリソース

BIZTALK SERVERを使用して SQL から FOR XML 句で SELECT ステートメントを使用してポーリングメッセージを受信する

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

ベストプラクティス