Redis学习笔记~把redis放在DATA层，作为一种数据源，我认为更合理，也更符合我的面向对象原则

ftlk

　　回到目录

一 一个Repository数据库操作基类，提供了通用的操作属性和方法




1 namespace Data
2 {
3     public abstract class RepositoryBase
4     {
5         protected static RedisClient_SortedSet redisClient = new RedisClient_SortedSet();
6         public static DataClasses1DataContext db = new DataClasses1DataContext();
7     }
8 }

二 接口定义操作规范




1 namespace Data
2 {
3     ///
4     /// 接口规范
5     ///
6     ///
7     public interface IRepository where TEntity : class
8     {
9         IQueryable GetModel();
10     }
11 }

三 提供不同的实现接口的方式




1 namespace Data.Sql　//使用SQL实现查询
2 {
3     public class PersonRepository : RepositoryBase, IRepository
4     {
5         #region IRepository 成员
6
7         public IQueryable GetModel()
8         {
9             return db.Res_Item.Select(i => new Res_Item_Ext
10             {
11                 ID = i.ID,
12                 Name = i.Name,
13                 PackageTime = i.PackageTime,
14             });
15         }
16
17         #endregion
18     }
19 }
20
21 namespace Data.Redis　//使用Redis实现查询
22 {
23     public class PersonRepository : RepositoryBase, IRepository
24     {
25
26         #region IRepository 成¨|员?à
27
28         public IQueryable GetModel()
29         {
30             return redisClient.GetList("Res_Item").Cast().ToList().AsQueryable();
31         }
32
33         #endregion
34     }
35 }

四 实体类，由于要被序列化，所以redis需要你的实体类标有Serializable特性



1    [Serializable]
2     public partial class Res_Item { }
3     [Serializable]
4     public class Res_Item_Ext : Res_Item
5     {
6
7     }
　　

五 如何在BLL层去调用你的redis数据库



1  #region 从数据库中建立一个redis缓存对象
2
3             try
4             {
5                 rds.SelectDB(2);
6                 new Data.Sql.PersonRepository().GetModel().Take(10).ToList().ForEach(i =>
7                 {
8                     rds.Add("Res_Item", i.ID, i);
9  
10                 });
11                 rds.BackgroundSave();//异步序列化到磁盘
12             }
13             catch (Exception)
14             {
15
16                 throw;
17             }
18             #endregion
19
20             #region
21             new Data.Redis.PersonRepository().GetModel().ToList().ForEach(i => Console.WriteLine(i.ID + i.Name + i.PackageTime));
22   #endregion

　　
　　回到目录