Redis學習筆記~是時候為Redis實現一個倉儲了，RedisRepository來了

文章出處

之前寫了不少關于倉儲的文章，所以，自己習慣把自己叫倉儲大叔，上次寫的XMLRepository得到了大家的好評，也有不少朋友給我發email，進行一些知識的探討，今天主要來實現一個RedisRepository，它始終是集成IRepository接口的，我這里的Redis倉儲主要服務為復雜類型的業務，對于只存string這種需求，不需要使用它。

對于Redis倉儲和說，它與XML倉儲有些不同，由于ＸＭＬ文件一般存儲在ＷＷＷ服務器，所以沒有網絡通訊問題，而redis一般部署在第三臺服務器上，我們一般稱為NoSQL服務器，它與ＷＷＷ通訊是通過socket協議完成的，正是如些，我們在進行倉儲設計時，應該考慮到如何去釋放它的資源，因為這種資源是非托管的，所以需要人為干預一下，.net提供了using關鍵字來做這事，而每個動作寫using這顯然是不友好的，所以，我這個redis倉儲是在析構方法里完成對資源的銷毀的，請看源代碼：

首先是redis基類，它是實現統一操作的前提

 　 /// <summary>
    /// Redis實體基類，所有redis實體類都應該集成它
    /// </summary>
    public abstract class RedisEntity
    {
        public RedisEntity()
        {
            RootID = Guid.NewGuid().ToString();
        }
        /// <summary>
        /// Redis實體主鍵，方法查詢，刪除，更新等操作
        /// </summary>
        public virtual string RootID { get; set; }
    }

下面才是RedisRepository倉儲的代碼

    /// <summary>
    /// Redis倉儲實現
    /// </summary>
    public class RedisRepository<TEntity> :
        IDisposable,
        IRepository<TEntity>
        where TEntity : RedisEntity
    {
        IRedisClient redisDB;
        IRedisTypedClient<TEntity> redisTypedClient;
        IRedisList<TEntity> table;
        public RedisRepository()
        {
            redisDB = RedisManager.GetClient();
            redisTypedClient = redisDB.GetTypedClient<TEntity>();
            table = redisTypedClient.Lists[typeof(TEntity).Name];
        }

        #region IRepository<TEntity>成員
        public void SetDbContext(IUnitOfWork unitOfWork)
        {
            throw new NotImplementedException();
        }

        public void Insert(TEntity item)
        {
            if (item != null)
              {
                redisTypedClient.AddItemToList(table, item);
                redisDB.Save();
              }

        }

        public void Delete(TEntity item)
        {
            if (item != null)
            {
                var entity = Find(item.RootID);
                redisTypedClient.RemoveItemFromList(table, entity);
                redisDB.Save();
            }
        }

        public void Update(TEntity item)
        {
            if (item != null)
            {
                var old = Find(item.RootID);
                if (old != null)
                {
                    redisTypedClient.RemoveItemFromList(table, old);
                    redisTypedClient.AddItemToList(table, item);
                    redisDB.Save();
                }
            }
        }

        public IQueryable<TEntity> GetModel()
        {
            return table.GetAll().AsQueryable();
        }

        public TEntity Find(params object[] id)
        {
            return table.Where(i => i.RootID == (string)id[0]).FirstOrDefault();
        }
        #endregion

        #region IDisposable成員
        public void Dispose()
        {
            this.ExplicitDispose();
        }
        #endregion

        #region Protected Methods

        /// <summary>
        /// Provides the facility that disposes the object in an explicit manner,
        /// preventing the Finalizer from being called after the object has been
        /// disposed explicitly.
        /// </summary>
        protected void ExplicitDispose()
        {
            this.Dispose(true);
            GC.SuppressFinalize(this);
        }

        protected void Dispose(bool disposing)
        {
            if (disposing)//清除非托管資源
            {
                table = null;
                redisTypedClient = null;
                redisDB.Dispose();
            }
        }
        #endregion

        #region Finalization Constructs
        /// <summary>
        /// Finalizes the object.
        /// </summary>
        ~RedisRepository()
        {
            this.Dispose(false);
        }
        #endregion
    }
}

下面是在控制臺中進行倉儲的調用

  　　　　　　IRepository<Car> repository = new Redis.Data.Core.RedisRepository<Car>();
            repository.Insert(new Car { ID = 3, Name = "占" });
            var entity = repository.GetModel().Where(i => i.ID == 3).FirstOrDefault();
            entity.Name = "修改了";
            repository.Update(entity);
            repository.GetModel().ToList().ForEach(e =>
            {
                Console.WriteLine(e.ID + "/" + e.RootID + "/" + e.Name);
            });