搭配 WCF 服務模型使用 SELECT 語句輪詢 Oracle E-Business Suite

發行項
10/14/2023

您可以設定 Oracle E-Business 配接器，以使用 SELECT 語句來持續輪詢 Oracle E-Business Suite 中的介面資料表、介面檢視、資料表和檢視，以接收週期性資料變更訊息。您可以將 SELECT 語句指定為配接器定期執行的輪詢語句，以輪詢 Oracle E-Business Suite。您也可以指定輪詢後 PL/SQL 程式碼區塊，配接器在執行輪詢語句之後執行。

若要啟用輪詢，您必須指定本主題中所述的特定系結屬性。如需配接器如何支援輪詢的詳細資訊，請參閱使用輪詢支援輸入呼叫。

使用 Oracle E-Business Suite 配接器系結屬性設定輪詢作業

下表摘要說明您用來設定配接器以接收資料變更訊息的 Oracle E-Business 配接器系結屬性。在執行輪詢應用程式時，您必須指定這些系結屬性。

Binding 屬性	Description
InboundOperationType	指定您是否要執行輪詢或通知輸入作業。預設值為輪詢。
PolledDataAvailableStatement	指定配接器執行的 SQL 語句，以判斷是否有任何資料可供輪詢。只有當記錄可用時，您為 PollingInput 系結屬性指定的 SELECT 語句才會執行。
PollingInterval	指定 Oracle E-Business 配接器針對 PolledDataAvailableStatement 系結屬性指定的語句，以秒為單位指定間隔。預設值為 30 秒。輪詢間隔會決定連續輪詢之間的時間間隔。如果語句是在指定的間隔內執行，配接器會睡眠間隔中的剩餘時間。
PollingInput	指定輪詢語句。若要使用 SELECT 語句輪詢，您必須為此系結屬性指定 SELECT 語句。預設值是 null。您必須指定 PollingInput 系結屬性的值，才能啟用輪詢。只有在有資料可供輪詢時，才會執行輪詢語句，這是由 PolledDataAvailableStatement 系結屬性所決定。
PollingAction	指定輪詢作業的動作。您可以使用新增配接器服務參考 Visual Studio 外掛程式，從為作業產生的服務介面判斷輪詢動作。
PostPollStatement	指定執行 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 接收輪詢型資料變更訊息。
將 DELETE 子句指定為 PostPollStatement 系結屬性的一部分。此語句會從 MS_SAMPLE_EMPLOYEE 介面資料表中刪除所有資料。在此範例中，您可以將這個系結屬性設定為：
```
DELETE FROM MS_SAMPLE_EMPLOYEE
```
發生這種情況之後，下次執行 針對 PollingInput 指定的語句時，它將不會擷取任何資料。
在將更多資料新增至 MS_SAMPLE_EMPLOYEE 介面資料表之前，您將不會收到任何輪詢訊息，因此您必須使用新的記錄重新填入MS_SAMPLE_EMPLOYEE介面資料表。您可以執行範例所提供的 insert_apps_data.sql 腳本來執行此動作。執行此腳本之後，下一個輪詢作業會擷取插入資料表的新記錄。

在 WCF 服務模型中設定輪詢

若要使用 Oracle E-Business 配接器搭配 WCF 服務模型輪詢介面資料表，您必須：

針對MS_SAMPLE_EMPLOYEE介面資料表上的輪詢作業產生 WCF 服務合約 (介面) 。若要這樣做，您可以使用 [新增配接器服務參考外掛程式]。
從這個介面實作 WCF 服務。
使用服務主機裝載此 WCF 服務， (System.ServiceModel.ServiceHost) 。

關於本主題中使用的範例

本主題中的範例會輪詢MS_SAMPLE_EMPLOYEE介面資料表。產生資料表的腳本會提供範例。如需範例的詳細資訊，請參閱 Oracle EBS 配接器的範例。本主題所依據的範例 SelectPolling_ServiceModel也隨附 Oracle E-Business 配接器範例。

WCF 服務合約和類別

您可以使用 [新增配接器服務參考外掛程式] 來建立 WCF 服務合約 (介面) 和支援輪詢作業的類別。如需產生 WCF 服務合約的詳細資訊，請參閱產生 WCF 用戶端或 Oracle E-Business Suite 解決方案成品的 WCF 服務合約。

WCF 服務合約 (介面)

下列程式碼顯示針對 MS_SAMPLE_EMPLOYEE 介面資料表上的輪詢作業產生的 WCF 服務合約) (介面。

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

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

訊息合約

以下是MS_SAMPLE_EMPLOYEE介面資料表上輪詢作業的訊息合約。

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

    [System.ServiceModel.MessageBodyMemberAttribute(Namespace="http://schemas.microsoft.com/OracleEBS/2008/05/InterfaceTables/FND/APPS/MS_SAMPLE" +
        "_EMPLOYEE", Order=0)]
    public schemas.microsoft.com.OracleEBS._2008._05.TableViewRecord.APPS.MS_SAMPLE_EMPLOYEE.SelectRecord[] DATA;

    public Poll() {
    }

    public Poll(schemas.microsoft.com.OracleEBS._2008._05.TableViewRecord.APPS.MS_SAMPLE_EMPLOYEE.SelectRecord[] DATA) {
        this.DATA = DATA;
    }
}

WCF 服務類別

[新增配接器服務參考外掛程式] 也會產生檔案，該檔案會從服務合約 (介面) 實作 WCF 服務類別的存根。檔案名為 OracleEBSBindingService.cs。您可以將邏輯直接插入此類別來處理 Poll 作業。下列程式碼顯示新增配接器服務參考外掛程式所產生的 WCF 服務類別。

namespace OracleEBSBindingNamespace {

    public class OracleEBSBindingService : InterfaceTables_FND_APPS_MS_SAMPLE_EMPLOYEE {

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

使用 SELECT 語句接收輪詢作業的輸入訊息

本節提供如何使用 Oracle E-Business 配接器撰寫 .NET 應用程式以接收輸入輪詢訊息的指示。

使用 SELECT 語句接收輪詢訊息

使用 [新增配接器服務參考外掛程式] 來產生 WCF 服務合約 (介面) ，以及MS_SAMPLE_EMPLOYEE介面資料表上輪詢作業的協助程式類別。如需詳細資訊，請參閱產生 Oracle E-Business Suite 解決方案成品的 WCF 用戶端或 WCF 服務合約。您可以在產生服務合約和協助程式類別時，選擇性地指定系結屬性。這可確保它們已正確設定在產生的組態檔中。

從步驟 1 中產生的介面和協助程式類別實作 WCF 服務。如果遇到錯誤處理從輪詢作業收到的資料，這個類別的Poll方法可能會擲回例外狀況來中止輪詢交易;否則，方法不會傳回任何專案。您必須屬性 WCF 服務類別，如下所示：

[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]

在 Poll 方法內，您可以直接實作應用程式邏輯。您可以在 OracleEBSBindingService.cs 中找到這個類別。此範例中的這個程式碼會子類別 OracleEBSBindingService 類別。在此程式碼中，已接收輪詢訊息，並寫入主控台。

[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]

public class PollingService : OracleEBSBindingNamespace.OracleEBSBindingService
{
    public override void Poll(Poll request)
    {
        Console.WriteLine("\nNew Polling Records Received");
        Console.WriteLine("*************************************************");
        Console.WriteLine("Emp No\tName\tDesignation\tSalary");
        for (int i = 0; i < request.DATA.Length; i++)
        {
            Console.WriteLine("{0}\t{1}\t{2}\t{3}",
            request.DATA[i].EMP_NO,
            request.DATA[i].NAME,
            request.DATA[i].DESIGNATION,
            request.DATA[i].SALARY);
        }
        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 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 = "myOracleEBSUserName";
binding.OraclePassword = "myOracleEBSPassword";
binding.OracleEBSResponsibilityName = "myOracleEBSResponsibility";
```

藉由具現化您在步驟 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 不能包含輸入識別碼。您也必須在這裡傳遞認證。

// 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，並視需要指定輸入識別碼。
- 將合約指定為「InterfaceTables_FND_APPS_MS_SAMPLE_EMPLOYEE」，以輪詢MS_SAMPLE_EMPLOYEE介面資料表。
```
// Add service endpoint: be sure to specify InterfaceTables_FND_APPS_MS_SAMPLE_EMPLOYEE as the contract
Uri ConnectionUri = new Uri("oracleebs://ebs_instance_name");
serviceHost.AddServiceEndpoint("InterfaceTables_FND_APPS_MS_SAMPLE_EMPLOYEE", binding, ConnectionUri);
```
若要接收輪詢資料，請開啟服務主機。每當查詢傳回結果集時，配接器就會傳回資料。
```
// Open the service host to begin polling
serviceHost.Open();
```
若要終止輪詢，請關閉服務主機。

重要

配接器會繼續輪詢，直到服務主機關閉為止。
```
serviceHost.Close();
```

範例

下列範例顯示輪詢應用程式，此應用程式會輪詢MS_SAMPLE_EMPLOYEE介面資料表。 PollingInput屬性包含 select 語句，可讀取MS_SAMPLE_EMPLOYEE資料表中的所有資料，而 post poll 語句會刪除相同資料表中的所有資料。第一個輪詢訊息會提供來自 MS_SAMPLE_EMPLOYEE 介面資料表的所有記錄。後續輪詢訊息不會包含任何記錄，因為 post poll 語句會刪除記錄。在將更多資料新增至 MS_SAMPLE_EMPLOYEE 介面資料表之前，您不會收到任何輪詢訊息。因此，您必須使用新的記錄重新填入MS_SAMPLE_EMPLOYEE介面資料表。您可以執行範例所提供的 insert_apps_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 SelectPolling_ServiceModel
{
    [ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]

    public class PollingService : OracleEBSBindingNamespace.OracleEBSBindingService
    {
        public override void Poll(Poll request)
        {
            Console.WriteLine("\nNew Polling Records Received");
            Console.WriteLine("*************************************************");
            Console.WriteLine("Emp No\tName\tDesignation\tSalary");
            for (int i = 0; i < request.DATA.Length; i++)
            {
                Console.WriteLine("{0}\t{1}\t{2}\t{3}",
                request.DATA[i].EMP_NO,
                request.DATA[i].NAME,
                request.DATA[i].DESIGNATION,
                request.DATA[i].SALARY);
            }
            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 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 = "myOracleEBSUserName";
                binding.OraclePassword = "myOracleEBSPassword";
                binding.OracleEBSResponsibilityName = "myOracleEBSResponsibility";

                // 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("InterfaceTables_FND_APPS_MS_SAMPLE_EMPLOYEE", 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

共用方式為