Entity Framework分页扩展

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Diagnostics;
 4 using System.IO;
 5 using System.Linq;
 6 using System.Linq.Expressions;
 7 using System.Runtime.Serialization;
 8 using System.Runtime.Serialization.Formatters.Binary;
 9 using System.Text;
10 using System.Threading.Tasks;
11 
12 namespace Sunc.Framework.Repository.Entity.Extension
13 {
14     public static class ExtensionIQueryable
15     {
16         /// <summary>
17         /// 分页
18         /// </summary>
19         /// <param name="list"> 数据源 </param>
20         /// <param name="order"> 排序表达式 </param>
21         /// <param name="pageIndex"> 第几页 </param>
22         /// <param name="pageSize"> 每页记录数 </param>
23         /// <param name="count"> 记录总数 </param>
24         /// <returns></returns>
25         public static IQueryable<T> Pagination<T, TKey>(this IQueryable<T> list, Expression<Func<T, bool>> predicate, Expression<Func<T, TKey>> order, int pageIndex, int pageSize, out int count, bool isOrder = true)
26         {
27             try
28             {
29                 var source = list.Where(predicate.Compile()).AsQueryable();
30                 count = source.Count();
31                 if (isOrder)
32                     return source.OrderBy(order).Skip((pageIndex - 1) * pageSize).Take(pageSize);
33                 return source.OrderByDescending(order).Skip((pageIndex - 1) * pageSize).Take(pageSize);
34             }
35             catch (Exception ex)
36             {
37                 Console.WriteLine(ex.Message);
38                 Debug.WriteLine(ex.Message);
39                 count = 0;
40                 return new List<T>().AsQueryable();
41             }
42         }
43 
44         public static V ToModel<T, V>(this T t) where T : ModelBase, V where V : ModelBase
45         {
46             return t;
47         }
48         public static string ToJson(this IQueryable<DatabaseModel> models)
49         {
50             return EntityBase.ToJson(models);
51         }
52 
53     }
54 }

 1    private static object _asynContextLock = new object();
 2         private static ItsmContext _context;
 3         public static ItsmContext Context
 4         {
 5             get
 6             {
 7                 lock (_asynContextLock)
 8                 {
 9                     if (_context == null)
10                     {
11                         _context = new ItsmContext();
12                     }
13                     return _context;
14                 }
15             }
16         }

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Linq;
 4 using System.Linq.Expressions;
 5 using System.Text;
 6 using System.Threading.Tasks;
 7 using Sunc.Framework.Repository.Entity;
 8 
 9 namespace Sunc.Framework.Repository.Interface.BaseMethod
10 {
11     public interface IBaseMethodPageList<Entity>
12     {
13         IBaseEntityPageList<Entity> GetPageList(int pageIndex, int pageSize);
14 
15 
16         IBaseEntityPageList<Entity> GetPageList<TKey>(Expression<Func<Entity, bool>> predicate, Expression<Func<Entity, TKey>> order, int pageIndex, int pageSize, bool isOrder = true);
17     }
18 }