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

    using System;
　　using System.Configuration;
　　using System.Data;
　　using System.Data.SqlClient;
　　using System.Collections;
　　
　　namespace MyCorporation.DepartMent.DataBase
　　{
　　/// <summary>
　　/// 通用数据库类
　　/// </summary>
　　public class DataBase
　　{
　　
　　private string ConnStr = null;
　　
　　public DataBase()
　　{
　　ConnStr = ConfigurationSettings.AppSettings["ConnStr"];
　　}
　　public DataBase(string Str)
　　{
　　try
　　{
　　this.ConnStr = Str;
　　
　　}
　　catch(Exception ex)
　　{
　　throw ex;
　　}
　　}
　　
　　/// <summary>
　　/// 返回connection对象
　　/// </summary>
　　/// <returns></returns>
　　public SqlConnection ReturnConn()
　　{
　　SqlConnection Conn = new SqlConnection(ConnStr);
　　Conn.Open();
　　return Conn;
　　}
　　public void Dispose(SqlConnection Conn)
　　{
　　if(Conn!=null)
　　{
　　Conn.Close();
　　Conn.Dispose();
　　}
　　GC.Collect();
　　}
　　/// <summary>
　　/// 运行SQL语句
　　/// </summary>
　　/// <param name="SQL"></param>
　　public void RunProc(string SQL)
　　{
　　SqlConnection Conn;
　　Conn = new SqlConnection(ConnStr);
　　Conn.Open();
　　SqlCommand Cmd ;
　　Cmd = CreateCmd(SQL, Conn);
　　try
　　{
　　Cmd.ExecuteNonQuery();
　　}
　　catch
　　{
　　throw new Exception(SQL);
　　}
　　Dispose(Conn);
　　return;
　　}
　　
　　/// <summary>
　　/// 运行SQL语句返回DataReader
　　/// </summary>
　　/// <param name="SQL"></param>
　　/// <returns>SqlDataReader对象.</returns>
　　public SqlDataReader RunProcGetReader(string SQL)
　　{
　　SqlConnection Conn;
　　Conn = new SqlConnection(ConnStr);
　　Conn.Open();
　　SqlCommand Cmd ;
　　Cmd = CreateCmd(SQL, Conn);
　　SqlDataReader Dr;
　　try
　　{
　　Dr = Cmd.ExecuteReader(CommandBehavior.Default);
　　}
　　catch
　　{
　　throw new Exception(SQL);
　　}
　　//Dispose(Conn);
　　return Dr;
　　}
　　
　　/// <summary>
　　/// 生成Command对象
　　/// </summary>
　　/// <param name="SQL"></param>
　　/// <param name="Conn"></param>
　　/// <returns></returns>
　　public SqlCommand CreateCmd(string SQL, SqlConnection Conn)
　　{
　　SqlCommand Cmd ;
　　Cmd = new SqlCommand(SQL, Conn);
　　return Cmd;
　　}
　　
　　/// <summary>
　　/// 生成Command对象
　　/// </summary>
　　/// <param name="SQL"></param>
　　/// <returns></returns>
　　public SqlCommand CreateCmd(string SQL)
　　{
　　SqlConnection Conn;
　　Conn = new SqlConnection(ConnStr);
　　Conn.Open();
　　SqlCommand Cmd ;
　　Cmd = new SqlCommand(SQL, Conn);
　　return Cmd;
　　}
　　
　　/// <summary>
　　/// 返回adapter对象
　　/// </summary>
　　/// <param name="SQL"></param>
　　/// <param name="Conn"></param>
　　/// <returns></returns>
　　public SqlDataAdapter CreateDa(string SQL)
　　{
　　SqlConnection Conn;
　　Conn = new SqlConnection(ConnStr);
　　Conn.Open();
　　SqlDataAdapter Da;
　　Da = new SqlDataAdapter(SQL, Conn);
　　return Da;
　　}
　　
　　/// <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)

查看本文来源