/// <summary>
  /// 返回SQL语句第一列,第ColumnI列,
  /// </summary>
  /// <returns>字符串</returns>
  public string ReturnValue(string SQL, int ColumnI)
  {
   SqlConnection Conn;
   Conn = new SqlConnection(ConnStr);
   Conn.Open();
   string result;
   SqlDataReader Dr ;
   try
   {
    Dr = CreateCmd(SQL,Conn).ExecuteReader();
   }
   catch
   {
    throw new Exception(SQL);
   }
   if (Dr.Read())
   {
    result = Dr[ColumnI].ToString();
   }
   else
   {
    result = "";
   }
   Dr.Close();
   Dispose(Conn);
   return result;
  }

  /// <summary>
  /// 生成一个存储过程使用的sqlcommand.
  /// </summary>
  /// <param name="procName">存储过程名.</param>
  /// <param name="prams">存储过程入参数组.</param>
  /// <returns>sqlcommand对象.</returns>
  public SqlCommand CreateCmd(string procName, SqlParameter[] prams)
  {
   SqlConnection Conn;
   Conn = new SqlConnection(ConnStr);
   Conn.Open();
   SqlCommand Cmd = new SqlCommand(procName, Conn);
   Cmd.CommandType = CommandType.StoredProcedure;
   if (prams != null)
   {
    foreach (SqlParameter parameter in prams)
    {
     if(parameter != null)
     {
      Cmd.Parameters.Add(parameter);
     }
    }
   }
   return Cmd;
  }

  /// <summary>
  /// 为存储过程生成一个SqlCommand对象
  /// </summary>
  /// <param name="procName">存储过程名</param>
  /// <param name="prams">存储过程参数</param>
  /// <returns>SqlCommand对象</returns>
  private SqlCommand CreateCmd(string procName, SqlParameter[] prams,SqlDataReader Dr)
  {
   SqlConnection Conn;
   Conn = new SqlConnection(ConnStr);
   Conn.Open();
   SqlCommand Cmd = new SqlCommand(procName, Conn);
   Cmd.CommandType = CommandType.StoredProcedure;
   if (prams != null)
   {
    foreach (SqlParameter parameter in prams)
     Cmd.Parameters.Add(parameter);
   }
   Cmd.Parameters.Add(
    new SqlParameter("ReturnValue", SqlDbType.Int, 4,
    ParameterDirection.ReturnValue, false, 0, 0,
    string.Empty, DataRowVersion.Default, null));

   return Cmd;
  }

  /// <summary>
  /// 运行存储过程,返回.
  /// </summary>
  /// <param name="procName">存储过程名</param>
  /// <param name="prams">存储过程参数</param>
  /// <param name="dataReader">SqlDataReader对象</param>
  public void RunProc(string procName, SqlParameter[] prams, SqlDataReader Dr)
  {

   SqlCommand Cmd = CreateCmd(procName, prams, Dr);
   Dr = Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
   return;
  }

  /// <summary>
  /// 运行存储过程,返回.
  /// </summary>
  /// <param name="procName">存储过程名</param>
  /// <param name="prams">存储过程参数</param>
  public string RunProc(string procName, SqlParameter[] prams)
  {
   SqlDataReader Dr;
   SqlCommand Cmd = CreateCmd(procName, prams);
   Dr = Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
   if(Dr.Read())
   {
    return Dr.GetValue(0).ToString();
   }
   else
   {
    return "";
   }
  }

  /// <summary>
  /// 运行存储过程,返回dataset.
  /// </summary>
  /// <param name="procName">存储过程名.</param>
  /// <param name="prams">存储过程入参数组.</param>
  /// <returns>dataset对象.</returns>
  public DataSet RunProc(string procName,SqlParameter[] prams,DataSet Ds)
  {
   SqlCommand Cmd = CreateCmd(procName,prams);
   SqlDataAdapter Da = new SqlDataAdapter(Cmd);
   try
   {
    Da.Fill(Ds);
   }
   catch(Exception Ex)
   {
    throw Ex;
   }
   return Ds;
  }

 }
}

上一页  [1] [2]