using EFLogging;using Microsoft.EntityFrameworkCore;using Microsoft.EntityFrameworkCore.Infrastructure;using Microsoft.Extensions.Logging;using System;using System.Collections.Generic;using System.Data.Common;using System.Linq;using System.Linq.Expressions;using System.Reflection;using System.Text;using System.Threading.Tasks;namespace efcore.Repository{ public class Repository where T : class, new() { #region 数据上下文 /// /// 数据上下文 /// private ApplicationDbContext _Context; public Repository(ApplicationDbContext Context) { _Context = Context; } #endregion #region 单模型 CRUD 操作 /// /// 按照字段修改 /// /// /// //M.Id = 91; // M.CarNumber = "vvvvvvvvvvvvvvvv"; // M.CreateTime = DateTime.Now; // var properties = new Expression >[2]; //properties[0] = d => d.CarNumber; // properties[1] = d => d.CreateTime; // CarBll.GetInstance().UpdateModified(M, properties); // 或 CarBll.GetInstance().UpdateModified(M, d => d.CarNumber, d => d.CreateTime); // 或 CarBll.GetInstance().UpdateModified(M, null); /// /// /// /// >[] properties) //{ // // _Context.Set ().Attach(entity); // _Context.Entry(entity).State = EntityState.Unchanged; // if (properties == null) // { // PropertyInfo[] props = entity.GetType().GetProperties(); // foreach (PropertyInfo prop in props) // { // _Context.Entry(entity).Property(prop.Name).IsModified = true; // } // } // else // { // foreach (var selector in properties) // { // _Context.Entry(entity).Property(selector).IsModified = true; // } // } // //foreach (var property in properties) // //{ // // var propertyName = ExpressionHelper.GetExpressionText(property); // // _context.Entry(entity).Property(propertyName).IsModified = true; // //} // if (IsCommit) // return _Context.SaveChanges() > 0; // else // return false; //} /// /// 增加一条记录 /// /// 实体模型 /// 是否提交（默认提交） /// ().Add(entity); if (IsCommit) return _Context.SaveChanges() > 0; else return false; } /// /// 增加一条记录(异步方式) /// /// 实体模型 /// 是否提交（默认提交） /// SaveAsync(T entity, bool IsCommit = true) { _Context.Set ().Add(entity); if (IsCommit) return await Task.Run(() => _Context.SaveChanges() > 0); else return await Task.Run(() => false); } /// /// 更新一条记录 /// /// 实体模型 /// 是否提交（默认提交） /// ().Attach(entity); _Context.Entry (entity).State = EntityState.Modified; if (IsCommit) return _Context.SaveChanges() > 0; else return false; } /// /// 更新一条记录（异步方式） /// /// 实体模型 /// 是否提交（默认提交） /// UpdateAsync(T entity, bool IsCommit = true) { _Context.Set ().Attach(entity); _Context.Entry (entity).State = EntityState.Modified; if (IsCommit) return await Task.Run(() => _Context.SaveChanges() > 0); else return await Task.Run(() => false); } /// /// 增加或更新一条记录 /// /// 实体模型 /// 是否增加 /// 是否提交（默认提交） /// /// 增加或更新一条记录（异步方式） /// /// 实体模型 /// 是否增加 /// 是否提交（默认提交） /// SaveOrUpdateAsync(T entity, bool IsSave, bool IsCommit = true) { return IsSave ? await SaveAsync(entity, IsCommit) : await UpdateAsync(entity, IsCommit); } /// /// 通过Lamda表达式获取实体 /// /// Lamda表达式（p=>p.Id==Id） /// > predicate) { return _Context.Set ().AsNoTracking().SingleOrDefault(predicate); } /// /// 通过Lamda表达式获取实体（异步方式） /// /// Lamda表达式（p=>p.Id==Id） /// GetAsync(Expression > predicate) { return await Task.Run(() => _Context.Set ().AsNoTracking().SingleOrDefault(predicate)); } /// /// 删除一条记录 /// /// 实体模型 /// 是否提交（默认提交） /// ().Attach(entity); _Context.Set ().Remove(entity); if (IsCommit) return _Context.SaveChanges() > 0; else return false; } /// /// 删除一条记录（异步方式） /// /// 实体模型 /// 是否提交（默认提交） /// DeleteAsync(T entity, bool IsCommit = true) { if (entity == null) return await Task.Run(() => false); _Context.Set ().Attach(entity); _Context.Set ().Remove(entity); if (IsCommit) return await Task.Run(() => _Context.SaveChanges() > 0); else return await Task.Run(() => false); ; } #endregion #region 多模型 操作 /// /// 增加多条记录，同一模型 /// /// 实体模型集合 /// 是否提交（默认提交） /// T1, bool IsCommit = true) { if (T1 == null || T1.Count == 0) return false; T1.ToList().ForEach(item => { _Context.Set ().Add(item); }); if (IsCommit) return _Context.SaveChanges() > 0; else return false; } /// /// 增加多条记录，同一模型（异步方式） /// /// 实体模型集合 /// 是否提交（默认提交） /// SaveListAsync(List T1, bool IsCommit = true) { if (T1 == null || T1.Count == 0) return await Task.Run(() => false); T1.ToList().ForEach(item => { _Context.Set ().Add(item); }); if (IsCommit) return await Task.Run(() => _Context.SaveChanges() > 0); else return await Task.Run(() => false); } /// /// 增加多条记录，独立模型 /// /// 实体模型集合 /// 是否提交（默认提交） /// (List T, bool IsCommit = true) where T1 : class { if (T == null || T.Count == 0) return false; var tmp = _Context.ChangeTracker.Entries ().ToList(); foreach (var x in tmp) { var properties = typeof(T).GetTypeInfo().GetProperties(); foreach (var y in properties) { var entry = x.Property(y.Name); entry.CurrentValue = entry.OriginalValue; entry.IsModified = false; y.SetValue(x.Entity, entry.OriginalValue); } x.State = EntityState.Unchanged; } T.ToList().ForEach(item => { _Context.Set ().Add(item); }); if (IsCommit) return _Context.SaveChanges() > 0; else return false; } /// /// 增加多条记录，独立模型（异步方式） /// /// 实体模型集合 /// 是否提交（默认提交） /// SaveListAsync (List T, bool IsCommit = true) where T1 : class { if (T == null || T.Count == 0) return await Task.Run(() => false); var tmp = _Context.ChangeTracker.Entries ().ToList(); foreach (var x in tmp) { var properties = typeof(T).GetTypeInfo().GetProperties(); foreach (var y in properties) { var entry = x.Property(y.Name); entry.CurrentValue = entry.OriginalValue; entry.IsModified = false; y.SetValue(x.Entity, entry.OriginalValue); } x.State = EntityState.Unchanged; } T.ToList().ForEach(item => { _Context.Set ().Add(item); }); if (IsCommit) return await Task.Run(() => _Context.SaveChanges() > 0); else return await Task.Run(() => false); } /// /// 更新多条记录，同一模型 /// /// 实体模型集合 /// 是否提交（默认提交） /// T1, bool IsCommit = true) { if (T1 == null || T1.Count == 0) return false; T1.ToList().ForEach(item => { _Context.Set ().Attach(item); _Context.Entry (item).State = EntityState.Modified; }); if (IsCommit) return _Context.SaveChanges() > 0; else return false; } /// /// 更新多条记录，同一模型（异步方式） /// /// 实体模型集合 /// 是否提交（默认提交） /// UpdateListAsync(List T1, bool IsCommit = true) { if (T1 == null || T1.Count == 0) return await Task.Run(() => false); T1.ToList().ForEach(item => { _Context.Set ().Attach(item); _Context.Entry (item).State = EntityState.Modified; }); if (IsCommit) return await Task.Run(() => _Context.SaveChanges() > 0); else return await Task.Run(() => false); } /// /// 更新多条记录，独立模型 /// /// 实体模型集合 /// 是否提交（默认提交） /// (List T, bool IsCommit = true) where T1 : class { if (T == null || T.Count == 0) return false; T.ToList().ForEach(item => { _Context.Set ().Attach(item); _Context.Entry (item).State = EntityState.Modified; }); if (IsCommit) return _Context.SaveChanges() > 0; else return false; } /// /// 更新多条记录，独立模型（异步方式） /// /// 实体模型集合 /// 是否提交（默认提交） /// UpdateListAsync (List T, bool IsCommit = true) where T1 : class { if (T == null || T.Count == 0) return await Task.Run(() => false); T.ToList().ForEach(item => { _Context.Set ().Attach(item); _Context.Entry (item).State = EntityState.Modified; }); if (IsCommit) return await Task.Run(() => _Context.SaveChanges() > 0); else return await Task.Run(() => false); } /// /// 删除多条记录，同一模型 /// /// 实体模型集合 /// 是否提交（默认提交） /// T1, bool IsCommit = true) { if (T1 == null || T1.Count == 0) return false; T1.ToList().ForEach(item => { _Context.Set ().Attach(item); _Context.Set ().Remove(item); }); if (IsCommit) return _Context.SaveChanges() > 0; else return false; } /// /// 删除多条记录，同一模型（异步方式） /// /// 实体模型集合 /// 是否提交（默认提交） /// DeleteListAsync(List T1, bool IsCommit = true) { if (T1 == null || T1.Count == 0) return await Task.Run(() => false); T1.ToList().ForEach(item => { _Context.Set ().Attach(item); _Context.Set ().Remove(item); }); if (IsCommit) return await Task.Run(() => _Context.SaveChanges() > 0); else return await Task.Run(() => false); } /// /// 删除多条记录，独立模型 /// /// 实体模型集合 /// 是否提交（默认提交） /// (List T, bool IsCommit = true) where T1 : class { if (T == null || T.Count == 0) return false; T.ToList().ForEach(item => { _Context.Set ().Attach(item); _Context.Set ().Remove(item); }); if (IsCommit) return _Context.SaveChanges() > 0; else return false; } /// /// 删除多条记录，独立模型（异步方式） /// /// 实体模型集合 /// 是否提交（默认提交） /// DeleteListAsync (List T, bool IsCommit = true) where T1 : class { if (T == null || T.Count == 0) return await Task.Run(() => false); T.ToList().ForEach(item => { _Context.Set ().Attach(item); _Context.Set ().Remove(item); }); if (IsCommit) return await Task.Run(() => _Context.SaveChanges() > 0); else return await Task.Run(() => false); } /// /// 通过Lamda表达式，删除一条或多条记录 /// /// /// /// > predicate, bool IsCommit = true) { IQueryable entry = (predicate == null) ? _Context.Set ().AsQueryable() : _Context.Set ().Where(predicate); List list = entry.ToList(); if (list != null && list.Count == 0) return false; list.ForEach(item => { _Context.Set ().Attach(item); _Context.Set ().Remove(item); }); if (IsCommit) return _Context.SaveChanges() > 0; else return false; } /// /// 通过Lamda表达式，删除一条或多条记录（异步方式） /// /// /// /// DeleteAsync(Expression > predicate, bool IsCommit = true) { IQueryable entry = (predicate == null) ? _Context.Set ().AsQueryable() : _Context.Set ().Where(predicate); List list = entry.ToList(); if (list != null && list.Count == 0) return await Task.Run(() => false); list.ForEach(item => { _Context.Set ().Attach(item); _Context.Set ().Remove(item); }); if (IsCommit) return await Task.Run(() => _Context.SaveChanges() > 0); else return await Task.Run(() => false); } #endregion #region 获取多条数据操作 /// /// linq 分页 /// /// GetLinqPage (Expression > whereQuery, QueryableOrderEntry orderQuery, int pageID, int pageSizes) { // pageID = pageID < 1 ? 0 : pageID - 1; List data = new List (); var query = _Context.Set ().Where(whereQuery);// repository.TableNoTracking.Where(whereQuery); int count = query.Count(); //if (selector != null) //{ // if (orderQuery.OrderDirection == OrderDirection.DESC) // { // data = query.OrderByDescending(orderQuery.Expression).Select(selector) // .Skip(pageSizes * pageID) // .Take(pageSizes).ToList(); // } // else // { // data = query // .OrderBy(orderQuery.Expression).Select(selector) // .Skip(pageSizes * pageID) // .Take(pageSizes).ToList(); // } //} //else //{ if (orderQuery.OrderDirection == OrderDirection.DESC) { data = query.OrderByDescending(orderQuery.Expression) .Skip(pageSizes * pageID) .Take(pageSizes).ToList (); } else { data = query .OrderBy(orderQuery.Expression) .Skip(pageSizes * pageID) .Take(pageSizes).ToList (); } //} // var serviceProvider = _Context.GetInfrastructure (); // var loggerFactory = serviceProvider.GetService (); // loggerFactory.AddProvider(new MyLoggerProvider()); return new PagedynamicResult { Data = data, ItemCount = count, PageSize = pageSizes, PageIndex = pageID + 1 }; } /// /// Lamda返回IQueryable集合，延时加载数据 /// /// /// LoadAll(Expression > predicate) { return predicate != null ? _Context.Set ().Where(predicate).AsNoTracking () : _Context.Set ().AsQueryable ().AsNoTracking (); } /// /// 返回IQueryable集合，延时加载数据（异步方式） /// /// /// > LoadAllAsync(Expression > predicate) { return predicate != null ? await Task.Run(() => _Context.Set ().Where(predicate).AsNoTracking ()) : await Task.Run(() => _Context.Set ().AsQueryable ().AsNoTracking ()); } /// /// 返回List 集合,不采用延时加载 /// /// /// LoadListAll(Expression > predicate) { return predicate != null ? _Context.Set ().Where(predicate).AsNoTracking().ToList() : _Context.Set ().AsQueryable ().AsNoTracking().ToList(); } // /// 返回List 集合,不采用延时加载（异步方式） /// /// /// > LoadListAllAsync(Expression > predicate) { return predicate != null ? await Task.Run(() => _Context.Set ().Where(predicate).AsNoTracking().ToList()) : await Task.Run(() => _Context.Set ().AsQueryable ().AsNoTracking().ToList()); } /// /// T-Sql方式：返回IQueryable 集合 /// /// SQL语句 /// Parameters参数 /// LoadAllBySql(string sql, params DbParameter[] para) { return _Context.Set ().FromSql(sql, para); } /// /// T-Sql方式：返回IQueryable 集合（异步方式） /// /// SQL语句 /// Parameters参数 /// > LoadAllBySqlAsync(string sql, params DbParameter[] para) { return await Task.Run(() => _Context.Set ().FromSql(sql, para)); } /// /// T-Sql方式：返回List 集合 /// /// SQL语句 /// Parameters参数 /// LoadListAllBySql(string sql, params DbParameter[] para) { return _Context.Set ().FromSql(sql, para).Cast ().ToList(); } /// /// T-Sql方式：返回List 集合（异步方式） /// /// SQL语句 /// Parameters参数 /// > LoadListAllBySqlAsync(string sql, params DbParameter[] para) { return await Task.Run(() => _Context.Set ().FromSql(sql, para).Cast ().ToList()); } /// /// 可指定返回结果、排序、查询条件的通用查询方法，返回实体对象集合 /// /// 实体对象 /// 排序字段类型 /// 数据结果，与TEntity一致 /// 过滤条件，需要用到类型转换的需要提前处理与数据表一致的 /// 排序字段 /// 返回结果（必须是模型中存在的字段） /// 排序方向，true为正序false为倒序 /// 实体集合 //public virtual List QueryEntity // (Expression > where, // Expression > orderby, // Expression > selector, // bool IsAsc) // where TEntity : class // where TResult : class //{ // IQueryable query = _Context.Set (); // if (where != null) // { // query = query.Where(where); // } // if (orderby != null) // { // query = IsAsc ? query.OrderBy(orderby) : query.OrderByDescending(orderby); // } // if (selector == null) // { // return query.Cast ().AsNoTracking().ToList(); // } // return query.Select(selector).AsNoTracking().ToList(); //} /// /// 可指定返回结果、排序、查询条件的通用查询方法，返回实体对象集合（异步方式） /// /// 实体对象 /// 排序字段类型 /// 数据结果，与TEntity一致 /// 过滤条件，需要用到类型转换的需要提前处理与数据表一致的 /// 排序字段 /// 返回结果（必须是模型中存在的字段） /// 排序方向，true为正序false为倒序 /// 实体集合 //public virtual async Task > QueryEntityAsync // (Expression > where, // Expression > orderby, // Expression > selector, // bool IsAsc) // where TEntity : class // where TResult : class //{ // IQueryable query = _Context.Set (); // if (where != null) // { // query = query.Where(where); // } // if (orderby != null) // { // query = IsAsc ? query.OrderBy(orderby) : query.OrderByDescending(orderby); // } // if (selector == null) // { // return await Task.Run(() => query.Cast ().AsNoTracking().ToList()); // } // return await Task.Run(() => query.Select(selector).AsNoTracking().ToList()); //} /// /// 可指定返回结果、排序、查询条件的通用查询方法，返回Object对象集合 /// /// 实体对象 /// 排序字段类型 /// 过滤条件，需要用到类型转换的需要提前处理与数据表一致的 /// 排序字段 /// 返回结果（必须是模型中存在的字段） /// 排序方向，true为正序false为倒序 /// 自定义实体集合 //public virtual List
using System;using System.Collections.Generic;using System.Text;namespace efcore.Repository{ /// /// Describe：工作单元实现类 /// Author：yuangang /// Date：2016/07/16 /// Blogs:http://www.cnblogs.com/yuangang /// public class UnitOfWork : IUnitOfWork, IDisposable { #region 数据上下文 /// /// 数据上下文 /// private ApplicationDbContext _Context; public UnitOfWork(ApplicationDbContext Context) { _Context = Context; } #endregion public bool Commit() { return _Context.SaveChanges() > 0; } public void Dispose() { if (_Context != null) { _Context.Dispose(); } GC.SuppressFinalize(this); } }}
using Microsoft.EntityFrameworkCore;using System;using System.Collections.Generic;using System.Diagnostics;using System.Linq;using System.Linq.Expressions;using System.Reflection;using System.Data.Common;using Microsoft.Extensions.Logging;namespace efcore.Repository{ public class ApplicationDbContext : DbContext { // private readonly ILogger _logger; private readonly ILoggerFactory _logger; public ApplicationDbContext(ILoggerFactory _loggerFactory, DbContextOptions options) : base(options) { // var fff= base.Database.ToString(); // options. ProviderManifestToken // _logger = _loggerFactory.CreateLogger (); _logger = _loggerFactory ; } public DbSet SYS_USER { get; set; } public DbSet tt { get; set; } protected override void OnModelCreating(ModelBuilder builder) { base.OnModelCreating(builder); } protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) { base.OnConfiguring(optionsBuilder); optionsBuilder.UseLoggerFactory(_logger); } } //#region DbCommandInterceptor拦截生成的SQL语句 //class EFIntercepterLogging : DbCommandInterceptor //{ // private readonly Stopwatch _stopwatch = new Stopwatch(); // public override void ScalarExecuting(System.Data.Common.DbCommand command, DbCommandInterceptionContext
services.AddDbContext(options => options.UseSqlServer(Configuration.GetConnectionString("SqlServerConnection"), b => b.UseRowNumberForPaging()));