WCF チャネル モデルを使用して Oracle Database で挿入操作を実行する

このセクションでは、チャネルを使用して Oracle データベースにレコードを挿入する方法について説明します。 メッセージを送信するときは、メッセージ本文とメッセージ アクションの両方を指定する必要があります。

メッセージの挿入

次の XML は、HR に対する挿入操作のメッセージ本文を示しています。EMPLOYEES テーブル。 レコード セットは、1 つの従業員レコードで構成されます。 挿入メッセージのスキーマの詳細については、「 テーブルとビューに対する基本的な挿入、更新、削除、および選択操作のメッセージ スキーマ」を参照してください。 これは、この例で使用されている Employee_Insert.xml ファイルの内容です。

<!-- New namespace: http://Microsoft.LobServices.OracleDB/2007/03/HR/Table/EMPLOYEES -->  
<Insert xmlns="http://Microsoft.LobServices.OracleDB/2007/03/HR/Table/EMPLOYEES">  
    <RECORDSET xmlns:i="http://www.w3.org/2001/XMLSchema-instance">  
        <EMPLOYEESRECORDINSERT>  
            <EMPLOYEE_ID>0</EMPLOYEE_ID>  
            <FIRST_NAME>Anton</FIRST_NAME>  
            <LAST_NAME>Kirilov</LAST_NAME>  
            <EMAIL></EMAIL>  
            <PHONE_NUMBER>555-0198</PHONE_NUMBER>  
            <HIRE_DATE>2007-03-01T00:00:00.0000000</HIRE_DATE>  
            <JOB_ID>FI_ACCOUNT</JOB_ID>  
            <SALARY>5000</SALARY>  
            <COMMISSION_PCT>0.15</COMMISSION_PCT>  
            <MANAGER_ID>108</MANAGER_ID>  
            <DEPARTMENT_ID>100</DEPARTMENT_ID>  
       </EMPLOYEESRECORDINSERT>  
    </RECORDSET>  
</Insert>  

メッセージ アクションの指定

Oracle Database アダプターに SOAP メッセージを送信するときは、メッセージ アクションを指定する必要があります。 次の例のように、メッセージを作成するときにメッセージ アクションを指定できます。

Message messageIn2 = Message.CreateMessage(MessageVersion.Default, "http://Microsoft.LobServices.OracleDB/2007/03/HR/Table/EMPLOYEES/Insert", readerIn2);  

この例のメッセージ アクション "/HR/Table/EMPLOYEES/Insert" は、HR に対する挿入操作を指定します。EMPLOYEES テーブルを実行する

挿入メッセージの送信

この例では、チャネルに対して Oracle テーブルに対して挿入操作を実行する方法を示します。 このコードでは、Oracle Database アダプターによって公開される SQLEXECUTE 操作を使用して、Oracle SEQUENCE の次の値を返します。 この値は、[挿入] レコードの [EMPLOYEE_ID] フィールドに書き込まれます。 このパターンを使用すると、自動生成された主キー値を持つデータベースに行を挿入できます。 チャネルを介した SQLEXECUTE 操作の呼び出しの詳細については、「 WCF チャネル モデルを使用して SQLEXECUTE 操作を実行する」を参照してください。

using System;  
using System.Collections.Generic;  
using System.Text;  
using System.Xml;  
using System.IO;  
  
using System.ServiceModel;  
using System.ServiceModel.Channels;  
  
using Microsoft.ServiceModel.Adapters;  
using Microsoft.Adapters.OracleDB;  
  
namespace OracleDMLChannel  
{  
    class Program  
    {  
        static void Main(string[] args)  
        {  
            // Create Endpoint  
            EndpointAddress address = new EndpointAddress("oracledb://ADAPTER");  
  
            // Create Binding  
            OracleDBBinding binding = new OracleDBBinding();  
  
            // Create Channel Factory  
            ChannelFactory<IRequestChannel> factory = new ChannelFactory<IRequestChannel>(binding, address);  
            factory.Credentials.UserName.UserName = "HR";  
            factory.Credentials.UserName.Password = "TIGER";  
            factory.Open();  
  
            // Create Request Channel  
            IRequestChannel channel = factory.CreateChannel();  
            channel.Open();  
  
            // Send Request  
            System.Xml.XmlReader readerIn = System.Xml.XmlReader.Create("SQLExecute.xml");  
  
            Message messageIn = Message.CreateMessage(MessageVersion.Default, "http://Microsoft.LobServices.OracleDB/2007/03/SQLEXECUTE", readerIn);  
            Message messageOut = channel.Request(messageIn);  
  
            // Get Response XML  
            XmlReader readerOut = messageOut.GetReaderAtBodyContents();  
  
            // Get Employee ID  
            string id = null;  
            XmlDocument doc = new XmlDocument();  
            doc.Load(readerOut);  
            XmlNodeList list = doc.GetElementsByTagName("ColumnValue");  
            if (list.Count > 0) id = list[0].InnerXml;  
  
            // Compose Insert XML  
            XmlDocument insertDoc = new XmlDocument();  
            insertDoc.Load("Employee_Insert.xml");  
  
            // Change Employee ID  
            XmlNodeList empidList = insertDoc.GetElementsByTagName("EMPLOYEE_ID");  
            XmlNode empidNode = empidList[0];  
            empidNode.InnerXml = id;  
  
            // Change email  
            XmlNodeList emailList = insertDoc.GetElementsByTagName("EMAIL");  
            XmlNode emailNode = emailList[0];  
            emailNode.InnerXml = "scotty" + id + "@microsoft.com";  
  
            // Change date  
            XmlNodeList dateList = insertDoc.GetElementsByTagName("HIRE_DATE");  
            XmlNode dateNode = dateList[0];  
            dateNode.InnerXml = "2007-03-01T00:00:00.0000000";  
  
            StringReader strReader = new StringReader(insertDoc.InnerXml);  
            XmlReader readerIn2 = XmlReader.Create(strReader);  
  
            // Send XML  
            Message messageIn2 = Message.CreateMessage(MessageVersion.Default, "http://Microsoft.LobServices.OracleDB/2007/03/HR/Table/EMPLOYEES/Insert ", readerIn2);  
            Message messageOut2 = channel.Request(messageIn2);  
  
            // Close the messages  
            messageOut.Close();  
            messageOut2.Close();  
  
            channel.Close();  
        }  
    }  
}  

参照

WCF チャネル モデルを使用して Oracle Database アプリケーションを開発する
Oracle Database を使用してチャネルを作成する
WCF チャネル モデルを使用して SQLEXECUTE 操作を実行する
WCF チャネル モデルを使用して Oracle データベースで関数を呼び出す