首页 > 代码库 > EF异步改造之路~第二回 让DbContextRepository去实现异步接口
EF异步改造之路~第二回 让DbContextRepository去实现异步接口
上一讲中,我们定义了三个异步操作接口,这回我们将对它进行实现,而有一个基础知识需要大家清楚,那就是实现接口的方式,一般我们使用默认的方式(隐式实现),这种方法实现的接口方式均为public,即它可以脱离接口,而直接通过类对象去访问,而当一个类继承多个接口,而这些接口中都有相同的方法时,我们就需要显示实现接口了,显示实现的接口成员只能通过接口实例去访问它,今天我们对DbContextRepository的改造就用到了这个特性。
基本关键字
async:用来标识这个方法为异步方法
await:用在异步方法中,它可以等待异步方法的返回值,即用来阻塞主线程,迫使它等待异步请求,当请求成功返回后,再执行下面的代码
Task:异步返回的结果,它有泛型版本,Task表示返回为void,而使用泛型版本时Task<T>返回结果为类型T
EF6引入的异步提交机制
public virtual Task<int> SaveChangesAsync();
一般地,仓储大叔习惯将系统方法变为自已的方法,这样方便以后去维护,如向SaveChangesAsync方法添加个什么日志,事件之类的东西,所以,就有了自己的版本。
/// <summary> /// 异步提交到数据库 /// </summary> protected async Task SaveChangesAsync() { try { await Db.SaveChangesAsync(); } catch (System.Data.Entity.Validation.DbEntityValidationException dbEx)//捕获实体验证异常 { var sb = new StringBuilder(); dbEx.EntityValidationErrors.First().ValidationErrors.ToList().ForEach(i => { sb.AppendFormat("属性为:{0},信息为:{1}\n\r", i.PropertyName, i.ErrorMessage); }); if (Logger == null) throw new Exception(sb.ToString()); Logger(sb.ToString() + "处理时间:" + DateTime.Now); } catch (OptimisticConcurrencyException)//并发冲突异常 { } catch (Exception ex)//捕获所有异常 { if (Logger == null)//如果没有定义日志功能,就把异常抛出来吧 throw new Exception(ex.Message); Logger(ex.Message + "处理时间:" + DateTime.Now); }
对DbContextRepository进行改造
下面代码,选自仓储大叔的DbContextRepository.cs文件,它是显式实现的异步操作接口的,具体实现如下
#region 异步操作-显示实现的接口,只能为接口实例进行调用 #region IExtensionRepositoryAsync<TEntity> 成员 async System.Threading.Tasks.Task IExtensionRepositoryAsync<TEntity>.Insert(IEnumerable<TEntity> item) { item.ToList().ForEach(i => { Db.Entry<TEntity>(i); Db.Set<TEntity>().Add(i); }); await this.SaveChangesAsync(); } async System.Threading.Tasks.Task IExtensionRepositoryAsync<TEntity>.Update(IEnumerable<TEntity> item) { item.ToList().ForEach(i => { Db.Set<TEntity>().Attach(i); Db.Entry(i).State = EntityState.Modified; }); try { await this.SaveChangesAsync(); } catch (OptimisticConcurrencyException)//并发冲突异常 { } } async System.Threading.Tasks.Task IExtensionRepositoryAsync<TEntity>.Delete(IEnumerable<TEntity> item) { item.ToList().ForEach(i => { Db.Set<TEntity>().Attach(i); Db.Set<TEntity>().Remove(i); }); await this.SaveChangesAsync(); } async System.Threading.Tasks.Task IExtensionRepositoryAsync<TEntity>.BulkInsert(IEnumerable<TEntity> item, bool isRemoveIdentity) { await Task.Run(() => { this.BulkInsert(item, isRemoveIdentity); }); } async System.Threading.Tasks.Task IExtensionRepositoryAsync<TEntity>.BulkInsert(IEnumerable<TEntity> item) { await Task.Run(() => { this.BulkInsert(item); }); } async System.Threading.Tasks.Task IExtensionRepositoryAsync<TEntity>.BulkUpdate(IEnumerable<TEntity> item, params string[] fieldParams) { await Task.Run(() => { this.BulkUpdate(item); }); } async System.Threading.Tasks.Task IExtensionRepositoryAsync<TEntity>.BulkDelete(IEnumerable<TEntity> item) { await Task.Run(() => { this.BulkDelete(item); }); } #endregion #region IRepositoryAsync<TEntity> 成员 async System.Threading.Tasks.Task IRepositoryAsync<TEntity>.Insert(TEntity item) { OnBeforeSaved(new SavedEventArgs(item, SaveAction.Insert)); Db.Entry<TEntity>(item); Db.Set<TEntity>().Add(item); await this.SaveChangesAsync(); OnAfterSaved(new SavedEventArgs(item, SaveAction.Insert)); } async System.Threading.Tasks.Task IRepositoryAsync<TEntity>.Delete(TEntity item) { OnBeforeSaved(new SavedEventArgs(item, SaveAction.Delete)); Db.Set<TEntity>().Attach(item); Db.Set<TEntity>().Remove(item); await this.SaveChangesAsync(); OnAfterSaved(new SavedEventArgs(item, SaveAction.Delete)); } async System.Threading.Tasks.Task IRepositoryAsync<TEntity>.Update(TEntity item) { OnBeforeSaved(new SavedEventArgs(item, SaveAction.Update)); Db.Set<TEntity>().Attach(item); Db.Entry(item).State = EntityState.Modified; try { await this.SaveChangesAsync(); } catch (OptimisticConcurrencyException)//并发冲突异常 { } OnAfterSaved(new SavedEventArgs(item, SaveAction.Update)); } #endregion #endregion
好了,到目前为止我们对DbContextRepository的改造就结束了,下一讲我们将介绍如何在具体项目中使用EF的异步功能,敬请期待!
EF异步改造之路~第二回 让DbContextRepository去实现异步接口
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。