思享工具箱

webos项目中EF仓储模式的代码

摘要：
在UPDATE中编写在线EF数据处理代码的方法不好，可能存在性能问题。

参考了网上EF数据处理的代码写成

在UPDATE的方法不太好，性能可能有问题。大家如果有什么好的方法可以给我留言。

暂时没有想到

接口类

using System;
using System.Collections.Generic;

namespace Model.EF
{
    public interface IRepository<TEntity>
        where TEntity : IEntity
    {
        TEntity FindById(int ID);
        #region 查询普通实现方案(基于Lambda表达式的Where查询)
        /// <summary>  
        /// 获取所有Entity 
        /// </summary>
        /// <param name="exp">Lambda条件的where</param> 
        /// <returns></returns>
        IEnumerable<TEntity> GetEntities(Func<TEntity, bool> exp);
        /// <summary>
        /// 计算总个数(分页)
        /// </summary>
        /// <param name="exp">Lambda条件的where</param>
        /// <returns></returns>
        int GetEntitiesCount(Func<TEntity, bool> exp);
        /// <summary>
        /// 分页查询(Linq分页方式)
        /// </summary>
        /// <param name="pageNumber">当前页</param>
        /// <param name="pageSize">页码</param>
        /// <param name="orderName">lambda排序名称</param>
        /// <param name="sortOrder">排序(升序or降序)</param>
        /// <param name="exp">lambda查询条件where</param>
        /// <returns></returns>
        IEnumerable<TEntity> GetEntitiesForPaging(int pageNumber, int pageSize, Func<TEntity, string> orderName, string sortOrder, Func<TEntity, bool> exp);
        /// <summary>
        /// 根据条件查找
        /// </summary>
        /// <param name="exp">lambda查询条件where</param>
        /// <returns></returns>
        TEntity GetEntity(Func<TEntity, bool> exp);
        #endregion       

        #region 查询Sql语句外接接口的查询实现
        /// <summary>
        /// 获取所有Entity(立即执行请使用ToList()
        /// </summary>
        /// <param name="commandText">Sql语句</param>
        /// <param name="objParams">可变参数</param>
        /// <returns></returns>
        IEnumerable<TEntity> GetEntities(string commandText);
        /// <summary>
        /// 计算总个数(分页)
        /// </summary>
        /// <param name="tableName">表名</param>
        /// <param name="commandText">>Sql where语句</param>
        /// <returns></returns>
        int GetEntitiesCount(string tableName, string commandText);
        /// <summary>
        /// 计算总个数(分页)
        /// </summary>
        /// <param name="commandText">Sql语句</param>
        /// <param name="objParams">可变参数</param>
        /// <returns></returns>
        int GetEntitiesCount(string commandText);

        /// <summary>
        /// 分页查询(Linq分页方式)
        /// </summary>
        /// <param name="tableName">表名</param>
        /// <param name="pageNumber">当前页</param>
        /// <param name="pageSize">页码</param>
        /// <param name="orderName">lambda排序名称</param>
        /// <param name="sortOrder">排序(升序or降序)</param>
        /// <param name="commandText">Sql语句</param>
        /// <param name="count">总个数</param>
        /// <returns></returns>
        IEnumerable<TEntity> GetEntitiesForPaging(string tableName, int pageNumber, int pageSize, string orderName, string sortOrder, string commandText, out int count);

        /// <summary>
        /// 根据条件查找
        /// </summary>
        /// <param name="commandText">Sql语句</param>
        /// <param name="objParams">可变参数</param>
        /// <returns></returns>
        TEntity GetEntity(string commandText);

        #endregion 

        List<TEntity> FindBy(string where);
        List<TEntity> FindPageList(string where, int pageIndex, int pageSize, out int totalRecord);
        IEnumerable<TEntity> FindAll();
        //IEnumerable<TEntity> FindAll(string query);
        IEnumerable<TEntity>　FindBySpecification(Func<TEntity,　bool>　spec);
        int Add(TEntity entity);
        void Delete(TEntity entity);
        void Update(TEntity entity);
        void Update(TEntity entity, params string[] fileds);

    }
}

实现类：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Data;
using System.Data.Entity;
using System.Data.Objects;
using System.Data.Entity.Infrastructure;
using Common;

namespace Model.EF
{
    public class EntityRepository<TEntity> : IRepository<TEntity>
        where TEntity : class, IEntity
    {
        private readonly NerdDinners m_dbContext;
        private ObjectContext context;
        public EntityRepository()
        {
            m_dbContext =new NerdDinners();
        }

        protected virtual void OnLoaded(TEntity entity)
        {

        }

        protected DbSet<TEntity> DbSet
        {
            get { return m_dbContext.Set<TEntity>(); }
        }

        public virtual IEnumerable<TEntity> GetEntities(Func<TEntity, bool> exp)
        {
            return DbSet.Where<TEntity>(exp).ToList();
        }

        public virtual int GetEntitiesCount(Func<TEntity, bool> exp) 
        {
            return DbSet.Where<TEntity>(exp).ToList().Count;
        }

        public virtual TEntity GetEntity(Func<TEntity, bool> exp)
        {
            return DbSet.SingleOrDefault<TEntity>(exp);
        }
        public virtual IEnumerable<TEntity> GetEntitiesForPaging(int pageNumber, int pageSize, Func<TEntity, string> orderName, string sortOrder, Func<TEntity, bool> exp)
        {
            if (sortOrder=="asc") 
            {
                return DbSet.Where<TEntity>(exp).OrderBy(orderName).Skip((pageNumber - 1) * pageSize).Take(pageSize).ToList();
            }else{
                return DbSet.Where<TEntity>(exp).OrderByDescending(orderName).Skip((pageNumber - 1) * pageSize).Take(pageSize).ToList();
            }
        }

        #region 查询Entity To Sql语句外接接口的查询实现

        /// <summary>
        /// 获取所有Entity(立即执行请使用ToList()
        /// </summary>
        /// <param name="commandText">Sql语句</param>
        /// <param name="objParams">可变参数</param>
        /// <returns></returns>
        public virtual IEnumerable<TEntity> GetEntities(string commandText)
        {            
            if (!commandText.IsNullOrEmpty())
                commandText = " where " + commandText;
            var context = ((IObjectContextAdapter)DbSet).ObjectContext;
            return context.ExecuteStoreQuery<TEntity>("select * from " + typeof(TEntity).Name + commandText).ToList();
        }

        /// <summary>
        /// 计算总个数(分页)
        /// </summary>
        /// <param name="tableName">表名</param>
        /// <param name="commandText">>Sql where语句</param>
        /// <returns></returns>
        public virtual int GetEntitiesCount(string tableName, string commandText)
        {
            if (!commandText.IsNullOrEmpty())
                commandText = " where " + commandText;
            var context = ((IObjectContextAdapter)DbSet).ObjectContext;
            return context.ExecuteStoreQuery<TEntity>("select * from " + tableName + commandText).Count();
        }

        /// <summary>
        /// 计算总个数(分页)
        /// </summary>
        /// <param name="CommandText">Sql语句</param>
        /// <returns></returns>
        public virtual int GetEntitiesCount(string CommandText)
        {            
            if (!CommandText.IsNullOrEmpty())
                CommandText = " where " + CommandText;
            var context = ((IObjectContextAdapter)DbSet).ObjectContext;
            return context.ExecuteStoreQuery<TEntity>("select * from " + typeof(TEntity).Name + CommandText).Count();            
        }
        /// <summary>
        /// 分页查询(Linq分页方式)
        /// </summary>
        /// <param name="tableName">表名</param>
        /// <param name="pageNumber">当前页</param>
        /// <param name="pageSize">页码</param>
        /// <param name="orderName">lambda排序名称</param>
        /// <param name="sortOrder">排序(升序or降序)</param>
        /// <param name="CommandText">Sql语句</param>
        /// <param name="Count">总个数</param>
        /// <returns></returns>
        public virtual IEnumerable<TEntity> GetEntitiesForPaging(string tableName, int pageNumber, int pageSize, string orderName, string sortOrder, string CommandText, out int Count)
        {
            PageHelper pager = new PageHelper(tableName, orderName, pageSize, pageNumber, sortOrder, CommandText);
            
            Count = GetEntitiesCount(tableName, CommandText);
            var context = ((IObjectContextAdapter)DbSet).ObjectContext;
            return context.ExecuteStoreQuery<TEntity>(pager.GetSelectTopByMaxOrMinPagination()).ToList();
        }

        /// <summary>
        /// 根据条件查找
        /// </summary>
        /// <param name="CommandText">Sql语句</param>
        /// <param name="objParams">可变参数</param>
        /// <returns></returns>
        public virtual TEntity GetEntity(string CommandText)
        {
            var context = ((IObjectContextAdapter)DbSet).ObjectContext;
            return context.ExecuteStoreQuery<TEntity>("select * from " + typeof(TEntity).Name + " where " + CommandText).SingleOrDefault();           
        }
        #endregion
        public IEnumerable<TEntity> FindAll()
        {
            return DbSet;
        }
        public List<TEntity> FindBy(string where)
        {

            var list = DbSet.SqlQuery(where);
            return list.ToList();
        }
        public List<TEntity> FindPageList(string where, int pageIndex, int pageSize, out int totalRecord)
        {
            totalRecord = 0;

            var list = DbSet.SqlQuery(where).Skip((pageIndex - 1) * pageSize).Take(pageSize);
            totalRecord = DbSet.SqlQuery(where).Count();
            return list.ToList();
        }

        public TEntity FindById(int id)
        {
            return DbSet.SingleOrDefault(entity => entity.ID== id);
        }

        public IEnumerable<TEntity> FindBySpecification(Func<TEntity, bool> spec)
        {
            throw　new　NotImplementedException();
        }
        public int Add(TEntity entity)
        {

            DbSet.Add(entity);
            return m_dbContext.SaveChanges();
        }

        public void Delete(TEntity entity)
        {
            var entry = m_dbContext.Entry(entity);
            if (entry.State == EntityState.Detached)
            {

                //DbSet.Attach(entity);
                entry.State = EntityState.Deleted;
                //var entityToUpdate = FindById(entity.Id);
                //EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper<TEntity, TEntity>().Map(entity, entityToUpdate);
            }
            m_dbContext.SaveChanges();
        }

        public void Update(TEntity entity)
        {
            
            var entry = m_dbContext.Entry(entity);
            
            if (entry.State == EntityState.Detached)
            {
                //DbSet.Attach(entity);
                //entry.State = EntityState.Unchanged;
                var entityToUpdate = DbSet.Find(entity.ID);
                EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper<TEntity, TEntity>().Map(entity, entityToUpdate);
                
            }            
            m_dbContext.SaveChanges();
        }
        public void Update(TEntity entity, params string[] fileds)
        {
            var entry = m_dbContext.Entry(entity);

            Type Ttype = typeof(TEntity);

            
            var entityToUpdate = FindById(entity.ID);
            context.AttachTo(Ttype.Name, entityToUpdate);
            var stateEntry = context.ObjectStateManager.GetObjectStateEntry(entity);

            for (int i = 0; i < fileds.Length - 1; i++)
            {
                stateEntry.SetModifiedProperty(fileds[i]);
            }
            
            
            m_dbContext.SaveChanges();
        }
    }
}

写的不好，有什么问题给我留言。

标签：#string#context | 浏览：114 | 发布日期：

免责声明：文章转载自《webos项目中EF仓储模式的代码》仅用于学习参考。如对内容有疑问，请及时联系本站处理。

上篇图像切割之（五）活动轮廓模型之Snake模型简单介绍博文与文档发布玩法：Github + MWeb + 语雀 + Cnbolgs下篇

宿迁高防，2C2G15M，22元/月；香港BGP，2C5G5M，25元/月 雨云优惠码：MjYwNzM=

相关文章

前端传多个数组集合，后端接收并匹配

传参格式  后端接收并在SQL匹配 @GetMapping(value = "xj/node/openApi/subnets") @ApiOperation(value = "查询openApi子网接口", httpMethod = "GET", response = String.class) public Map<Strin...

使用Java反射机制将Bean对象转换成Map(驼峰命名方式 — 下划线命名方式)

packagecom.yunping.asap.core.util; importjava.beans.PropertyDescriptor; importjava.lang.reflect.Field; importjava.lang.reflect.Method; importjava.util.ArrayList; importjava.util....

(转)Asp.Net(C#) XML+Xslt转Excel的解决方案

1. 新建一个Excel文档，并填写表头与两行左右的内容，然后另存为XML表格 格式 并修改成Xslt模板;2. 将要导入的数据生成XML格式文档;3. 通过Xslt模板将数据生成，并设定Response.ContentType = "application/vnd.ms-excel"; 4. 刷新输出页保存文件即为Excel格式的文档 ExportCar...

java后台访问接口

// 发送url地址获取信息 public static String sendPost(String jsonStr, String path) { String msg = "";// 保存调用http服务后的响应信息 try { byte[] data = jsonStr.getByte...

实全软件产品自动升级管理解决方案

实全软件产品自动升级管理解决方案 目 录 1. 描述... 1 2. 产品管理后台系统... 1 2.1. 产品发布... 1 2.2. 产品下载... 2 2.3. 下载日志... 3 2.4. 异常日志... 3 3. 产品Web Service服务接口... 3 3.1. 接口说明... 4 4. 产品升级更新程序... 4 4.1. 产品升级自动更...

java 正则表达式

java 正则表达式 package com.project.utils; import org.apache.commons.lang.StringUtils; import java.util.regex.Matcher; import java.util.regex.Pattern; public class ContentUtils {...

最新文章

随机推荐

思享工具箱导航