用SQLHelper类对数据库进行增删改查+C#3层架构开发

【实例简介】

开发时建议用SQLHelper类，因为此类对数据库操作的方法进行了封装，开发时，只需要反复调用就可以了。提高重用性。

【实例截图】

【核心代码】

using System;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;

namespace CustomerManagementSystem.DAL
{
    class SqlHelper
    {
        public static readonly string connstr = ConfigurationManager.ConnectionStrings["connstr"].ConnectionString;
        
        public static int ExecuteNonQuery(string sql,
            params SqlParameter[] parameters)
        {
            using (SqlConnection conn = new SqlConnection(connstr))
            {
                conn.Open();
                using (SqlCommand cmd = conn.CreateCommand())
                {
                    cmd.CommandText = sql;
                    cmd.Parameters.AddRange(parameters);
                    return cmd.ExecuteNonQuery();
                }
            }
        }

        public static object ExecuteScalar(string sql,
            params SqlParameter[] parameters)
        {
            using (SqlConnection conn = new SqlConnection(connstr))
            {
                conn.Open();
                using (SqlCommand cmd = conn.CreateCommand())
                {
                    cmd.CommandText = sql;
                    cmd.Parameters.AddRange(parameters);
                    return cmd.ExecuteScalar();
                }
            }
        }

        public static DataTable ExecuteDataTable(string sql,
            params SqlParameter[] parameters)
        {
            using (SqlConnection conn = new SqlConnection(connstr))
            {
                conn.Open();
                using (SqlCommand cmd = conn.CreateCommand())
                {
                    cmd.CommandText = sql;
                    cmd.Parameters.AddRange(parameters);

                    DataSet dataset = new DataSet();
                    SqlDataAdapter adapter = new SqlDataAdapter(cmd);
                    adapter.Fill(dataset);
                    return dataset.Tables[0];
                }
            }
        }

        public static object FromDbValue(object value)
        {
            if (value == DBNull.Value)
            {
                return null;
            }
            else
            {
                return value;
            }
        }

        public static object ToDbValue(object value)
        {
            if (value == null)
            {
                return DBNull.Value;
            }
            else
            {
                return value;
            }
        }
    }
}

using CustomerManagementSystem.Model;
using System;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;

namespace CustomerManagementSystem.DAL
{
    public class CustomerDAL
    {
        private Customer ToCustomer(DataRow row)
        {
            Customer cust = new Customer();
            cust.Id = (long)row["Id"];
            cust.Name = (string)row["Name"];
            cust.Sex = (string)row["Sex"];
            cust.Age = (int)row["Age"];
            cust.Department = (string)row["Department"];
            cust.BirthDay = (DateTime?)SqlHelper.FromDbValue(row["BirthDay"]);
            cust.HireDate = (DateTime?)SqlHelper.FromDbValue(row["HireDate"]);
            cust.TelNum = (string)row["TelNum"];
            cust.Address = (string)row["Address"];
            return cust;
        }


        #region  增加
        public void Insert(Customer customer)
        {
            SqlHelper.ExecuteNonQuery(@"INSERT INTO [T_Customer]
                       ([Name],[Sex],[Age],[Department]
                       ,[BirthDay],[HireDate],[Address],[TelNum])                                 
                        VALUES
                       (@Name,@Sex,@Age,@Department,@BirthDay,@HireDate,@Address,@TelNum)",
                new SqlParameter("@Name", customer.Name),
                new SqlParameter("@Sex", customer.Sex),
                new SqlParameter("@Age", customer.Age),
                new SqlParameter("@Department", customer.Department),
                new SqlParameter("@BirthDay", SqlHelper.ToDbValue(customer.BirthDay)),
                new SqlParameter("@HireDate", SqlHelper.ToDbValue(customer.HireDate)),
                new SqlParameter("@Address", customer.Address),
                new SqlParameter("@TelNum", customer.TelNum));
        }
        #endregion

        #region  删除
        public void DeleteById(long id)
        {
            SqlHelper.ExecuteNonQuery("delete from T_Customer where Id=@Id",
                new SqlParameter("@Id", id));
        }
        #endregion

        #region 更改
        public void Update(Customer customer)
        {
            SqlHelper.ExecuteNonQuery(@"UPDATE [T_Customer]
                       SET  [Name]=@Name
                           ,[Sex]=@Sex
                           ,[Age]=@Age
                           ,[Department]=@Department
                           ,[BirthDay] = @BirthDay
                           ,[HireDate]=@HireDate
                           ,[Address] = @Address
                           ,[TelNum] = @TelNum        
                            WHERE Id=@Id",
                new SqlParameter("@Name", customer.Name),
                new SqlParameter("@Sex", customer.Sex),
                new SqlParameter("@Age", customer.Age),
                new SqlParameter("@Department", customer.Department),
                new SqlParameter("@BirthDay", SqlHelper.ToDbValue(customer.BirthDay)),
                new SqlParameter("@HireDate", SqlHelper.ToDbValue(customer.HireDate)),
                new SqlParameter("@Address", customer.Address),
                new SqlParameter("@TelNum", customer.TelNum),
               new SqlParameter("@Id", customer.Id));
        }
        #endregion

        //public Customer GetDataById(long id)
        //{
        //    DataTable dt = SqlHelper.ExecuteDataTable("select * from T_Customer where Id=@Id",
        //        new SqlParameter("@Id", id));
        //    if (dt.Rows.Count <= 0)
        //    {
        //        return null;
        //    }
        //    else if (dt.Rows.Count > 1)
        //    {
        //        throw new Exception("严重错误，查出多条数据！");
        //    }
        //    else
        //    {
        //        DataRow row = dt.Rows[0];
        //        return ToCustomer(row);
        //    }
        //}

        public Customer[] GetDataById(long id)
        {
            DataTable dt = SqlHelper.ExecuteDataTable("select * from T_Customer where Id=@Id",
                new SqlParameter("@Id", id));
            Customer[] customers = new Customer[dt.Rows.Count];
            if (dt.Rows.Count <= 0)
            {
                return null;
            }
            else if (dt.Rows.Count > 1)
            {
                throw new Exception("严重错误，查出多条数据！");
            }
            else
            {
                for (int i = 0; i < dt.Rows.Count; i )
                {
                    DataRow row = dt.Rows[i];
                    customers[i] = ToCustomer(row);
                }
            }
            return customers;
        }
        public Customer[] GetDataBySex(string Sex)
        {
            DataTable dt = SqlHelper.ExecuteDataTable("select * from T_Customer where Sex=@Sex",
                new SqlParameter("@Sex", Sex));
            Customer[] customers = new Customer[dt.Rows.Count];
            if (dt.Rows.Count <= 0)
            {
                return null;
            }
            else
            {
                for (int i = 0; i < dt.Rows.Count; i )
                {
                    DataRow row = dt.Rows[i];
                    customers[i] = ToCustomer(row);
                }
            }
            return customers;
        }
        public Customer[] GetDataByDepartment(string Department)
        {
            DataTable dt = SqlHelper.ExecuteDataTable("select * from T_Customer where Department=@Department", new SqlParameter("@Department", Department));
            Customer[] customers = new Customer[dt.Rows.Count];
            if (dt.Rows.Count <= 0)
            {
                return null;
            }
            else
            {
                for (int i = 0; i < dt.Rows.Count; i )
                {
                    DataRow row = dt.Rows[i];
                    customers[i] = ToCustomer(row);
                }
            }
            return customers;
        }
        public Customer[] GetAllData()
        {

            DataTable table = SqlHelper.ExecuteDataTable("select * from T_Customer");
            Customer[] customers = new Customer[table.Rows.Count];
            for (int i = 0; i < table.Rows.Count; i )
            {
                DataRow row = table.Rows[i];
                customers[i] = ToCustomer(row);
            }
            return customers;
        }


    }
}

    本人QQ:1150801389

不足之处，希望相关学者指点指点，谢谢！