問題:在MSSQLServer中定義的存儲過程可以直接返回一個數據集,如:create procedure sp_getAllEmployeesasSELECT * FROM [NORTHWND].[dbo].[Employees]在Oracle資料庫中這樣定義是錯誤的,怎麼解決?辦法: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#訪問存儲過程的腳本如下:
1 //定義連接對象 2 OracleConnection conn = new OracleConnection("Data Source=orcl;Persist Security Info=True;User ID=t52;Unicode=True;Password=t52"); 3 //註意:包名.存儲過程名的形式 4 OracleCommand cmd = new OracleCommand("pkg_products.proc_GetAllProducts", conn); 5 //設置命令類型為存儲過程 6 cmd.CommandType = CommandType.StoredProcedure; 7 //定義參數,註意參數名必須與存儲過程定義時一致,且類型為OracleType.Cursor 8 OracleParameter cur_set = 9 new OracleParameter("cur_set", OracleType.Cursor); 10 //設置參數為輸出類型 11 cur_set.Direction = ParameterDirection.Output; 12 //添加參數 13 cmd.Parameters.Add(cur_set); 14 //打開連接 15 conn.Open(); 16 //執行並返回OracleDataReader,註意使用後釋放 17 return cmd.ExecuteReader(CommandBehavior.CloseConnection);
註意項目要添加引用程式集:System.Data.OracleClient,代碼中也要using;另外如果使用sql語句在C#中作為字元串出現時儘量不要換行,也不要以分號結尾。上面訪問資料庫的代碼沒有封裝,返回DataSet,DataTable也可以,示例代碼如下: