前言:最初做web开发的时候,经常会碰到对数据库的增删改的操作,因而经常会重复的写很多代码,感觉在做很多重复的工作,特郁闷,所以自己想把常用的操作封装成类,但是自己又是比较菜的菜鸟,比较懒..呵呵...,就在网站搜索,有很多,我找到一个比较全的,至少对于我来讲是这样,然后根据自己的需要增加了一两个方法,做成一个DB操作类,所以以后每次做web项目就把这类拿过去,省了很多事,因此帖在此处,让更多初学者学习使用它
申明:这个类是我在网上找到的,版权归原作者所有 ,我只是根据我的需要做了小小的修改
DB.CS类:
using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using System.Data.SqlClient;
/**//// <summary>
/// DB 的摘要说明
/// </summary>
public class DB
...{
private string ConnStr = null;
public DB()
...{
//
// TODO: 在此处添加构造函数逻辑
ConnStr = System.Web.Configuration.WebConfigurationManager.ConnectionStrings["EAConString"].ToString();
//
}
public DB(string Str)
...{
try
...{
this.ConnStr = Str;
}
catch (Exception ex)
...{
throw ex;
}
}
public string constr()
...{
return System.Web.Configuration.WebConfigurationManager.ConnectionStrings["EAConString"].ToString();
}
public static SqlConnection CreateCon()
...{
return new SqlConnection(System.Web.Configuration.WebConfigurationManager.ConnectionStrings["EAConString"].ToString());
}
/**//// <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(Exception ex)
...{
string exm = ex.Message;
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)
...{
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using System.Data.SqlClient;
/**//// <summary>
/// DB 的摘要说明
/// </summary>
public class DB
...{
private string ConnStr = null;
public DB()
...{
//
// TODO: 在此处添加构造函数逻辑
ConnStr = System.Web.Configuration.WebConfigurationManager.ConnectionStrings["EAConString"].ToString();
//
}
public DB(string Str)
...{
try
...{
this.ConnStr = Str;
}
catch (Exception ex)
...{
throw ex;
}
}
public string constr()
...{
return System.Web.Configuration.WebConfigurationManager.ConnectionStrings["EAConString"].ToString();
}
public static SqlConnection CreateCon()
...{
return new SqlConnection(System.Web.Configuration.WebConfigurationManager.ConnectionStrings["EAConString"].ToString());
}
/**//// <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(Exception ex)
...{
string exm = ex.Message;
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)
...{