.net 呼叫Oracle儲存過程

阿新 • • 發佈：2019-01-11

在.NET中呼叫Oracle9i儲存過程經驗總結(1)

在.NET中呼叫Oracle9i儲存過程可以用多個數據提供者，比如OralceClient，OleDb。本文將用OralceClient為例。.NET語言用C#。

一、呼叫一個帶輸入、輸出引數的儲存過程

首先，在Oralce中建立儲存過程如下：

create or replace procedure GetRecords(name_out out varchar2,age_in in varchar2) 
as
begin
select NAMEinto name_out from test where AGE = age_in;
end;

然後，在C#專案中作如下呼叫：

string connectionString = "DataSource=YXZHANG;User ID=YXZHANG;Password=YXZHANG";
     string queryString = "getrecords";
    OracleConnection cn = newOracleConnection(connectionString);
    OracleCommand cmd = newOracleCommand(queryString,cn);
    cmd.CommandType = CommandType.StoredProcedure;
    cmd.Parameters.Add("name_out",OracleType.VarChar,20);
    cmd.Parameters["name_out"].Direction = ParameterDirection.Output;
    cmd.Parameters.Add("age_in",21);
    
     try
     {
        cn.Open();
        cmd.ExecuteNonQuery();
        Console.WriteLine("Nameis:{0}",cmd.Parameters["name_out"].Value.ToString());
        cn.Close();
     }
     catch( OracleException ex )
     {
        Console.WriteLine("Exception occurred!");
        Console.WriteLine("The exception messageis:{0}",ex.Message.ToString());
     }
     finally
     {
        Console.WriteLine("------------------End-------------------");
     }

小結：

以上是很平常的呼叫方法，但是我在做這個示例程式的時候，卻不是那麼一帆風順。這裡要指出OracleClient的一個不盡如人意之處，就是對於引數名稱，必須和儲存過程定義中的引數同名，否則就會報錯。比如將程式碼中的“name_out”改為別的名稱的話，就會報異常。但我試著用OleDb代替OralceClient，卻沒有這個問題。不知道在新版本的資料提供程式中會否改進這一點？

二、呼叫不返回資料的儲存過程

首先，在Oralce中建立儲存過程如下：

create or replace procedure insertRecord(UserID in varchar2,
UserName in varchar2,
                                        UserAge in varchar2) is
    begin
     insert into test values(UserID, UserName, UserAge);
    end;

然後，在C#專案中作如下呼叫：

string connectionString= "Data Source=YXZHANG;User ID=YXZHANG;Password=YXZHANG";
string queryString ="insertRecord";
OracleConnection cn = newOracleConnection(connectionString);
OracleCommand cmd = newOracleCommand(queryString,cn);
cmd.CommandType = CommandType.StoredProcedure;
     cmd.Parameters.Add("UserID","007");
    cmd.Parameters.Add("UserName","Dell");
    cmd.Parameters.Add("UserAge","40");     
     try
     {
        cn.Open();
        cmd.ExecuteNonQuery();
        Console.WriteLine("Record inserted!");
        cn.Close();
     }
     catch( OracleException ex )
     {
        Console.WriteLine("Exception occurred!");
        Console.WriteLine("The exception messageis:{0}",ex.Message.ToString());
     }
     finally
     {
        Console.WriteLine("------------------End-------------------");
     }

小結：

不返回資料的儲存過程一般有Delete, Insert, Update等。雖然它們的SQL語句不同，但是呼叫方面都是一樣的。只要傳入正確的引數，一般不會出什麼問題。不過還是要注意，在使用OralceClient作為資料提供者的時候，引數名稱一定要和儲存過程定義中的一致！至於引數新增的順序倒是無所謂的，因為有引數名稱作為區別。

在.NET中呼叫Oracle9i儲存過程經驗總結(2)

三、IDENTITY 和 SEQUENCE

Sql Server中，定義一個列為遞增列很容易，但我在Oracle中卻怎麼也找不到設定的方法。不過查了點資料後知道Oracle中有個叫Sequence的物件，產生一個唯一的序列號，類似於Sql Server中的IDENTITY。於是，我做了如下實驗：

首先，在Oracle中建立了一個名為TEST_SEQ的Sequence物件，SQL語句如下：

create sequence TEST_SEQ
minvalue 100
maxvalue 999
start with 102
increment by 1
nocache;

語法應該是比較易懂的，最小最大值分別用minvalue,maxvalue表示，初始值是102（這個數字是動態變化的，我建立的時候設的是100，後因插入了2條資料後就自動增加了2），increment當然就是步長了。在PL/SQL中可以用test_seq.nextval訪問下一個序列號，用test_seq.currval訪問當前的序列號。

定義完了Sequence，接下來就是建立一個儲存過程InsertRecordWithSequence：

--這次我修改了test表的定義，和前面的示例不同。其中，UserID是PK。

create or replace procedureInsertRecordWithSequence(UserID   out number,
                                                        UserName in varchar2,
                                                        UserAge  in number)
is
begin
        insert into test(id, name,age)         --插入一條記錄，PK值從Sequece獲取
        values(test_seq.nextval, UserName,UserAge);
/*返回PK值。注意Dual表的用法*/
select test_seq.currval intoUserIDfrom dual;   
end InsertRecordWithSequence;

接下來，就是在C#中進行呼叫了：

string connectionString= "Data Source=YXZHANG;User ID=YXZHANG;Password=YXZHANG";
     string queryString ="InsertRecordWithSequence";
    OracleConnection cn = newOracleConnection(connectionString);
    OracleCommand cmd = new OracleCommand(queryString,cn);
    cmd.CommandType = CommandType.StoredProcedure;
    cmd.Parameters.Add("UserID",OracleType.Number);
    cmd.Parameters["UserID"].Direction = ParameterDirection.Output;
     cmd.Parameters.Add("UserName","Jack");
    cmd.Parameters.Add("UserAge",40); 
     try
     {
         cn.Open();
         int rowAffected =cmd.ExecuteNonQuery();
         Console.WriteLine("{0}行已插入。",rowAffected);
         Console.WriteLine("插入行的ID為：{0}",cmd.Parameters["UserID"].Value.ToString());
        cn.Close();
     }
     catch( OracleException ex )
     {
        Console.WriteLine("Exception occurred!");
        Console.WriteLine("The exception messageis:{0}",ex.Message.ToString());
     }
     finally
     {
        Console.WriteLine("------------------End-------------------");
     }

小結：

使用Sequece物件可以很容易地建立唯一序列，在儲存過程中的呼叫也十分方便，只要sequence_name.nextval以及sequence.currval就能得到下一個以及當前的序列值。倒是Dual表值得注意。

在.NET中呼叫Oracle儲存過程經驗總結(3)

四、使用DataReader讀取返回的結果集

為了讓儲存過程返回結果集，必須定義一個遊標變數作為輸出引數。這和Sql Server中有著很大的不同！並且還要用到Oracle中“包”（Package）的概念，似乎有點繁瑣，但熟悉後也會覺得很方便。

關於“包”的概念，有很多內容可以參考，在此就不贅述了。首先，我建立了一個名為TestPackage的包，包頭是這麼定義的：

 create or replace package TestPackage is
    typemycursor is ref cursor; --定義遊標變數
     procedureGetRecords(ret_cursor out mycursor);-- 定義過程，用遊標變數作為返回引數
endTestPackage;

包體是這麼定義的：

create orreplace package body TestPackage is
/*過程體*/
         procedure GetRecords(ret_cursor outmycursor) as
         begin
             open ret_cursor for select*from test;
         end GetRecords;
endTestPackage;

已經萬事具備了，讓我們前臺呼叫試試：

string connectionString= "Data Source=YXZHANG;User ID=YXZHANG;Password=YXZHANG";
     string queryString ="TestPackage.GetRecords";    //注意呼叫方法
    OracleConnection cn = newOracleConnection(connectionString);
    OracleCommand cmd = newOracleCommand(queryString,cn);
    cmd.CommandType = CommandType.StoredProcedure;
    cmd.Parameters.Add("ret_cursor",OracleType.Cursor);    //注意這裡的型別
     cmd.Parameters["ret_cursor"].Direction =ParameterDirection.Output;
    
     try
     {
        cn.Open();
        OracleDataReader dr = cmd.ExecuteReader();
        int i = 1;
        while( dr.Read() )
        {
             Console.WriteLine("Record {0}:",i++);
             Console.WriteLine("ID:{0}   Name:{1} Age:{2}",
dr.GetOracleNumber(0),
dr.GetOracleString(1),
dr.GetOracleNumber(2));
             Console.WriteLine();
        }
        dr.Close();        //用完DataReader物件要記得及時關閉
        cn.Close();        //DataReader物件未關閉之前，不能關閉連線
     }
     catch( OracleException ex )
     {
        Console.WriteLine("Exception occurred!");
        Console.WriteLine("The exception messageis:{0}",ex.Message.ToString());
     }
     finally
     {
        Console.WriteLine("------------------End-------------------");
     }

請看結果：

Record 1:

ID:100 Name:Tony Age:23

Record 2:

ID:101 Name:Jack Age:40

------------------End-------------------

小結：

包是Oracle特有的概念，Sql Server中找不到相匹配的東西。在我看來，包有點像VC++的類，包頭就是.h檔案，包體就是.cpp檔案。包頭只負責定義，包體則負責具體實現。如果包返回多個遊標，則DataReader會按照您向引數集合中新增它們的順序來訪問這些遊標，而不是按照它們在過程中出現的順序來訪問。可使用DataReader的NextResult()方法前進到下一個遊標。

在.NET中呼叫Oracle儲存過程經驗總結(4)

五、用返回的結果集填充DataSet

ADO.NET捨棄了原來ADO中RecordSet的概念，而使用全新的DataSet來替代。DataSet可以提供更加強大的功能！有了前面的基礎，利用ADO.NET從Oralce返回DataSet也是非常簡單的。主要思想就是用DataAdapter接收返回的遊標，再用DataAdapter的Fill()方法填充資料集。在下面的例子中，我仍用了前一個例子中建好的TestPackage包。

下面是前臺呼叫主要程式碼：

string connectionString= "Data Source=YXZHANG;User ID=YXZHANG;Password=YXZHANG";
     string queryString = "TestPackage.GetRecords";
    OracleConnection cn = newOracleConnection(connectionString);
    OracleCommand cmd = newOracleCommand(queryString,cn);
    cmd.CommandType = CommandType.StoredProcedure;
    cmd.Parameters.Add("ret_cursor",OracleType.Cursor);
    cmd.Parameters["ret_cursor"].Direction = ParameterDirection.Output;
    
     try
     {
        cn.Open();
        OracleDataAdapter da = newOracleDataAdapter(cmd);
        DataSet ds = new DataSet();
        da.Fill(ds,"TestTable");
        cn.Close();
        for( int i =0;i <= ds.Tables["TestTable"].Rows.Count-1;i++ )
        {
             string id =ds.Tables["TestTable"].Rows[i]["ID"].ToString();
             string name =ds.Tables["TestTable"].Rows[i]["NAME"].ToString();
             string age =ds.Tables["TestTable"].Rows[i]["AGE"].ToString();
             Console.WriteLine("Record {0}:",i+1);
             Console.WriteLine("ID:{0}\tName:{1}\tAge:{2}\n",id,name,age);
        }
     }
     catch( OracleException ex )
     {
        Console.WriteLine("Exception occurred!");
        Console.WriteLine("The exception messageis:{0}",ex.Message.ToString());
     }
     finally
     {
        Console.WriteLine("------------------End-------------------");
     }

小結：

程式呼叫後的結果和剛才用DataReader呼叫的結果一樣。這裡只說明怎樣利用ADO.NET呼叫Oracle儲存過程，以及怎樣填充至資料集中。至於怎樣操縱DataSet，不是本文的討論範圍。有興趣的讀者可以參考MSDN以及相關書籍。

在.NET中呼叫Oracle儲存過程經驗總結(5)

六、用DataAdapter更新資料庫

通常用DataAdapter取回DataSet，將會對DataSet進行一些修改，繼而更新資料庫（如果只是為了獲取資料，微軟推薦使用DataReader代替DataSet）。然而，通過儲存過程更新資料庫，並不是那麼簡單，不能簡單地通過DataAdapter的Update()方法進行更新。必須手動為DataAdapter新增InsertCommand, DeleteCommand,UpdateCommand，因為儲存過程對這些操作的細節是不知情的，必須人為給出。

為了達成這個目標，我完善了之前的TestPackage包，包頭如下：

create or replace package TestPackage is
     typemycursor is ref cursor;
     procedureUpdateRecords(id_in in number,newNamein varchar2,newAgein number);
     procedureSelectRecords(ret_cursor out mycursor);
     procedureDeleteRecords(id_in in number);
     procedureInsertRecords(name_in in varchar2, age_inin number);
endTestPackage;

包體如下：

create orreplace package body TestPackage is
    procedure UpdateRecords(id_in in number,newName in varchar2, newAge  in number) as
    begin
     update test set age = newAge, name= newNamewhere id = id_in;
    end UpdateRecords;

    procedure SelectRecords(ret_cursor outmycursor)as
    begin
       open ret_cursor for select* from test;
    end SelectRecords;

    procedure DeleteRecords(id_in in number)as
    begin
       delete from test whereid = id_in;
    end DeleteRecords;

    procedure InsertRecords(name_in in varchar2,age_inin number) as
    begin
       insert into test values(test_seq.nextval, name_in, age_in);
--test_seq是一個已建的Sequence物件，請參照前面的示例
endInsertRecords;
    end TestPackage;

前臺呼叫程式碼如下，有點繁瑣，請耐心閱讀：

string connectionString = "Data Source=YXZHANG;User ID=YXZHANG;Password=YXZHANG";
     string queryString ="TestPackage.SelectRecords";
    OracleConnection cn = newOracleConnection(connectionString);
    OracleCommand cmd = newOracleCommand(queryString,cn);
    cmd.CommandType = CommandType.StoredProcedure;
    cmd.Parameters.Add("ret_cursor",OracleType.Cursor);
     cmd.Parameters["ret_cursor"].Direction =ParameterDirection.Output;
    
     try
     {
         cn.Open();
         OracleDataAdapter da = newOracleDataAdapter(cmd);
         DataSet ds = new DataSet();
         da.Fill(ds,"TestTable");
         cn.Close();
         int count =ds.Tables["TestTable"].Rows.Count;
        
         /*列印原始記錄*/
         Console.WriteLine("Old Records is:");
         for( int i = 0;i <= count - 1;i++ )
        {
             string id =ds.Tables["TestTable"].Rows[i]["ID"].ToString();
             string name =ds.Tables["TestTable"].Rows[i]["NAME"].ToString();
             string age =ds.Tables["TestTable"].Rows[i]["AGE"].ToString();
 
             Console.WriteLine("Record {0}:",i+1);
             Console.WriteLine("ID:{0}\tName:{1}\tAge:{2}\n",id,name,age);
        }
        
        da.SelectCommand = cmd;    //為DataAdapter指定SelectCommand
 
        OracleCommand updateCmd = newOracleCommand("TestPackage.UpdateRecords",cn);
        updateCmd.CommandType = CommandType.StoredProcedure;
        updateCmd.Parameters.Add("id_in",OracleType.Number,3,"ID");
        updateCmd.Parameters.Add("newName",OracleType.VarChar,20,"NAME");
        updateCmd.Parameters.Add("newAge",OracleType.Number,3,"AGE");
        da.UpdateCommand = updateCmd;        //為DataAdapter指定UpdateCommand
 
        OracleCommand deleteCmd = newOracleCommand("TestPackage.DeleteRecords",cn);
        deleteCmd.CommandType = CommandType.StoredProcedure;
        deleteCmd.Parameters.Add("id_in",OracleType.Number,3,"ID");
        da.DeleteCommand = deleteCmd;        //為DataAdapter指定DeleteCommand
 
        OracleCommand insertCmd = newOracleCommand("TestPackage.InsertRecords",cn);
         insertCmd.CommandType = CommandType.StoredProcedure;
        insertCmd.Parameters.Add("name_in",OracleType.VarChar,20,"NAME");
        insertCmd.Parameters.Add("age_in",OracleType.Number,3,"AGE");
        da.InsertCommand = insertCmd;        //為DataAdapter指定InsertCommand
 
        DataTable newTable = ds.Tables["TestTable"];
        
        /*修改第一條記錄*/
        newTable.Rows[0]["AGE"] = 22;
        newTable.Rows[0]["NAME"] = "John";
        
        /*刪除一條記錄*/
        newTable.Rows[2].Delete();
 
        /*插入一條記錄*/
        DataRow newRow = newTable.NewRow();
        newRow["NAME"] = "Bob";
        newRow["AGE"] = 99;
        newTable.Rows.Add(newRow);
 
        cn.Open();
        da.Update(newTable);       //將更改更新到資料庫
        newTable.Clear();            //清空DataTable
        da.Fill(newTable);           //獲取更改後的資料
        cn.Close();
 
        /*列印新記錄*/
        Console.WriteLine("New Records is:");
        for( int i =0;i <= newTable.Rows.Count - 1;i++ )
        {
             string id =newTable.Rows[i]["ID"].ToString();
             string name =newTable.Rows[i]["NAME"].ToString();
             string age =newTable.Rows[i]["AGE"].ToString();
 
             Console.WriteLine("Record {0}:",i+1);
            Console.WriteLine("ID:{0}\tName:{1}\tAge:{2}\n",id,name,age);
        }
     }
     catch( OracleException ex )
     {
         Console.WriteLine("Exception occurred!");
         Console.WriteLine("The exception messageis:{0}",ex.Message.ToString());
     }
     finally
     {
        Console.WriteLine("------------------End-------------------");
}

執行結果如下：

Old Records is:

Record 1:

ID:100 Name:Tony Age:23

Record 2:

ID:101 Name:Jack Age:34

Record 3:

ID:103 Name:newAdd Age:100

New Records is:

Record 1:

ID:100 Name:John Age:22

Record 2:

ID:101 Name:Jack Age:34

Record 3:

ID:104 Name:Bob Age:99

------------------End-------------------

小結：

使用Update()方法更新資料庫是非常有用的，但是隻侷限於單個表，對於表連線的情況，還是直接用OracleCommand的ExcuteNonQuery()方法去執行更新操作比較方便。

七、本文總結：

在.NET中利用ADO.NET呼叫Oralce9i中的儲存過程，函式，包等，可以提高效率，也能完成一些複雜的業務邏輯。然而呼叫Oracle儲存過程和Sql Server中有著很大不同，最需要明確的一個思想就是：在Oracle的過程中，所有返回值必須以輸出引數的形式出現。在Oracle中，要返回一個結果集，就必須把REF CURSOR作為返回引數，因此就要用到包。包類似於C++中的類，封裝了一些全域性變數、常量和函式，在函式中又可以有自己的私有變數。通過返回給應用程式的遊標，應用程式就可以用DataReader或者DataAdapter接收它，進而做一些處理。還還可以用DataAdapter的Update()方法更新資料庫，當然它需要你給出更新資料庫的一些操作（為其定義處理過程）。

由於筆者是邊學邊寫，以上示例不免有些不妥之處，請多多指教！

.net 呼叫Oracle儲存過程

.net 呼叫Oracle儲存過程

ASP.NET呼叫oracle儲存過程實現快速分頁

C#呼叫ORACLE儲存過程返回結果集

java中呼叫Oracle儲存過程時，出現異常：java.sql.SQLException: ORA-00928: 缺失 SELECT 關鍵字(已解決)

python呼叫oracle儲存過程

C#呼叫oracle儲存過程最簡單的例項

通過shell指令碼呼叫oracle儲存過程並加入定時任務

mybatis 呼叫oracle儲存過程，傳參、返回遊標的值獲取--示例

使用c#呼叫oracle儲存過程獲取儲存過程引數資訊

用指令碼呼叫Oracle儲存過程

OCI 呼叫Oracle 儲存過程實現

幾種應用程式呼叫Oracle儲存過程的方法

C#呼叫Oracle儲存過程並返回結果集

java呼叫oracle儲存過程例子

用java呼叫oracle儲存過程總結

mybatis呼叫Oracle儲存過程返回結果集

hibernate5 呼叫 oracle 儲存過程和函式

mybatis呼叫oracle儲存過程返回sys_refcursor

在Python中使用cx_Oracle呼叫Oracle儲存過程

bat批處理指令碼呼叫oracle儲存過程，系統定時呼叫指令碼

.net 呼叫Oracle儲存過程

相關推薦