source/Repid.Core/DbSet/BaseDbSet.cs

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

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

using System;
using System.Collections.Generic;
using System.Data.Entity;
using System.Linq;
using System.Linq.Expressions;
using System.Reflection;
using Repid.Entity;
using Repid.Core.Context;

namespace Repid.Core.DbSet
{
    /// <summary>
    /// 基本数据
    /// </summary>
    /// <typeparam name="T">实体类型</typeparam>
    internal class BaseDbSet<T> where T : EntityBase, new()
    {
        /// <summary>
        /// 数据上下文
        /// </summary>
        protected DataContext dbContext = null;

        /// <summary>
        /// 查询计算器
        /// </summary>
        /// <returns>查询计算器</returns>
        internal virtual IQueryable<T> Query()
        {
            return dbContext.Ef.Set<T>().AsNoTracking().OrderBy(m => m.InsertTime);
        }

        /// <summary>
        /// 查询计算器
        /// </summary>
        /// <param name="predicate">查询条件</param>
        /// <returns>查询计算器</returns>
        internal virtual IQueryable<T> Query(Expression<Func<T, bool>> predicate)
        {
            return Query().Where(predicate);
        }

        /// <summary>
        /// 分页查询
        /// </summary>
        /// <param name="rows">行数</param>
        /// <param name="page">页码</param>
        /// <param name="entities">查询计算器</param>
        /// <returns>查询计算器</returns>
        internal virtual IQueryable<T> Pager(int rows, int page, IQueryable<T> entities = null)
        {
            if (entities == null) { entities = Query(); }

            return entities.Skip(rows * (page - 1)).Take(rows);
        }

        /// <summary>
        /// 分页查询
        /// </summary>
        /// <param name="rows">行数</param>
        /// <param name="page">页码</param>