memberdal.cs

c#三层架构项目开发的全过程

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using Model.Members;

namespace DAL.Members
{
   public class MemberDal
    {
    
    
        #region 执行查询sql
        /// <summary>
        /// 执行查询sql
        /// </summary>
        /// <param name="procname">存储过程名称</param>
        /// <param name="pars">参数数组</param>
        /// <returns>返回DataTable</returns>
        public static DataTable search(string procname, SqlParameter[] pars)
        {
            DataTable dt = new DataTable();
            //1.建立一个连接
            using (SqlConnection conn = new SqlConnection(SqlHelper.conStr))
            {
                //2.创建cmd对象
                SqlCommand cmd = new SqlCommand(procname, conn);

                //3.参数加入到cmd
                cmd.CommandType = CommandType.StoredProcedure;
                if (pars != null)
                {
                    foreach (SqlParameter item in pars)
                    {
                        cmd.Parameters.Add(item);
                    }
                }

                //4.创建da对象
                SqlDataAdapter da = new SqlDataAdapter(cmd);
                //5.填充数据集
                da.Fill(dt);
            }


            return dt;


        }
        #endregion
    

        #region 会员添加存储过程

        public void add(Memberb model)
        {
            SqlParameter[] pars = new SqlParameter[7];
            pars[0] = new SqlParameter("@Member_ID", SqlDbType.VarChar, 18);

            pars[1] = new SqlParameter("@Member_level_ID", SqlDbType.Int);

            pars[2] = new SqlParameter("@Member_name", SqlDbType.VarChar, 10);

            pars[3] = new SqlParameter("@Member_Sex", SqlDbType.VarChar, 4);

            pars[4] = new SqlParameter("@HYMember_Mobile", SqlDbType.VarChar, 15);

            pars[5] = new SqlParameter("@HYMember_Birthday", SqlDbType.VarChar, 10);

            pars[6] = new SqlParameter("@HYMember_Text", SqlDbType.Text);
            pars[0].Value = model.Member_ID;
            pars[1].Value = model.Member_level_ID;
            pars[2].Value = model.Member_name;
            pars[3].Value = model.Member_Sex;
            pars[4].Value = model.HYMember_Mobile;
            pars[5].Value = model.HYMember_Birthday;
            pars[6].Value = model.HYMember_Text;
            search("MemberAdd", pars);

        }
        #endregion


        #region 客户添加存储过程

        public void khadd(Memberb model)
        {
            SqlParameter[] pars = new SqlParameter[4];
            pars[0] = new SqlParameter("@Member_ID", SqlDbType.VarChar, 18);

           

            pars[1] = new SqlParameter("@Member_name", SqlDbType.VarChar, 10);



            pars[2] = new SqlParameter("@KHMember_Mobile", SqlDbType.VarChar, 15);



            pars[3] = new SqlParameter("@KHMember_Text", SqlDbType.Text);
            pars[0].Value = model.Member_ID;
            
            pars[1].Value = model.Member_name;
           
            pars[2].Value = model.HYMember_Mobile;
           
            pars[3].Value = model.HYMember_Text;
            search("khmenber", pars);

        }
        #endregion
       
        #region 会员/客户查询存储过程
        public DataTable select(Memberb moder)
        {
            SqlParameter[] pars = new SqlParameter[1];
            pars[0] = new SqlParameter("@Membername", SqlDbType.VarChar, 10);
            pars[0].Value = moder.Member_name;
            return search("Memberselct", pars);

        }
        #endregion
        #region 会员修改存储过程
        public DataTable update(Memberb moder)
        {
            SqlParameter[] pars = new SqlParameter[7];
            pars[0] = new SqlParameter("@Member_ID", SqlDbType.VarChar, 18);
            pars[1] = new SqlParameter("@Member_level_ID", SqlDbType.Int);
            pars[2] = new SqlParameter("@Member_name", SqlDbType.VarChar, 10);
            pars[3] = new SqlParameter("@Member_Sex", SqlDbType.VarChar, 4);
            pars[4] = new SqlParameter("@HYMember_Mobile", SqlDbType.VarChar, 15);
            pars[5] = new SqlParameter("@HYMember_Birthday", SqlDbType.VarChar, 10);
            pars[6] = new SqlParameter("@HYMember_Text", SqlDbType.Text);
            pars[0].Value = moder.Member_ID;
            pars[1].Value = moder.Member_level_ID;
            pars[2].Value = moder.Member_name;
            pars[3].Value = moder.Member_Sex;
            pars[4].Value = moder.HYMember_Mobile;
            pars[5].Value = moder.HYMember_Birthday;
            pars[6].Value = moder.HYMember_Text;
            return search("Memberupdate", pars);

        }
        #endregion
        #region 客户信息修改存储过程
        public DataTable KHupdate(Memberb moder)
        {
            SqlParameter[] pars = new SqlParameter[4];
            pars[0] = new SqlParameter("@Member_ID", SqlDbType.VarChar, 18);
           
            pars[1] = new SqlParameter("@Member_name", SqlDbType.VarChar, 10);
           
            pars[2] = new SqlParameter("@HYMember_Mobile", SqlDbType.VarChar, 15);
           
            pars[3] = new SqlParameter("@HYMember_Text", SqlDbType.Text);
            pars[0].Value = moder.Member_ID;
           
            pars[1].Value = moder.Member_name;
          
            pars[2].Value = moder.HYMember_Mobile;
           
            pars[3].Value = moder.HYMember_Text;
            return search("KHMemberupdate", pars);

        }
        #endregion
    }
}