WCF サービスモデルでストアドプロシージャを使用して Oracle E-Business Suite をポーリングする

2023-07-21

ストアドプロシージャを使用して Oracle データベースを定期的にポーリングすることで、定期的なデータ変更メッセージを受信するように Oracle E-Business アダプターを構成できます。 Oracle データベースをポーリングするためにアダプターが定期的に実行するポーリングステートメントとしてストアドプロシージャを指定できます。

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

Oracle E-Business Adapter のバインドプロパティを使用したポーリング操作の構成

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

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

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

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

このトピックでは、Oracle E-Business アダプターがストアドプロシージャを使用したデータ変更メッセージの受信をサポートする方法を示すために、GET_ACTIVITYS ストアドプロシージャを使用して Oracle データベースの 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 スクリプトを実行します。このスクリプトを実行すると、次のポーリング操作によって、テーブルに挿入された新しいレコードが取得されます。

WCF サービスモデルでのポーリングの構成

WCF サービスモデルを使用して Oracle E-Business アダプターでストアドプロシージャを使用してポーリングするには、次の操作を行う必要があります。

ポーリングに使用するストアドプロシージャのために、WCF サービスコントラクト (インターフェイス) を生成します。この例では、GET_ACTIVITYS ストアドプロシージャの WCF サービス コントラクトを受信 操作として生成する必要があります。これを行うには、アダプターサービス参照の追加プラグインを使用できます。
このインターフェイスから WCF サービスを実装します。
サービスホスト (System.ServiceModel.ServiceHost) を使用して、この WCF サービスをホストします。

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

このトピックの例では、GET_ACTIVITYS ストアドプロシージャを使用して ACCOUNTACTIVITY データベーステーブルをポーリングします。テーブルとストアドプロシージャを生成するスクリプトがサンプルと共に提供されます。サンプルの詳細については、 Oracle EBS アダプターのサンプルを参照してください。このトピックに基づく サンプル StoredProcPolling_ServiceModelは、Oracle E-Business アダプターのサンプルでも提供されています。

WCF サービスコントラクトとクラス

アダプターサービス参照の追加プラグインを使用して、WCF サービスコントラクト (インターフェイス) と GET_ACTIVITYS 受信操作のサポートクラスを作成できます。 WCF サービスコントラクトの生成の詳細については、「 Oracle E-Business Suite ソリューション成果物の WCF クライアントまたは WCF サービスコントラクトを生成する」を参照してください。

WCF サービスコントラクト (インターフェイス)

次のコードは、 GET_ACTIVITYS 受信操作用に生成された WCF サービスコントラクト (インターフェイス) を示しています。

[System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")]
[System.ServiceModel.ServiceContractAttribute(Namespace="http://schemas.microsoft.com/OracleEBS/", ConfigurationName="PollingPackageApis_APPS_ACCOUNT_PKG")]
public interface PollingPackageApis_APPS_ACCOUNT_PKG {

    // CODEGEN: Generating message contract since the wrapper namespace (https://schemas.microsoft.com/OracleEBS/2008/05/PollingPackageApis/APPS/ACCOUNT_PKG) of message GET_ACTIVITYS
    // does not match the default value (https://schemas.microsoft.com/OracleEBS/)
    [System.ServiceModel.OperationContractAttribute(IsOneWay=true, Action="PollingPackageApis/APPS/ACCOUNT_PKG/GET_ACTIVITYS")]
    void GET_ACTIVITYS(GET_ACTIVITYS request);
}

メッセージコントラクト

以下にGET_ACTIVITYS受信操作のメッセージコントラクトを示します。

[System.Diagnostics.DebuggerStepThroughAttribute()]
[System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")]
[System.ServiceModel.MessageContractAttribute(WrapperName="GET_ACTIVITYS", WrapperNamespace="http://schemas.microsoft.com/OracleEBS/2008/05/PollingPackageApis/APPS/ACCOUNT_PK" +
    "G", IsWrapped=true)]
public partial class GET_ACTIVITYS {

    [System.ServiceModel.MessageBodyMemberAttribute(Namespace="http://schemas.microsoft.com/OracleEBS/2008/05/PollingPackageApis/APPS/ACCOUNT_PK" +
        "G", Order=0)]
    public schemas.microsoft.com.OracleEBS._2008._05.RecordTypes.APPS.ACCOUNT_PKG.GET_ACTIVITYS.OUTRECSRecord[] OUTRECS;

    public GET_ACTIVITYS() {
    }

    public GET_ACTIVITYS(schemas.microsoft.com.OracleEBS._2008._05.RecordTypes.APPS.ACCOUNT_PKG.GET_ACTIVITYS.OUTRECSRecord[] OUTRECS) {
        this.OUTRECS = OUTRECS;
    }
}

WCF サービスクラス

アダプターサービス参照の追加プラグインは、サービスコントラクト (インターフェイス) から実装された WCF サービスクラスのスタブを持つファイルも生成します。ファイルの名前はOracleEBSBindingService.cs。 GET_ACTIVITYS操作をこのクラスに直接処理するロジックを挿入できます。次のコードは、アダプターサービス参照プラグインの追加によって生成される WCF サービスクラスを示しています。

namespace OracleEBSBindingNamespace {

    public class OracleEBSBindingService : PollingPackageApis_APPS_ACCOUNT_PKG {

        // CODEGEN: Generating message contract since the wrapper namespace (https://schemas.microsoft.com/OracleEBS/2008/05/PollingPackageApis/APPS/ACCOUNT_PKG) of message GET_ACTIVITYS
        // does not match the default value (https://schemas.microsoft.com/OracleEBS/)
        public virtual void GET_ACTIVITYS(GET_ACTIVITYS request) {
            throw new System.NotImplementedException("The method or operation is not implemented.");
        }
    }
}

ポーリング用の受信メッセージをストアドプロシージャで処理する

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

ストアドプロシージャを使用してポーリングメッセージを受信するには

アダプターサービス参照の追加プラグインを使用して、GET_ACTIVITYS 受信操作のWCFサービスコントラクト (インターフェイス) とヘルパークラスを生成します。詳細については、「 Oracle E-Business Suite ソリューション成果物の WCF クライアントまたは WCF サービスコントラクトを生成する」を参照してください。必要に応じて、サービスコントラクトとヘルパークラスの生成中にバインディングプロパティを指定できます。これにより、生成された構成ファイルに正しく設定されます。

手順 1 で生成されたインターフェイスとヘルパークラスから WCF サービスを実装します。このクラスの GET_ACTIVITYS メソッドは、 GET_ACTIVITYS操作から 受信したデータの処理でエラーが発生した場合に、ポーリングトランザクションを中止する例外をスローできます。それ以外の場合、メソッドは何も返しません。 WCF サービスクラスの属性を次に示す必要があります。

[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]

GET_ACTIVITYS メソッド内では、アプリケーションロジックを直接実装できます。このクラスは、OracleEBSBindingService.csにあります。この例のこのコードは、 OracleEBSBindingService クラスを サブクラス化します。このコードでは、ポーリングメッセージが受信され、コンソールに書き込まれます。

[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]

public class PollingService : OracleEBSBindingNamespace.OracleEBSBindingService
{
    public override void  GET_ACTIVITYS(GET_ACTIVITYS request)
    {
        Console.WriteLine("\nNew Polling Records Received");
        Console.WriteLine("*************************************************");
        Console.WriteLine("Tx Id\tAccount\tAmount\tProcessed");
        for (int i = 0; i < request.OUTRECS.Length; i++)
        {
            Console.WriteLine("{0}\t{1}\t{2}\t{3}",
            request.OUTRECS[i].TID,
            request.OUTRECS[i].ACCOUNT,
            request.OUTRECS[i].AMOUNT,
            request.OUTRECS[i].PROCESSED);
        }
        Console.WriteLine("*************************************************");
        Console.WriteLine("\nHit <RETURN> to stop polling");
    }
}

URI の一部として資格情報を渡さないようにするには、次のクラスを実装する必要があります。アプリケーションの後半では、このクラスをインスタンス化して資格情報を渡します。

class PollingCredentials : ClientCredentials, IServiceBehavior
{
    public void AddBindingParameters(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase, Collection<ServiceEndpoint> endpoints, BindingParameterCollection bindingParameters)
    {
        bindingParameters.Add(this);
    }

    public void ApplyDispatchBehavior(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase)
    { }

    public void Validate(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase)
    { }

    protected override ClientCredentials CloneCore()
    {
        ClientCredentials clone = new PollingCredentials();
        clone.UserName.UserName = this.UserName.UserName;
        clone.UserName.Password = this.UserName.Password;
        return clone;
    }
}

OracleEBSBinding を作成し、バインドプロパティを指定してポーリング操作を構成します。これは、コードで明示的に行うか、構成で宣言によって行うことができます。少なくとも、 InboundOperationType、 PolledDataAvailableStatement、 PollingInput、および PollingAction バインディングプロパティを指定する必要があります。
```
OracleEBSBinding binding = new OracleEBSBinding();
binding.InboundOperationType = InboundOperation.Polling;
binding.PolledDataAvailableStatement = "SELECT COUNT (*) FROM ACCOUNTACTIVITY";
binding.PollingInput = "<GET_ACTIVITYS xmlns='http://schemas.microsoft.com/OracleEBS/2008/05/PackageApis/APPS/ACCOUNT_PKG'><INRECS>OPEN ? FOR SELECT * FROM ACCOUNTACTIVITY</INRECS></GET_ACTIVITYS>";
binding.PollingAction = "PollingPackageApis/APPS/ACCOUNT_PKG/GET_ACTIVITYS";
binding.PostPollStatement = "BEGIN ACCOUNT_PKG.PROCESS_ACTIVITY(); END;";
```
注

PollingInput バインドプロパティの値には、GET_ACTIVITYS ストアドプロシージャを送信操作として呼び出すための要求メッセージが含まれていることに注意してください。

Von Bedeutung

この例では、データベーステーブルをポーリングするため、アプリケーションコンテキストを設定する必要はありません。ただし、インターフェイステーブルをポーリングする場合は、 OracleUserName、 OraclePassword、 OracleEBSResponsibilityName のバインドプロパティを指定して、アプリケーションコンテキストを設定する必要があります。アプリケーションコンテキストの詳細については、「アプリケーションコンテキストの設定」を参照してください。

手順 3 で作成 した PollingCredentials クラスをインスタンス化して、Oracle E-Business Suite の資格情報を指定します。

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

手順 2 で作成した WCF サービスのインスタンスを作成します。
```
// create service instance
PollingService service = new PollingService();
```
WCF サービスとベース接続 URI を使用して 、System.ServiceModel.ServiceHost のインスタンスを作成します。基本接続 URI に受信 ID を含めることはできません (指定されている場合)。ここでも資格情報を渡す必要があります。
```
// Enable service host
Uri[] baseUri = new Uri[] { new Uri("oracleebs://ebs_instance_name") };
ServiceHost serviceHost = new ServiceHost(service, baseUri);
serviceHost.Description.Behaviors.Add(credentials);
```
サービスホストにサービスエンドポイントを追加します。これを行うには:
- 手順 4 で作成したバインディングを使用します。
- 資格情報を含む接続 URI と、必要に応じて受信 ID を指定します。
- コントラクトを "PollingPackageApis_APPS_ACCOUNT_PKG" として指定して、MS_SAMPLE_EMPLOYEE インターフェイステーブルをポーリングします。
```
// Add service endpoint: be sure to specify PollingPackageApis_APPS_ACCOUNT_PKG as the contract
Uri ConnectionUri = new Uri("oracleebs://ebs_instance_name");
serviceHost.AddServiceEndpoint("PollingPackageApis_APPS_ACCOUNT_PKG", binding, ConnectionUri);
```
ポーリングデータを受信するには、サービスホストを開きます。アダプターは、クエリが結果セットを返すたびにデータを返します。
```
// Open the service host to begin polling
serviceHost.Open();
```
ポーリングを終了するには、サービスホストを閉じます。

Von Bedeutung

アダプターは、サービスホストが閉じられるまでポーリングを続行します。
```
serviceHost.Close();
```

例

次の例は、GET_ACTIVITYS ストアドプロシージャを使用して ACCOUNTACTIVITY データベーステーブルをポーリングするポーリングアプリケーションを示しています。 PollingInput バインディングプロパティには、ACCOUNTACTIVITY テーブルからすべてのデータを読み取るGET_ACTIVITYS ストアドプロシージャを呼び出す要求メッセージが含まれており、ポーリング後のステートメントは ACCOUNTACTIVITY から ACTIVITYHISTORY テーブルにすべてのデータを移動します。

最初のポーリングメッセージは、ACCOUNTACTIVITY テーブルのすべてのレコードを示します。後続のポーリングメッセージにはレコードは含まれません。これは、post poll ステートメントによってレコードが削除されるためです。 ACCOUNTACTIVITY テーブルにさらにデータが追加されるまで、ポーリングメッセージは取得されないため、ACCOUNTACTIVITY テーブルに新しいレコードを再入力する必要があります。これを行うには、サンプルで提供されているmore_activity_data.sql スクリプトを実行します。

このスクリプトを実行すると、次のポーリング操作によって、テーブルに挿入された新しいレコードが取得されます。アダプターは、 <RETURN>を押してサービスホストを閉じるまでポーリングを続行します。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Microsoft.Adapters.OracleEBS;
using Microsoft.ServiceModel.Channels;
using System.ServiceModel;
using System.ServiceModel.Description;
using System.ServiceModel.Channels;
using System.Collections.ObjectModel;

namespace StoredProcPolling_ServiceModel
{
    [ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]

    public class PollingService : OracleEBSBindingNamespace.OracleEBSBindingService
    {
        public override void  GET_ACTIVITYS(GET_ACTIVITYS request)
        {
            Console.WriteLine("\nNew Polling Records Received");
            Console.WriteLine("*************************************************");
            Console.WriteLine("Tx Id\tAccount\tAmount\tProcessed");
            for (int i = 0; i < request.OUTRECS.Length; i++)
            {
                Console.WriteLine("{0}\t{1}\t{2}\t{3}",
                request.OUTRECS[i].TID,
                request.OUTRECS[i].ACCOUNT,
                request.OUTRECS[i].AMOUNT,
                request.OUTRECS[i].PROCESSED);
            }
            Console.WriteLine("*************************************************");
            Console.WriteLine("\nHit <RETURN> to stop polling");
        }
    }

    class PollingCredentials : ClientCredentials, IServiceBehavior
    {
        public void AddBindingParameters(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase, Collection<ServiceEndpoint> endpoints, BindingParameterCollection bindingParameters)
        {
            bindingParameters.Add(this);
        }

        public void ApplyDispatchBehavior(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase)
        { }

        public void Validate(ServiceDescription serviceDescription, ServiceHostBase serviceHostBase)
        { }

        protected override ClientCredentials CloneCore()
        {
            ClientCredentials clone = new PollingCredentials();
            clone.UserName.UserName = this.UserName.UserName;
            clone.UserName.Password = this.UserName.Password;
            return clone;
        }
    }

    class Program
    {
        static void Main(string[] args)
        {
            ServiceHost serviceHost = null;
            try
            {
                Console.WriteLine("Sample started...");
                Console.WriteLine("Press any key to start polling...");
                Console.ReadLine();

                OracleEBSBinding binding = new OracleEBSBinding();
                binding.InboundOperationType = InboundOperation.Polling;
                binding.PolledDataAvailableStatement = "SELECT COUNT (*) FROM ACCOUNTACTIVITY";
                binding.PollingInput = "<GET_ACTIVITYS xmlns='http://schemas.microsoft.com/OracleEBS/2008/05/PackageApis/APPS/ACCOUNT_PKG'><INRECS>OPEN ? FOR SELECT * FROM ACCOUNTACTIVITY</INRECS></GET_ACTIVITYS>";
                binding.PollingAction = "PollingPackageApis/APPS/ACCOUNT_PKG/GET_ACTIVITYS";
                binding.PostPollStatement = "BEGIN ACCOUNT_PKG.PROCESS_ACTIVITY(); END;";

                // This URI is used to specify the address for the ServiceEndpoint
                // It must contain the InboundId that was used to generate
                // the WCF service callback interface
                Uri ConnectionUri = new Uri("oracleebs://ebs_instance_name");

                // This URI is used to initialize the ServiceHost. It cannot contain
                // an InboundID; otherwise,an exception is thrown when
                // the ServiceHost is initialized.
                Uri[] baseUri = new Uri[] { new Uri("oracleebs://ebs_instance_name") };

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

                Console.WriteLine("Opening service host...");
                PollingService service = new PollingService();
                serviceHost = new ServiceHost(service, baseUri);
                serviceHost.Description.Behaviors.Add(credentials);
                serviceHost.AddServiceEndpoint("PollingPackageApis_APPS_ACCOUNT_PKG", binding, ConnectionUri);
                serviceHost.Open();
                Console.WriteLine("Service host opened...");
                Console.WriteLine("Polling started...");
                Console.ReadLine();
            }
            catch (Exception e)
            {
                Console.WriteLine("Exception :" + e.Message);
                Console.ReadLine();

                /* If there is an error it will be specified in the inner exception */
                if (e.InnerException != null)
                {
                    Console.WriteLine("InnerException: " + e.InnerException.Message);
                    Console.ReadLine();
                }
            }
            finally
            {
                // IMPORTANT: you must close the ServiceHost to stop polling
                if (serviceHost.State == CommunicationState.Opened)
                    serviceHost.Close();
                else
                    serviceHost.Abort();
            }
        }
    }
}

こちらもご覧ください

WCF サービスモデルを使用して Oracle E-Business Suite をポーリングする

次の方法で共有

WCF サービス モデルでストアド プロシージャを使用して Oracle E-Business Suite をポーリングする

Oracle E-Business Adapter のバインド プロパティを使用したポーリング操作の構成

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

WCF サービス モデルでのポーリングの構成

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

WCF サービス コントラクトとクラス

WCF サービス コントラクト (インターフェイス)

メッセージ コントラクト

WCF サービス クラス

ポーリング用の受信メッセージをストアド プロシージャで処理する

ストアド プロシージャを使用してポーリング メッセージを受信するには

例