Hidistro.SqlDal/Commodities/AttributeDao.cs

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

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

namespace Hidistro.SqlDal.Commodities
{
    using Hidistro.Core;
    using Hidistro.Entities;
    using Hidistro.Entities.Commodities;
    using Microsoft.Practices.EnterpriseLibrary.Data;
    using System;
    using System.Collections.Generic;
    using System.Data;
    using System.Data.Common;

    public class AttributeDao
    {
        private Database database = DatabaseFactory.CreateDatabase();

        public bool AddAttribute(AttributeInfo attribute)
        {
            DbCommand sqlStringCommand = this.database.GetSqlStringCommand("DECLARE @DisplaySequence AS INT SELECT @DisplaySequence = (CASE WHEN MAX(DisplaySequence) IS NULL THEN 1 ELSE MAX(DisplaySequence) + 1 END) FROM Hishop_Attributes; INSERT INTO Hishop_Attributes(AttributeName, DisplaySequence, TypeId, UsageMode, UseAttributeImage) VALUES(@AttributeName, @DisplaySequence, @TypeId, @UsageMode, @UseAttributeImage); SELECT @@IDENTITY");
            this.database.AddInParameter(sqlStringCommand, "AttributeName", DbType.String, attribute.AttributeName);
            this.database.AddInParameter(sqlStringCommand, "TypeId", DbType.Int32, attribute.TypeId);
            this.database.AddInParameter(sqlStringCommand, "UsageMode", DbType.Int32, (int) attribute.UsageMode);
            this.database.AddInParameter(sqlStringCommand, "UseAttributeImage", DbType.Boolean, attribute.UseAttributeImage);
            object obj2 = this.database.ExecuteScalar(sqlStringCommand);
            if ((attribute.AttributeValues.Count != 0) && (obj2 != null))
            {
                int num = Convert.ToInt32(obj2);
                foreach (AttributeValueInfo info in attribute.AttributeValues)
                {
                    DbCommand command = this.database.GetSqlStringCommand("DECLARE @DisplaySequence AS INT SELECT @DisplaySequence = (CASE WHEN MAX(DisplaySequence) IS NULL THEN 1 ELSE MAX(DisplaySequence) + 1 END) FROM Hishop_AttributeValues; INSERT INTO Hishop_AttributeValues(AttributeId, DisplaySequence, ValueStr, ImageUrl) VALUES(@AttributeId, @DisplaySequence, @ValueStr, @ImageUrl)");
                    this.database.AddInParameter(command, "AttributeId", DbType.Int32, num);
                    this.database.AddInParameter(command, "ValueStr", DbType.String, info.ValueStr);
                    this.database.AddInParameter(command, "ImageUrl", DbType.String, info.ImageUrl);
                    this.database.ExecuteNonQuery(command);
                }
            }
            return (obj2 != null);
        }

        public int AddAttributeName(AttributeInfo attribute)
        {
            int num = 0;
            DbCommand sqlStringCommand = this.database.GetSqlStringCommand("DECLARE @DisplaySequence AS INT SELECT @DisplaySequence = (CASE WHEN MAX(DisplaySequence) IS NULL THEN 1 ELSE MAX(DisplaySequence) + 1 END) FROM Hishop_Attributes; INSERT INTO Hishop_Attributes(AttributeName, DisplaySequence, TypeId, UsageMode, UseAttributeImage) VALUES(@AttributeName, @DisplaySequence, @TypeId, @UsageMode, @UseAttributeImage); SELECT @@IDENTITY");
            this.database.AddInParameter(sqlStringCommand, "AttributeName", DbType.String, attribute.AttributeName);
            this.database.AddInParameter(sqlStringCommand, "TypeId", DbType.Int32, attribute.TypeId);
            this.database.AddInParameter(sqlStringCommand, "UsageMode", DbType.Int32, (int) attribute.UsageMode);
            this.database.AddInParameter(sqlStringCommand, "UseAttributeImage", DbType.Boolean, attribute.UseAttributeImage);
            object obj2 = this.database.ExecuteScalar(sqlStringCommand);
            if (obj2 != null)
            {
                num = Convert.ToInt32(obj2);
            }
            return num;
        }

        public bool DeleteAttribute(int attributeId)
        {
            DbCommand sqlStringCommand = this.database.GetSqlStringCommand("DELETE FROM Hishop_Attributes WHERE AttributeId = @AttributeId AND not exists (SELECT * FROM Hishop_SKUItems WHERE AttributeId = @AttributeId)");
            this.database.AddInParameter(sqlStringCommand, "AttributeId", DbType.Int32, attributeId);
            return (this.database.ExecuteNonQuery(sqlStringCommand) > 0);
        }