BizTalk Serverを使用して、SQL Serverから厳密に型指定されたポーリング ベースのデータ変更メッセージを受信する
SQL Serverから厳密に型指定されたポーリング メッセージを受信するように SQL アダプターを構成できます。 データベースをポーリングするためにアダプターが実行するポーリング ステートメントを指定できます。 ポーリング ステートメントには、SELECT ステートメント、または結果セットを返すストアド プロシージャを指定できます。
ポーリング メッセージ内の要素を他のスキーマにマップするシナリオでは、厳密に型指定されたポーリングを使用する必要があります。 マップするスキーマは、SQL Serverに対する別の操作の場合があります。 たとえば、ポーリング メッセージ内の特定の要素を、別のテーブルに対する挿入操作のスキーマにマップできます。 そのため、ポーリング メッセージの値は、挿入操作のパラメーターとして機能します。 より単純なシナリオでは、厳密に型指定されたポーリング メッセージのスキーマを、情報のみを格納するスキーマ ファイルにマップできます。
重要
1 つの BizTalk アプリケーションで複数のポーリング操作を行う場合は、接続 URI の一部として InboundID 接続プロパティを指定して一意にする必要があります。 一意の接続 URI を使用すると、同じデータベース、またはデータベース内の同じテーブルをポーリングする複数の受信ポートを作成できます。 詳細については、「 Biztalk Server を使用して SQL から複数の受信ポート間でポーリング メッセージを受信する」を参照してください。
アダプターが厳密に型指定されたポーリングをサポートする方法の詳細については、「 ポーリングのサポート」を参照してください。 厳密に型指定されたポーリングのメッセージ スキーマの詳細については、「 ポーリングおよび TypedPolling 操作のメッセージ スキーマ」を参照してください。
このトピックで厳密に型指定されたポーリングを示す方法
このトピックでは、厳密に型指定されたポーリングを使用して、ポーリング メッセージを別のスキーマにマップする方法について説明します。 このトピックでは、BizTalk プロジェクトを作成し、 TypedPolling 操作のスキーマを生成する方法について説明します。 TypedPolling 操作のスキーマを生成する前に、次の操作を行う必要があります。
接続 URI の一部として InboundID を指定する必要があります。
PollingStatement バインド プロパティのポーリング ステートメントを指定する必要があります。
ポーリング ステートメントの一部として、次の操作を実行します。
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
TypedPolling 操作のスキーマを生成するため、スキーマは厳密に型指定され、ポーリング メッセージに含まれるすべての要素が含まれます。
同じ BizTalk プロジェクトの一部として、別のスキーマ ファイル (EmployeeDetails.xsd など) を追加します。 EmployeeDetails.xsd のスキーマは次のようになります。
<?xml version="1.0" encoding="utf-16" ?>
<xs:schema xmlns:b="http://schemas.microsoft.com/BizTalk/2003" xmlns="http://Typed_Polling.EmployeeDetails" elementFormDefault="qualified" targetNamespace="http://Typed_Polling.EmployeeDetails" xmlns:xs="http://www.w3.org/2001/XMLSchema">
<xs:element name="EmployeeDetails">
<xs:complexType>
<xs:sequence>
<xs:element name="Employee_Info" type="xs:string" />
<xs:element name="Employee_Profile" type="xs:string" />
<xs:element name="Employee_Performance" type="xs:string" />
</xs:sequence>
</xs:complexType>
</xs:element>
</xs:schema>
また、BizTalk マッパーをプロジェクトに追加して、Employee テーブル (ポーリング メッセージとして受信) の要素を EmployeeDetails.xsd スキーマの要素にマップします。 マップの一部として、ポーリング メッセージから 1 つ以上の要素を結合し、EmployeeDetails スキーマの 1 つの要素にマップします。 これを行うには、 文字列連結 Functoid を使用します。
最後に、BizTalk プロジェクトの一部として、EmployeeDetails.xsd スキーマに準拠するファイルが FILE 送信ポートにドロップされます。
SQL アダプターのバインド プロパティを使用して型指定されたポーリングを構成する
次の表は、データ変更メッセージを受信するようにアダプターを構成するために使用する SQL アダプターのバインド プロパティをまとめたものです。 BizTalk Server管理コンソールで受信ポートを構成する際には、PollingStatement バインド プロパティ以外に、このセクションに記載されている他のすべてのバインド プロパティが必要です。 TypedPolling 操作のスキーマを生成する前に、PollingStatement バインド プロパティを指定する必要があります。
Note
型指定されたポーリングでは、スキーマの生成中に PollingStatement の biding プロパティを指定する必要があります。 スキーマの生成中に、他のバインド プロパティも指定することもできますが、必須ではありません。 バインド プロパティを指定した場合、アダプター サービス アドインを使用してメタデータ生成の一部として生成されるポート バインド ファイルには、バインド プロパティに指定した値も含まれます。 このバインド ファイルは、後で BizTalk Server 管理コンソールにインポートして、バインド プロパティが既に設定されている WCF-custom または WCF-SQL 受信ポートを作成できます。 バインド ファイルを使用してポートを作成する方法の詳細については、「 SQL アダプターを使用するようにポート バインド ファイルを使用して物理ポート バインドを構成する」を参照してください。
Binding プロパティ | 説明 |
---|---|
InboundOperationType | ポーリング、TypedPolling、または通知の受信操作を実行するかどうかを指定します。 既定値は ポーリングです。 厳密に型指定されたポーリング メッセージを受信するには、これを TypedPolling に設定します。 |
PolledDataAvailableStatement | ポーリングに使用できるデータがあるかどうかを判断するためにアダプターが実行する SQL ステートメントを指定します。 SQL ステートメントは、行と列で構成される結果セットを返す必要があります。 行が使用可能な場合にのみ、 PollingStatement バインディング プロパティに指定された SQL ステートメントが実行されます。 |
PollingIntervalInSeconds | SQL アダプターが PolledDataAvailableStatement バインディング プロパティに指定されたステートメントを実行する間隔を秒単位で指定します。 既定値は 30 秒です。 ポーリング間隔は、連続するポーリング間の時間間隔を決定します。 ステートメントが指定された期間内に実行された場合、アダプターはその間隔の残りの時間を待機します。 |
PollingStatement | SQL Server データベース テーブルをポーリングする SQL ステートメントを指定します。 ポーリング ステートメントには、単純な SELECT ステートメントまたはストアド プロシージャを指定できます。 既定値は null です。 ポーリングを有効にするには、 PollingStatement の値を指定する必要があります。 ポーリング ステートメントは、ポーリングに使用できるデータがある場合にのみ実行されます。これは、 PolledDataAvailableStatement バインディング プロパティによって決定されます。 セミコロンで区切られた任意の数の SQL ステートメントを指定できます。 大事な:TypedPolling の場合は、メタデータを生成する前に、このバインド プロパティを指定する必要があります。 |
PollWhileDataFound | ポーリング対象のテーブルでデータが使用可能な場合に、SQL アダプターがポーリング間隔を無視し、 PolledDataAvailableStatement バインディング プロパティに対して指定された SQL ステートメントを継続的に実行するかどうかを指定します。 テーブルに使用可能なデータがない場合、アダプターは、指定されたポーリング間隔で SQL ステートメントを実行するように戻ります。 既定値は falseです。 |
これらのプロパティの詳細については、「BizTalk Adapter for SQL Server adapter Binding Properties」を参照してください。 SQL アダプターを使用してSQL Serverをポーリングする方法の詳細については、詳細を参照してください。
SQL Server データベースから厳密に型指定されたデータ変更メッセージを受信する方法
BizTalk Serverで SQL アダプターを使用してSQL Server データベースに対して操作を実行するには、「Sql アダプターを使用して BizTalk アプリケーションを開発するための構成要素」で説明されている手順に従います。 厳密に型指定されたデータ変更メッセージを受信するようにアダプターを構成するには、次のタスクを実行します。
BizTalk プロジェクトを作成し、 TypedPolling 操作のスキーマを生成します。 スキーマの生成中に 、InboundID 接続プロパティと PollingStatement バインディング プロパティを指定する必要があります。 たとえば、受信 ID が指定された接続 URI は次のようになります。
mssql://mysqlserver//mysqldatabase?InboundID=mydatabaseId
SQL Server データベースからメッセージを受信するためのメッセージを BizTalk プロジェクトに作成します。
SQL Server データベースからメッセージを受信し、フォルダーに保存するオーケストレーションを作成します。
スキーマ (EmployeeDetails.xsd など) を BizTalk プロジェクトに追加します。
BizTalk マッパーを追加して、ポーリング メッセージのスキーマを EmployeeDetails.xsd スキーマにマップします。
BizTalk プロジェクトをビルドして展開します。
物理送受信ポートを作成して BizTalk アプリケーションを構成します。
重要
受信ポーリングのシナリオでは、常に一方向の WCF-Custom または WCF-SQL 受信ポートを構成する必要があります。 双方向 WCF-Custom または WCF-SQL 受信ポートは、受信操作ではサポートされていません。
BizTalk アプリケーションを起動します。
このトピックでは、これらのタスクを実行する手順について説明します。
このトピックに基づくサンプル
このトピックに基づく TypedPolling のサンプルは、BizTalk アダプター パックで提供されています。 詳細については、「 SQL アダプターのサンプル」を参照してください。
スキーマの生成
TypedPolling 操作のスキーマを生成する必要があります。 スキーマの生成方法の詳細については、「SQL アダプターを使用した Visual Studio でのSQL Server操作のメタデータの取得」を参照してください。 スキーマを生成するときは、次のタスクを実行します。
接続 URI を指定するときに 、InboundID 接続プロパティを指定します。 このトピックでは、 InboundID を Employee として指定できます。 接続 URI の詳細については、「SQL Server接続 URI を作成する」を参照してください。
PollingStatement バインド プロパティの値を指定します。 このバインディング プロパティの詳細については、「BizTalk Adapter for SQL Server adapter Binding Properties」を参照してください。
バインド プロパティを指定する方法については、「 SQL アダプターのバインド プロパティを構成する」を参照してください。
コントラクトの種類を [サービス (受信操作)] として選択します。
TypedPolling 操作のスキーマを生成します。
メッセージとメッセージの種類を定義する
前に生成したスキーマでは、オーケストレーション内のメッセージに必要な "型" について説明します。 通常、メッセージは変数であり、対応するスキーマによって定義される型です。 スキーマが生成されたら、BizTalk プロジェクトのオーケストレーション ビューからメッセージにリンクする必要があります。
このトピックでは、SQL Server データベースからメッセージを受信するメッセージを 1 つ作成する必要があります。
メッセージを作成してスキーマにリンクするには、次の手順を実行します。
メッセージを作成し、スキーマにリンクする
BizTalk プロジェクトにオーケストレーションを追加します。 ソリューション エクスプローラーから BizTalk プロジェクト名を右クリックし、[追加] をポイントして、[新しい項目] をクリックします。 BizTalk オーケストレーションの名前を入力し、[ 追加] をクリックします。
BizTalk プロジェクトがまだ開いていない場合は、オーケストレーション ビュー ウィンドウを開きます。 [ 表示] をクリックし、[ その他のウィンドウ] をポイントして、[ オーケストレーション ビュー] をクリックします。
オーケストレーション ビューで、[メッセージ] を右クリックし、[新しいメッセージ] をクリックします。
新しく作成したメッセージを右クリックし、[ プロパティ ウィンドウ] を選択します。
Message_1の [プロパティ] ウィンドウで、次の操作を行います。
プロパティ 目的 識別子 「 PollingMessage」と入力します。 メッセージ型 ドロップダウン リストから [ スキーマ] を展開し、[ Typed_Polling.TypedPolling_Employee.TypedPolling] を選択します。 ここで、Typed_Polling は BizTalk プロジェクトの名前です。 TypedPolling_Employee は、 TypedPolling 操作に対して生成されるスキーマです。
オーケストレーションを設定する
SQL Server データベースからポーリング ベースのデータ変更メッセージを受信するためにBizTalk Serverを使用するには、BizTalk オーケストレーションを作成する必要があります。 このオーケストレーションでは、アダプターは指定されたポーリング ステートメントのポーリング メッセージを受信します。 次に、BizTalk マッパーはポーリング メッセージ スキーマを EmployeeDetails.xsd スキーマにマップします。 その後、マップされたメッセージは FILE の場所に保存されます。 SQL Server データベースから厳密に型指定されたポーリング メッセージを受信するための一般的なオーケストレーションには、次のものが含まれます。
SQL Serverからメッセージを受信し、それぞれ FILE ポートに送信する図形を受信および送信します。
SQL Serverからメッセージを受信する一方向の受信ポート。
重要
受信ポーリングシナリオでは、常に一方向の受信ポートを構成する必要があります。 双方向の受信ポートは、受信操作ではサポートされていません。
SQL Server データベースからフォルダーにポーリング応答を送信する一方向送信ポート。
ポーリング メッセージのスキーマを他のスキーマにマップする BizTalk マッパー。
サンプル オーケストレーションは次のようになります。
メッセージ図形を追加する
メッセージ図形ごとに次のプロパティを指定してください。 [図形] 列に表示される名前は、前述のオーケストレーションに表示されるメッセージ図形の名前です。
図形 | 図形の種類 | プロパティ |
---|---|---|
ReceiveMessage | 受信 | - 名前を ReceiveMessage に設定する - アクティブ化を True に設定する |
SaveMessage | Send | - 名前を SaveMessage に設定する |
ポートの追加
論理ポートごとに次のプロパティを指定してください。 [ポート] 列に表示される名前は、オーケストレーションに表示されるポートの名前です。
Port | プロパティ |
---|---|
SQLReceivePort | - 識別子を SQLReceivePort に設定する - 型を SQLReceivePortType に設定する - 通信パターンを一方向に設定する - 通信方向を受信に設定する |
SaveMessagePort | - 識別子を SaveMessagePort に設定する - Type を SaveMessagePortType に設定する - 通信パターンを一方向に設定する - [通信の方向] を [送信] に設定する |
アクション 図形のメッセージを入力し、ポートに接続する
次の表では、アクション図形のメッセージを指定し、メッセージをポートにリンクするために設定するプロパティとその値を指定します。 [図形] 列に表示される名前は、前述のオーケストレーションに表示されるメッセージ図形の名前です。
図形 | プロパティ |
---|---|
ReceiveMessage | メッセージを PollingMessage に設定する 操作を SQLReceivePort.TypedPolling.Request に設定する |
SaveMessage | メッセージを PollingMessage に設定する 操作を SaveMessagePort.TypedPolling.Request に設定する |
これらのプロパティを指定すると、メッセージの図形とポートが接続されます。
BizTalk マッパーを追加する
ポーリング メッセージ スキーマを EmployeeDetails.xsd スキーマにマップするには、BizTalk マッパーをオーケストレーションに追加する必要があります。 BizTalk Server管理コンソールでは、このマッパーを使用して、ポーリング メッセージのスキーマを EmployeeDetails.xsd スキーマにマップします。
BizTalk マッパーを BizTalk プロジェクトに追加します。 BizTalk プロジェクトを右クリックし、[ 追加] をポイントして、[ 新しい項目] をクリックします。
[ 新しい項目の追加 ] ダイアログ ボックスの左側のウィンドウで、[ マップ ファイル] を選択します。 右側のウィンドウで、[マップ] を選択 します。 マップの名前を指定します (例:
MapSchema.btm
)。 [追加] をクリックします。[ソース スキーマ] ウィンドウで、[ ソース スキーマを開く] をクリックします。
[ BizTalk Type Picker ] ダイアログ ボックスで、プロジェクト名を展開し、[ スキーマ] を展開して、ポーリング メッセージのスキーマを選択します。 このトピックでは、[Typed_Polling.TypedPolling_Employee] を選択します。 [OK] をクリックします。
[ ソース スキーマのルート ノード ] ダイアログ ボックスで、[TypedPolling] を選択し、[OK] をクリック します。
[宛先スキーマ] ウィンドウで、[ 宛先スキーマを開く] をクリックします。
[BizTalk の種類の選択] ダイアログ ボックスで、プロジェクト名を展開し、[スキーマ] を展開して、EmployeeDetails のスキーマを選択します。 このトピックでは、[Typed_Polling.EmployeeDetails] を選択します。 [OK] をクリックします。
ポーリング メッセージのソース スキーマで、TypedPollingResultSet0 ノードと後続のノードを展開して、ポーリング メッセージで返される要素を確認します。 宛先スキーマで、EmployeeDetails ノードを展開して、スキーマのさまざまな要素を確認します。 このトピックでは、次のようにスキーマをマップする必要があります。
ソース スキーマのEmployee_IDと名前は、移行先スキーマのEmployee_Infoにマップする必要があります。
ソース スキーマの指定とJob_Descriptionは、宛先スキーマのEmployee_Profileにマップする必要があります。
ソース スキーマの評価と給与は、移行先スキーマのEmployee_Performanceにマップする必要があります。
ソース スキーマ内の複数のノードを結合し、それらを宛先スキーマの 1 つのノードにマップするには、 String Concatenate Functoid を使用する必要があります。 UI ガイダンスと開発者 API 名前空間リファレンスの詳細。
文字列連結 Functoid を使用するには:
ツールボックスから[文字列連結]Functoid をドラッグし、Mapper グリッドにドロップします。
ソース スキーマの Employee_ID 要素と Name 要素を Functoid に接続します。
functoid を宛先スキーマの Employee_Info 要素に接続します。
マップするすべての要素に対して、次の手順を繰り返します。 完成したマップは次のようになります。
マップする
マップを保存します。
オーケストレーションは、マッパーを作成した後に完了します。 BizTalk ソリューションをビルドし、BizTalk Serverに展開する必要があります。 詳細については、「オーケストレーションの ビルドと実行」を参照してください。
BizTalk アプリケーションを構成する
BizTalk プロジェクトを展開すると、前に作成したオーケストレーションが、BizTalk Server管理コンソールの [オーケストレーション] ウィンドウの下に一覧表示されます。 アプリケーションを構成するには、BizTalk Server管理コンソールを使用する必要があります。 チュートリアルについては、「 チュートリアル: 基本的な BizTalk アプリケーションの展開」を参照してください。
アプリケーションの構成には、次の作業が含まれます。
アプリケーションのホストの選択。
オーケストレーションで作成したポートを、BizTalk Server管理コンソールの物理ポートにマッピングします。 このオーケストレーションでは、次の操作を行う必要があります。
物理 WCF-Custom または WCF-SQL の一方向受信ポートを定義します。 このポートは、ポートに指定したポーリング ステートメントを使用して、SQL Server データベースをポーリングします。 ポートを作成する方法については、「 SQL アダプターへの物理ポート バインドを手動で構成する」を参照してください。 受信ポートには、次のバインド プロパティを指定してください。
重要
接続 URI の一部として InboundID を指定してください。 受信 ID は、スキーマの生成時に指定したのと同じである必要があります。
重要
デザイン時にバインド プロパティを指定した場合は、この手順を実行する必要はありません。 このような場合は、アダプター サービスアドインによって作成されたバインド ファイルをインポートすることで、必要なバインド プロパティを設定して、WCF-custom または WCF-SQL 受信ポートを作成できます。 詳細については、「 SQL アダプターを使用するようにポート バインド ファイルを使用して物理ポート バインドを構成する」を参照してください。
Binding プロパティ 値 InboundOperationType これを TypedPolling に設定してください。 PolledDataAvailableStatement スキーマの生成時に指定したのと同じ 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 Adapter Binding Properties」を参照してください。
Note
SQL アダプターを使用して受信操作を実行するときに、トランザクション分離レベルとトランザクション タイムアウトを構成することをお勧めします。 これを行うには、WCF-Custom または WCF-SQL 受信ポートの構成中にサービスの動作を追加します。 サービスの動作を追加する方法については、「SQL を使用して トランザクション分離レベルとトランザクション タイムアウトを構成する」を参照してください。
アダプターがメッセージをドロップする FILE 送信ポートを定義します。 この送信ポートでは、オーケストレーションで作成したマップも使用して、ポーリング メッセージを EmployeeDetails.xsd スキーマに準拠するメッセージにマップします。 マップを使用するように FILE 送信ポートを構成するには、次の手順を実行します。
FILE 送信ポートを作成します。
[送信ポートのプロパティ] ダイアログ ボックスの左側のウィンドウで、[ 送信マップ] をクリックします。 右側のウィンドウで、[ マップ ] 列の下のフィールドをクリックし、ドロップダウンから [MapSchema] を選択します。 [OK] をクリックします。
に送信マップを構成する
アプリケーションを起動する
SQL Server データベースからメッセージを受信するには、BizTalk アプリケーションを起動する必要があります。 BizTalk アプリケーションを起動する手順については、「オーケストレーションを 開始する方法」を参照してください。
この段階で、次のことを確認します。
PollingStatement バインディング プロパティに指定されたステートメントを使用してSQL Server データベースをポーリングする、WCF-Custom または WCF-SQL の一方向受信ポートが実行されています。
ポーリング メッセージを EmployeeDetails スキーマにマップする FILE 送信ポートが実行されています。
操作の BizTalk オーケストレーションが実行されています。
操作を実行する
アプリケーションを実行すると、同じ順序で次の一連のアクションが実行されます。
アダプターは、Employee テーブルで PolledDataAvailableStatement を実行し、テーブルにポーリング用のレコードがあることを判断します。
アダプターはポーリング ステートメントを実行します。 ポーリング ステートメントは SELECT ステートメントとストアド プロシージャで構成されるため、アダプターはすべてのステートメントを 1 つずつ実行します。
アダプターは、まず、Employee テーブル内のすべてのレコードを返す SELECT ステートメントを実行します。
次に、アダプターは、Employee テーブルから EmployeeHistory テーブルにすべてのデータを移動するMOVE_EMP_DATAストアド プロシージャを実行します。 このストアド プロシージャは値を返しません。
その後、アダプターは、1 つのレコードを Employee テーブルに追加するADD_EMP_DETAILS ストアド プロシージャを実行します。 このストアド プロシージャは、挿入されたレコードの従業員 ID を返します。
ポーリング ステートメントが実行され、メッセージが受信されると、ポーリング メッセージは FILE 送信ポートに送信されます。 ここでは、送信ポートで構成された送信マップ (MapSchema) は、ポーリング メッセージを EmployeeDetails スキーマにマップし、メッセージをファイルの場所にドロップします。 メッセージは次のようになります。
<?xml version="1.0" encoding="utf-8" ?> <EmployeeDetails xmlns="http://Typed_Polling.EmployeeDetails"> <Employee_Info>10751John</Employee_Info> <Employee_Profile>TesterManagesTesting</Employee_Profile> <Employee_Performance>100000</EmployeePerformance> </EmployeeDetails>
前の応答では、Employee_Info 要素に従業員 ID (10751) と従業員名 (John) の組み合わせが含まれていることに気付くことができます。 他の要素には、オーケストレーションの一部として作成したマッパーでマップされた組み合わせも含まれます。
Note
SQL アダプターは、BizTalk Server管理コンソールから受信ポートを明示的に無効にするまでポーリングを続行します。
ベスト プラクティス
BizTalk プロジェクトを展開して構成したら、構成設定をバインド ファイルと呼ばれる XML ファイルにエクスポートできます。 バインド ファイルを生成したら、ファイルから構成設定をインポートして、同じオーケストレーションの送信ポートと受信ポートを作成する必要がないようにすることができます。 バインド ファイルの詳細については、「アダプター バインドを 再利用する」を参照してください。