ADO NET的壹個幫助類庫 只須壹個連接 壹條SQL語句 輕松實現數據庫的查旬 再加壹個object 輕松實現數據庫的增刪改
該類庫根據是否需要事務可分為兩個部分 分別由三個構造方法決定
命名空間DBAssistant 類DBAssist
方法ExecNoQueryWithTran（） 實現帶事務的增刪改 返回（int）影響的行數
方法 ExecNoQuery（）實現不帶事務的增刪改 返回（int） 影響的行數
方法ExecScalar（） 實現返回首行首列的查詢 返回（object）
方法ExecSelect（） 返回SqlDataReader
方法GetDataSet（） 返回DataSet
using System;using System Collections Generic;using System Text;using System Data;using System Data SqlClient;using WriteException;namespace DBAssistant{public class DBAssist{/// <summary>/// 重載的構造方法/// </summary>public DBAssist() { }public DBAssist(string strSql SqlConnection conn){this StrSql = strSql;this Conn = conn;}public DBAssist(string strSql object obj SqlConnection conn){this StrSql = strSql;this Obj = obj;this Conn = conn;}public DBAssist(string strSql object obj SqlConnection conn SqlTransaction sqlTran){this StrSql = strSql;this Obj = obj;this Conn = conn;this sqlTran = sqlTran;}/// <summary>/// sql語句/// </summary>string strSql;public string StrSql{get { return strSql; }set { strSql = value; }}/// <summary>/// 要操作的對象 需要對數據庫操作的數據存於其中/// </summary>object obj;public object Obj{get { return obj; }set { obj = value; }}/// <summary>/// 連接/// </summary>SqlConnection conn;public SqlConnection Conn{get { return conn; }set { conn = value; }}/// <summary>/// 事務/// </summary>SqlTransaction sqlTran;public SqlTransaction SqlTran{get { return sqlTran; }set { sqlTran = value; }}public object count;/// <summary>/// 帶事務增刪改方法/// </summary>/// <returns>int</returns>public int ExecNoQueryWithTran(){int num = ;try{using (SqlCommand cmd = new SqlCommand(strSql conn)){cmd Transaction = sqlTran;num = cmd ExecuteNonQuery();//SqlTran Commit();}}catch (Exception ex){WriException Write(ex);//SqlTran Rollback();}return num;}/// <summary>/// 不帶事務的增刪改方法/// </summary>/// <returns>int</returns>public int ExecNoQuery(){int num = ;try{using (SqlCommand cmd = new SqlCommand(strSql conn)){num = cmd ExecuteNonQuery();}}catch (Exception ex){WriException Write(ex);}return num;}/// <summary>/// 返回 SqlDataReader 的查詢方法/// </summary>/// <returns>SqlDataReader</returns>public SqlDataReader ExecSelect(){SqlDataReader dr = null;try{SqlCommand cmd = new SqlCommand(strSql conn);dr = cmd ExecuteReader(CommandBehavior CloseConnection);return dr;}catch (Exception ex){WriException Write(ex);}return null;}/// <summary>/// 調用ExecuteScalar()方法 返回 object 的查詢方法/// </summary>/// <returns>Object</returns>public object ExecScalar(){count=null;try{using (SqlCommand cmd = new SqlCommand(strSql conn)){count = cmd ExecuteScalar();}}catch (Exception ex){WriException Write(ex);}return count;}DataSet ds;/// <summary>/// 返回DataSet的查詢方法/// </summary>/// <returns>DataSet</returns>public DataSet GetDataSet(){ds = null;using (SqlDataAdapter sda = new SqlDataAdapter(strSql conn)){using (ds = new DataSet()){sda Fill(ds);}}return ds;}
}}
lishixinzhi/Article/program/net/201311/12853