首页 > 代码库 > 强大的SQLHelper类
强大的SQLHelper类
在做机房收费系统的时候,曾经使用过Sqlhelper,当时对此内容理解不是很好,参照的是下篇的博客:
vb.net—SQLHelper类的使用
而做过之后,当再次回首往事的时候,发现这个SQLHelper类并
不是那么的强大。其实可以在多扩充些。并且不好的地方是没有加入安全的事务机制,在此小编在前人的基础上,模仿别人写了一个类似的Sqlhelper。先看下类图。
首先看一下此类,一共包含了13中方法,是对数据库增删改查的扩充,方便了用户的各种操作。比如当查询数据库的时候,可以返回DataRow、DataTable、DataSet、SqlDataReader类型的数值;当进行增删操作时,返回的数值类型包括bool、int等,分别代表是否更新成功、插入的行数等
其次在本类中更新数据库的时候,采用了HashTable传参的方式,只需要把更新的数值赋给HashTable以及更新的表名即可,免去了当初拼接更新数据库语句的麻烦。
最后,在本类中引入了SqlTransaction事务机制安全机制,当出现意外时,可以采取事务回滚的办法保证了数据的完整性和一致性问题。
<span style="font-family:SimSun;font-size:18px;">// 数据库接口类 public class DataBase { //私有变量,数据库连接 protected SqlConnection Connection; protected string ConnectionString; //构造函数 public DataBase() { ConnectionString = "Data Source=(local);DataBase=**;User ID=sa;Password=**;"; } //保护方法,打开数据库连接 private void Open() { //判断数据库连接是否存在 if (Connection == null) { //不存在,新建并打开 Connection = new SqlConnection(ConnectionString); Connection.Open(); } else { //存在,判断是否处于关闭状态 if (Connection.State.Equals(ConnectionState.Closed)) Connection.Open(); //连接处于关闭状态,重新打开 } } //公有方法,关闭数据库连接 public void Close() { if (Connection.State.Equals(ConnectionState.Open)) { Connection.Close(); //连接处于打开状态,关闭连接 } } /// <summary> /// 析构函数,释放非托管资源 /// </summary> ~DataBase() { try { if (Connection != null) Connection.Close(); } catch{} try { Dispose(); } catch{} } //公有方法,释放资源 public void Dispose() { if (Connection != null) // 确保连接被关闭 { Connection.Dispose(); Connection = null; } } //公有方法,根据Sql语句,返回是否查询到记录 public bool GetRecord(string XSqlString) { Open(); SqlDataAdapter adapter = new SqlDataAdapter(XSqlString, Connection); DataSet dataset = new DataSet(); adapter.Fill(dataset); Close(); if (dataset.Tables[0].Rows.Count > 0) { return true; } else { return false; } } //公有方法,返回Sql语句获得的数据值 //SqlString的格式:select count(*) from XXX where ... // select max(XXX) from YYY where ... public int GetRecordCount(string XSqlString) { string SCount; Open(); SqlCommand Cmd = new SqlCommand(XSqlString,Connection); SCount = Cmd.ExecuteScalar().ToString().Trim(); if (SCount=="") SCount="0"; Close(); return Convert.ToInt32(SCount); } //公有方法,根据XWhere查询数据表XTableName中的某些纪录 //XTableName--表名 //XHT--哈希表,键为字段名,值为字段值 public DataSet AdvancedSearch(string XTableName, Hashtable XHT) { int Count = 0; string Fields = ""; foreach(DictionaryEntry Item in XHT) { if (Count != 0) { Fields += " and "; } Fields += Item.Key.ToString(); Fields += " like '%"; Fields += Item.Value.ToString(); Fields += "%'"; Count++; } Fields += " "; string SqlString = "select * from " + XTableName + " where " + Fields; Open(); SqlDataAdapter Adapter = new SqlDataAdapter(SqlString, Connection); DataSet Ds = new DataSet(); Adapter.Fill(Ds); Close(); return Ds; } //私有方法,获得一个用来调用存储过程的SqlCommand //输入: // ProcName - 存储过程名 // Params - 用来调用存储过程的参数表 private SqlCommand CreateCommand(string ProcName, SqlParameter[] Prams) { Open(); SqlCommand Cmd = new SqlCommand(ProcName, Connection); Cmd.CommandType = CommandType.StoredProcedure; if (Prams != null) { foreach (SqlParameter Parameter in Prams) Cmd.Parameters.Add(Parameter); } return Cmd; } //私有方法,执行SQL命令 //输入: // StrName - 存储过程名 // Params - 用来调用存储过程的参数表 private SqlCommand CreateStrCommand(string StrName, SqlParameter[] Prams) { Open(); SqlCommand Cmd = new SqlCommand(StrName, Connection); Cmd.CommandType = CommandType.Text; if (Prams != null) { foreach (SqlParameter Parameter in Prams) Cmd.Parameters.Add(Parameter); } return Cmd; } //公有方法,实例化一个用于调用存储过程的参数 //输入: // ParamName - 参数名称 // DbType - 参数类型 // Size - 参数大小 // Direction - 传递方向 // Value - 值 public SqlParameter MakeParam(string ParamName, SqlDbType DbType, Int32 Size, ParameterDirection Direction, object Value) { SqlParameter Param; if(Size > 0) Param = new SqlParameter(ParamName, DbType, Size); else Param = new SqlParameter(ParamName, DbType); Param.Direction = Direction; if (Value != null) Param.Value = http://www.mamicode.com/Value;>
总结:
其实从宏观上来分析此SQLHelper,其实就是对数据库增删改查的应用。在增和删的基础上加入了事务安全机制,在查的基础上,返回值为多种类型可供选择。此SQLHelper类简单易用,用的时候,只需调用相应函数并传入参数即可。
强大的SQLHelper类
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。