通用数据库连接执行类（SQL）

[align=left]using System;[/align]
[align=left]using System.Data;[/align]
[align=left]using System.Data.SqlClient;[/align]
[align=left] [/align]
[align=left]namespace Public[/align]
[align=left]{[/align]
[align=left] ///<summary>[/align]
[align=left] /// CustomADO 数据连接执行类。[/align]
[align=left] ///</summary>[/align]
[align=left] public class CustomADO[/align]
[align=left] {[/align]
[align=left] [/align]
[align=left] #region定义或创建类私有变量或对象[/align]
[align=left] [/align]
[align=left] private string _connstr; //连接字符串存储变量[/align]
[align=left] private string _procedure; //存储过程名或数据命令字符串变量[/align]
[align=left] private bool _isprocedure; //是否使用存储过程[/align]
[align=left] private SqlConnection _conn; //连接对象[/align]
[align=left] private SqlCommand _comm; //数据命令对象[/align]
[align=left] private SqlDataReader _dr; //定义数据读取器[/align]
[align=left] private DataSet _ds; //定义数据存储器[/align]
[align=left] [/align]
[align=left] #endregion[/align]
[align=left] [/align]
[align=left] #region构造函数[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///构造函数重载1[/align]
[align=left] ///</summary>[/align]
[align=left] public CustomADO()[/align]
[align=left] {[/align]
[align=left] _connstr = null;[/align]
[align=left] _procedure = null;[/align]
[align=left] _isprocedure = false;[/align]
[align=left] [/align]
[align=left] _conn = new SqlConnection();[/align]
[align=left] _comm = new SqlCommand();[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///构造函数重载2[/align]
[align=left] ///</summary>[/align]
[align=left] ///<param name="connstring">数据库连接字符串</param>[/align]
[align=left] ///<param name="procedure">存储过程或SQL命令</param>[/align]
[align=left] ///<param name="isprocedure">是否使用存储过程</param>[/align]
[align=left] public CustomADO(string connstring,string procedure,bool isprocedure)[/align]
[align=left] {[/align]
[align=left] _connstr = connstring;[/align]
[align=left] _procedure = procedure;[/align]
[align=left] _isprocedure = isprocedure;[/align]
[align=left] [/align]
[align=left] _conn = new SqlConnection();[/align]
[align=left] _comm = new SqlCommand();[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] #endregion[/align]
[align=left] [/align]
[align=left] #region属性[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///设置或获取数据库连接字符串[/align]
[align=left] ///</summary>[/align]
[align=left] public string ConnString[/align]
[align=left] {[/align]
[align=left] get[/align]
[align=left] {[/align]
[align=left] return _connstr;[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] set[/align]
[align=left] {[/align]
[align=left] _connstr = value;[/align]
[align=left] [/align]
[align=left] _conn.ConnectionString = _connstr;[/align]
[align=left] _comm.Connection = _conn;[/align]
[align=left] }[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///设置或获取存储过程名或SQL命令字符串[/align]
[align=left] ///</summary>[/align]
[align=left] public string Procedure[/align]
[align=left] {[/align]
[align=left] get[/align]
[align=left] {[/align]
[align=left] return _procedure;[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] set[/align]
[align=left] {[/align]
[align=left] _procedure = value;[/align]
[align=left] [/align]
[align=left] _comm.CommandText = _procedure;[/align]
[align=left] }[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///设置是否存储过程属性[/align]
[align=left] ///</summary>[/align]
[align=left] public bool IsProcedure[/align]
[align=left] {[/align]
[align=left] set[/align]
[align=left] {[/align]
[align=left] _isprocedure = value;[/align]
[align=left] [/align]
[align=left] if (_isprocedure)[/align]
[align=left] {[/align]
[align=left] _comm.CommandType = CommandType.StoredProcedure;[/align]
[align=left] }[/align]
[align=left] else[/align]
[align=left] {[/align]
[align=left] _comm.CommandType = CommandType.Text;[/align]
[align=left] }[/align]
[align=left] }[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] #endregion[/align]
[align=left] [/align]
[align=left] #region方法[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///打开连接[/align]
[align=left] ///</summary>[/align]
[align=left] public void OpenConnection()[/align]
[align=left] {[/align]
[align=left] _conn.Open();[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///关闭连接和数据读取器并清空数据集合[/align]
[align=left] ///</summary>[/align]
[align=left] public void CloseConnection()[/align]
[align=left] {[/align]
[align=left] _conn.Close();[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///销毁连接对象和方法[/align]
[align=left] ///</summary>[/align]
[align=left] public void Dispost()[/align]
[align=left] {[/align]
[align=left] if (_ds != null)[/align]
[align=left] {[/align]
[align=left] _ds.Clear();[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] if (_dr!=null)[/align]
[align=left] {[/align]
[align=left] _dr.Close();[/align]
[align=left] }[/align]
[align=left] _comm.Dispose();[/align]
[align=left] _conn.Close();[/align]
[align=left] _conn.Dispose();[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///添加参数重载1[/align]
[align=left] ///</summary>[/align]
[align=left] ///<param name="dbtype">参数类型</param>[/align]
[align=left] ///<param name="parametername">参数名</param>[/align]
[align=left] ///<param name="pvalue">参数值</param>[/align]
[align=left] public void AddParameter(DbType dbtype,string parametername,object pvalue)[/align]
[align=left] {[/align]
[align=left] SqlParameter p = new SqlParameter();[/align]
[align=left] [/align]
[align=left] p.DbType = dbtype;[/align]
[align=left] p.ParameterName = parametername;[/align]
[align=left] p.Value = pvalue;[/align]
[align=left] [/align]
[align=left] _comm.Parameters.Add(p);[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///添加参数重载2[/align]
[align=left] ///</summary>[/align]
[align=left] ///<param name="dbtype">参数类型</param>[/align]
[align=left] ///<param name="parametername">参数名</param>[/align]
[align=left] ///<param name="pvalue">参数值</param>[/align]
[align=left] ///<param name="parameterdirection">参数类型</param>[/align]
[align=left] public void AddParameter(DbType dbtype,string parametername,object pvalue,ParameterDirection parameterdirection)[/align]
[align=left] {[/align]
[align=left] SqlParameter p = new SqlParameter();[/align]
[align=left] [/align]
[align=left] p.DbType = dbtype;[/align]
[align=left] p.ParameterName = parametername;[/align]
[align=left] p.Value = pvalue;[/align]
[align=left] p.Direction = parameterdirection;[/align]
[align=left] [/align]
[align=left] _comm.Parameters.Add(p);[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///添加返回参数[/align]
[align=left] ///</summary>[/align]
[align=left] ///<param name="dbtype">DbType参数类型</param>[/align]
[align=left] ///<param name="parametername">参数名</param>[/align]
[align=left] public void AddParameterReturnValue(DbType dbtype,string parametername)[/align]
[align=left] {[/align]
[align=left] SqlParameter p = new SqlParameter();[/align]
[align=left] p.DbType = dbtype;[/align]
[align=left] p.ParameterName = parametername;[/align]
[align=left] p.Direction = ParameterDirection.ReturnValue;[/align]
[align=left] [/align]
[align=left] _comm.Parameters.Add(p);[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///返回DataSet对象[/align]
[align=left] ///</summary>[/align]
[align=left] ///<returns>执行数据命令后返回的DataSet对象</returns>[/align]
[align=left] public DataSet ExecuteDataSet()[/align]
[align=left] {[/align]
[align=left] _ds = new DataSet();[/align]
[align=left] SqlDataAdapter da = new SqlDataAdapter();[/align]
[align=left] da.SelectCommand = _comm;[/align]
[align=left] da.Fill(_ds);[/align]
[align=left] return _ds;[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///返回DataReader对象 重载1[/align]
[align=left] ///</summary>[/align]
[align=left] ///<returns>数据读取器</returns>[/align]
[align=left] public SqlDataReader ExecuteDataReader()[/align]
[align=left] {[/align]
[align=left] _dr = _comm.ExecuteReader();[/align]
[align=left] [/align]
[align=left] return _dr;[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///返回DataReader对象 重载2[/align]
[align=left] ///</summary>[/align]
[align=left] ///<param name="behavior">CommandBehavior参数,对参数结果的数据库影响说明</param>[/align]
[align=left] ///<returns>数据读取器</returns>[/align]
[align=left] public SqlDataReader ExecuteDataReader(CommandBehavior behavior)[/align]
[align=left] {[/align]
[align=left] _dr = _comm.ExecuteReader(behavior);[/align]
[align=left] [/align]
[align=left] return _dr;[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///执行数据命令并返回影响行数[/align]
[align=left] ///</summary>[/align]
[align=left] public int ExecuteNonQuery()[/align]
[align=left] {[/align]
[align=left] return _comm.ExecuteNonQuery();[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] ///<summary>[/align]
[align=left] ///通过参数名获得参数值[/align]
[align=left] ///</summary>[/align]
[align=left] ///<param name="parametername">参数名</param>[/align]
[align=left] ///<returns>返回参数值</returns>[/align]
[align=left] public object GetParameterValue(string parametername)[/align]
[align=left] {[/align]
[align=left] object returnvalue;[/align]
[align=left] [/align]
[align=left] returnvalue = _comm.Parameters[parametername].Value;[/align]
[align=left] [/align]
[align=left] return returnvalue;[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] #endregion[/align]
[align=left] [/align]
[align=left] }[/align]
[align=left]}[/align]