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

发表于:2007-06-30来源:作者:点击数: 标签:
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
     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;
   }
  
   }
  }
  
  
  
  
  
  

原文转自:http://www.ltesting.net