orderdal.cs

一个简单的网上书店

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

namespace DAL
{
   public class OrderDal:IOrder
    {
        #region IOrder 成员

        public bool addOrder(Orders order)
        {
            string sqlStr = "insert into orders (id,userid,totalprice) values (@id,@userid,@total) ";
            SqlParameter[] p = new SqlParameter[] 
            {
                new SqlParameter("@id",order.id),
                new SqlParameter("@userid",order.UserId),
                new SqlParameter("@total",order.Totalprice)
            };
            return DBHelp.Rework1(sqlStr, p) > 0 ? true : false;
        }

        public bool updateOrder(int id)
        {
            string sqlStr = "update orders set state=0 where id=@id";
            SqlParameter[] p = new SqlParameter[] 
            {
                new SqlParameter("@total",id)
            };
            return DBHelp.Rework1(sqlStr, p) > 0 ? true : false;
        }

        public bool delOrder(string id)
        {
            string sqlStr = "delete from orders where id in "+id;
            return DBHelp.Rework(sqlStr) > 0 ? true : false;
        }

        public List<Orders> selOrders(Page pager)
        {
            string sqlStr = "select top " + pager.getPageSize() + "o.id,o.orderdate,o.userid,u.[name],o.Totalprice,o.state ";
            sqlStr += "from orders as o,users as u where o.userid=u.id and o.id not in ";
            sqlStr += " (select top " + (pager.getCurrentPage() - 1) * (pager.getPageSize()) + " o.id from orders as o,users as u where o.userid=u.id)";
            List<Orders> list = new List<Orders>();
            using (SqlDataReader read = DBHelp.Sel(sqlStr))
            {
                while (read.Read())
                {
                    Orders order = new Orders();
                    order.id=int.Parse(read["id"].ToString());
                    order.OrderDate = DateTime.Parse(read["orderdate"].ToString());
                    order.UserId = int.Parse(read["userid"].ToString());
                    order.User.Name = read["name"].ToString();
                    order.Totalprice = double.Parse(read["totalprice"].ToString());
                    order.state = int.Parse(read["state"].ToString());
                    list.Add(order);
                }
                return list;
            }
        }

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

        #endregion

        #region IOrder 成员


        public int selOrderId()
        {
            string sqlStr = "select max(id) from Orders";
            try
            {
                using (SqlDataReader read = DBHelp.Sel(sqlStr))
                {
                    int count = 0;
                    if (read.Read())
                        count = (read[0] != null) ? int.Parse(read[0].ToString()) : 0;
                    return count;
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        #endregion
    }
}