首页 > 代码库 > 强大的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类