大規模なデータベース システムでは、ストアド プロシージャとトリガーが重要な役割を果たします。ストアド プロシージャであってもトリガーであっても、SQL ステートメントとフロー制御ステートメントの集合です。
ORACLE コード
CREATE OR REPLACE PROCEDURE gd_CURSOR(MYCS1 OUT SYS_REFCURSOR,MYCS2 OUT SYS_REFCURSOR,a out varchar)as BEGIN a:='test'; OPEN MYCS1 FOR SELECT 1 from dual; OPEN MYCS2 FOR SELECT 2 from dual; END;
C# コード
/// <summary> /// 执行oracle存储过程返回多个结果集 /// </summary> /// <param name="strProcName">存储过程名称</param> /// <param name="ResultCount">返回个数</param> /// <param name="paras">参数</param> /// <returns>任意对象数组</returns> public object[] ExcuteProc_N_Result(string strProcName, int ResultCount, params OracleParameter[] paras) { using (OracleConnection conn = new OracleConnection("User ID=用户名;Password=密码;Data Source=数据库;")) { OracleCommand cmd = new OracleCommand(strProcName, conn); if (paras != null && paras.Length > 0) { for (int j = 0; j < paras.Length; j++) { if (paras[j].Value == null) { paras[j].Value = DBNull.Value; } } } cmd.Parameters.AddRange(paras); cmd.CommandType = CommandType.StoredProcedure; conn.Open(); cmd.ExecuteNonQuery(); int i = 0; //int nOutputParametersCount = 0; object[] objResult = new object[ResultCount]; foreach (OracleParameter p in cmd.Parameters) { if (p.Direction == ParameterDirection.Output || p.Direction == ParameterDirection.InputOutput) { if (p.Value is OracleDataReader) { OracleDataReader reader = p.Value as OracleDataReader; objResult[i++] = ConvertDataReaderToDataTable(reader); } else { objResult[i++] = p.Value; } } } return objResult; } } /// <summary> /// 将DataReader 转为 DataTable /// </summary> /// <param name="DataReader">OleDbDataReader</param> protected DataTable ConvertDataReaderToDataTable(OracleDataReader reader) { DataTable objDataTable = new DataTable("TmpDataTable"); try { int intFieldCount = reader.FieldCount;//获取当前行中的列数; for (int intCounter = 0; intCounter <= intFieldCount - 1; intCounter++) { objDataTable.Columns.Add(reader.GetName(intCounter), reader.GetFieldType(intCounter)); } //populate datatable objDataTable.BeginLoadData(); //object[] objValues = new object[intFieldCount -1]; object[] objValues = new object[intFieldCount]; while (reader.Read()) { reader.GetValues(objValues); objDataTable.LoadDataRow(objValues, true); } reader.Close(); objDataTable.EndLoadData(); return objDataTable; } catch (Exception ex) { throw new Exception("转换出错出错!", ex); } }
メソッドの呼び出し
OracleParameter[] oracleParameter = new OracleParameter[]{ new OracleParameter("MYCS1",OracleType.Cursor), new OracleParameter("MYCS2",OracleType.Cursor), new OracleParameter("a",OracleType.VarChar,200), }; oracleParameter[0].Direction = ParameterDirection.Output; oracleParameter[1].Direction = ParameterDirection.Output; oracleParameter[2].Direction = ParameterDirection.Output; object[] xxx = ExcuteProc_N_Result("gd_CURSOR", 3, oracleParameter);
上記のコンテンツでは、コードを通じて asp.net の Oracle ストアド プロシージャを紹介します。
次に、2 番目の方法で Oracle ストアド プロシージャ (画像とテキスト) を紹介します。
次の方法と手順を参照してください
ステップ 1: COST
など、ORACLE に付属する Net Manager 経由で接続する必要があるデータベースを構成します。ステップ 2: PL/SQL データベース ツールを開き、正しいユーザー名とパスワードを入力し、「OK」をクリックしてストアド プロシージャを作成する必要があるユーザーを入力します
ステップ 3: 一般的なストアド プロシージャの形式を理解する
プロシージャ ストアド プロシージャ名を作成または置換します (param1 in タイプ、param2 out タイプ)
として
変数 1 の型 (値の範囲);
変数 2 の型 (値の範囲);
開始
ステートメントブロック
例外 -- 例外処理
他の人がその時
ロールバック;
終了;
ステップ 4: SQL 入力インターフェイスに作成するストアド プロシージャを入力します
create or replace procedure sp_demo(param1 in varchar2,param2 out varchar2) /* * 存储过程实例 */ as cnt int; rst varchar2(100) Begin Select count(*) into cst from Tab_Demo where Col_Value = param1; If (cst > 0) then --判断条件 param2 := '有匹配的值'; Else param2 := '无匹配的值'; End if; Exception When others then Rollback; End;
以下に示すように
ステップ 5: 作成したストアド プロシージャをテストする
exec sp_demo('male');
終了
メモ
別のストアド プロシージャ内のストアド プロシージャを削除することはできません。別のストアド プロシージャを呼び出すことのみが可能です
作成プロシージャまたは置換プロシージャを使用する場合、ストアド プロシージャを作成するときに、ユーザーの下にある既存のストアド プロシージャと同じ名前を持たないよう注意してください。これにより、現在のストアド プロシージャが上書きされます
ストアド プロシージャ パラメータには値の範囲がありません。in は受信を意味し、out は出力を意味します
上記では、Oracle ストアド プロシージャを 2 つの方法で紹介していますが、皆さんのお役に立てば幸いです。