대규모 데이터베이스 시스템에서는 저장 프로시저와 트리거가 중요한 역할을 합니다. 저장 프로시저든 트리거든 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 저장 프로시저를 소개합니다.
다음으로 두 번째 방법을 통해 오라클 저장 프로시저(그림 및 텍스트)를 소개하겠습니다.
다음 방법과 단계를 참고하세요
1단계: COST 등 ORACLE과 함께 제공되는 Net Manager를 통해 연결해야 하는 데이터베이스를 구성합니다
2단계: PL/SQL 데이터베이스 도구를 열고 올바른 사용자 이름과 비밀번호를 입력한 후 확인을 클릭하여 저장 프로시저를 생성해야 하는 사용자를 입력합니다.
3단계: 일반 저장 프로시저의 형식 이해
프로시저 저장 프로시저 이름(param1 입력 유형, param2 출력 유형) 생성 또는 바꾸기
변수 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('남성');
종료
참고
다른 저장 프로시저 내에서는 저장 프로시저를 삭제할 수 없으며, 다른 저장 프로시저를 호출할 수만 있습니다
create or replacement 프로시저를 사용하는 경우 저장 프로시저 생성 시 사용자의 기존 저장 프로시저와 동일한 이름을 사용하면 현재 저장 프로시저를 덮어쓰게 되므로 주의하세요
저장 프로시저 매개변수에는 값 범위가 없습니다. in은 수신을 의미하고 out은 출력을 의미합니다
위에서는 두 가지 방식으로 Oracle 저장 프로시저를 소개하고 있어 모든 분들께 도움이 되기를 바랍니다.