开发学院 WEB开发 ASP.NET 为ASP.NET封装的SQL数据库访问类阅读

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

　2004-12-15 17:00:27　来源：WEB开发网　闂傚倸鍊搁崐鎼佸磹妞嬪孩顐芥慨姗嗗厳缂傛氨鎲稿鍫罕闂備礁婀遍搹搴ㄥ窗閺嶎偆涓嶆い鏍仦閻撱儵鏌ｉ弴鐐测偓鍦偓姘炬嫹

闂傚倸鍊搁崐鎼佸磹妞嬪海鐭嗗〒姘ｅ亾妤犵偛顦甸弫鎾绘偐閹绘帞鈧參姊哄Ч鍥х仼闁诲繑鑹鹃悾鐑藉蓟閵夛妇鍘甸梺瑙勵問閸犳牠銆傛總鍛婄厱閹艰揪绱曟牎闂侀潧娲ょ€氫即鐛幒妤€绠ｆ繝闈涘暙娴滈箖鏌ｉ姀鈶跺湱澹曟繝姘厵闁绘劦鍓氶悘杈ㄤ繆閹绘帞澧涚紒缁樼洴瀹曞崬螖閸愬啠鍓濈换娑樼暆婵犱胶鏁栫紓浣介哺閹瑰洤鐣烽幒鎴僵闁瑰吀鐒﹂悗鎼佹⒒娴ｇ儤鍤€闁搞倖鐗犻獮蹇涙晸閿燂拷

濠电姷鏁告慨鐑藉极閸涘﹥鍙忔い鎾卞灩缁狀垶鏌涢幇闈涙灈鐎瑰憡绻冮妵鍕箻鐎靛摜鐣奸梺纭咁潐濞茬喎顫忕紒妯肩懝闁逞屽墮宀ｈ儻顦查悡銈夋煏閸繃鍋繛宸簻鎯熼梺瀹犳〃閼冲爼宕濋敃鈧—鍐Χ閸℃鐟愰梺鐓庡暱閻栧ジ宕烘繝鍥у嵆闁靛骏绱曢崢顏堟⒑閹肩偛鍔楅柡鍛⊕缁傛帟顦寸紒杈ㄥ笚濞煎繘鍩℃担閿嬵潟闂備浇妗ㄩ悞锕傚箲閸ヮ剙鏋侀柟鍓х帛閺呮悂鏌ㄩ悤鍌涘闂傚倸鍊搁崐鎼佸磹妞嬪孩顐芥慨姗嗗厳缂傛氨鎲稿鍫罕闂備礁婀遍搹搴ㄥ窗閺嶎偆涓嶆い鏍仦閻撱儵鏌ｉ弴鐐测偓鍦偓姘炬嫹　　闂傚倸鍊搁崐鎼佸磹閻戣姤鍤勯柤鍝ユ暩娴犳氨绱撻崒娆掑厡缂侇噮鍨堕妴鍐川閺夋垹鍘洪悗骞垮劚椤︻垶宕￠幎鑺ョ厪闊洦娲栨牎闂佽瀵掗崜鐔奉潖閾忓湱纾兼俊顖氭惈椤矂姊洪崷顓涙嫛闁稿妫濋幆鈧い蹇撴祩濡嫰姊洪崫鍕拱婵炲弶岣块幑銏犫攽婵犲嫮鏉搁梺鍝勬川婵兘鎮伴妷鈺傗拻濞达絽鎼敮璺侯熆閻熷府鏀荤紒鍌氱Т楗即宕煎锝呬壕闁哄啫鐗嗙粈鍐┿亜韫囧海顦﹀ù婊堢畺閺屻劌鈹戦崱娑扁偓妤€顭胯閸犳牠婀侀梺缁樕戦悷銉р偓姘煎枤缁粯銈ｉ崘鈺冨幈濡炪倖鍔戦崐鏇㈠几鎼淬劍鐓熼煫鍥ь儏閸旀粓鏌曢崶褍顏€殿喗娼欒灒闁告繂瀚濠碉紕鍋戦崐鎴﹀垂濞差亝鍋￠柍鍝勬噹缁犳牠鏌嶉埡浣告殲闁稿海鍠栭弻鏇㈠炊瑜嶇花濠氭煙閸戙倖瀚�

核心提示：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;
}