为ASP.NET封装的SQL数据库访问类

    /// <summary> /// 运行SQL语句，返回DataSet对象/// </summary> /// <param name="procName">SQL语句</param> /// <param name="prams">DataSet对象</param> public DataSet RunProc（string SQL ，DataSet Ds）

    { SqlConnection Conn；Conn = new SqlConnection（ConnStr）；Conn.Open（）；SqlDataAdapter Da；//Da = CreateDa（SQL， Conn）；Da = new SqlDataAdapter（SQL，Conn）；try { Da.Fill（Ds）；} catch（Exception Err）

    { throw Err；} Dispose（Conn）；return Ds；}

    /// <summary> /// 运行SQL语句，返回DataSet对象/// </summary> /// <param name="procName">SQL语句</param> /// <param name="prams">DataSet对象</param> /// <param name="dataReader">表名</param> public DataSet RunProc（string SQL ，DataSet Ds，string tablename）

    { SqlConnection Conn；Conn = new SqlConnection（ConnStr）；Conn.Open（）；SqlDataAdapter Da；Da = CreateDa（SQL）；try { Da.Fill（Ds，tablename）；} catch（Exception Ex）

    { throw Ex；} Dispose（Conn）；return Ds；}

    /// <summary> /// 运行SQL语句，返回DataSet对象/// </summary> /// <param name="procName">SQL语句</param> /// <param name="prams">DataSet对象</param> /// <param name="dataReader">表名</param> public DataSet RunProc（string SQL ， DataSet Ds ，int StartIndex ，int PageSize， string tablename ）

    { SqlConnection Conn；Conn = new SqlConnection（ConnStr）；Conn.Open（）；SqlDataAdapter Da ；Da = CreateDa（SQL）；try { Da.Fill（Ds， StartIndex， PageSize， tablename）；} catch（Exception Ex）

    { throw Ex；} Dispose（Conn）；return Ds；}

    /// <summary> /// 检验是否存在数据/// </summary> /// <returns></returns> public bool ExistDate（string SQL）

    { SqlConnection Conn；Conn = new SqlConnection（ConnStr）；Conn.Open（）；SqlDataReader Dr ；Dr = CreateCmd（SQL，Conn）。ExecuteReader（）；if （Dr.Read（））

    { Dispose（Conn）；return true；} else { Dispose（Conn）；return false；}

    /// <summary> /// 返回SQL语句执行结果的第一行第一列/// </summary> /// <returns>字符串</returns> public string ReturnValue（string SQL）

    { SqlConnection Conn；Conn = new SqlConnection（ConnStr）；Conn.Open（）；string result；SqlDataReader Dr ；try { Dr = CreateCmd（SQL，Conn）。ExecuteReader（）；if （Dr.Read（））

    { result = Dr[0].ToString（）；Dr.Close（）；} else { result = ""；Dr.Close（）；} catch { throw new Exception（SQL）；} Dispose（Conn）；return result；}

    /// <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] 

【责编:yuan】