SqlHelper 拿來主義--逐步完善

    public static class SqlHelper

    {

        //獲取連接字符串

        private static readonly string constr = ConfigurationManager.ConnectionStrings["connectionStr"].ConnectionString;

        //ExecuteNonQuery()方法

        //ExecuteScalar()方法

        //ExecuteReader()方法

        //ExecuteDataTable()方法

        //執行增刪改的

        public static int ExecuteNonQuery(string sql, params SqlParameter[] pms)

        {

            //使用using關鍵字定義一個范圍，在范圍結束時自動調用這個類實例的Dispose處理對象

            using (SqlConnection con = new SqlConnection(constr))

            {

                //創建執行sql命令對象

                using (SqlCommand cmd = new SqlCommand(sql, con))

                {

                    //判斷是否傳遞了sql參數

                    if (pms != null)

                    {

                        //將參數添加到Parameters集合中

                        cmd.Parameters.AddRange(pms);

                    }

                    con.Open();

                    return cmd.ExecuteNonQuery();

                }

            }

        }

        //執行返回單個值的

        public static object ExecuteScalar(string sql, params SqlParameter[] pms)

        {

            using (SqlConnection con = new SqlConnection(constr))

            {

                using (SqlCommand cmd = new SqlCommand(sql, con))

                {

                    if (pms != null)

                    {

                        cmd.Parameters.AddRange(pms);

                    }

                    con.Open();

                    return cmd.ExecuteScalar();

                }

            }

        }

        //執行返回SqlDataReader

        public static SqlDataReader ExecuteReader(string sql, params SqlParameter[] pms)

        {

            SqlConnection con = new SqlConnection(constr);

            using (SqlCommand cmd = new SqlCommand(sql, con))

            {

                if (pms != null)

                {

                    cmd.Parameters.AddRange(pms);

                }

                try

                {

                    con.Open();

                    return cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);

                }

                catch (Exception ex)

                {

                    con.Close();

                    con.Dispose();

                    throw;

                }

            }

        }

        //執行返回DataTable

        public static DataTable ExecuteDataTable(string sql, params SqlParameter[] pms)

        {

            DataTable dt = new DataTable();

            using (SqlDataAdapter adapter = new SqlDataAdapter(sql, constr))

            {

                if (pms != null)

                {

                    adapter.SelectCommand.Parameters.AddRange(pms);

                }

                adapter.Fill(dt);

            }

            return dt;

        }

        public static DataSet Query(string SQLString,params SqlParameter[] pms)

        {

            DataSet ds = new DataSet();

            using (SqlDataAdapter adapter = new SqlDataAdapter(SQLString, constr))

            {

                if (pms != null)

                {

                    adapter.SelectCommand.Parameters.AddRange(pms);

                }

                adapter.Fill(ds);

            }

            return ds;

        }

    }