BizTalk Server を使用して SQL Server からポーリング ベースのデータ変更メッセージを受信する

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

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

このトピックがポーリングを説明する方法

このトピックでは、SQL アダプターがデータ変更メッセージの受信をサポートする方法を示すために、BizTalk プロジェクトを作成し、 ポーリング 操作のスキーマを生成します。 デザイン時にポーリング関連のバインド プロパティを指定する場合は、 PolledDataAvailableStatement を次のように指定します。

SELECT COUNT(*) FROM Employee  

PolledDataAvailableStatement は、正の値を含む最初のセルで結果セットを返す必要があります。 最初のセルに正の値が含まれていない場合、アダプターはポーリング ステートメントを実行しません。

ポーリング ステートメントの一部として、次の操作を実行します。

• Employee テーブルからすべての行を選択します。

• ストアド プロシージャ (MOVE_EMP_DATA) を実行して、すべてのレコードを Employee テーブルから EmployeeHistory テーブルに移動します。

• ストアド プロシージャ (ADD_EMP_DETAILS) を実行して、Employee テーブルに新しいレコードを追加します。 この手順では、従業員の名前、指定、給与をパラメーターとして受け取ります。

  これらの操作を実行するには、 PollingStatement バインディング プロパティに次を指定する必要があります。

SELECT * FROM Employee;EXEC MOVE_EMP_DATA;EXEC ADD_EMP_DETAILS John, Tester, 100000   

ポーリング ステートメントが実行されると、Employee テーブルのすべてのレコードが選択され、SQL Server からのメッセージが受信場所にドロップされます。 MOVE_EMP_DATA ストアド プロシージャがアダプターによって実行されると、すべてのレコードが EmployeeHistory テーブルに移動されます。 次に、ADD_EMP_DETAILS ストアド プロシージャが実行され、Employee テーブルに新しいレコードが追加されます。 次のポーリング実行では、1 つのレコードのみが返されます。 このサイクルは、SQL Server をポーリングする受信ポートを無効にするまで続行されます。

SQL アダプターのバインド プロパティを使用したポーリング クエリの構成

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

これらのプロパティの詳細については、「 BizTalk Adapter for SQL Server アダプターのバインドプロパティ」を参照してください。 SQL アダプターを使用して SQL Server をポーリングする方法の詳細については、詳細を参照してください。

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

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

1. BizTalk プロジェクトを作成し、 ポーリング 操作のスキーマを生成します。 必要に応じて、 PolledDataAvailableStatement および PollingStatement バインド プロパティの値を指定できます。

2. SQL Server データベースからメッセージを受信するためのメッセージを BizTalk プロジェクトに作成します。

3. SQL Server データベースからメッセージを受信し、フォルダーに保存するオーケストレーションを作成します。

4. BizTalk プロジェクトをビルドして展開します。

5. 物理送受信ポートを作成して BizTalk アプリケーションを構成します。

   Von Bedeutung

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

6. BizTalk アプリケーションを起動します。

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

スキーマの生成

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

1. スキーマの生成中 に PolledDataAvailableStatement および PollingStatement バインディング プロパティの値を指定します。 このバインディング プロパティの詳細については、「 BizTalk Adapter for SQL Server アダプターのバインドプロパティ」を参照してください。

   バインディング プロパティを指定する方法については、「 SQL アダプターのバインド プロパティを構成する」を参照してください。

2. コントラクトの種類として サービス (受信操作) を選択します。

3. ポーリング操作のスキーマを生成します。

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

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

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

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

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

1. BizTalk プロジェクトにオーケストレーションを追加します。 ソリューション エクスプローラーで、BizTalk プロジェクト名を右クリックし、[ 追加] をポイントして、[ 新しい項目] をクリックします。 BizTalk オーケストレーションの名前を入力し、[ 追加] をクリックします。

2. まだ開いていない場合は、BizTalk プロジェクトのオーケストレーション ビュー ウィンドウを開きます。 [ 表示] をクリックし、[ その他のウィンドウ] をポイントし、[ オーケストレーション ビュー] をクリックします。

3. オーケストレーション ビューで、[メッセージ] を右クリックし、[新しいメッセージ] をクリックします。

4. 新しく作成したメッセージを右クリックし、[ プロパティ ウィンドウ] を選択します。

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

   これを使用する	目的
   識別子	「Receive」と入力します。
   メッセージの種類	ドロップダウン リストから [ スキーマ] を展開し、[ PollingQuery.Polling] を選択します。 PollingQuery は BizTalk プロジェクトの名前です。 ポーリング は、 ポーリング 操作用に生成されたスキーマです。

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

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

• 受信と送信の図形を使用して、SQL Server からメッセージを受信し、FILE ポートに送信します。

• SQL Server からメッセージを受信する一方向の受信ポート。

  Von Bedeutung

  受信ポーリングのシナリオでは、常に一方向の受信ポートを構成する必要があります。 双方向の受信ポートは、受信操作ではサポートされていません。

• SQL Server データベースからフォルダーにポーリング応答を送信する一方向送信ポート。

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

  

メッセージ図形の追加

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

ポートの追加

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

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

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

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

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	[ ポーリング] に設定していることを確認します。
    ポーリングデータの利用可能声明	必ず SQL ステートメントを指定してください。 このトピックでは、次を指定します。 SELECT COUNT(*) FROM Employee
    PollingStatement	ポーリング ステートメントを指定してください。 このトピックでは、次を指定します。 SELECT * FROM Employee;EXEC MOVE_EMP_DATA;EXEC ADD_EMP_DETAILS John, Tester, 100000

    さまざまなバインド プロパティの詳細については、「 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 を実行し、テーブルにポーリング用のレコードがあることを確認します。

• アダプターはポーリング ステートメントを実行します。 ポーリング ステートメントは SELECT ステートメントとストアド プロシージャで構成されるため、アダプターはすべてのステートメントを 1 つずつ実行します。

  • アダプターは、まず、Employee テーブル内のすべてのレコードを返す SELECT ステートメントを実行します。

  • その後、アダプターは、Employee テーブルから EmployeeHistory テーブルにすべてのデータを移動するMOVE_EMP_DATA ストアド プロシージャを実行します。 このストアド プロシージャは値を返しません。

  • その後、アダプターは、1 つのレコードを Employee テーブルに追加するADD_EMP_DETAILS ストアド プロシージャを実行します。 このストアド プロシージャは、挿入されたレコードの従業員 ID を返します。

    そのため、SQL Server から受信したメッセージには複数の結果セット (SELECT ステートメントとADD_EMP_DETAILS ストアド プロシージャの場合) が含まれており、次のようになります。

  <?xml version="1.0" encoding="utf-8" ?>   
  <Polling xmlns="http://schemas.microsoft.com/Sql/2008/05/Polling/">  
    <PolledData>  
      <DataSet xmlns="http://schemas.datacontract.org/2004/07/System.Data">  
        <xs:schema id="NewDataSet" xmlns:xs="http://www.w3.org/2001/XMLSchema" xmlns:msdata="urn:schemas-microsoft-com:xml-msdata">  
          <xs:element msdata:IsDataSet="true" name="NewDataSet">  
            <xs:complexType>  
              <xs:sequence>  
                <xs:element minOccurs="0" maxOccurs="unbounded" name="NewTable">  
                  <xs:complexType>  
                    <xs:sequence>  
                      <xs:element minOccurs="0" name="Employee_ID" type="xs:int" />   
                      <xs:element minOccurs="0" name="Name" type="xs:string" />   
                      <xs:element minOccurs="0" name="DOJ" type="xs:dateTime" />   
                      <xs:element minOccurs="0" name="Designation" type="xs:string" />   
                      <xs:element minOccurs="0" name="Job_Description" type="xs:string" />   
                      <xs:element minOccurs="0" name="Photo" type="xs:base64Binary" />   
                      <xs:element minOccurs="0" name="Rating" type="xs:string" />   
                      <xs:element minOccurs="0" name="Salary" type="xs:decimal" />   
                      <xs:element minOccurs="0" name="Last_Modified" type="xs:base64Binary" />   
                    </xs:sequence>  
                  </xs:complexType>  
                </xs:element>  
              </xs:sequence>  
            </xs:complexType>  
          </xs:element>  
        </xs:schema>  
        <diffgr:diffgram xmlns:diffgr="urn:schemas-microsoft-com:xml-diffgram-v1">  
          <NewDataSet xmlns="">  
            <NewTable>  
              <Employee_ID>10001</Employee_ID>   
              <Name>John</Name>   
              <Designation>Tester</Designation>   
              <Salary>100000.00</Salary>   
              <Last_Modified>AAAAAAAAF34=</Last_Modified>   
            </NewTable>  
            ........  
            ........  
            <NewTable>  
              <Employee_ID>10005</Employee_ID>   
              <Name>Wilson</Name>   
              <Designation>Tester3</Designation>   
              <Salary>100000.00</Salary>   
              <Last_Modified>AAAAAAAAF4E=</Last_Modified>   
            </NewTable>  
          </NewDataSet>  
        </diffgr:diffgram>  
      </DataSet>  
      <DataSet xmlns="http://schemas.datacontract.org/2004/07/System.Data">  
        <xs:schema id="NewDataSet" xmlns:xs="http://www.w3.org/2001/XMLSchema" xmlns:msdata="urn:schemas-microsoft-com:xml-msdata">  
          <xs:element msdata:IsDataSet="true" name="NewDataSet">  
            <xs:complexType>  
              <xs:sequence>  
                <xs:element minOccurs="0" maxOccurs="unbounded" name="NewTable">  
                  <xs:complexType>  
                    <xs:sequence>  
                      <xs:element minOccurs="0" name="Employee_ID" type="xs:int" />   
                    </xs:sequence>  
                  </xs:complexType>  
                </xs:element>  
              </xs:sequence>  
            </xs:complexType>  
          </xs:element>  
        </xs:schema>  
        <diffgr:diffgram xmlns:diffgr="urn:schemas-microsoft-com:xml-diffgram-v1">  
          <NewDataSet xmlns="">  
            <NewTable>  
              <Employee_ID>10006</Employee_ID>  
            </NewTable>  
          </NewDataSet>  
        </diffgr:diffgram>  
      </DataSet>  
    </PolledData>  
  </Polling>  
  

  上記の応答には、2 つのデータ セットが含まれています。 最初のデータ セットには、SELECT ステートメントの応答が含まれています。 SELECT ステートメントは、Employee テーブル内のすべてのレコードを選択します。 2 番目のデータ セットは、ADD_EMP_DETAILS ストアド プロシージャ用です。 このストアド プロシージャは、Employee テーブルにレコードを追加し、新しいレコードの従業員 ID を返します。

  注

  MOVE_EMP_DATA ストアド プロシージャは結果セットを返しません。 そのため、応答メッセージに対応するデータ セットはありません。

• アダプターは、 PollDataAvailableStatement をもう一度実行すると、ADD_EMP_DETAILS ストアド プロシージャによって挿入された 1 つのレコードを検索します。 その後、アダプターは 、PollingStatement バインディング プロパティに指定されている 3 つのステートメントをすべて実行します。 今回は、SQL Server からの応答には、SELECT ステートメントのレコードと、ADD_EMP_DETAILS ストアド プロシージャのレコードが 1 つだけ含まれます。 それ以降のすべてのポーリングでは、同様の応答が返されます。

ベスト プラクティス

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

こちらもご覧ください

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