ADO.net 数据库操作类

using System;


using System.Data;


using System.Data.SqlClient;


using System.Configuration;


using System.Web;


using System.Web.Configuration;


using System.Web.Security;


using System.Web.UI;


using System.Web.UI.HtmlControls;


using System.Web.UI.WebControls;


using System.Web.UI.WebControls.WebParts;





/// <summary>
/// Summary description for OperateSQL
/// </summary>


public class OperateSQL


{


private static string connString = WebConfigurationManager.ConnectionStrings["DailyPlanConnectionString"].ConnectionString;


public OperateSQL()


{


//


// TODO: Add constructor logic here


//


}






/// <summary>


/// 修改连接SQL数据库的 “连接字符串”


/// </summary>


public void SetConnectionString(string conn)


{


connString = conn;




}






/// <summary>


/// 执行SQL数据库的硬性连接，读取SQL数据库的数据返回一个SqlDataReader对象


/// 注意：调用该函数结束后必须用返回对象执行close()方法来释放数据库


/// </summary>


public SqlDataReader GetSQLDataReader(String MySQL)


{


SqlConnection MyConn = new SqlConnection(connString);


SqlDataReader dr = null;


SqlCommand MyComm = null;


try // 正常运行


{


// 使用 ConnectionString 所指定的属性设置打开数据库连接


MyConn.Open();


// 数据库SQL语句


String strSQL = MySQL.Trim().ToString();


// 要对数据库执行的一个SQL语句或存储过程


MyComm = new SqlCommand(strSQL, MyConn);


// 提供一种从数据库读取只进的行流的一种方式


dr = MyComm.ExecuteReader(CommandBehavior.CloseConnection);




}


catch (SqlException e) // 数据库操作异常处理


{


Console.Write("<script language=JavaScript>");


string mes="系统提示：当前数据库操作失败"+e.Message;


Console.Write("alert("+mes+")");


Console.Write("</script>");


if (MyConn.State == ConnectionState.Open)


{


// 关闭数据库连接


MyConn.Close();


}


return null;


}


MyComm.Dispose();


return dr;


}






/// <summary>


/// 执行SQL数据库的硬性连接，根据输入的SQL语句对数据库直接进行操作


/// </summary>


public void UpdateDeleteInsertSQL(String SQLCMD)


{


string constr=SQLCMD.Trim().ToString();


SqlConnection MyConn = new SqlConnection(connString);


SqlCommand mysql = new SqlCommand(constr, MyConn);


try


{


MyConn.Open();


mysql.ExecuteNonQuery();


}


catch (SqlException e) // 数据库操作异常处理


{


Console.Write("<script language=JavaScript>");


string mes = "系统提示：当前数据库操作失败" + e.Message;


Console.Write("alert(" + mes + ")");


Console.Write("</script>");


if (MyConn.State == ConnectionState.Open)


{


// 关闭数据库连接


MyConn.Close();


}


}


finally


{


if (MyConn.State == ConnectionState.Open)


{


// 关闭数据库连接


MyConn.Close();


}


}


}




/// <summary>


/// 执行SQL数据库的断开连接，读取SQL数据库的数据并返回一个DataSet对象


/// </summary>


public DataSet GetSQLDateSet(string SQLCMD) //SQLCMD为SELECT语句


{


string SQL =SQLCMD.Trim().ToString();


SqlConnection mysql = new SqlConnection(connString);


SqlDataAdapter da = new SqlDataAdapter(SQL, mysql);


DataSet ds = new DataSet();


da.Fill(ds);


return ds;




}






/// <summary>


/// 执行SQL数据库的断开连接，读取SQL数据库的数据并返回一个DataTable对象


/// </summary>


public DataTable GetSQLDataTable(string SQLCMD) //SQLCMD为SELECT语句


{


string SQL = SQLCMD.Trim().ToString();


SqlConnection mysql = new SqlConnection(connString);


SqlDataAdapter da = new SqlDataAdapter(SQL, mysql);


DataTable dt = new DataTable();


da.Fill(dt);


return dt;




}




}
以上是我自己封装的一个操作数据库的，按道理说应该是个数据库的储存过程，使用的时候新建个operateSQL对象就行，自己随手先得，每个函数都测试过了，绝对没问题，可能代码写的不够规范，请大家指出来，代码的健壮性也不行，我编码还是个新手~