传说中的SQLHelper

    技术2022-05-20  35

    几天没写过东西感觉少点什么,这是个好现象,到了什么时候不学习,什么时候都难受的时候我也就满意了.不管结果如何起码我问心无愧.接着前几天的学习.

    测试过了ADO.NET中从配置文件读取连接字符串,三层架构,然后就该写传说中的SQLHelper了,虽然开发的时候都是用别人写好的,但是自己写一遍更容易理解,应用起来也更得心应手吧.

    一般连接数据库步骤是:读取连接字符串,创建数据库连接对象,打开数据库,创建sqlcommand对象,拼接数据库连接字符串.这几步都是可重用的所以可以都写在SQLHelper中,至于参数化查询,都当参数传递就行.直接代码.解释也都在里面了:

    SQLHelper.cs

     

    using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Configuration; using System.Data.SqlClient; using System.Data;

    namespace Login.UI {     class SQLHelper     {         public static readonly string strConnection = ConfigurationManager.ConnectionStrings["Localconn"].ConnectionString;

            /// <summary>         /// 使用默认连接         /// </summary>         /// <param name="cmdText">命令文本或者叫SQL语句</param>         /// <param name="parameters">参数集</param>         /// <returns>int</returns>         public static int ExecuteNonQuery(string cmdText,params SqlParameter[] parameters)         {             using (SqlConnection sqlconn=new SqlConnection (strConnection))             {                 sqlconn.Open();                 using (SqlCommand sqlcmd=sqlconn.CreateCommand())                 {                     sqlcmd.CommandText = cmdText;                     foreach (SqlParameter parameter in parameters)                     {                         sqlcmd.Parameters.Add(parameter);                     }                     return  sqlcmd.ExecuteNonQuery();                 }             }         }         public static object ExecuteScalar(string cmdText, params SqlParameter[] parameters)         {             using (SqlConnection sqlconn=new SqlConnection (strConnection))             {                 sqlconn.Open();                 using (SqlCommand sqlcmd=sqlconn.CreateCommand())                 {                                         sqlcmd.CommandText = cmdText;                     foreach (SqlParameter  parameter in parameters)                     {                         sqlcmd.Parameters.Add(parameter);                     }                     return sqlcmd.ExecuteScalar();                 }             }

            }         /*          *SqlDataReader是连接相关的,其查询结果不是放在本地程序中,而是放在数据库服务器上,SqlDataReader只是相当于放了一个指针(游标)          *只能读取当前游标指向的行,一旦廉洁断开就不能再读取,这样做的好处就是无论查询结果有多少条,对程序占用的内存都几乎没有影响          *因为关闭了连接不能再读取,而下面程序用了Using方法结束时自动关闭连接,所以无法使用          */         //public static SqlDataReader ExecuteReader(string cmdText,params SqlParameter[] parameters)         //{         //    using (SqlConnection sqlconn = new SqlConnection(strConnection))         //    {         //        sqlconn.Open();         //        using (SqlCommand sqlcmd = sqlconn.CreateCommand())         //        {         //            sqlcmd.CommandText = cmdText;         //            foreach (SqlParameter parameter in parameters)         //            {         //                sqlcmd.Parameters.Add(parameter);         //            }         //            return sqlcmd.ExecuteReader();         //        }         //    }         //}         //如果要使用SqlDataReader则不能用using关闭连接,在SQLHelper中不应关闭连接,应该留给用户关闭         public static SqlDataReader ExecuteReader(string cmdText, params SqlParameter[] parameters)         {             SqlConnection sqlconn = new SqlConnection(strConnection);                 sqlconn.Open();                 using (SqlCommand sqlcmd = sqlconn.CreateCommand())                 {                     sqlcmd.CommandText = cmdText;                     foreach (SqlParameter parameter in parameters)                     {                         sqlcmd.Parameters.Add(parameter);                     }                     return sqlcmd.ExecuteReader();                 }                  }         /*          *所以SqlDataReader对于小数据量的程序来说没有什么优势。          *ADO.Net中提供了另一种数据集的方式将查询及过填充到本地内存中。          *这样即使连接断开,或者服务器断开都不影响数据的读取                 *DataSet dataset=new DataSet();SqlDataAdapter adapter=new SqlDataAdapter(cmd);adapter.Fill(dataset);          *SqlDataAdapter是DataSet和数据之间的沟通桥梁,数据集DataSet包含若干          *表DataTable。DataTable包含若干行DataRow。          *foreach(DataRow row in dataset.Tables[0].Rows)          *row["Name"]          */         public static DataTable ExecuteDataTable(string cmdText,params SqlParameter[] parameters)         {             using (SqlConnection sqlconn=new SqlConnection (strConnection))             {                 sqlconn.Open();                 using (SqlCommand sqlcmd=sqlconn.CreateCommand())                 {                     sqlcmd.CommandText = cmdText;                     foreach (SqlParameter parameter in parameters)                     {                         sqlcmd.Parameters.Add(parameter);                      }                     DataSet dataset = new DataSet();                     SqlDataAdapter adapter=new SqlDataAdapter(sqlcmd);                     adapter.Fill(dataset);                     //因为只返回一张表,所以取出数组的第一个                     return dataset.Tables[0];                 }             }

            }

        } }


    最新回复(0)