ストアド プロシージャを使用して Oracle データベースを継続的にポーリングすることで、定期的なデータ変更メッセージを受信するように Oracle E-Business アダプターを構成できます。 Oracle データベースをポーリングするためにアダプターが定期的に実行するポーリング ステートメントとしてストアド プロシージャを指定できます。
ポーリングを有効にするには、受信ポートWCF-CustomまたはWCF-OracleEBSに特定のバインドプロパティを指定する必要があります。 アダプターがポーリングをサポートする方法の詳細については、「 ポーリングを使用した受信呼び出しのサポート」を参照してください。 ポーリング操作用の SOAP メッセージの構造については、「ポーリング操作の メッセージ スキーマ」を参照してください。
Oracle E-Business Adapter のバインド プロパティを使用したポーリング操作の構成
次の表は、データ変更メッセージを受信するようにアダプターを構成するために使用する Oracle E-Business アダプター バインド プロパティをまとめたものです。 BizTalk Server 管理コンソールで WCF-Custom または WCF-OracleEBS 受信ポートを構成するときに、これらのバインド プロパティを指定する必要があります。
| バインディングプロパティ | 説明 |
|---|---|
| InboundOperationType | ポーリングまたは通知の受信操作を実行するかどうかを指定します。 既定値は ポーリングです。 |
| ポーリングデータの利用可能声明 | ポーリングに使用できるデータがあるかどうかを判断するためにアダプターが実行する SQL ステートメントを指定します。 レコードが使用可能な場合にのみ、 PollingInput バインディング プロパティに指定したストアド プロシージャが実行されます。 |
| PollingInterval | Oracle E-Business アダプターが PolledDataAvailableStatement バインディング プロパティに指定されたステートメントを実行する間隔を秒単位で指定します。 既定値は 30 秒です。 ポーリング間隔は、連続するポーリング間の時間間隔を決定します。 ステートメントが指定された期間内に実行された場合、アダプターはその間隔の残りの時間スリープ状態になります。 |
| PollingInput | ポーリング ステートメントを指定します。 ストアド プロシージャを使用してポーリングするには、このバインド プロパティの要求メッセージ全体を指定する必要があります。 要求メッセージは、ストアド プロシージャを送信操作として呼び出すためにアダプターに送信するメッセージと同じである必要があります。 既定値は null です。 ポーリングを有効にするには、 PollingInput バインド プロパティの値を指定する必要があります。 ポーリング ステートメントは、 PolledDataAvailableStatement バインディング プロパティによって決定されるポーリングに使用できるデータがある場合にのみ実行されます。 |
| PollingAction | ポーリング操作のアクションを指定します。 アダプター サービス アドインを使用して、操作に対して生成したメタデータから、特定の操作のポーリング アクションを決定できます。 |
| 投票後声明 | PollingInput バインディング プロパティで指定されたステートメントが実行された後に実行されるステートメント ブロックを指定します。 |
| PollWhileDataFound | ポーリング対象のテーブルでデータが使用可能な場合に、Oracle E-Business アダプターがポーリング間隔を無視し、ポーリング ステートメントを継続的に実行するかどうかを指定します。 テーブルにデータが存在しない場合、アダプターは、指定されたポーリング間隔でポーリング ステートメントを実行するように戻ります。 既定値は false です。 |
これらのプロパティの詳細については、「 BizTalk Adapter for Oracle E-Business Suite Binding Properties」を参照してください。 Oracle E-Business アダプターを使用して Oracle データベースをポーリングする方法の詳細については、次のセクションを参照してください。
このトピックがポーリングを説明する方法
このトピックでは、Oracle E-Business アダプターがストアド プロシージャを使用したデータ変更メッセージの受信をサポートする方法を示すために、BizTalk プロジェクトを作成し、Oracle データベースのポーリングに使用するストアド プロシージャのスキーマを生成します。 このトピックでは、GET_ACTIVITYS ストアド プロシージャを使用して ACCOUNTACTIVITY テーブルをポーリングします。 このストアド プロシージャは、ACCOUNT_PKG パッケージで使用できます。 サンプルに付属の SQL スクリプトを実行して、これらのオブジェクトをデータベースに作成できます。
注
このトピックのオーケストレーションでは、ACCOUNTACTIVITY テーブルをポーリングします。これは、サンプルで提供されるスクリプトを実行して作成されたベース データベース テーブルです。 インターフェイス テーブルを含む他のテーブルをポーリングするには、このトピックの説明と同様の手順を実行する必要があります。
ポーリング操作を示すために、次の操作を行います。
PolledDataAvailableStatement バインディング プロパティの SELECT ステートメントを指定して、ポーリング対象のテーブル (ACCOUNTACTIVITY) にデータが含まれている場所を決定します。 この例では、このバインド プロパティを次のように設定できます。
SELECT COUNT (*) FROM ACCOUNTACTIVITYこれにより、ACCOUNTACTIVITY テーブルに一部のレコードがある場合にのみ、アダプターでポーリング ステートメントが実行されます。
PollingInput バインディング プロパティの一部として要求メッセージを指定して、GET_ACTIVITYSストアド プロシージャを実行します。 このストアド プロシージャは ACCOUNTACTIVITY テーブル内のすべての行を取得し、アダプターから応答メッセージを取得します。
PostPollStatement バインディング プロパティの一部として PL/SQL ブロックを実行します。 このステートメントは、ACCOUNTACTIVITY テーブルからデータベース内の別のテーブルにすべてのデータを移動します。 これが発生すると、次に PollingInput が実行されると、データはフェッチされないため、GET_ACTIVITYSストアド プロシージャは空の応答メッセージを返します。
ACCOUNTACTIVITY テーブルにさらにデータが追加されるまで、空の応答メッセージを取得し続けます。 そのため、ACCOUNTACTIVITY テーブルに新しいレコードを再入力する必要があります。 これを行うには、サンプルで提供されているmore_activity_data.sql スクリプトを実行します。 このスクリプトを実行すると、次のポーリング操作によって、テーブルに挿入された新しいレコードが取得されます。
Oracle からデータ変更メッセージを受信する方法
BizTalk Server で Oracle E-Business アダプターを使用して Oracle データベースに対して操作を実行するには、「 Oracle E-Business Suite アプリケーションを作成するための構成要素」で説明されている次の手順を実行します。 ストアド プロシージャを使用して Oracle データベースをポーリングするようにアダプターを構成するには、次のタスクを実行します。
BizTalk プロジェクトを作成し、ポーリングに使用するストアド プロシージャのスキーマを生成します。
Oracle データベースからメッセージを受信するためのメッセージを BizTalk プロジェクトに作成します。
Oracle データベースからメッセージを受信し、フォルダーに保存するオーケストレーションを作成します。
BizTalk プロジェクトをビルドして展開します。
物理送受信ポートを作成して BizTalk アプリケーションを構成します。
Von Bedeutung
受信ポーリングのシナリオでは、常に一方向の受信ポートを構成する必要があります。 双方向の受信ポートは、受信操作ではサポートされていません。
BizTalk アプリケーションを起動します。
このトピックでは、これらのタスクを実行する手順について説明します。
このトピックに基づくサンプル
このトピックに基づくサンプル PollingUsingStoredProc も BizTalk アダプター パックで提供されています。 詳細については、「 サンプル」を参照してください。
スキーマの生成
GET_ACTIVITYS操作のスキーマを生成する必要があります。 Consume Adapter Service アドインを使用してスキーマを生成するときに、次のタスクを実行します。
コントラクトの種類として サービス (受信操作) を選択します。
GET_ACTIVITYS プロシージャのスキーマを生成します。
スキーマを生成する方法の詳細については、「 Oracle E-Business 操作のメタデータの参照、検索、および取得」を参照してください。
メッセージとメッセージの種類の定義
前に生成したスキーマでは、オーケストレーション内のメッセージに必要な "型" が記述されています。 通常、メッセージは変数であり、対応するスキーマによって定義される型です。 スキーマが生成されたら、BizTalk プロジェクトのオーケストレーション ビューからメッセージにリンクする必要があります。
このトピックでは、Oracle からメッセージを受信するメッセージを 1 つ作成する必要があります。
メッセージを作成し、スキーマにリンクするには、次の手順を実行します。
メッセージを作成し、スキーマにリンクするには
BizTalk プロジェクトにオーケストレーションを追加します。 ソリューション エクスプローラーで、BizTalk プロジェクト名を右クリックし、[ 追加] をポイントして、[ 新しい項目] をクリックします。 BizTalk オーケストレーションの名前を入力し、[ 追加] をクリックします。
まだ開いていない場合は、BizTalk プロジェクトのオーケストレーション ビュー ウィンドウを開きます。 [ 表示] をクリックし、[ その他のウィンドウ] をポイントし、[ オーケストレーション ビュー] をクリックします。
オーケストレーション ビューで、[メッセージ] を右クリックし、[新しいメッセージ] をクリックします。
新しく作成したメッセージを右クリックし、[ プロパティ ウィンドウ] を選択します。
Message_1の [プロパティ] ウィンドウで、次の操作を行います。
これを使用する 目的 識別子 「Receive」と入力します。 メッセージの種類 ドロップダウン リストから [ スキーマ] を展開し、 Polling.OracleEBSBindingSchema を選択します。 ポーリング は BizTalk プロジェクトの名前です。 OracleEBSBindingSchema は、 GET_ACTIVITYS ストアド プロシージャに対して生成される応答スキーマです。
大事な： ポーリングは一方向の操作であるため、アダプターによって生成されるスキーマには応答ノードが含まれていないため、スキーマにはルート ノードが 1 つだけ存在します。 メッセージの種類にこのようなスキーマを使用する場合は、生成されたスキーマのファイル名でスキーマを識別する必要があります。
たとえば、双方向操作のスキーマを作成する場合、名前OracleEBSBindingSchemaを持つスキーマ ファイル内のノードは、"要求" と "応答" のようになります。 要求スキーマにマップされるメッセージをオーケストレーションで作成する場合は、OracleEBSBindingSchema.Requestを探して一覧内のスキーマを識別できます。 ただし、ポーリング操作の場合、唯一のノードが "Poll" であるため、単一ノードのスキーマが <schemafilename>.< として一覧表示されないため、マップするスキーマを識別するのは簡単ではありません。rootnodename>。 代わりに、このようなスキーマはファイル名のみで一覧表示されます。 このような場合、スキーマを識別する唯一の方法は、OracleEBSBindingSchema などのスキーマ ファイル名によって行われます。コンシューム アダプター サービス アドインは、GET_ACTIVITYS ストアドプロシージャのインバウンドおよびアウトバウンドの両方の操作のスキーマを生成します。 受信操作のためにスキーマを次の目的で使用する必要があります。
オーケストレーションの一部として作成されたメッセージをマップします。
アクションを取得するには、実行時に PollingAction バインディング プロパティに指定する必要があります。
送信操作のスキーマを使用して、 PollingInput バインディング プロパティの一部として指定する必要がある要求メッセージを取得する必要があります。
オーケストレーションの設定
Oracle からポーリング ベースのデータ変更メッセージを受信するために BizTalk Server を使用するには、BizTalk オーケストレーションを作成する必要があります。 このオーケストレーションでは、要求メッセージを PollingInput バインド プロパティの一部として指定したストアド プロシージャを実行して、アダプターが応答を受信します。 ストアド プロシージャの応答メッセージは、FILE の場所に保存されます。 Oracle データベースをポーリングするための一般的なオーケストレーションには、次のものが含まれます。
Oracle からメッセージを受信し、それぞれ FILE ポートに送信する図形を受信および送信します。
Oracle データベースからメッセージを受信する一方向の受信ポート。
Von Bedeutung
受信ポーリングのシナリオでは、常に一方向の受信ポートを構成する必要があります。 双方向の受信ポートは、受信操作ではサポートされていません。
Oracle データベースからポーリング応答を送信する一方向送信ポート。
サンプル オーケストレーションは次のようになります。
メッセージ図形の追加
メッセージ図形ごとに次のプロパティを指定してください。 [図形] 列に一覧表示される名前は、先ほど説明したオーケストレーションに表示されるメッセージ図形の名前です。
| 形 | 図形の種類 | 特性 |
|---|---|---|
| メッセージ受信 | 受け取る | - 名前を ReceiveMessage に設定する - アクティブ化を True に設定する |
| メッセージを保存 | 送信 | - 名前を SaveMessage に設定する |
ポートの追加
論理ポートごとに次のプロパティを指定してください。 [ポート] 列に表示される名前は、オーケストレーションに表示されるポートの名前です。
| 港 / ポート | 特性 |
|---|---|
| OracleReceivePort | - 識別子を OracleReceivePort に設定する - 型を OracleReceivePortType に設定する - 通信パターンを一方向に設定する - 通信方向を受信に設定する |
| SaveMessagePort | - 識別子を SaveMessagePort に設定する - 型を SaveMessagePortType に設定する - 通信パターンを一方向に設定する - 通信方向を送信に設定する |
アクション図形のメッセージを指定し、ポートに接続する
次の表では、アクション図形のメッセージを指定し、メッセージをポートにリンクするために設定するプロパティとその値を指定します。 [図形] 列に表示される名前は、前述のオーケストレーションに表示されるメッセージ図形の名前です。
| 形 | 特性 |
|---|---|
| メッセージ受信 | - メッセージを受信に設定する - 操作を OracleReceivePort.Polling.Request に設定する |
| メッセージを保存 | - メッセージを受信に設定する - SaveMessagePort.Polling.Request に操作を設定する |
これらのプロパティを指定すると、メッセージの図形とポートが接続され、オーケストレーションが完了します。
BizTalk ソリューションをビルドし、BizTalk Server に展開する必要があります。 詳細については、「オーケストレーションの ビルドと実行」を参照してください。
BizTalk アプリケーションの構成
BizTalk プロジェクトを展開すると、前に作成したオーケストレーションが BizTalk Server 管理コンソールの [ オーケストレーション ] ウィンドウの下に一覧表示されます。 BizTalk Server 管理コンソールを使用してアプリケーションを構成する必要があります。 チュートリアルについては、「 チュートリアル: 基本的な BizTalk アプリケーションの展開」を参照してください。
アプリケーションの構成には、次の作業が含まれます。
アプリケーションのホストの選択。
オーケストレーションで作成したポートを BizTalk Server 管理コンソールの物理ポートにマッピングします。 このオーケストレーションでは、次の操作を行う必要があります。
ハード ディスク上の場所と、BizTalk オーケストレーションが Oracle からメッセージを削除する対応する FILE ポートを定義します。 これらのメッセージは、受信ポートに指定したポーリング ステートメントに応答します。
物理 WCF-Custom または一方向の受信ポート WCF-OracleEBS 定義します。 このポートは Oracle データベースをポーリングします。 受信ポートを作成する方法については、「 Oracle E-Business アダプターへの物理ポート バインドを手動で構成する」を参照してください。 受信ポートには、次のバインド プロパティを指定してください。
バインディングプロパティ 価値 InboundOperationType これをポーリングに設定 します。 ポーリングデータの利用可能声明 この例では、このバインド プロパティを次の値に設定します。
SELECT COUNT (*) FROM ACCOUNTACTIVITY
これにより、ACCOUNTACTIVITY テーブルに一部のレコードがある場合にのみ、アダプターでポーリング ステートメントが実行されます。PollingAction GET_ACTIVITYS プロシージャの受信メッセージに対して生成されたスキーマからポーリング アクションを取得します。 この例では、このバインド プロパティを PollingPackageApis/APPS/ACCOUNT_PKG/GET_ACTIVITYS に設定します。 PollingInput このバインド プロパティでは、GET_ACTIVITYS ストアド プロシージャを呼び出す要求メッセージを指定します。 アダプター サービス アドインにより生成された送信操作用のスキーマから要求メッセージを取得できます。 このバインディング プロパティの入力として、XML メッセージ全体を指定する必要があります。 この例では、このバインド プロパティを次の値に設定します。
<GET_ACTIVITYS xmlns="http://schemas.microsoft.com/OracleEBS/2008/05/PackageApis/APPS/ACCOUNT_PKG"> <INRECS>OPEN ? FOR SELECT * FROM ACCOUNTACTIVITY</INRECS> </GET_ACTIVITYS>
GET_ACTIVITYS ストアド プロシージャは、入力 REF CURSOR をパラメーターとして受け取ります。投票後声明 すべてのデータを ACCOUNTACTIVITY テーブルから別のテーブルに移動するには、ポーリング後のステートメントを指定します。 この例では、このバインド プロパティを次の値に設定します。
BEGIN ACCOUNT_PKG.PROCESS_ACTIVITY(); END;さまざまなバインド プロパティの詳細については、「 BizTalk Adapter for Oracle E-Business Suite のバインド プロパティ」を参照してください。
Von Bedeutung
インターフェイス テーブルをポーリングする場合は、必要なバインド プロパティを指定してアプリケーション コンテキストを設定する必要があります。 アプリケーション コンテキストの設定の詳細については、「アプリケーション コンテキストの 設定」を参照してください。
注
Oracle E-Business アダプターを使用して受信操作を実行するときに、トランザクション分離レベルとトランザクション タイムアウトを構成することをお勧めします。 サービス動作を WCF-Custom または WCF-OracleEBS 受信ポートの構成時に追加します。 サービスの動作を追加する方法については、「 Oracle E-Business Suite でトランザクション分離レベルとトランザクション タイムアウトを構成する」を参照してください。
アプリケーションの起動
Oracle データベースをポーリングするには、BizTalk アプリケーションを起動する必要があります。 BizTalk アプリケーションを起動する手順については、「オーケストレーションを 開始する方法」を参照してください。
この段階で、次のことを確認します。
WCF-Custom または WCF-OracleEBS 一方向の受信ポートは、PollingInput バインド プロパティに指定されたストアド プロシージャを使用して Oracle をポーリングしており、稼働中です。
Oracle データベースからメッセージを受信する FILE 送信ポートが実行されています。
操作の BizTalk オーケストレーションが実行されています。
操作の実行
アプリケーションを実行すると、同じ順序で次の一連のアクションが実行されます。
アダプターは PolledDataAvailableStatement を実行し、 PollingInput バインディング プロパティに指定されたステートメントを実行するアダプターを示す正の値を返します。
アダプターは、 PollingInput バインド プロパティに指定されたGET_ACTIVITYS ストアド プロシージャを実行し、ACCOUNTACTIVITY テーブル内のすべての行を返します。 Oracle データベースからの応答は次のようになります。
<?xml version="1.0" encoding="utf-8" ?> <GET_ACTIVITYS xmlns="http://schemas.microsoft.com/OracleEBS/2008/05/PollingPackageApis/APPS/ACCOUNT_PKG"> <OUTRECS> <OUTRECSRecord xmlns="http://schemas.microsoft.com/OracleEBS/2008/05/ReferencedRecordTypes/APPS/ACCOUNT_PKG/GET_ACTIVITYS/APPS/GET_ACTIVITYS"> <TID>1</TID> <ACCOUNT>100001</ACCOUNT> <AMOUNT>500</AMOUNT> <DESCRIPTION /> <TRANSDATE>2008-06-21T15:52:19</TRANSDATE> <PROCESSED>n</PROCESSED> </OUTRECSRecord> <OUTRECSRecord xmlns="http://schemas.microsoft.com/OracleEBS/2008/05/ReferencedRecordTypes/APPS/ACCOUNT_PKG/GET_ACTIVITYS/APPS/GET_ACTIVITYS"> ...... ...... </OUTRECSRecord> ...... ...... </OUTRECS> </GET_ACTIVITYS>アダプターは、すべてのデータを ACCOUNTACTIVITY テーブルから別のテーブルに移動する、ポーリング後のステートメントを実行します。
ポーリング間隔の後、アダプターは 再度 PolledDataAvailableStatement を実行します。 ACCOUNTACTIVITY テーブルにはレコードがないため、 PolledDataAvailableStatement は正の値を返さないため、アダプターは PollingInput バインディング プロパティに指定されたステートメントを実行しません。 その結果、アダプター クライアントはポーリング メッセージを受け取りません。
一部のレコードが ACCOUNTACTIVITY テーブルに明示的に挿入されるまで、アダプター クライアントはそれ以上ポーリング メッセージを取得しません。 さらにレコードを挿入するには、サンプルで提供されているmore_activity_data.sql スクリプトを実行します。 このスクリプトを実行すると、次 に PolledDataAvailableStatement が実行されると、正の値が返されます。 その結果、アダプターはポーリング ステートメントを実行し、アダプター クライアントは再度ポーリング メッセージを受信します。
注
Oracle E-Business アダプターは、BizTalk Server 管理コンソールから受信ポートを明示的に無効にするまでポーリングを続行します。
ベスト プラクティス
BizTalk プロジェクトを展開して構成したら、構成設定をバインド ファイルと呼ばれる XML ファイルにエクスポートできます。 バインド ファイルを生成したら、同じオーケストレーションの送信ポートと受信ポートを作成する必要がないように、ファイルから構成設定をインポートできます。 バインド ファイルの詳細については、「 SQL アダプター バインドの再利用」を参照してください。