memberinfoservice.cs~rf2f21b93.tmp

个人版音像管理系统,可以扩展,内含数据库,支持多数据库使用

using System;
using System.Collections.Generic;
using System.Text;
using DiscSystemModel;
using DiscSystemIDAL;
using System.Data.SqlClient;
using System.Configuration;
using System.Data;


namespace DiscSystemDAL.SqlServer
{
    public class MemberInfoService:IMemberInfoService
    {
        private static string connStr = ConfigurationManager.ConnectionStrings["Sql"].ConnectionString;

        #region IMemberInfoService 成员

        public List<MemberInfo> SelectMemberInfo(object obj)
        {
            List<MemberInfo> memList = new List<MemberInfo>();
            using (SqlConnection conn=new SqlConnection(connStr))
            {
                string cmdStr = "proc_select_MemberInfo";
                SqlCommand cmd = new SqlCommand(cmdStr, conn);
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.Parameters.Add("@where", SqlDbType.VarChar, 50).Value = obj;
                conn.Open();
                using (SqlDataReader dr = cmd.ExecuteReader())
                {
                    while (dr.Read())
                    {
                        MemberInfo mem = new MemberInfo();
                        mem.MemberID = (string)dr["memberID"];
                        mem.MemberName = (string)dr["memberName"];
                        mem.MemberPhone = (string)dr["memberPhone"];
                        mem.MemberAddress = (string)dr["memberAddress"];
                        mem.MemberLV = (string)dr["MemberLV"];
                        mem.MaxCount = (int)dr["MaxCount"];
                        mem.DiscCount = (int)dr["DiscCount"];
                        memList.Add(mem);
                    }
                }
            }
            return memList;
        }

        public int InsertMemberInfo(MemberInfo mem)
        {
            int check = 0;
            using (SqlConnection conn=new SqlConnection(connStr))
            {
                string cmdStr = "proc_insert_MemberInfo";
                SqlCommand cmd = new SqlCommand(cmdStr, conn);
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.Parameters.Add("@MemberID", SqlDbType.VarChar, 10).Value = mem.MemberID;
                cmd.Parameters.Add("@MemberName", SqlDbType.VarChar, 20).Value = mem.MemberName;
                cmd.Parameters.Add("@MemberPhone", SqlDbType.VarChar, 15).Value = mem.MemberPhone;
                cmd.Parameters.Add("@MemberAddress", SqlDbType.VarChar, 20).Value = mem.MemberAddress;
                cmd.Parameters.Add("@LevelName", SqlDbType.VarChar, 20).Value = mem.MemberLV;
                conn.Open();
                check = cmd.ExecuteNonQuery();
            }
            return check;
        }

        public int UpdateMemberInfo(MemberInfo mem)
        {
            int check = 0;
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                string cmdStr = "proc_update_MemberInfo";
                SqlCommand cmd = new SqlCommand(cmdStr, conn);
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.Parameters.Add("@MemberID", SqlDbType.Int).Value = mem.MemberID;
                cmd.Parameters.Add("@MemberID", SqlDbType.VarChar, 10).Value = mem.MemberID;
                cmd.Parameters.Add("@MemberName", SqlDbType.VarChar, 20).Value = mem.MemberName;
                cmd.Parameters.Add("@MemberPhone", SqlDbType.VarChar, 15).Value = mem.MemberPhone;
                cmd.Parameters.Add("@MemberAddress", SqlDbType.VarChar, 20).Value = mem.MemberAddress;
                cmd.Parameters.Add("@LevelName", SqlDbType.VarChar, 20).Value = mem.MemberLV;
                conn.Open();
                check = cmd.ExecuteNonQuery();
            }
            return check;
        }

        public int DeleteMemberInfo(string MemberID)
        {
            int check = 0;
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                string cmdStr = string.Format("delete from MemberInfo where memberID = '{0}'",MemberID);
                SqlCommand cmd = new SqlCommand(cmdStr, conn);
                conn.Open();
                check = cmd.ExecuteNonQuery();
            }
            return check;
        }

        #endregion
    }
}