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

核心提示：using System;using System.Configuration;using System.Data;using System.Data.SqlClient;using System.Collections;namespace MyCorporation.DepartMent.DataBase{ ///

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)
　  {
　　 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;
  }

 }
}