WCF サービスモデルを使用して Oracle Database でポーリングベースのデータ変更メッセージを受信する

[アーティクル]
07/21/2023

Oracle テーブルまたはビューに対してポーリングベースのデータ変更メッセージを受信するように Microsoft BizTalk Adapter for Oracle Database を構成できます。データ変更メッセージを受信するために、アダプターは Oracle テーブルまたはビューに対して SQL クエリを定期的に実行し、その後にオプションの PL/SQL コードブロックを実行します。 SQL クエリの結果は、Oracle Database アダプターによって、受信 POLLINGSTMT 操作で厳密に型指定された結果セットとしてアプリケーションに返されます。 Oracle データベースアダプターを使用して Oracle データベースのポーリングを構成および実行するために使用されるメカニズムの詳細については、「 Oracle Database アダプターでポーリングベースのデータ変更メッセージを受信する」を参照してください。先に進む前に、このトピックを読むことを強くお勧めします。

WCF サービスモデルを使用するときに POLLINGSTMT 操作を受信するには、次の操作を行う必要があります。

アダプターによって公開されるメタデータから POLLINGSTMT 操作の WCF サービスコントラクト (インターフェイス) を生成します。これを行うには、アダプターサービス参照の追加 Visual Studio プラグインまたは ServiceModel メタデータユーティリティツール (svcutil.exe) を使用します。
このインターフェイスから WCF サービスを実装します。
サービスホスト (System.ServiceModel.ServiceHost) を使用して、この WCF サービスをホストします。

このセクションのトピックでは、WCF サービスモデルの Oracle データベーステーブルとビューに対してポーリングを実行するのに役立つ情報と手順について説明します。

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

このトピックの例では、/SCOTT/ACCOUNTACTIVITY テーブルと /SCOTT/Package/ACCOUNT_PKG/PROCESS_ACTIVITY 関数を使用します。これらの成果物を生成するスクリプトは、BizTalk アダプターパックのサンプルと共に提供されています。サンプルの詳細については、「アダプターのサンプル」を参照してください。

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

Oracle データベースのテーブルとビューに対してポーリングを実行するように Oracle Database アダプターを構成するには、バインドプロパティとオプションの接続プロパティ (パラメーター) を設定します。これらのプロパティの一部は必須であり、一部のプロパティはデザイン時と実行時の両方で設定する必要があります。

設計時に、Oracle Database に接続して WCF サービスコントラクトを生成するときに、接続パラメーターとバインドプロパティを設定します。
実行時に、サービスホストの作成に使用する OracleDBBinding オブジェクトにバインドプロパティを設定します。接続パラメーターは、サービスホストにサービスリスナーを追加するときに設定します。

次の一覧は、ポーリングの構成に使用されるバインドプロパティと接続パラメーターの概要を示しています。
PollingStatement バインドプロパティ。このバインディングプロパティは、デザイン時と実行時の両方に設定する必要があります。
省略可能なバインドプロパティ。これらは実行時にのみ設定する必要があります。
AcceptCredentialsInUri バインドプロパティ。接続 URI で資格情報を有効にする場合は、実行時にこのバインドプロパティを true に設定する必要があります。サービスエンドポイントをサービスホストに追加するときは、接続 URI にユーザー名とパスワードが存在する必要があります。
接続 URI の PollingId クエリ文字列パラメーター。 POLLINGSTMT 操作の名前空間を変更する場合は、デザイン時と実行時の両方でこの接続プロパティを設定する必要があります。

ポーリングの構成に使用されるバインドプロパティと接続パラメーターの詳細については、「 Oracle Database アダプターでポーリングベースのデータ変更メッセージを受信する」を参照してください。

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

アダプターサービス参照の追加 Visual Studio プラグインまたは ServiceModel メタデータユーティリティツール (svcutil.exe) を使用して、WCF サービスコントラクト (インターフェイス) と POLLINGSTMT 操作のサポートクラスを作成します。

これらのツールのいずれかを使用して Oracle データベースに接続し、POLLINGSTMT 操作のサービスコントラクトを生成する場合:

PollingStatement バインドプロパティを指定する必要があります。アダプターは、このバインディングプロパティの SELECT ステートメントを使用して、POLLINGSTMT 操作によって返される厳密に型指定された結果セットの正しいメタデータを生成します。
必要に応じて、接続 URI に PollingId パラメーターを指定できます。アダプターはこのパラメーターを使用して、POLLINGSTMT 操作の名前空間を生成します。

次の例で以下を実行します。
PollingStatement が "SELECT * FROM ACCOUNTACTIVITY FOR UPDATE" に設定されています。
PollingId が "AcctActivity" に設定されています。

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

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

[System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")]  
[System.ServiceModel.ServiceContractAttribute(Namespace="http://Microsoft.LobServices.OracleDB/2007/03", ConfigurationName="POLLINGSTMT_OperationGroup")]  
public interface POLLINGSTMT_OperationGroup {  
  
    // CODEGEN: Generating message contract since the wrapper namespace (http://Microsoft.LobServices.OracleDB/2007/03/POLLINGSTMTAcctActivity)  
    // of message POLLINGSTMT does not match the default value (http://Microsoft.LobServices.OracleDB/2007/03)  
    [System.ServiceModel.OperationContractAttribute(IsOneWay=true, Action="http://Microsoft.LobServices.OracleDB/2007/03/POLLINGSTMT")]  
    void POLLINGSTMT(POLLINGSTMT request);  
}

メッセージコントラクト

メッセージコントラクト名前空間は、接続 URI の PollingId パラメーターによって変更されます。要求メッセージは、厳密に型指定されたレコードのセットを返します。

[System.Diagnostics.DebuggerStepThroughAttribute()]  
[System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")]  
[System.ServiceModel.MessageContractAttribute(WrapperName="POLLINGSTMT", WrapperNamespace="http://Microsoft.LobServices.OracleDB/2007/03/POLLINGSTMTAcctActivity", IsWrapped=true)]  
public partial class POLLINGSTMT {  
  
    [System.ServiceModel.MessageBodyMemberAttribute(Namespace="http://Microsoft.LobServices.OracleDB/2007/03/POLLINGSTMTAcctActivity", Order=0)]  
    public microsoft.lobservices.oracledb._2007._03.POLLINGSTMTAcctActivity.POLLINGSTMTRECORD[] POLLINGSTMTRECORD;  
  
    public POLLINGSTMT() {  
    }  
  
    public POLLINGSTMT(microsoft.lobservices.oracledb._2007._03.POLLINGSTMTAcctActivity.POLLINGSTMTRECORD[] POLLINGSTMTRECORD) {  
        this.POLLINGSTMTRECORD = POLLINGSTMTRECORD;  
    }  
}

データコントラクト名前空間

データコントラクトは、サービスとクライアントの間の正式な取り決めであり、交換されるデータが抽象的に記述されています。つまり、通信するために、クライアントとサービスは同じ型を共有する必要はなく、同じデータコントラクトのみを共有する必要があります。

データ変更メッセージの場合、データコントラクト名前空間も、接続 URI の PollingId パラメーター (指定されている場合) によって変更されます。データコントラクトは、クエリ結果セット内の厳密に型指定されたレコードを表すクラスで構成されます。この例では、クラス定義の詳細を省略します。クラスには、結果セット内の列を表すプロパティが含まれています。

次の例では、PollingId "AcctActivity" が使用されています。

namespace microsoft.lobservices.oracledb._2007._03.POLLINGSTMTAcctActivity {  
    using System.Runtime.Serialization;  
  
    [System.Diagnostics.DebuggerStepThroughAttribute()]  
    [System.CodeDom.Compiler.GeneratedCodeAttribute("System.Runtime.Serialization", "3.0.0.0")]  
    [System.Runtime.Serialization.DataContractAttribute(Name="POLLINGSTMTRECORD", Namespace="http://Microsoft.LobServices.OracleDB/2007/03/POLLINGSTMTAcctActivity")]  
    public partial class POLLINGSTMTRECORD : object, System.Runtime.Serialization.IExtensibleDataObject {…}  
     }  
}

WCF サービスクラス

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

namespace OracleDBBindingNamespace {  
  
    public class OracleDBBindingService : POLLINGSTMT_OperationGroup {  
  
        // CODEGEN: Generating message contract since the wrapper namespace (http://Microsoft.LobServices.OracleDB/2007/03/POLLINGSTMTAcctActivity)   
        // of message POLLINGSTMT does not match the default value (http://Microsoft.LobServices.OracleDB/2007/03)  
        public virtual void POLLINGSTMT(POLLINGSTMT request) {  
            throw new System.NotImplementedException("The method or operation is not implemented.");  
        }  
    }  
}

POLLINGSTMT 操作の受信

Oracle Database アダプターからポーリングデータを受信するには

アダプターサービス参照プラグインの追加または svcutil.exe を使用して、POLLINGSTMT 操作の WCF サービスコントラクト (インターフェイス) とヘルパークラスを生成します。詳細については、「 Oracle Database ソリューション成果物の WCF クライアントまたは WCF サービスコントラクトを生成する」を参照してください。アダプターに接続するときは、少なくとも PollingStatement バインドプロパティを設定する必要があります。必要に応じて、接続 URI に PollingId パラメーターを指定できます。アダプターサービス参照の追加プラグインを使用している場合は、構成に必要なすべてのバインドパラメーターを設定する必要があります。これにより、生成された構成ファイルに正しく設定されます。
手順 1 で生成されたインターフェイスクラスとヘルパークラスから WCF サービスを実装します。 POLLINGSTMT 操作から受信したデータの処理でエラーが発生した場合、このクラスの POLLINGSTMT メソッドは例外をスローしてポーリングトランザクションを中止できます。それ以外の場合、メソッドは何も返しません。 WCF サービスクラスを次のように属性化する必要があります。
```
[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]  
```
1. アダプターサービス参照プラグインを使用してインターフェイスを生成した場合は、生成された OracleDBBindingService クラスの POLLINGSTMT メソッドにロジックを直接実装できます。このクラスは OracleDBBindingService.cs にあります。この例のこのコードは、 OracleDBBindingService クラスを サブクラスします。
```
[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]  

public class PollingStmtService : OracleDBBindingService  
{  
    public override void POLLINGSTMT(POLLINGSTMT request)  
    {  
        Console.WriteLine("\nNew Polling Records Received");  
        Console.WriteLine("Tx Id\tAccount\tAmount\tDate\t\t\tDescription");  
        for (int i = 0; i < request.POLLINGSTMTRECORD.Length; i++)  
        {  
            Console.WriteLine("{0}\t{1}\t{2}\t{3}\t{4}", request.POLLINGSTMTRECORD[i].TID,  
                                request.POLLINGSTMTRECORD[i].ACCOUNT,  
                                request.POLLINGSTMTRECORD[i].AMOUNT,  
                                request.POLLINGSTMTRECORD[i].TRANSDATE,  
                                request.POLLINGSTMTRECORD[i].DESCRIPTION);  
        }  
    }  
}  
```
2. svcutil.exe を使用してインターフェイスを生成した場合は、インターフェイスを実装し、このクラスの POLLINGSTMT メソッドにロジックを実装する WCF サービスを作成する必要があります。

手順 2 で作成した WCF サービスのインスタンスを作成します。

// create service instance  
PollingStmtService pollingInstance = new PollingStmtService();

WCF サービスとベース接続 URI を使用して 、System.ServiceModel.ServiceHost のインスタンスを作成します。基本接続 URI に userinfoparams またはquery_stringを含めることはできません。
```
// Enable service host  
Uri[] baseUri = new Uri[] { new Uri("oracledb://Adapter") };  
ServiceHost srvHost = new ServiceHost(pollingInstance, baseUri);  
```

OracleDBBinding を作成し、そのバインドプロパティを設定してポーリング操作を構成します。これは、コード内で明示的に行うか、構成で宣言的に行うことができます。少なくとも、ポーリングステートメントとポーリング間隔を指定する必要があります。この例では、URI の一部として資格情報を指定するので、 AcceptCredentialsInUri も true に設定する必要があります。

// Create and configure a binding for the service endpoint. NOTE: binding  
// parameters are set here for clarity, but these are already set in the  
// the generated configuration file  
OracleDBBinding binding = new OracleDBBinding();  

// The credentials are included in the connection URI, so set this property to true  
binding.AcceptCredentialsInUri = true;  

// Same as statement specified in Configure Adapter dialog box  
binding.PollingStatement = "SELECT * FROM ACCOUNTACTIVITY FOR UPDATE";  
binding.PostPollStatement = "BEGIN ACCOUNT_PKG.PROCESS_ACTIVITY(); END;";  

// Be sure to set the interval long enough to complete processing before  
// the next poll  
binding.PollingInterval = 15;  
// Polling is transactional; be sure to set an adequate isolation level   
// for your environment  
binding.TransactionIsolationLevel = TransactionIsolationLevel.ReadCommitted;

サービスエンドポイントをサービスホストに追加します。これを行うには、次の手順を実行します。
- 手順 5 で作成したバインディングを使用します。
- 資格情報と必要に応じて PollingId を含む接続 URI を指定します。
- コントラクトを "POLLINGSTMT_OperationGroup" として指定します。
```
// Add service endpoint: be sure to specify POLLINGSTMT_OperationGroup as the contract  
Uri serviceUri = new Uri("oracledb://User=SCOTT;Password=TIGER@Adapter?PollingId=AcctActivity");  
srvHost.AddServiceEndpoint("POLLINGSTMT_OperationGroup", binding, serviceUri);  
```
ポーリングデータを受信するには、サービスホストを開きます。アダプターは、クエリが結果セットを返すたびにデータを返します。
```
// Open the service host to begin polling  
srvHost.Open();  
```
ポーリングを終了するには、サービスホストを閉じます。

重要

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

例

次の例は、/SCOTT/ACCOUNTACTIVITY テーブルに対して実行されるポーリングクエリを示しています。ポーリング後ステートメントは、処理されたレコードを別のテーブル /SCOTT/ACCOUNTHISTORY に移動する Oracle 関数を呼び出します。 POLLINGSTMT 操作の名前空間は、接続 URI で PollingId パラメーターを "AccountActivity" に設定することで変更されます。この例では、生成された OracleDBBindingService クラスをサブクラス化して、POLLINGSTMT 操作の WCF サービスを作成します。ただし、生成されたクラスにロジックを直接実装できます。

using System;  
using System.Collections.Generic;  
using System.Text;  
  
// Add these three references to use the Oracle adapter  
using System.ServiceModel;  
using Microsoft.ServiceModel.Channels;  
using Microsoft.Adapters.OracleDB;  
  
using microsoft.lobservices.oracledb._2007._03.POLLINGSTMTAcctActivity;  
using OracleDBBindingNamespace;  
  
namespace OraclePollingSM  
{  
    [ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]  
  
    public class PollingStmtService : OracleDBBindingService  
    {  
        public override void POLLINGSTMT(POLLINGSTMT request)  
        {  
            Console.WriteLine("\nNew Polling Records Received");  
            Console.WriteLine("Tx Id\tAccount\tAmount\tDate\t\t\tDescription");  
            for (int i = 0; i < request.POLLINGSTMTRECORD.Length; i++)  
            {  
                Console.WriteLine("{0}\t{1}\t{2}\t{3}\t{4}", request.POLLINGSTMTRECORD[i].TID,  
                                    request.POLLINGSTMTRECORD[i].ACCOUNT,  
                                    request.POLLINGSTMTRECORD[i].AMOUNT,  
                                    request.POLLINGSTMTRECORD[i].TRANSDATE,  
                                    request.POLLINGSTMTRECORD[i].DESCRIPTION);  
  
            }  
            Console.WriteLine("\nHit <RETURN> to stop polling");  
         }  
    }  
  
    class Program  
    {  
        static void Main(string[] args)  
        {  
            ServiceHost srvHost = null;  
  
            // This URI is used to specify the address for the ServiceEndpoint  
            // It must contain credentials and the PollingId (if any) that was used to generate  
            // the WCF service callback interface  
            Uri serviceUri = new Uri("OracleDb://User=SCOTT;Password=TIGER@Adapter?PollingId=AcctActivity");  
  
            // This URI is used to initialize the ServiceHost. It cannot contain  
            // userinfoparms (credentials) or a query_string (PollingId); otherwise,  
            // an exception is thrown when the ServiceHost is initialized.  
            Uri[] baseUri = new Uri[] { new Uri("OracleDb://Adapter") };  
  
            Console.WriteLine("Sample started, initializing service host -- please wait");  
  
            // create an instanc of the WCF service callback class  
            PollingStmtService pollingInstance = new PollingStmtService();  
  
            try  
            {  
                // Create a ServiceHost with the service callback instance and a base URI (address)  
                srvHost = new ServiceHost(pollingInstance, baseUri);  
  
                // Create and configure a binding for the service endpoint. Note: binding  
                // parameters are set here for clarity but these are already set in the  
                // generated configuration file  
                //  
                // The following properties are set  
                //    AcceptCredentialsInUri (true) to enable credentials in the connection URI for AddServiceEndpoint  
                //    PollingStatement  
                //    PostPollStatement calls PROCESS_ACTIVITY on Oracle. This procedure moves the queried records to  
                //                      the ACCOUNTHISTORY table  
                //    PollingInterval (15 seconds)  
                //    TransactionIsolationLevel   
  
                OracleDBBinding binding = new OracleDBBinding();  
  
                // The Credentials are included in the Connection Uri so set this property true  
                binding.AcceptCredentialsInUri = true;  
  
                // Same as statement specified in Configure Adapter dialog box  
                binding.InboundOperationType = InboundOperation.Polling;  
                binding.PollingStatement = "SELECT * FROM ACCOUNTACTIVITY FOR UPDATE";  
                binding.PostPollStatement = "BEGIN ACCOUNT_PKG.PROCESS_ACTIVITY(); END;";  
  
                // Be sure to set the interval long enough to complete processing before  
                // the next poll  
                binding.PollingInterval = 15;  
  
                // Polling is transactional, be sure to set an adequate isolation level   
                // for your environment  
                binding.TransactionIsolationLevel = TransactionIsolationLevel.ReadCommitted;  
  
                // Add service endpoint: be sure to specify POLLINGSTMT_OperationGroup as the contract  
                srvHost.AddServiceEndpoint("POLLINGSTMT_OperationGroup", binding, serviceUri);  
  
                Console.WriteLine("Opening the service host");  
                // Open the service host to begin polling  
                srvHost.Open();  
  
                // Wait to receive request  
                Console.WriteLine("\nPolling started. Returned records will be written to the console.");  
                Console.WriteLine("Hit <RETURN> to stop polling");  
                Console.ReadLine();  
            }  
            catch (Exception e)  
            {  
                Console.WriteLine("Exception :" + e.Message);  
                Console.ReadLine();  
  
                /* If there is an Oracle 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 (srvHost.State == CommunicationState.Opened)  
                    srvHost.Close();  
                else  
                    srvHost.Abort();  
            }  
  
        }  
    }  
}

参照

WCF サービスモデルを使用して Oracle Database アプリケーションを開発する

WCF サービスモデルを使用して Oracle Database でポーリングベースのデータ変更メッセージを受信する

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

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

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

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

メッセージコントラクト

データコントラクト名前空間

WCF サービスクラス

POLLINGSTMT 操作の受信

Oracle Database アダプターからポーリングデータを受信するには

例

参照

フィードバック

フィードバック

その他のリソース

WCF サービス モデルを使用して Oracle Database でポーリング ベースのデータ変更メッセージを受信する

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

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

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

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

メッセージ コントラクト

データ コントラクト名前空間

WCF サービス クラス

POLLINGSTMT 操作の受信

Oracle Database アダプターからポーリング データを受信するには

例

参照

フィードバック

フィードバック

その他のリソース

WCF サービスモデルを使用して Oracle Database でポーリングベースのデータ変更メッセージを受信する

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

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

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

メッセージコントラクト

データコントラクト名前空間

WCF サービスクラス

Oracle Database アダプターからポーリングデータを受信するには