C#二十六 使用Ado.Net调用存储过程

测试表：Person
Create table Person
{
   psnNo Nchar(6) PrimaryKey,
   psnName Nvarchar(5) NotNull,
   psnSex  Nchar(1) not null,
   psnAge smallint notnull,
   psnAddress Nvarchar(50)not null
}
go

SqlConnection cn=new SqlConnection(＂server=.;database=Test;uid=sa;pwd=123456＂);
try
{
  cn.Open();
//创建带参数的Sql语句
  string sql=＂Insert into Personvalues(@Id,@Name,@Sex,@Age,@Address) ＂;
  SqlCommand cmd=newSqlCommand(sql,cn);
//创建参数并加入到Parameters集合里
  cmd.Parameters.Add(＂@Id＂,SqlDbType.NChar,6);
  cmd.Parameters.Add(＂@Name＂,SqlDbType.Nvarchar,5);
  cmd.Parameters.Add(＂@Sex＂,SqlDbType.Nchar,1);
  cmd.Parameters.Add(＂@Age＂,SqlDbType.SmallInt);
  cmd.Parameters.Add(＂@Address＂,SqlDbType.NvarChar,50);
//设置参数的值，并执行插入
  cmd.Parameters[＂@Id＂].Value=＂004＂;
  cmd.Parameters[＂@Name＂].Value=＂帕瓦罗蒂＂;
  cmd.Parameters[＂@Sex＂].Value=＂男＂;
  cmd.Parameters[＂@Age＂].Value=＂32＂;
  cmd.Parameters[＂@Address＂].Value=＂东部部落＂;
  cmd.ExecuteNonQuery();
//设置带参数的值，并执行插入
cmd.Parameters[＂@Id＂].Value=＂005＂;
cmd.Parameters[＂@Name＂].Value=＂天使毛毛＂;
cmd.Parameters[＂@Age＂].Value=＂18＂;
cmd.Parameters[＂@Address＂].Value=＂东部部落＂;
//此处设置的值可以为对应的Winform、Webform的文本框、下拉框等用户输入的值；
//如：ccmd.Parameters[＂@Id＂].Value=txtId.Text;
cmd.ExecuteNonQuery();
}
catch(SqlExecption ex)
{
  //数据库出错报错信息
}
finally
{
  cn.Close();
}

Create Proc ch_Person
as
    Update Person
        Set psnAddress=’乞力马扎罗’
    Where psnName=’帕瓦罗蒂’
Go

SqlConnection cn=new SqlConnection(＂server=.;database=test;uid=sa;pwd=123456＂);
try
{
    cn.Open();
    SqlCommandcmd=cn.CreateCommand();
    //设置命令类型为存储过程
    cmd.CommandType=CommandType.StoreProcedure;
    //设置存储过程的名字
    cmd.CommandText=＂ch_Person＂;
    //执行存储过程
    cmd.ExecuteNonQuery();
}
catch(SqlExecption ex)
{
    //数据库出错信息提示
}
finally
    {
    cn.Close();
}

Create Proc ch_Person
    @p_psnName NvarChar(5),
    @p_psnAddress NvarChar(50)
As
   Update Person
       Set psnAddress=@p_psnAddress
   Where psnName=@p_psnName
Go1. Creat

SqlConnection cn=new SqlConnection(＂server=.;database=test;uid=sa;pwd=123456＂);
try
{
  cn.Open();
  SqlCommandcmd=new SqlCommand(＂ch_Person＂,cn);
  cmd.CommandType=CommandType.StoredProcedure;
//加入参数对象，并设置其值
  cmd.Parameters.Add(＂@p_psnName＂,SqlDbType.NVarChar).Value=＂帕瓦罗蒂＂;
  cmd.Parameters.Add(＂@p_psnAddress＂,SqlDbType.NVarChar).Value=＂日本广岛＂;
//后面的具体的值，在设置的时候可以变为具体的文本框控件等的值；
//如：cmd.Parameters.Add(＂@p_psnName＂,SqlDbType.NVarChar).Value=txtName.Text
//执行存储过程
  cmd.ExecuteNonQuery();
}
catch(SqlException ex)
{
  //操作数据库出错信息处理
}
finally
{
  cn.Close();
}1. S

Create Proc gt_Address
   @p_psnName NvarChar(5)  //请输入姓名
   @g_psnAddress NvarChar(5)OutPut  //返回此人的地址
As
   Select@g_psnAddress=psnAddress From Person
   WherepsnName=@p_psnName
   If@@Error<>0
       Return-1   //如果查询语句出错返回-1
   Else
       Return 0
Go

SqlConnection cn=new SqlConnection(＂server=.;database=test;uid=sa;pwd=123456＂);
try
{
   cn.Open();
   SqlCommandcmd=new SqlCommand(＂gt_Address＂,cn);
   cmd.CommandType=CommandType.StoredProcedure;
   //加入参数，并设置参数的值和Direction属性
   cmd.Parameters.Add(＂@p_psnName＂,SqlDbType.NvarChar).Value=＂帕瓦罗蒂＂;
   SqlParametercpar=cmd.Parameters.Add(＂@g_psnAddress＂,SqlDbType.NvarChar,50);
   cpar.Direction=ParameterDirection.Output;
   SqlParametercres=cmd.Parameters.Add(＂@return＂,SqlDbType.Int);
   cres.Direction=ParameterDirection.ReturnValue;
   //执行存储过程
   cmd.ExecuteNonQuery();
   //获得参数的值
   intres=(int)cres.Value;
   stringaddress=(string)cpar.Value;
   Console.WriteLine（＂返回值：{0},地址：{1}＂，res，address）;  
}
catch(SqlException ex)
{
   //数据库出错信息报告
}
finally
{
   cn.Close();
}
运行结果：
返回值：0,地址：日本广岛

SqlConnection cn=new SqlConnection(＂server=.;database=test;uid=sa;pwd=123456＂);
try
{
   cn.Open();
   SqlCommandcmd=new SqlCommand(＂gt_Address＂,cn);
   cmd.CommandType=CommandType.StoredProcedure;
   //为命令对象生成参数
   SqlCommandBuilder.DeriveParameters(cmd);
   //设置输入参数的值
   cmd.Parameters.Add(＂@p_psnName＂,SqlDbType.NvarChar).Value=＂帕瓦罗蒂＂;
   //执行存储过程
   cmd.ExecuteNonQuery();
   intres=(int)cmd.Parameters[＂@Return＂].Value;
   string address=(string)cmd.Parameters[＂@p_psnAddress＂].Value;
   Console.WriteLine（＂返回值：{0},地址：{1}＂，res，address）;  
}
catch(SqlException ex)
{
   //数据库出错信息报告
}
finally
{
   cn.Close();
}