解決C#中用Oracle執行存儲過程返回DataSet的問題
執行存儲過程返回DataSet:
1.存儲過程中 一定要有一個Output參數的游標,以便返回存儲過程
- --建立存儲過程的返回臨時表
- create global temporary table TMP_HIS_PPTN_JP
- (
- STCD VARCHAR2(12) not null,
- STNM VARCHAR2(50),
- ADDVCD VARCHAR2(6),
- RGNNM VARCHAR2(50),
- HISAVG NUMBER(13,3),
- ACCP NUMBER(10,1),
- JP NUMBER(10,2)
- )
- on commit delete rows;--[1]當事務完成后刪除數據
- alter table TMP_HIS_PPTN_JP
- add primary key (STCD);
- --建立存儲過程
- CREATE OR REPLACE PROCEDURE PROC_RAIN_JP(
- V_STCDS VARCHAR2,--要求V_PTM1,V_PTM2不垮年 ,返回臨時表TMP_HIS_PPTN_JP
- V_PTM1 VARCHAR2,
- V_PTM2 VARCHAR2,
- V_CS OUT SYS_REFCURSOR
- )
- AS
- --定義變量......
- BEGIN
- --數據的處理......
- OPEN V_CS FOR SELECT * FROM TMP_HIS_PPTN_JP;
- RETURN ;
- END;
2. 在C#中用Oracle執行存儲過程
- IDbConnection con = this.DBInterface.CreateConnection();//自已定義的數據訪問接口
- con.Open();
- IDbTransaction trans = con.BeginTransaction();
- cmd = con.CreateCommand();
- cmd.Transaction = trans; //Set Transaction For Command
- cmd.CommandType = System.Data.CommandType.StoredProcedure;
- cmd.CommandText = "PROC_RAIN_JP";
- System.Data.OracleClient.OracleParameter p;
- p = new System.Data.OracleClient.OracleParameter("V_STCDS", System.Data.OracleClient.OracleType.VarChar, 2000);
- cmd.Parameters.Add(p);
- p.Direction = System.Data.ParameterDirection.Input;
- p.Value = STC;
- p = new System.Data.OracleClient.OracleParameter("V_PTM1", System.Data.OracleClient.OracleType.VarChar, 20);
- cmd.Parameters.Add(p);
- p.Direction = System.Data.ParameterDirection.Input;
- p.Value = this.getParamValue("SDATE");
- p = new System.Data.OracleClient.OracleParameter("V_PTM2", System.Data.OracleClient.OracleType.VarChar, 20);
- cmd.Parameters.Add(p);
- p.Direction = System.Data.ParameterDirection.Input;
- p.Value = this.getParamValue("EDATE");
- //輸出的DataSet
- p = new System.Data.OracleClient.OracleParameter("V_CS", System.Data.OracleClient.OracleType.Cursor);
- cmd.Parameters.Add(p);
- p.Direction = System.Data.ParameterDirection.Output;//設置為Output
- DataSet ds = new DataSet();
- IDbDataAdapter da = new System.Data.OracleClient.OracleDataAdapter(cmd as System.Data.OracleClient.OracleCommand);
- da.Fill(ds);
- trans.Commit();
- if (con.State != ConnectionState.Closed)
- ...{
- try
- ...{
- con.Close();
- }
- catch
- ...{
- }
- }
- return ds.Tables[0];
3.注意上邊的C#代碼我們是打開的一個事務,為什么呢:
如果我們沒有用事務的話,在sqlplus中調試是沒有任何問題的,但在是.net執行的時間就會報ORA-08103: object no longer exists 錯誤,原因就在存儲過程中,臨時表的創建選項由on commit delete rows[1]如果改為on commit preserve rows; 就不會有問題,但是在ASP.Net頁中查詢臨時表數據時,每查一次都要多出一些重復記錄原因肯定是Oracle的會話連接沒有結束,導致每次執行存儲過程都要先插入記錄。Oracle會話為什么沒有結束,肯定是ASP.NET服務程序在數據連接池中保持著與數據庫的連接。但是為了性能我們也不能不用連接池。這樣基于Oracle 會話的臨時表是不能用了。
重新回到基于Oracle事務的臨時表,也就是臨時表的創建選項用on commit delete rows。然后,在ASP.Net應用程序中調用ODP自身的事務處理機制,這樣C#中用Oracle執行存儲過程返回DataSet的問題得以解決!
注:
(1)理論上,不要在存儲過程中執行Commit,即不要在存儲過程中使用PL/SQL的事務處理, 否則ASP.NET頁面也無法得到數據,因為commit 后,臨時表中數據會自動清空。
(2)理論上,不用ODP的話,用OLEDB或微軟提供的ORACLE事務處理機制應該也可以。
【編輯推薦】