这个框架到如今最大的变化立即就要出现了,哪就是对缓存的使用。由于系统常常要去读取数据库数据。可是大家知道。数据库的处理能力是有限的,所以对于一些数据量不大,可是又 须要常常去读取的功能来说。更好的方法就是使用缓存。 上面4的方法是不适用缓存的

 

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using JFrame.AccessCommon;
using System.Data.Objects.DataClasses;
using JFrame.Utility;
using System.Linq.Expressions;
using System.Reflection; namespace JFrame.Dal
{
/// <summary>
/// 使用缓存进行数据更新,缓存临时仅仅支持lamda表达式
/// </summary>
/// <typeparam name="T"></typeparam>
public class DalBaseDataCache<T> : AccessBase<T> where T : EntityObject
{
static DataCacheCommon<T> CacheCommon; //DataCacheCommon<T>.Instance(GetListByWhere);
public DalBaseDataCache()
: base(ConnectionString: DataBaseConnectionString.GetConnectionString())
{
CacheCommon = DataCacheCommon<T>.Instance(GetListByWhere);
} public DalBaseDataCache(string PrimaryKey = "", string strTableName = "", string QueryColums = "")
: base(ConnectionString: DataBaseConnectionString.GetConnectionString(), PrimaryKey: PrimaryKey, strTableName: strTableName, QueryColums: QueryColums)
{
CacheCommon = DataCacheCommon<T>.Instance(GetListByWhere);
} /// <summary>
/// 添加单个实体
/// </summary>
/// <param name="t"></param>
public virtual void AddEntity(T t)
{
Data.InsertEntity<T>(t);
CacheCommon.Add(t);
} /// <summary>
/// 获取单个实体
/// </summary>
/// <param name="query">查询条件</param>
/// <returns></returns>
public virtual T GetSingleEntity(Expression<Func<T, bool>> query)
{
return CacheCommon.GetDataList(query).FirstOrDefault(); // Data.GetSingleEntity<T>(query);
} public virtual List<T> GetAllEntityByPage(Expression<Func<T, bool>> query, PagingInfo PageInfo, Func<T, object> orderByDesc)
{
return CacheCommon.GetDataList(query, PageInfo, orderByDesc);
} /// <summary>
/// 获取单个实体
/// </summary>
/// <typeparam name="T">泛型类型參数</typeparam>
/// <param name="express">查询条件</param>
/// <returns></returns>
public virtual T TryGetSingleEntity(Expression<Func<T, bool>> query)
{
try
{
return CacheCommon.GetDataList(query).FirstOrDefault();// Data.GetSingleEntity<T>(query);
}
catch (Exception ex)
{
return null;
}
} /// <summary>
/// 改动单个实体
/// </summary>
/// <param name="t"></param>
public virtual void UpdateEntity(T t)
{ Type type = typeof(T);
PropertyInfo[] infos = type.GetProperties();
PropertyInfo info = infos.Where(p => p.Name == _PrimaryKey).FirstOrDefault();
object value = null;
if (info != null)
{
value = info.GetValue(t, null);
}
else
{
return;
}
Data.Update<T>(t, _PrimaryKey, value);
CacheCommon.NextDataUpdate = DateTime.Now; }
/// <summary>
/// 更新实体。不会从数据库同步
/// </summary>
/// <param name="t"></param>
/// <param name="query"></param>
public virtual void UpdateEntity(T t, Expression<Func<T, bool>> query)
{
Type type = typeof(T);
PropertyInfo[] infos = type.GetProperties();
PropertyInfo info = infos.Where(p => p.Name == _PrimaryKey).FirstOrDefault();
object value = null;
if (info != null)
{
value = info.GetValue(t, null);
}
else
{
return;
}
Data.Update<T>(t, _PrimaryKey, value);
CacheCommon.Update(t, query.Compile());
} /// <summary>
/// 依据条件删除信息
/// </summary>
/// <param name="query">条件</param>
public virtual void Delete(Expression<Func<T, bool>> query)
{
Data.DeleteEntitys<T>(query);
CacheCommon.Delete(query);
} /// <summary>
/// (缓存中)依据条件获取相关监測信息表
/// </summary>
/// <param name="strWhere">Where条件</param>
/// <returns>数据集合</returns>
public virtual List<T> GetListByWhere(Expression<Func<T, bool>> query)
{ //new System.Linq.Expressions.Expression.BinaryExpressionProxy (query.Body)
//(new System.Linq.Expressions.Expression.BinaryExpressionProxy((new System.Linq.Expressions.Expression.LambdaExpressionProxy(query)).Body)).DebugView return CacheCommon.GetDataList(query);
} /// <summary>
/// 依据条件获取相关监測信息表
/// </summary>
/// <param name="strWhere">Where条件</param>
/// <returns>数据集合</returns>
public virtual List<T> GetALLCacheList()
{
return CacheCommon.GetDataList();
} }
}

 

最新文章

  1. priority_queue 示例
  2. struts2使用Convention Plugin在weblogic上以war包部署时,找不到Action的解决办法
  3. 20160220 - JavaScript for OS X Automation 调试技巧
  4. Streaming data from Oracle using Oracle GoldenGate and Kafka Connect
  5. C#完美实现斐波那契数列
  6. SignalR 跨域设置
  7. POJ3663
  8. Json.Net序列化和反序列化设置
  9. &lt;JAVA&gt;可变参数列表
  10. Git常用的操作
  11. Servlet基本_セッション属性
  12. java 枚举 封装操作方法
  13. USACO holstein AC code
  14. ant学习笔记-taskdef
  15. 《Algorithms算法》笔记:优先队列(1)——API和初等实现
  16. Docker容器跨主机通信之:直接路由方式
  17. FA_手工明细增加固定资产(流程)
  18. windows下PIP安装模块编码错误解决
  19. PyCharm2018 安装及破解方法
  20. vue - config(dev.env.js和prov.env.js)

热门文章

  1. HDU-1698-Just a Hook-区间更新+线段树成段更新
  2. 新建mapping
  3. Spring MVC(十五)--SpringMVC国际化配置项
  4. collections,time,random,os, sys 模块的使用
  5. LTE基本架构
  6. .NET中DataTable的常用操作
  7. Java事件监听机制与观察者设计模式
  8. pytorch基础2
  9. 怎样理解js数组中indexOf()的用法与lastIndexOf
  10. 虚拟机vm安装黑群晖6.2