SqlHelper

逃离我推掉我的手 2022-08-21 14:51 175阅读 0赞

数据库操作的时候，模式很固定。于是把这些操作都封装起来。  
达到提供sql语句或参数，得到结果的目的。  
我们把这个类库叫SqlHelper

# SqlHelper #

using System;
    using System.Configuration;
    using System.Data;
    using System.Data.SqlClient;
    
    namespace YZLibrary
    {
        class SqlHelper
        {
            private static readonly string connStr = ConfigurationManager.ConnectionStrings["sql"].ConnectionString;
    
            /// <summary>
            /// 执行非查询语句并返回受影响行数
            /// </summary>
            /// <param name="sql"></param>
            /// <param name="pms"></param>
            /// <returns></returns>
            public static int ExecuteNonQuery(string sql, params SqlParameter[] pms)
            {
                using (SqlConnection conn = new SqlConnection(connStr))
                {
                    using (SqlCommand cmd = new SqlCommand(sql, conn))
                    {
                        cmd.Parameters.AddRange(pms);
                        conn.Open();
                        return cmd.ExecuteNonQuery();
                    }
                }
            } 
    
            /// <summary>
            /// 执行查询，并返回查询的结果集中的第一行第一列
            /// </summary>
            /// <param name="sql"></param>
            /// <param name="pms"></param>
            /// <returns></returns>
            public static object ExecuteScalar(string sql,  params SqlParameter[] pms)
            {
                using (SqlConnection conn = new SqlConnection(connStr))
                {
                    using (SqlCommand cmd = new SqlCommand(sql, conn))
                    {
    
                        cmd.Parameters.AddRange(pms);
                        conn.Open();
                        return cmd.ExecuteScalar();
                    }
                }
            }
    
            /// <summary>
            /// 执行查询，并返回SqlDataReader。
            /// </summary>
            /// <param name="sql"></param>
            /// <param name="pms"></param>
            /// <returns></returns>
            public static SqlDataReader ExecuteReader(string sql, params SqlParameter[] pms)
            {
                SqlConnection conn = new SqlConnection(connStr);
                try
                {
                    using (SqlCommand cmd = new SqlCommand(sql, conn))
                    {
                        cmd.Parameters.AddRange(pms);
                        conn.Open();
                        return cmd.ExecuteReader(CommandBehavior.CloseConnection);
                    }
                }
                catch (Exception ex)
                {
                    conn.Dispose();
                    throw ex;
                }
            }
    
            /// <summary>
            /// 执行查询，返回DataTable
            /// </summary>
            /// <param name="sql"></param>
            /// <param name="pms"></param>
            /// <returns></returns>
            public static DataTable ExecuteDataTable(string sql,params SqlParameter[] pms)
            {
                DataTable dt = new DataTable();
                using (SqlDataAdapter adapter = new SqlDataAdapter(sql, connStr))
                {
                    adapter.SelectCommand.Parameters.AddRange(pms);
                    adapter.Fill(dt);
                }
    
                return dt;
            } 
        }
    }

## ExecuteReader ##

ExecuteScalar只执行一次，执行完后就可以把连接断开，但ExecuteReader要从数据库取好几次，所以连接要一直开着，直到数据取完了。  
那怎么关掉连接，开始是想从外边关，但从外边关根本无法访问到函数里边的conn对象，没法儿关。  
于是就用到了CommandBehavior.CloseConnection，在执行该命令时，如果关闭关联的 DataReader 对象，则关联的 Connection 对象也将关闭。

# 使用SQLHelper #

//ExecuteNonQuery 无参的
                string sql = "update LoginTest set pwd=1234 where uid='小明';";
                int res = SqlHelper.ExecuteNonQuery(sql);
                Console.WriteLine(res);
                Console.ReadKey();
    
                //ExecuteNonQuery 有参的
                string sql = "update LoginTest set pwd=@pwd where uid=@uid;";
                SqlParameter[] ps =
                {
                    new SqlParameter("@pwd",1),//如果第二个参数为0，要用（object）强转，否则会默认为第二个构造函数。第二个构造函数，是枚举型，和第一个构造函数冲突
                    new SqlParameter("@uid","小明"),
                };
                int res = SqlHelper.ExecuteNonQuery(sql, ps);
                Console.WriteLine(res);
                Console.ReadKey();  
    
    
                //ExecuteScalar 参数化模糊查询
                string sql = "select count(*) from LoginTest where uid like @uid";
                SqlParameter pUid = new SqlParameter("@uid", "杨%");
                int count = (int)SqlHelper.ExecuteScalar(sql, pUid);
                Console.WriteLine(count);
                Console.ReadKey();
    
                //ExecuteReader
                using (SqlDataReader reader = SqlHelper.ExecuteReader("select * from LoginTest"))
                {
                    while (reader.Read())
                    {
                        List<string> list = new List<string>();
                        for (int i = 0; i < reader.FieldCount; i++)
                        {
                            list.Add(reader[i].ToString());
                        }
                        Console.WriteLine(string.Join(",", list));
                    }
                }
                Console.ReadKey();
    
                //DataAdapter,这个要建winform程序
                string sql = "select * from LoginTest";
                dataGridView1.DataSource = SqlHelper.ExecuteDataTable(sql);

这是比较简单的SqlHelper。  
还有比较完善的[微软SQLHelper.cs类 中文版][SQLHelper.cs_]

[SQLHelper.cs_]: http://www.cnblogs.com/liwuyi/archive/2012/05/16/2505461.html