com.eshop.www.DAL/ProductRelateArticleDAO.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

//
// 
// 网址：http://.taobao.com
// QQ：



using System;
using System.Collections.Generic;
using System.Text;
using com.eshop.www.Model;
using Microsoft.Practices.EnterpriseLibrary.Data;
using System.Data.Common;
using System.Data;

namespace com.eshop.www.DAL
{
    public class ProductRelateArticleDAO
    {
        public bool Add(ProductRelateArticle productRelateArticle)
        {
            Database database = DatabaseFactory.CreateDatabase();
            string sql = "insert into product_relate_article(product_id,relate_article_id) values (@product_id,@relate_article_id)";
            DbCommand cmd = database.GetSqlStringCommand(sql);
            database.AddInParameter(cmd, "@product_id", DbType.Int32, productRelateArticle.ProductId);
            database.AddInParameter(cmd, "@relate_article_id", DbType.Int32, productRelateArticle.RelatedArticleId);
            int row = database.ExecuteNonQuery(cmd);
            return row > 0;
        }

        public bool Delete(int Id)
        {
            Database database = DatabaseFactory.CreateDatabase();
            string sql = "delete from product_relate_article where Id=@Id";
            DbCommand cmd = database.GetSqlStringCommand(sql);
            database.AddInParameter(cmd, "@Id", DbType.Int32, Id);
            int row = database.ExecuteNonQuery(cmd);
            return row > 0;
        }

        public bool Update(ProductRelateArticle productRelateArticle)
        {
            Database database = DatabaseFactory.CreateDatabase();
            string sql = "update product_relate_article set product_id=@product_id,relate_article_id=@relate_article_id where Id=@Id";
            DbCommand cmd = database.GetSqlStringCommand(sql);
            database.AddInParameter(cmd, "@product_id", DbType.Int32, productRelateArticle.ProductId);
            database.AddInParameter(cmd, "@relate_article_id", DbType.Int32, productRelateArticle.RelatedArticleId);
            database.AddInParameter(cmd, "@Id", DbType.Int32, productRelateArticle.Id);
            int row = database.ExecuteNonQuery(cmd);
            return row > 0;
        }

        public ProductRelateArticle GetEntity(int Id)
        {
            ProductRelateArticle productRelateArticle = new ProductRelateArticle();
            Database database = DatabaseFactory.CreateDatabase();