OR REPLACE PROCEDURE gd_CURSOR(MYCS1 OUT SYS_REFCURSOR,MYCS2 OUT SYS_REFCURSOR,a out varchar)asBEGIN 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 存储过程
标签:
小编还为您整理了以下内容,可能对您也有帮助:
在ASP.NET中如何调用 oracle 存储过程调用
调用存储过程方法:
//存储过程
//proName 存储过程名称
//values 存储过程参数
public int ExecutePro(string proName,SqlParameter[]values)
{
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
cmd.CommandText = proName;
cmd.Parameters.AddRange(values);
cmd.CommandType = CommandType.StoredProcere;
try
{
con.Open();
cmd.ExecuteNonQuery();
return int.Parse(values[values.Length - 1].Value.ToString());
}
catch
{
return -1;
}
finally
{
con.Close();
}
}
例如:
#region 注册用户
/// <summary>
/// 注册用户
/// </summary>
/// <param name="user">用户对象</param>
/// <returns>
/// 0 成功
///-1 失败
///1 已存在
///</returns>
public static int Regist(UserInfo user)
{
//procere pro_Regist(@ub_loginId varchar(50),@up_pwd text,@ud_Name varchar(20),@ud_sex bit,@ud_phone char(11),@ud_remark varchar(50),@flag int output)
SqlParameter[] param = {
new SqlParameter("@ub_loginId",user.U_ub_loginid),
new SqlParameter("@up_pwd",FormsAuthentication.HashPasswordForStoringInConfigFile( user.U_ub_pwd,"MD5")),
new SqlParameter("@ud_Name",user.U_ud_Name),
new SqlParameter("@ud_sex",user.U_ud_sex),
new SqlParameter("@ud_phone",user.U_ud_phone),
new SqlParameter("@ud_remark",user.U_ud_remark),
new SqlParameter("@flag",0)
};
param[param.Length-1].Direction = ParameterDirection.Output;
return DBHelper.CreateInstance().ExecutePro("pro_Regist", param);
}
#endregion
在ASP.NET中如何调用 oracle 存储过程调用
调用存储过程方法:
//存储过程
//proName 存储过程名称
//values 存储过程参数
public int ExecutePro(string proName,SqlParameter[]values)
{
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
cmd.CommandText = proName;
cmd.Parameters.AddRange(values);
cmd.CommandType = CommandType.StoredProcere;
try
{
con.Open();
cmd.ExecuteNonQuery();
return int.Parse(values[values.Length - 1].Value.ToString());
}
catch
{
return -1;
}
finally
{
con.Close();
}
}
例如:
#region 注册用户
/// <summary>
/// 注册用户
/// </summary>
/// <param name="user">用户对象</param>
/// <returns>
/// 0 成功
///-1 失败
///1 已存在
///</returns>
public static int Regist(UserInfo user)
{
//procere pro_Regist(@ub_loginId varchar(50),@up_pwd text,@ud_Name varchar(20),@ud_sex bit,@ud_phone char(11),@ud_remark varchar(50),@flag int output)
SqlParameter[] param = {
new SqlParameter("@ub_loginId",user.U_ub_loginid),
new SqlParameter("@up_pwd",FormsAuthentication.HashPasswordForStoringInConfigFile( user.U_ub_pwd,"MD5")),
new SqlParameter("@ud_Name",user.U_ud_Name),
new SqlParameter("@ud_sex",user.U_ud_sex),
new SqlParameter("@ud_phone",user.U_ud_phone),
new SqlParameter("@ud_remark",user.U_ud_remark),
new SqlParameter("@flag",0)
};
param[param.Length-1].Direction = ParameterDirection.Output;
return DBHelper.CreateInstance().ExecutePro("pro_Regist", param);
}
#endregion
asp.net 调用存储过程
两种不同的存储过程调用方法
为了突出新方法的优点,首先介绍一下在.NET中调用存储过程的“官方”方法。另外,本文的所有示例程序均工作于SqlServer数据库上,其它情况类似,以后不再一一说明。本文所有例子均采用C#语言。
要在应用程序中访问数据库,一般性的步骤是:首先声明一个数据库连接SqlConnection,然后声明一个数据库命令SqlCommand,用来执行SQL语句和存储过程。有了这两个对象后,就可以根据自己的需要采用不同的执行方式达到目的。需要补充的是,不要忘记在页面上添加如下的引用语句:using System.Data.SqlClient。
就执行存储过程来说,如果执行的是第一类存储过程,那么就要用一个DataAdapter将结果填充到一个DataSet中,然后就可以使用数据网格控件将结果呈现在页面上了;如果执行的是第二和第三种存储过程,则不需要此过程,只需要根据特定的返回判定操作是否成功完成即可。
(1)执行一个没有参数的存储过程的代码如下:
SqlConnection conn=new SqlConnection(“connectionString”);
SqlDataAdapter da = new SqlDataAdapter();
da.selectCommand = new SqlCommand();
da.selectCommand.Connection = conn;
da.selectCommand.CommandText = "NameOfProcere";
da.selectCommand.CommandType = CommandType.StoredProcere;
然后只要选择适当的方式执行此处过程,用于不同的目的即可。
(2)执行一个有参数的存储过程的代码如下(我们可以将调用存储过程的函数声明为ExeProcere(string inputdate)):
SqlConnection conn=new SqlConnection(“connectionString”);
SqlDataAdapter da = new SqlDataAdapter();
da.selectCommand = new SqlCommand();
da.selectCommand.Connection = conn;
da.selectCommand.CommandText = "NameOfProcere";
da.selectCommand.CommandType = CommandType.StoredProcere;
(以上代码相同,以下为要添加的代码)
param = new SqlParameter("@ParameterName", SqlDbType.DateTime);
param.Direction = ParameterDirection.Input;
param.Value = Convert.ToDateTime(inputdate);
da.selectCommand.Parameters.Add(param);
这样就添加了一个输入参数。若需要添加输出参数:
param = new SqlParameter("@ParameterName", SqlDbType.DateTime);
param.Direction = ParameterDirection.Output;
param.Value = Convert.ToDateTime(inputdate);
da.selectCommand.Parameters.Add(param);
若要获得参储过程的返回值:
param = new SqlParameter("@ParameterName", SqlDbType.DateTime);
param.Direction = ParameterDirection.ReturnValue;
param.Value = Convert.ToDateTime(inputdate);
da.selectCommand.Parameters.Add(param);
从上面的代码我们可以看出,当存储过程比较多或者存储过程的参数比较多时,这种方法会大大影响开发的速度;另外一方面,如果项目比较大,那么这些用于数据库逻辑的函数在以后的维护中也是一个很大的负担。那么,有没有一种改进的方法可以解决这个问题呢?想到在执行没有参数的存储过程时只需要传入一个存储过程的名字就可以调用相应的存储过程,而且在SqlServer数据库中我们可以直接在查询分析器中敲入“存储过程名(参数列表)”样的字符串就可以执行存储过程,那么,是否可以把这种思想应用到应用程序中呢?
于是在编译器中键入相应代码。这些代码是在调用不带参数的存储过程的代码的基础上改的。具体代码如下:
SqlConnection conn=new SqlConnection(“connectionString”);
SqlDataAdapter da = new SqlDataAdapter();
da.selectCommand = new SqlCommand();
da.selectCommand.Connection = conn;
da.selectCommand.CommandText = "NameOfProcere('para1','para2',para3)";
da.selectCommand.CommandType = CommandType.StoredProcere;
为了使代码更具有代表性,要调用的存储过程的第一个和第二个参数都为字符串类型,第三个参数为整型。执行以后发现,完全可以达到预期的效果!
两种调用方法的比较
通过比较我们可以看到,第二种方法具有一个很明显的优点,那就是可以提高开发速度,节省开发时间,而且代码容易维护,在一定程度上也减少了系统大小。但是,由于对存储过程参数的处理比较笼统,如果要获取输出参数或者得到存储过程的返回值,这种方法就不能满足需要了。虽然如此,但是,这种方法毕竟可以让开发人员少些很大一部分的代码。如果不需要获取输出参数和返回值,那么几乎可以做到“一劳永逸”。因此在实际的程序开发中,这种方法还是具有一定的实用价值的。
用ASP.NET与SQL SERVER可是缘份最好了,稍大的程序一般第一先考虑的是SQL SERVER,只是一些很考虑经济的才使用ACCESS等了。用SQL SERVER,为了使数据库的效率更好,一般都会才取存储过程,因存储过程执行速度快,并且可以实现一些高级的查询等功能。比如传入一些数据参数,但执行的SQL过程可能不同等。
下面就来个例子,建立一新的角色,要求角色的名字不能重复,以下是一存储过程。
CREATE PROCEDURE sp_AccountRole_Create@CategoryID int,@RoleName nvarchar(10),@Description nvarchar(50),@RoleID int outputAS DECLARE @Count int -- 查找是否有相同名称的记录 SELECT @Count = Count(RoleID) FROM Account_Role WHERE RoleName = @RoleName IF @Count = 0 INSERT INTO Account_Role (CategoryID, RoleName, Description) valueS (@CategoryID, @RoleName, @Description) SET @RoleID = @@IDENTITY RETURN 1GO 执行存储过程的C#过程:
SqlConnection DbConnection = new SqlConnection(mConnectionString);SqlCommand command = new SqlCommand( "sp_AccountRole_Create", DbConnection );DbConnection.Open(connectString);// 废置SqlCommand的属性为存储过程command.CommandType = CommandType.StoredProcere;command.Parameters.Add("@CategoryID", SqlDbType.Int, 4);command.Parameters.Add("@RoleName", SqlDbType.NVarChar, 10);command.Parameters.Add("@Description", SqlDbType.NVarChar, 50);command.Parameters.Add("@RoleID", SqlDbType.Int, 4);// 返回值command.Parameters.Add("Returnvalue", SqlDbType.Int, 4, // Size ParameterDirection.Returnvalue, false, // is nullable 0, // byte precision 0, // byte scale string.Empty, DataRowVersion.Default, null );command.parameters["@CategoryID"].value = permission.CategoryID;command.parameters["@RoleName"].value = permission.PermissionName;command.parameters["@Description"].value = permission.Description;// 可以返回新的ID值command.parameters["@RoleID"].Direction = ParameterDirection.Output;int rowsAffected = command.ExecuteNonQuery();int result = command.parameters["Returnvalue"].value;int newID = command.parameters["@RoleID"].value;
50分求ASP.NET调用存储过程方法
SqlConnection conn = new SqlConnection(ConfigurationManager.ConnectionStrings["连接字符串"].ConnectionString);//数据库连接字符串
SqlCommand cmd = new SqlCommand("存储过程名称", conn);
cmd.CommandType = CommandType.StoredProcere;//指定命令类型为存储过程
cmd.Parameters.AddWithValue("@参数1", 值1);
cmd.Parameters.AddWithValue("@参数2", 值2);
conn.Open();
cmd.ExecuteNonQuery();
conn.Close();
这个给LZ比较好理解 支持了