WCF チャネルモデルで SELECT ステートメントを使用して Oracle E-Business Suite をポーリングする

2023-07-21

SELECT ステートメントを使用して Oracle E-Business Suite のインターフェイステーブル、インターフェイスビュー、テーブル、ビューを継続的にポーリングすることで、定期的なデータ変更メッセージを受信するように Oracle E-Business アダプターを構成できます。 SELECT ステートメントは、Oracle E-Business Suite をポーリングするためにアダプターが定期的に実行するポーリングステートメントとして指定できます。ポーリング後の PL/SQL コードブロックを指定して、ポーリングステートメントの実行後にアダプターを実行することもできます。

ポーリングを有効にするには、このトピックの説明に従って特定のバインドプロパティを指定する必要があります。アダプターがポーリングをサポートする方法の詳細については、「ポーリングを使用した受信呼び出しのサポート」を参照してください。

Oracle E-Business Suite アダプターバインディングプロパティを使ったポーリング操作の設定

次の表は、データ変更メッセージを受信するようにアダプターを構成するために使用する Oracle E-Business アダプターのバインドプロパティをまとめたものです。ポーリングアプリケーションの実行中に、これらのバインドプロパティを指定する必要があります。

バインディングプロパティ	説明
InboundOperationType	ポーリングまたは通知の受信操作を実行するかどうかを指定します。既定値はポーリングです。
ポーリングデータの利用可能声明	ポーリングに使用できるデータがあるかどうかを判断するためにアダプターが実行する SQL ステートメントを指定します。レコードが使用可能な場合にのみ、 PollingInput バインディングプロパティに指定した SELECT ステートメントが実行されます。
PollingInterval	Oracle E-Business アダプターが PolledDataAvailableStatement バインディングプロパティに指定されたステートメントを実行する間隔を秒単位で指定します。既定値は 30 秒です。ポーリング間隔は、連続するポーリング間の時間間隔を決定します。ステートメントが指定された期間内に実行された場合、アダプターはその間隔の残りの時間スリープ状態になります。
PollingInput	ポーリングステートメントを指定します。 SELECT ステートメントを使用してポーリングするには、このバインドプロパティに SELECT ステートメントを指定する必要があります。既定値は null です。ポーリングを有効にするには、 PollingInput バインドプロパティの値を指定する必要があります。ポーリングステートメントは、 PolledDataAvailableStatement バインディングプロパティによって決定されるポーリングに使用できるデータがある場合にのみ実行されます。
PollingAction	ポーリング操作のアクションを指定します。操作用に生成されたサービスインターフェイスからポーリングアクションを決定するには、「アダプターサービス参照の追加」Visual Studioプラグインを使用します。
投票後声明	PollingInput バインディングプロパティで指定されたステートメントが実行された後に実行されるステートメントブロックを指定します。
PollWhileDataFound	ポーリング対象のテーブルでデータが使用可能な場合に、Oracle E-Business アダプターがポーリング間隔を無視し、ポーリングステートメントを継続的に実行するかどうかを指定します。テーブルにデータが存在しない場合、アダプターは、指定されたポーリング間隔でポーリングステートメントを実行するように戻ります。既定値は false です。

これらのプロパティの詳細については、「 BizTalk Adapter for Oracle E-Business Suite バインディングプロパティの読み取り」を参照してください。 Oracle E-Business アダプターを使用して Oracle データベースをポーリングする方法の詳細については、このトピックの残りの部分を参照してください。

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

このトピックでは、Oracle E-Business アダプターが SELECT ステートメントを使用したデータ変更メッセージの受信をサポートする方法を示すために、アプリケーションオブジェクトライブラリ アプリケーションの MS_SAMPLE_EMPLOYEE インターフェイステーブルをポーリングします。このテーブルは、サンプルで提供されているcreate_apps_artifacts.sql スクリプトを実行して、Oracle E-Business Suite でこれらのオブジェクトを作成するときに作成されます。

ポーリング操作を示すために、次の操作を行います。

PolledDataAvailableStatement バインディングプロパティの SELECT ステートメントを指定して、ポーリング対象のインターフェイステーブル (MS_SAMPLE_EMPLOYEE) にデータが含まれている場所を判断します。この例では、このバインドプロパティを次のように設定できます。
```
SELECT COUNT (*) FROM MS_SAMPLE_EMPLOYEE  
```
これにより、MS_SAMPLE_EMPLOYEE インターフェイステーブルに一部のレコードがある場合にのみ、アダプターがポーリングステートメントを実行します。
PollingInput バインディングプロパティの SELECT ステートメントを指定します。このステートメントは、MS_SAMPLE_EMPLOYEE インターフェイステーブル内のすべての行を取得します。この例では、このバインドプロパティを次のように設定できます。
```
SELECT * FROM MS_SAMPLE_EMPLOYEE FOR UPDATE  
```
注

SELECT ステートメントで使用される FOR UPDATE 句の詳細については、「 Oracle E-Business Suite からポーリングベースのデータ変更メッセージを受信する」を参照してください。
PostPollStatement バインドプロパティの一部として DELETE ステートメントを指定します。この文は、MS_SAMPLE_EMPLOYEEインターフェーステーブルからすべてのデータを削除します。この例では、このバインドプロパティを次のように設定できます。
```
DELETE FROM MS_SAMPLE_EMPLOYEE  
```
この処理が行われると、PollingInput に指定された次のステートメントが実行されると、データは取得されません。
MS_SAMPLE_EMPLOYEE インターフェイステーブルにさらにデータが追加されるまで、ポーリングメッセージは取得されないため、MS_SAMPLE_EMPLOYEE インターフェイステーブルに新しいレコードを再入力する必要があります。これを行うには、サンプルで提供されているinsert_apps_data.sql スクリプトを実行します。このスクリプトを実行すると、次のポーリング操作によって、テーブルに挿入された新しいレコードが取得されます。

ポーリング要求メッセージの処理

アダプターは、あなたのコードに対してポーリング操作を実行し、Oracle E-Business Suite をポーリングします。つまり、アダプターは、IInputChannel チャネル図形を介して受信したポーリング要求メッセージを送信します。ポーリング要求メッセージには、 PollingInput バインディングプロパティで指定されたクエリの結果セットが含まれています。ポーリングメッセージは、次の 2 つの方法のいずれかで使用できます。

ノード値ストリーミングを使用してメッセージを使用するには、応答メッセージで WriteBodyContents メソッドを呼び出し、ノード値ストリーミングを実装する XmlDictionaryWriter を渡す必要があります。
ノードストリーミングを使用してメッセージを使用するには、応答メッセージで GetReaderAtBodyContents を呼び出して XmlReader を取得します。

このトピックで使用する例について

このトピックの例では、MS_SAMPLE_EMPLOYEE インターフェイステーブルをポーリングします。テーブルを生成するスクリプトがサンプルと共に提供されます。サンプルの詳細については、 Oracle EBS アダプターのサンプルを参照してください。このトピックに基づく サンプル SelectPolling_ChannelModelは、Oracle E-Business アダプターのサンプルでも提供されています。

WCF チャネルモデルを使用したポーリング操作用の受信メッセージの受信

このセクションでは、Oracle E-Business アダプターを使用して受信ポーリングメッセージを受信する .NET アプリケーション (チャネルモデル) を記述する方法について説明します。

アダプターからポーリングメッセージを受信するには

Visual Studio で Microsoft Visual C# ® プロジェクトを作成します。このトピックでは、コンソールアプリケーションを作成します。
ソリューションエクスプローラーで、 Microsoft.Adapters.OracleEBS、 Microsoft.ServiceModel.Channels、 System.ServiceModel、および System.Runtime.Serializationへの参照を追加します。
Program.cs ファイルを開き、次の名前空間を追加します。
- Microsoft.Adapters.OracleEBS
- System.ServiceModel
- System.ServiceModel.Description
- System.ServiceModel.Channels
- System.Xml
接続 URI を指定します。アダプター接続 URI の詳細については、「 Oracle E-Business Suite 接続 URI の作成」を参照してください。
```
Uri ConnectionUri = new Uri("oracleebs://ebs_instance_name");  
```
OracleEBSBinding のインスタンスを作成し、ポーリングを構成するために必要なバインディングプロパティを設定します。少なくとも、 InboundOperationType、 PolledDataAvailableStatement、 PollingInput、および PollingAction バインディングプロパティを設定する必要があります。ポーリングの構成に使用されるバインディングプロパティの詳細については、「ポーリングを使用した受信呼び出しのサポート」を参照してください。
```
OracleEBSBinding binding = new OracleEBSBinding();  
binding.InboundOperationType = InboundOperation.Polling;  
binding.PolledDataAvailableStatement = "SELECT COUNT (*) FROM MS_SAMPLE_EMPLOYEE";  
binding.PollingInput = "SELECT * FROM MS_SAMPLE_EMPLOYEE FOR UPDATE";  
binding.PollingAction = "InterfaceTables/Poll/FND/APPS/MS_SAMPLE_EMPLOYEE";  
binding.PostPollStatement = "DELETE FROM MS_SAMPLE_EMPLOYEE";  
```
インターフェイステーブルをポーリングするため、アプリケーションコンテキストも設定する必要があります。アプリケーションコンテキストの設定に必要なアプリケーションコンテキストとバインドプロパティの詳細については、「アプリケーションコンテキストの設定」を参照してください。
```
binding.OracleUserName = "<Enter user name here>";  
binding.OraclePassword = "<Enter password here>";  
binding.OracleEBSResponsibilityName = "<Enter responsibility here>";  
```

バインドパラメーターコレクションを作成し、資格情報を設定します。

ClientCredentials credentials = new ClientCredentials();  
credentials.UserName.UserName = "<Enter user name here>";  
credentials.UserName.Password = "<Enter password here>";  

BindingParameterCollection bindingParams = new BindingParameterCollection();  
bindingParams.Add(credentials);

チャネルリスナーを作成して開きます。リスナーを作成する場合は、OracleEBSBinding で BuildChannelListener<IInputChannel> メソッドを呼び出します。
```
IChannelListener<IInputChannel> listener = binding.BuildChannelListener<IInputChannel>(connectionUri, bindingParams);  
listener.Open();  
```
リスナーで AcceptChannel メソッドを呼び出して IInputChannel チャネルを取得し、開きます。
```
IInputChannel channel = listener.AcceptChannel();  
channel.Open();  
```
チャネルで Receive を呼び出して、アダプターから次の受信メッセージを取得します。
```
Message message = channel.Receive();  
```
受信操作によって返される結果セットを処理します。 XmlReader または XmlDictionaryWriter を使用してメッセージを使用できます。
```
XmlReader reader = message.GetReaderAtBodyContents();  
```
要求の処理が完了したら、チャネルを閉じます。
```
channel.Close()  
```
Von Bedeutung

受信操作の処理が完了したら、チャネルを閉じる必要があります。チャネルを閉じできないと、コードの動作に影響する可能性があります。
データ変更メッセージの受信が完了したら、リスナーを閉じます。
```
listener.Close()  
```
Von Bedeutung

リスナーを閉じても、リスナーを使用して作成されたチャネルは閉じません。リスナーを使用して作成された各チャネルを明示的に閉じる必要があります。

例

次の例は、MS_SAMPLE_EMPLOYEE インターフェイステーブルをポーリングするポーリングアプリケーションを示しています。 PollingInput プロパティには、MS_SAMPLE_EMPLOYEE テーブルからすべてのデータを読み取る select ステートメントが含まれており、post poll ステートメントは同じテーブルからすべてのデータを削除します。ポーリングメッセージは、 C:\PollingOutput.xmlに書き込まれます。

後続のポーリングメッセージには、MS_SAMPLE_EMPLOYEE インターフェイステーブルにさらにデータが追加されるまで、レコードは含まれません。これを行うには、サンプルで提供されているinsert_apps_data.sql スクリプトを実行します。このスクリプトを実行すると、次のポーリング操作によって、テーブルに挿入された新しいレコードが取得されます。アダプターは、 <RETURN> を押してサービスホストを閉じるまでポーリングを続行します。

using System;  
using Microsoft.Adapters.OracleEBS;  
using System.ServiceModel;  
using System.ServiceModel.Description;  
using System.ServiceModel.Channels;  
using System.Xml;  

namespace SelectPolling_ChannelModel  
{  
    class Program  
    {  
        static void Main(string[] args)  
        {  
            Console.WriteLine("Sample started. This sample will poll 5 times and will perform the following tasks:");  
            Console.WriteLine("Press any key to start polling...");  
            Console.ReadLine();  
            IChannelListener<IInputChannel> listener = null;  

            IInputChannel channel = null;  

            try  
            {  
                TimeSpan messageTimeout = new TimeSpan(0, 0, 30);  

                OracleEBSBinding binding = new OracleEBSBinding();  
                binding.InboundOperationType = InboundOperation.Polling;  
                binding.PolledDataAvailableStatement = "SELECT COUNT (*) FROM MS_SAMPLE_EMPLOYEE";  
                binding.PollingInput = "SELECT * FROM MS_SAMPLE_EMPLOYEE FOR UPDATE";  
                binding.PollingAction = "InterfaceTables/Poll/FND/APPS/MS_SAMPLE_EMPLOYEE";  
                binding.PostPollStatement = "DELETE FROM MS_SAMPLE_EMPLOYEE";  
                binding.OracleUserName = "<Enter user name here>";  
                binding.OraclePassword = "<Enter password here>";  
                binding.OracleEBSResponsibilityName = "<Enter responsibility here>";  

                Uri ConnectionUri = new Uri("oracleebs://ebs_instance_name?");  

                ClientCredentials credentials = new ClientCredentials();  
                credentials.UserName.UserName = "<Enter user name here>";  
                credentials.UserName.Password = "<Enter password here>";  

                BindingParameterCollection bindingParams = new BindingParameterCollection();  
                bindingParams.Add(credentials);  

                listener = binding.BuildChannelListener<IInputChannel>(ConnectionUri, bindingParams);  
                listener.Open();  

                channel = listener.AcceptChannel();  
                channel.Open();  

                Console.WriteLine("Channel and Listener opened...");  
                Console.WriteLine("\nWaiting for polled data...");  
                Console.WriteLine("Receive request timeout is {0}", messageTimeout);  

                // Poll five times with the specified message timeout   
                // If a timeout occurs polling will be aborted  
                for (int i = 0; i < 5; i++)  
                {  
                    Console.WriteLine("Polling: " + i);  
                    Message message = null;  
                    XmlReader reader = null;  
                    try  
                    {  
                        //Message is received so process the results  
                        message = channel.Receive(messageTimeout);  
                    }  
                    catch (System.TimeoutException toEx)  
                    {  
                        Console.WriteLine("\nNo data for request number {0}: {1}", i + 1, toEx.Message);  
                        continue;  
                    }  

                    // Get the query results using an XML reader  
                    try  
                    {  
                        reader = message.GetReaderAtBodyContents();  
                    }  
                    catch (Exception ex)  
                    {  
                        Console.WriteLine("Exception :" + ex);  
                        throw;                          
                    }  

                    XmlDocument doc = new XmlDocument();  
                    doc.Load(reader);  
                    using (XmlWriter writer = XmlWriter.Create("C:\\PollingOutput.xml"))  
                    {  
                        doc.WriteTo(writer);  
                        Console.WriteLine("The polling response is saved at 'C:\\PollingOutput.xml'");  
                    }  
                    // return the cursor  
                    Console.WriteLine();  

                    // close the reader  
                    reader.Close();  

                    message.Close();  
                }  
                Console.WriteLine("\nPolling done -- hit <RETURN> to finish");  
                Console.ReadLine();  
            }  
            catch (Exception ex)  
            {  
                Console.WriteLine("Exception is: " + ex.Message);  
                Console.ReadLine();  
                if (ex.InnerException != null)  
                {  
                    Console.WriteLine("Inner Exception is: " + ex.InnerException.Message);  
                    Console.ReadLine();  
                }  
            }  
            finally  
            {  
                // IMPORTANT: close the channel and listener to stop polling  
                if (channel != null)  
                {  
                    if (channel.State == CommunicationState.Opened)  
                        channel.Close();  
                    else  
                        channel.Abort();  
                }  

                if (listener != null)  
                {  
                    if (listener.State == CommunicationState.Opened)  
                        listener.Close();  
                    else  
                        listener.Abort();  
                }  
            }  
        }  
    }  
}

こちらもご覧ください

WCF チャネルモデルを使用して Oracle E-Business Suite アプリケーションを開発する

次の方法で共有

WCF チャネル モデルで SELECT ステートメントを使用して Oracle E-Business Suite をポーリングする

Oracle E-Business Suite アダプターバインディングプロパティを使ったポーリング操作の設定

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

ポーリング要求メッセージの処理

このトピックで使用する例について

WCF チャネル モデルを使用したポーリング操作用の受信メッセージの受信

アダプターからポーリング メッセージを受信するには

例

こちらもご覧ください

フィードバック

その他のリソース

WCF チャネルモデルで SELECT ステートメントを使用して Oracle E-Business Suite をポーリングする

WCF チャネルモデルを使用したポーリング操作用の受信メッセージの受信

アダプターからポーリングメッセージを受信するには