FOR XML 句を含む SELECT ステートメントまたはストアド プロシージャを使用して、SQL Server テーブルまたはビューの定期的なデータ変更メッセージを受信するように SQL アダプターを構成できます。 これらのステートメントは、アダプターがデータベースをポーリングするために実行するポーリング ステートメントとして指定できます。 ポーリング ステートメントには、結果セットを返す SELECT ステートメントまたはストアド プロシージャを指定できます。
アダプターがポーリングをサポートする方法の詳細については、「 ポーリングのサポート」を参照してください。 ポーリング操作用の SOAP メッセージの構造については、「 ポーリング操作と TypedPolling 操作のメッセージ スキーマ」を参照してください。 SQL FOR XML 句 では、詳細が提供されます。
注
このトピックでは、 XmlPolling 受信操作を使用してポーリング メッセージを受信する方法について説明します。 XmlPolling 操作は、FOR XML 句を含む SELECT ステートメントまたはストアド プロシージャを使用して SQL Server データベースをポーリングするために使用されます。 XmlPolling 操作のメッセージには、SQL Server Management Studio で SELECT ステートメントまたはストアド プロシージャを実行して受信した xml メッセージが含まれます。
アダプターを使用して、さまざまな種類のポーリング メッセージを受信することもできます。
- 型付けの緩やかなポーリングメッセージを取得したい場合は、ポーリング操作を行う必要があります。 詳細については、「 BizTalk Server を使用して SQL Server からポーリング ベースのデータ変更メッセージを受信する」を参照してください。
- 厳密に型指定されたポーリング メッセージを取得する場合は、 TypedPolling 操作を使用する必要があります。 また、 TypedPolling 操作を使用して、1 つの BizTalk アプリケーションで複数のポーリング操作を行う必要があります。 TypedPolling 操作を実行する方法については、「BizTalk Server を使用して SQL Server から厳密に型指定されたポーリング ベースのデータ変更メッセージを受信する」を参照してください。
Von Bedeutung
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 アプリケーションを構成します。
Von Bedeutung
受信ポーリングのシナリオでは、常に一方向の WCF-Custom または WCF-SQL の受信ポートを構成する必要があります。 双方向 WCF-Custom または WCF-SQL 受信ポートは、受信操作ではサポートされていません。
BizTalk アプリケーションを起動します。
SELECT ステートメントの応答メッセージのスキーマの生成
xmlschema句を for xml 句に含めることで、SELECT ステートメントの応答メッセージのスキーマを生成できます。 このトピックでは、SELECT ステートメントを使用して、特定の従業員 ID の従業員の詳細を取得します。 SELECT ステートメントを実行してスキーマを取得するには、SELECT ステートメントを次のように記述する必要があります。
SELECT Employee_ID ,Name ,Designation FROM Employee for xml auto, xmlschema
この SELECT ステートメントを実行して、応答メッセージのスキーマを取得します。 スキーマを保存します。 Visual Studio で BizTalk プロジェクトを作成し、このスキーマをプロジェクトに追加する必要があります。 この例では、このスキーマに PollingResponse.xsd という名前を付けることができます。
Von Bedeutung
SELECT ステートメントを実行してスキーマを生成した後、必ず xmlschema 句を削除してください。 これを行わない場合、最終的に XmlPolling 操作の一部として BizTalk を介して SELECT ステートメントを実行すると、応答メッセージでスキーマが再度生成されます。 そのため、応答メッセージを xml として取得するには、 xmlschema 句を削除する必要があります。
BizTalk プロジェクトにスキーマを追加するには
Visual Studio で BizTalk プロジェクトを作成します。
ストアド プロシージャ用に生成した応答スキーマを BizTalk プロジェクトに追加します。 ソリューション エクスプローラーで BizTalk プロジェクトを右クリックし、[ 追加] をポイントして、[ 既存の項目] をクリックします。 [既存の項目の追加] ダイアログ ボックスで、スキーマを保存した場所に移動し、[ 追加] をクリックします。
Visual Studio でスキーマを開き、次の変更を行います。
スキーマにノードを追加し、この新しく追加されたノードの下に既存のルート ノードを移動します。 ルート ノードに名前を付けます。 このトピックでは、ルート ノードの名前を Root に変更します。
SELECT ステートメントに対して生成された応答スキーマは、sqltypes.xsd を参照します。 https://go.microsoft.com/fwlink/?linkid=31850から sqltypes.xsd スキーマを取得できます。 BizTalk プロジェクトに sqltypes.xsd スキーマを追加します。 このスキーマの詳細については、以下を参照してください。
SELECT ステートメント用に生成されたスキーマで、
import schemaLocationの値を次のように変更します。import schemaLocation=”sqltypes.xsd”これは、既に sqltypes.xsd スキーマを BizTalk プロジェクトに追加しているためです。
スキーマのターゲット名前空間を指定します。 <Schema> ノードをクリックし、[プロパティ] ウィンドウの [ターゲット名前空間] プロパティで名前空間を指定します。 このトピックでは、名前空間を
http://ForXmlPolling/namespaceとして指定します。
メッセージとメッセージの種類の定義
前に生成したスキーマでは、オーケストレーション内のメッセージに必要な "型" が記述されています。 通常、メッセージは変数であり、対応するスキーマによって定義される型です。 スキーマが生成されたら、BizTalk プロジェクトのオーケストレーション ビューからメッセージにリンクする必要があります。
このトピックでは、SQL Server データベースからメッセージを受信するメッセージを 1 つ作成する必要があります。
メッセージを作成し、スキーマにリンクするには、次の手順を実行します。
メッセージを作成し、スキーマにリンクするには
BizTalk プロジェクトにオーケストレーションを追加します。 ソリューション エクスプローラーで、BizTalk プロジェクト名を右クリックし、[ 追加] をポイントして、[ 新しい項目] をクリックします。 BizTalk オーケストレーションの名前を入力し、[ 追加] をクリックします。
まだ開いていない場合は、BizTalk プロジェクトのオーケストレーション ビュー ウィンドウを開きます。 [ 表示] をクリックし、[ その他のウィンドウ] をポイントし、[ オーケストレーション ビュー] をクリックします。
オーケストレーション ビューで、[メッセージ] を右クリックし、[新しいメッセージ] をクリックします。
新しく作成したメッセージを右クリックし、[ プロパティ ウィンドウ] を選択します。
Message_1の [プロパティ] ウィンドウで、次の操作を行います。
これを使用する 目的 識別子 「 PollingMessage」と入力します。 メッセージの種類 ドロップダウン リストから [ スキーマ] を展開し、 ForXMLPolling.PollingResponse を選択します。 ForXMLPolling は BizTalk プロジェクトの名前です。 PollingResponse は、「 BIZTalk Server を使用して SQL から SELECT ステートメントと FOR XML 句を使用してポーリング メッセージを受信する」で説明されているように、SELECT ステートメントを実行して生成される応答スキーマの名前です。
オーケストレーションの設定
SQL Server データベースからポーリング ベースのデータ変更メッセージを受信するために BizTalk Server を使用するには、BizTalk オーケストレーションを作成する必要があります。 このオーケストレーションでは、アダプターは 、PollingStatement バインディング プロパティに指定された select ステートメントの応答を受け取ります。 SELECT ステートメントの応答は FILE の場所に保存されます。 SQL Server データベースをポーリングするための一般的なオーケストレーションには、次のものが含まれます。
受信と送信の図形を使用して、SQL Server からメッセージを受信し、FILE ポートに送信します。
SQL Server からメッセージを受信する一方向の受信ポート。
Von Bedeutung
受信ポーリングのシナリオでは、常に一方向の受信ポートを構成する必要があります。 双方向の受信ポートは、受信操作ではサポートされていません。
SQL Server データベースからフォルダーにポーリング応答を送信する一方向送信ポート。
サンプル オーケストレーションは次のようになります。
メッセージ図形の追加
メッセージ図形ごとに次のプロパティを指定してください。 [図形] 列に一覧表示される名前は、先ほど説明したオーケストレーションに表示されるメッセージ図形の名前です。
| 形 | 図形の種類 | 特性 |
|---|---|---|
| メッセージ受信 | 受け取る | - 名前を ReceiveMessage に設定する - アクティブ化を True に設定する |
| メッセージを保存 | 送信 | - 名前を SaveMessage に設定する |
ポートの追加
論理ポートごとに次のプロパティを指定してください。 [ポート] 列に表示される名前は、オーケストレーションに表示されるポートの名前です。
| 港 / ポート | 特性 |
|---|---|
| SQLReceivePort | - 識別子を SQLReceivePort に設定する - 型を SQLReceivePortType に設定する - 通信パターンを一方向に設定する - 通信方向を受信に設定する |
| SaveMessagePort | - 識別子を SaveMessagePort に設定する - 型を SaveMessagePortType に設定する - 通信パターンを一方向に設定する - 通信方向を送信に設定する |
アクション図形のメッセージを指定し、ポートに接続する
次の表では、アクション図形のメッセージを指定し、メッセージをポートにリンクするために設定するプロパティとその値を指定します。 [図形] 列に表示される名前は、前述のオーケストレーションに表示されるメッセージ図形の名前です。
| 形 | 特性 |
|---|---|
| メッセージ受信 | - メッセージを受信に設定する - 操作を SQLReceivePort.XmlPolling.Request に設定する |
| メッセージを保存 | - メッセージを受信に設定する - 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 アダプターへの物理ポート バインドを手動で構成する」を参照してください。 受信ポートには、次のバインド プロパティを指定してください。
Von Bedeutung
デザイン時にバインド プロパティを指定した場合は、この手順を実行する必要はありません。 このような場合は、アダプターの使用サービス アドインによって作成されたバインド ファイルをインポートすることで、必要なバインド プロパティを設定して、WCF カスタムまたは WCF-SQL 受信ポートを作成できます。 詳細については、 SQL アダプターを使用するようにポート バインド ファイルを使用して物理ポート バインドを構成するを参照してください。
バインディングプロパティ 価値 InboundOperationType これを XmlPolling に設定してください。 ポーリングデータの利用可能声明 必ず SQL ステートメントを指定してください。 このトピックでは、次を指定します。
SELECT COUNT(*) FROM EmployeePollingStatement BIZTalk Server を使用した SQL からの SELECT ステートメントと FOR XML 句を使用したポーリング メッセージの受信に関する説明に従って、スキーマの生成中に指定したのと同じステートメントを、 xmlschema句なしで指定してください。
SELECT Employee_ID ,Name ,Designation FROM Employee for xml auto
手記： SELECT ステートメントにxmlschema句が含まれていないことに注意してください。XmlStoredProcedureRootNodeName SELECT ステートメントの応答メッセージのスキーマ生成の説明に従って、SELECT ステートメント用に生成した応答スキーマに追加 したルート ノードの名前を指定します。 このトピックでは、これを Root に設定します。 Xmlストアードプロシージャルートノードネームスペース SELECT ステートメントの応答メッセージのスキーマの生成で説明されているように、SELECT ステートメント用に 生成した応答スキーマのターゲット名前空間を指定します。 このトピックでは、これを http://ForXmlPolling/namespaceに設定します。さまざまなバインド プロパティの詳細については、「 BizTalk Adapter for SQL Server アダプターのバインドプロパティ」を参照してください。
注
SQL アダプターを使用して受信操作を実行するときに、トランザクション分離レベルとトランザクション タイムアウトを構成することをお勧めします。 サービス動作を WCF-Custom または WCF-SQL 受信ポートの構成時に追加します。 サービスの動作を追加する方法については、「SQL を使用して トランザクション分離レベルとトランザクション タイムアウトを構成する」を参照してください。
アプリケーションの起動
SQL Server データベースからメッセージを受信するには、BizTalk アプリケーションを起動する必要があります。 BizTalk アプリケーションを起動する手順については、「オーケストレーションを 開始する方法」を参照してください。
この段階で、次のことを確認します。
pollingStatement バインディング プロパティに指定されたステートメントを使用して SQL Server データベースをポーリングする、WCF-Custom または WCF-SQL 一方向の受信ポートが実行されています。
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 バインド プロパティの値として指定した値と同じであることに注意してください。
注
BIZTalk Server 管理コンソールから受信ポートを明示的に無効にするまで、SQL アダプターはポーリングを続行します。
ベスト プラクティス
BizTalk プロジェクトを展開して構成したら、構成設定をバインド ファイルと呼ばれる XML ファイルにエクスポートできます。 バインド ファイルを生成したら、同じオーケストレーションの送信ポートと受信ポートを作成する必要がないように、ファイルから構成設定をインポートできます。 バインディング・ファイルの詳細については、 アダプター・バインディングの再利用を参照してください。