BizTalk Serverを使用した SQL での ExecuteReader、ExecuteScalar、または ExecuteNonQuery 操作
SQL アダプターは、ExecuteNonQuery、ExecuteReader、ExecuteScalar などの汎用SQL Server操作を公開します。 これらの操作を使用して、SQL Server データベースに対して任意の SQL ステートメントを実行できます。 これらの操作は、SQL ステートメントに対して取得する応答の種類によって異なります。 アダプターがこれらの操作をサポートする方法の詳細については、「 ExecuteNonQuery、ExecuteReader、ExecuteScalar 操作のサポート」を参照してください。
このトピックでは、BizTalk Serverを使用して SQL アダプターを使用して ExecuteReader 操作を実行する方法について説明します。 このトピックで説明されているのと同じ手順のセットに従って、 ExecuteNonQuery および ExecuteScalar 操作を 実行できます。
前提条件
SQL アダプターとSQL Serverを実行しているコンピューターで MSDTC を構成します。
SQL Server データベースで ExecuteReader 操作を呼び出す
BizTalk Serverで SQL アダプターを使用してSQL Server データベースに対して操作を実行するには、「Building blocks to develop BizTalk applications with the SQL adapter」で説明されている手続き型タスクが含まれます。 SQL Serverで ExecuteReader 操作を呼び出すには、次のタスクを実行します。
BizTalk プロジェクトを作成し、 ExecuteReader 操作のスキーマを生成します。
SQL Serverからメッセージを送受信するためのメッセージを BizTalk プロジェクトに作成します。
SQL Serverで操作を呼び出すオーケストレーションを作成します。
BizTalk プロジェクトをビルドして展開します。
物理送受信ポートを作成して BizTalk アプリケーションを構成します。
BizTalk アプリケーションを起動します。
このトピックでは、これらのタスクを実行する手順について説明します。
スキーマの生成
このトピックでは、BizTalk Serverで SQL アダプターを使用して、SQL Serverで ExecuteReader 操作を呼び出す方法について説明します。 ExecuteReader 操作は、任意の SQL ステートメントをパラメーターとして受け取り、その操作の結果セットを DataSet の配列として返します。 このトピックでは、 ExecuteReader 操作を使用してADD_EMP_DETAILSストアド プロシージャを実行する方法について説明します。 このストアド プロシージャは、Employee テーブルにレコードを追加し、新しく追加された従業員の ID を返します。 このトピックで使用されるテーブルとストアド プロシージャは、サンプルに用意されているスクリプトを実行して作成されます。 スクリプトの詳細については、「 SQL アダプターのサンプル」を参照してください。
ExecuteReader 操作を呼び出す方法を示すために、ExecuteReader 操作のスキーマが生成されます。 BizTalk プロジェクトを作成し、アダプター サービス アドインを使用してスキーマを生成する必要があります。 スキーマの生成方法の詳細については、「SQL アダプターを使用した Visual Studio でのSQL Server操作のメタデータの取得」を参照してください。
メッセージとメッセージの種類を定義する
先に生成したスキーマは、オーケストレーションのメッセージに求められる "型" を記述します。 通常、メッセージは変数であり、対応するスキーマによって定義される型です。 次に、オーケストレーションのメッセージを作成し、前の手順で生成したスキーマにリンクします。
BizTalk プロジェクトにオーケストレーションを追加します。 ソリューション エクスプローラーで、BizTalk プロジェクト名を右クリックし、[追加] をポイントして、[新しい項目] をクリックします。 BizTalk オーケストレーションの名前を入力し、[ 追加] をクリックします。
BizTalk プロジェクトの [オーケストレーションの種類] ウィンドウを開きます (まだ表示されていない場合)。 これを行うには、[ 表示] をクリックし、[ その他のウィンドウ] をポイントして、[ オーケストレーション ビュー] をクリックします。
[オーケストレーション ビュー] で、[ メッセージ] を右クリックし、[ 新しいメッセージ] をクリックします。
新しく作成したメッセージを右クリックし、[ プロパティ ウィンドウ] を選択します。
Message_1の [プロパティ] ウィンドウで、次の操作を行います。
プロパティ 目的 識別子 「 Request」と入力しますメッセージ型 ドロップダウン リストから [ スキーマ] を展開し、[ Execute_Reader.GenericOperation.ExecuteReader] を選択します。ここで、Execute_Readerは BizTalk プロジェクトの名前です。 GenericOperation は、 ExecuteReader 操作用に生成されるスキーマです。 手順 2 を繰り返して、新しいメッセージを作成します。 新しいメッセージの [プロパティ ] ウィンドウで、次の操作を行います。
プロパティ 目的 識別子 「 Response」と入力しますメッセージ型 ドロップダウン リストから [ スキーマ] を展開し、[ Execute_Reader.GenericOperation.ExecuteReaderResponse] を選択します。
オーケストレーションを設定する
SQL Serverで操作を実行するためにBizTalk Serverを使用する BizTalk オーケストレーションを作成します。 このオーケストレーションでは、定義された受信場所に要求メッセージをドロップします。 SQL アダプターはこのメッセージを使用し、SQL Serverに渡します。 SQL Serverからの応答は、別の場所に保存されます。 SQL Serverにメッセージを送信したり、応答を受信したりするには、[送受信] 図形を含める必要があります。 ExecuteReader 操作を呼び出すためのサンプル オーケストレーションは、次のようになります。
ExecuteReader 操作 を
メッセージ図形を追加する
メッセージ図形ごとに次のプロパティを入力します。 [図形] 列に表示される名前は、前述のオーケストレーションに表示されるメッセージ図形の名前です。
| 図形 | 図形の種類 | プロパティ |
|---|---|---|
| ReceiveMessage | 受信 | - 名前を ReceiveMessage に設定する - アクティブ化を True に設定する |
| SendMessage | Send | - 名前を SendMessage に設定する |
| ReceiveResponse | 受信 | - 名前を ReceiveResponse に設定する - アクティブ化を False に設定する |
| SendResponse | Send | - 名前を SendResponse に設定する |
ポートの追加
論理ポートごとに次のプロパティを指定してください。 [ポート] 列に表示される名前は、オーケストレーションに表示されるポートの名前です。
| Port | プロパティ |
|---|---|
| MessageIn | - 識別子を MessageIn に設定する - Type を MessageInType に設定する - 通信パターンを一方向に設定する - 通信方向を受信に設定する |
| LOBPort | - 識別子を LOBPort に設定する - 型を LOBPortType に設定する - 通信パターンを Request-Response に設定する - [通信の方向] を [送受信] に設定する |
| ResponseOut | - 識別子を ResponseOut に設定する - Type を ResponseOutType に設定する - 通信パターンを一方向に設定する - [通信の方向] を [送信] に設定する |
アクション図形のメッセージを入力し、ポートに接続する
次の表では、アクション図形のメッセージを指定し、メッセージをポートにリンクするために設定する必要があるプロパティとその値を指定します。 [図形] 列に表示される名前は、前述のオーケストレーションに表示されるメッセージ図形の名前です。
| 図形 | プロパティ |
|---|---|
| ReceiveMessage | - メッセージを要求に設定する - 操作を MessageIn.ExecuteReader.Request に設定する |
| SendMessage | - メッセージを要求に設定する - 操作を LOBPort.ExecuteReader.Request に設定する |
| ReceiveResponse | - [メッセージ] を [応答] に設定する - 操作を LOBPort.ExecuteReader.Response に設定する |
| SendResponse | - [メッセージ] を [応答] に設定する - 操作を ResponseOut.ExecuteReader.Request に設定する |
これらのプロパティを指定すると、メッセージの図形とポートが接続され、オーケストレーションが完了します。
BizTalk ソリューションをビルドし、BizTalk Serverに展開する必要があります。 詳細については、「オーケストレーションの ビルドと実行」を参照してください。
BizTalk アプリケーションを構成する
BizTalk プロジェクトを展開すると、前に作成したオーケストレーションが、BizTalk Server管理コンソールの [オーケストレーション] ウィンドウの下に一覧表示されます。 アプリケーションを構成するには、BizTalk Server管理コンソールを使用する必要があります。 アプリケーションの構成の詳細については、「 チュートリアル: 基本的な BizTalk アプリケーションの展開」を参照してください。
アプリケーションの構成には、次の作業が含まれます。
アプリケーションのホストの選択。
オーケストレーションで作成したポートを、BizTalk Server管理コンソールの物理ポートにマッピングします。 このオーケストレーションでは、次の操作を行う必要があります。
ハード ディスク上の場所と、要求メッセージを削除する対応するファイル ポートを定義します。 BizTalk オーケストレーションは要求メッセージを使用し、SQL Server データベースに送信します。
ハード ディスク上の場所と、BizTalk オーケストレーションがSQL Server データベースからの応答を含む応答メッセージを削除する対応するファイル ポートを定義します。
SQL Server データベースにメッセージを送信する物理 WCF-Custom または WCF-SQL 送信ポートを定義します。 また、送信ポートでアクションを指定する必要があります。 ポートを作成する方法については、「 SQL アダプターへの物理ポート バインドを手動で構成する」を参照してください。
Note
アダプター サービス BizTalk プロジェクト アドインを使用してスキーマを生成すると、ポートとそれらのポートに設定するアクションに関する情報を含むバインド ファイルも作成されます。 このバインド ファイルをBizTalk Server管理コンソールからインポートして、送信ポート (送信呼び出しの場合) または受信ポート (受信呼び出し用) を作成できます。 詳細については、「 SQL アダプターを使用するようにポート バインド ファイルを使用して物理ポート バインドを構成する」を参照してください。
アプリケーションを起動する
SQL Server データベースで ExecuteReader 操作を呼び出すための BizTalk アプリケーションを起動します。 BizTalk アプリケーションを起動する手順については、「オーケストレーションを 開始する方法」を参照してください。
この段階で、次のことを確認します。
オーケストレーションの要求メッセージを受信する FILE 受信ポートが実行されています。
オーケストレーションから応答メッセージを受信する FILE 送信ポートが実行されています。
SQL Server データベースにメッセージを送信する WCF-Custom または WCF-SQL 送信ポートが実行されています。
操作の BizTalk オーケストレーションが実行されています。
操作を実行する
アプリケーションを実行した後、FILE 受信場所に要求メッセージをドロップする必要があります。 要求メッセージのスキーマは、前に生成した ExecuteReader 操作のスキーマに準拠している必要があります。 たとえば、 ExecuteReader 操作を使用してADD_EMP_DETAILSを呼び出す要求メッセージは次のとおりです。
<ExecuteReader xmlns="http://schemas.microsoft.com/Sql/2008/05/GenericTableOp/">
<Query>EXEC ADD_EMP_DETAILS Tom,Manager,100000</Query>
</ExecuteReader>
SQL アダプターを使用して ExecuteReader 操作を呼び出すための要求メッセージ スキーマの詳細については、「ExecuteNonQuery、ExecuteReader、ExecuteScalar 操作のメッセージ スキーマ」を参照してください。
Note
タグ内では <Query> 、複数の SQL ステートメントをセミコロンで区切って指定できます。
オーケストレーションによってメッセージが使用され、SQL Server データベースに送信されます。 SQL Server データベースからの応答は、オーケストレーションの一部として定義されている他の FILE の場所に保存されます。 ExecuteReader 操作の応答には、DataSet 配列として結果セットが含まれています。 たとえば、上記の要求メッセージに対するSQL Server データベースからの応答は次のようになります。
<?xml version="1.0" encoding="utf-8" ?>
<ExecuteReaderResponse xmlns="http://schemas.microsoft.com/Sql/2008/05/GenericTableOp/">
<ExecuteReaderResult>
<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>10767</Employee_ID>
</NewTable>
</NewDataSet>
</diffgr:diffgram>
</DataSet>
</ExecuteReaderResult>
</ExecuteReaderResponse>
応答では、10767 は新しく作成された従業員の ID です。
ベスト プラクティス
BizTalk プロジェクトを展開して構成したら、構成設定をバインド ファイルと呼ばれる XML ファイルにエクスポートできます。 バインド ファイルを生成したら、ファイルから構成設定をインポートして、同じオーケストレーションの送信ポートや受信ポートなどの項目を作成する必要がないようにすることができます。 バインド ファイルの詳細については、「アダプター バインドを 再利用する」を参照してください。