關於C#中使用Oracle存儲過程返回結果集的問題

問題:

在MSSQLServer中定義的存儲過程可以直接返回一個數據集,如:

create procedure sp_getAllEmployees
as
SELECT * FROM [NORTHWND].[dbo].[Employees]

在Oracle數據庫中這樣定義是錯誤的,怎麼解決?

辦法:

Oracle中可以使用遊標(Cursor)對數據集進行操作,但在存儲過程輸出參數中直接使用Cursor錯誤,此時的Cursor應該是一個定義遊標的關鍵字並非類型,所以先要定義一個包,在包中聲明全局的自定義遊標類型,如:

/**創建一個名為pkg_products的包**/
create or replace package pkg_products is
--定義一個公有的遊標類型cursor_pdt
--ref 可以在程序間傳遞結果集
--一個程序裡打開遊標變量,在另外的程序裡處理數據
type cursor_pdt is ref cursor;
--聲明一個存儲過程 ,遊標類型參數為輸出類型
procedure proc_GetAllProducts(cur_set out cursor_pdt);
end pkg_products;

這個包(package)有點類似OO中的接口,C++中的文件頭,實現這個包時叫包體(package body),且名稱要相同,如:

/**創建一個包體**/
create or replace package body pkg_products is
  --實現包中沒有實現的存儲過程
  procedure proc_GetAllProducts(cur_set out cursor_pdt) as
    begin 
      --打開遊標,由於定義遊標時使用ref處理遊標可以推遲到客戶端
      open cur_set for select id, name, producttype, price,picture, isout, mark, adddate from products;
      end;
end;

定義成功,且編譯通過,就可以先在Oracle中測試,如:

/**使用過程測試定義的存儲過程**/
declare
--定義遊標類型的變量
cur_set pkg_products.cursor_pdt;
--定義行類型
pdtrow products%rowtype;
begin
  --執行存儲過程
  pkg_products.proc_GetAllProducts(cur_set);
  --遍歷遊標中的數據
       LOOP
         --取當前行數據存入pdtrow
           FETCH cur_set INTO pdtrow;
           --如果未獲取數據就結束循環
           EXIT WHEN cur_set%NOTFOUND;
           --輸出獲取到的數據
           DBMS_OUTPUT.PUT_LINE (pdtrow.id||','||pdtrow.name);
         END LOOP;
         CLOSE cur_set;
  end;

如果運行上面的PL/SQL過程腳本能取到結果,說明定義的包與包體的實現就成功瞭,可以使用.NET,Java或其它程序訪問定義好的存儲過程,如使用C#訪問存儲過程的腳本如下:

//定義連接對象
            OracleConnection conn = new OracleConnection("Data Source=orcl;Persist Security Info=True;User ID=t52;Unicode=True;Password=t52");
            //註意:包名.存儲過程名的形式
            OracleCommand cmd = new OracleCommand("pkg_products.proc_GetAllProducts", conn);
            //設置命令類型為存儲過程
            cmd.CommandType = CommandType.StoredProcedure;
            //定義參數,註意參數名必須與存儲過程定義時一致,且類型為OracleType.Cursor
            OracleParameter cur_set =
                new OracleParameter("cur_set", OracleType.Cursor);
            //設置參數為輸出類型
            cur_set.Direction = ParameterDirection.Output;
            //添加參數
            cmd.Parameters.Add(cur_set);
            //打開連接
            conn.Open();
            //執行並返回OracleDataReader,註意使用後釋放
            return cmd.ExecuteReader(CommandBehavior.CloseConnection);

註意項目要添加引用程序集:System.Data.OracleClient,代碼中也要using;另外如果使用sql語句在C#中作為字符串出現時盡量不要換行,也不要以分號結尾。上面訪問數據庫的代碼沒有封裝,返回DataSet,DataTable也可以,示例代碼如下:

示例代碼下載

求更好的辦法。

到此這篇關於C#中使用Oracle存儲過程返回結果集的文章就介紹到這瞭,更多相關Oracle存儲過程返回結果集內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!

推薦閱讀: