文章詳情頁
用.NET調用oracle存儲過程返回記錄集
瀏覽:32日期:2023-11-12 19:04:05
Oracle的存儲過程返回記錄集,要害之處是要用游標。 關于數據庫的游標(cursor)大家肯定都接觸不少,我們可以通過OPEN,FETCH,CLOSE操作控制游標進行各種方便的操作,這方面的例子我就不在重復了。我們現在要介紹的是游標變量(cursor variable)。類似游標,游標變量也是指向一個查詢結果集的當前行。不同的是,游標變量能為任何類型相似(type-compatible)的查詢打開,而并不是綁定到某一個特定的查詢。通過游標變量,你可以在數據庫的數據提取中獲得更多的方便。 首先是建立表: CREATE TABLE LIHUAN.BILL_POINTS ( POINTS_ID NUMBER(10,0) NOT NULL, CUSTOMER_ID NUMBER(10,0) NOT NULL, BILL_POINT_NO NUMBER(2,0) DEFAULT 1 NOT NULL, CONSTRAINT PK_BILL_POINTS PRIMARY KEY (POINTS_ID) ) / 其次,建PACKAGE CREATE OR REPLACE PACKAGE LIHUAN.YY_PKG_BILL_POINT_NO/*取得用戶的所有計費電序號*/ IS TYPE T_CURSOR IS REF CURSOR; PROCEDURE BILL_POINT_NO(P_CUSTOMER_ID BILL_POINTS.CUSTOMER_ID%TYPE, Re_CURSOR OUT T_CURSOR); END; / 再次,建PACKAGE BODY CREATE OR REPLACE PACKAGE BODY LIHUAN.YY_PKG_BILL_POINT_NO/*取得用戶的所有計費電序號*/ IS PROCEDURE BILL_POINT_NO(P_CUSTOMER_ID BILL_POINTS.CUSTOMER_ID%TYPE, Re_CURSOR OUT T_CURSOR) IS V_CURSOR T_CURSOR; BEGIN OPEN V_CURSOR FOR select Bill_Point_No from BILL_POINTS where CUSTOMER_ID =P_CUSTOMER_ID; Re_CURSOR := V_CURSOR; END; END; / 最后,在.NET中程序調用。 public DataSet Bill_Point_No(string CUSTOMER_ID)//ok { DataSet dataset = new DataSet(); Hashtable HT=new Hashtable(); HT.Add('P_CUSTOMER_ID',CUSTOMER_ID); if(RunProcedure('Re_CURSOR',OracleType.Cursor,ref dataset,HT,bmsOracleUser+'.YY_PKG_BILL_POINT_NO.BILL_POINT_NO',bmsOracleConnectionString)) { ; } else { dataset=null; } return dataset; } public bool RunProcedure(string ReturnParameter,OracleType ParamType,ref DataSet Dataset,Hashtable HT ,string ProcedureName,string OracleConnection) { System.Data.OracleClient.OracleConnection dsconnection = new System.Data.OracleClient.OracleConnection(OracleConnection); System.Data.OracleClient.OracleCommand dacommand = new System.Data.OracleClient.OracleCommand(ProcedureName,dsconnection); dsconnection.Open(); dacommand.CommandType=CommandType.StoredProcedure; IDictionaryEnumerator Enumerator; Enumerator = HT.GetEnumerator(); object Value=null; OracleParameter OracleParam; OracleParam = dacommand.Parameters.Add(new OracleParameter(ReturnParameter,ParamType)); OracleParam.Direction = ParameterDirection.Output; while(Enumerator.MoveNext()) { Value = Enumerator.Value; OracleParam=dacommand.Parameters.Add(new OracleParameter(Enumerator.Key.ToString(), Value)); } OracleDataAdapter ODAdapter=new OracleDataAdapter(dacommand); try { ODAdapter.Fill(Dataset); return true; } catch(System.Exception e) { e.ToString(); return false; } finally { HT.Clear(); dacommand.Parameters.Clear(); dsconnection.Close(); } }
排行榜
