publisherdal.cs

一个简单的网上书店

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using BLL;
using BLL.interfaces;
using Model;

namespace DAL
{
     public  class PublisherDal:IPublisher
    {

        #region IPublisher 成员

        public bool addPublisher(Publishers pub)
        {
            string sqlStr = "insert into Publishers ([name],address,phone,linkman) values (@name,@address,@phone,@linkman) ";
            SqlParameter[] p = new SqlParameter[] 
            {
                new SqlParameter("@name",pub.Name),
                new SqlParameter("@address",pub.address),
                new SqlParameter("@phone",pub.phone),
                new SqlParameter("@linkman",pub.linkman)
            };
            return DBHelp.Rework1(sqlStr, p) > 0 ? true : false;
        }

        public bool updatePub(Publishers pub)
        {
            string sqlStr = "update Publishers set([name]= @name,address=@address,phone=@phone,linkman=@linkman) where id=@id ";
            SqlParameter[] p = new SqlParameter[] 
            {
                new SqlParameter("@name",pub.Name),
                new SqlParameter("@address",pub.address),
                new SqlParameter("@phone",pub.phone),
                new SqlParameter("@linkman",pub.linkman),
                new SqlParameter("@id",pub.Id)
            };
            return DBHelp.Rework1(sqlStr, p) > 0 ? true : false;
        }

        public bool delPub(List<string> lst)
        {
           string id = "";
           for (int i = 0; i < lst.Count; i++)
           {
               id += lst[i]+",";
           }
            string sqlStr = "delete from Publishers where id in ("+id.Substring(0,id.Length-1)+") ";
            return DBHelp.Rework(sqlStr) > 0 ? true : false;
        }

        public List<Publishers> selPub(Page pager)
        {
            string sqlStr = "select top " + pager.getPageSize() + " * from publishers where id not in ";
            sqlStr += " (select top " + (pager.getCurrentPage() - 1) * (pager.getPageSize()) + " id from publishers)";
            List<Publishers> list = new List<Publishers>();
            using (SqlDataReader read = DBHelp.Sel(sqlStr))
            {
                while (read.Read())
                {
                    Publishers pub = new Publishers();
                    pub.Id=int.Parse(read["id"].ToString());
                    pub.Name = read["name"].ToString();
                    pub.address = read["address"].ToString();
                    pub.phone = read["phone"].ToString();
                    pub.linkman = read["linkman"].ToString();
                    list.Add(pub);
                }
                return list;
            }
        }

        public int count()
        {
            int rows = 0;
            string sqlStr = "select count(*) from publishers";
            rows = Count.getCount(sqlStr);
            return rows;
        }

        public List<Publishers> selOnly(int id)
        {
            string sqlStr = "select [name],address,phone,linkman from publishers where id=@id";
            SqlParameter[] p = new SqlParameter[]
            {
                new SqlParameter("@id",id)
            };
            List<Publishers> list = new List<Publishers>();
            using(SqlDataReader read=DBHelp.Selparam(sqlStr,p))
            {
                while (read.Read()) 
                {
                    Publishers pub = new Publishers();
                    pub.Name=read["name"].ToString();
                    pub.address=read["address"].ToString();
                    pub.phone=read["phone"].ToString();
                    pub.linkman=read["linkman"].ToString();
                    list.Add(pub);
                }
                return list;
            }
        }

        #endregion

         public List<Publishers> sel()
         {
             string sqlStr = "select id,[name] from publishers";
             List<Publishers> list = new List<Publishers>();
             using (SqlDataReader read = DBHelp.Sel(sqlStr))
             {
                 while (read.Read())
                 {
                     Publishers pub = new Publishers();
                     pub.Id = int.Parse(read["id"].ToString());
                     pub.Name = read["name"].ToString();
                     list.Add(pub);
                 }
                 return list;
             }
         }
    }
}