orderbookdal.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 OrderBookDal:IOrderBook
    {
        #region IOrderBook 成员

        public bool addOrderBook(OrderBook orderBook)
        {
            string sqlStr = "insert into orderbook (orderid,bookid,quantity,unitprice,price) ";
            sqlStr += "values (@orderid,@bookid,@quantity,@unitprice,@price)";
            SqlParameter[] p = new SqlParameter[] 
            {
                new SqlParameter("@orderid",orderBook.OrderId),
                new SqlParameter("@bookid",orderBook.BookId),
                new SqlParameter("@quantity",orderBook.Quantity),
                new SqlParameter("@unitprice",orderBook.UnitPrice),
                new SqlParameter("@price",(orderBook.UnitPrice)*(orderBook.Quantity))
            };
            return DBHelp.Rework1(sqlStr, p) > 0 ? true : false;
        }

        public bool updateOrderBook(OrderBook orderBook)
        {
            return false;
        }

        public bool delOrderBook(int id)
        {
            string sqlStr = "delete from orderbook where id=@id ";
            SqlParameter[] p = new SqlParameter[] 
            {
                new SqlParameter("@id",id)
            };
            return DBHelp.Rework1(sqlStr, p) > 0 ? true : false;
        }

        public List<OrderBook> selOrderBook(int id)
        {
            string sqlStr = "select o.id,o.orderid,o.bookid,b.title,o.quantity,o.unitprice,o.price ";
            sqlStr += "from orderbook as o,books as b where o.bookid=b.id and o.orderid=@orderid ";
            //sqlStr += " (select top " + (pager.getCurrentPage() - 1) * (pager.getPageSize()) + " o.id from orderbook where o.orderid=@orderid)";
            SqlParameter[] p = new SqlParameter[] 
            {
                new SqlParameter("@orderid",id)
            };
            List<OrderBook> list = new List<OrderBook>();
            using (SqlDataReader read = DBHelp.Selparam(sqlStr,p))
            {
                while (read.Read())
                {
                    OrderBook order = new OrderBook();
                    order.Id = int.Parse(read["id"].ToString());
                    order.BookId = int.Parse(read["bookid"].ToString());
                    order.Book.Title = read["title"].ToString();
                    order.Quantity = int.Parse(read["quantity"].ToString());
                    order.UnitPrice = Double.Parse(read["unitprice"].ToString());
                    order.Price = Double.Parse(read["price"].ToString());
                    
                    list.Add(order);
                }
                return list;
            }
        }

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

        #endregion
    }
}