役魅肋 发表于 2025-5-29 15:41:01

Entity Framework 4.1 Code First学习之路(二)

写系列的上一篇已经是很久之前的事儿了= =在此期间,EF 4.1的RTW都已经出来了,NH 3.2的Alpha已经2了。。。其实不是我懒,工作中也在一直使用EF 4.1。主要是上次承诺过的一个Update功能搞不定= =
总之这一次的目标是

   
[*]实现一个完整的IRepository(添加增删改能力)   
[*]领域对象的继承   
[*]事物
首先来看IRepository
我的接口如下
             1: public interface IRepository<TEntity>       2:   where TEntity : IEntity       3: {       4:   IEnumerable<TEntity> FindAll();       5:   TEntity FindById(int id);       6:   void Add(TEntity entity);       7:   void Delete(TEntity entity);       8:   void Update(TEntity entity);       9: }应该算是一个最基本的仓储接口了。
其中前几个接口都是很好实现的,上次提及的DbSet对象提供了相应的接口,直接调用即可,代码是类似这样的。
         1: protected DbSet<TEntity> DbSet       2: {       3:   get { return m_dbContext.Set<TEntity>(); }       4: }       5:         6: public IEnumerable<TEntity> FindAll()       7: {       8:   return DbSet;       9: }    10:      11: public TEntity FindById(int id)    12: {    13:   return DbSet.SingleOrDefault(entity => entity.Id == id);    14: }    15:      16: public void Add(TEntity entity)    17: {    18:   DbSet.Add(entity);    19:   m_dbContext.SaveChanges();    20: }    21:      22: public void Delete(TEntity entity)    23: {    24:   DbSet.Remove(entity);    25:   m_dbContext.SaveChanges();    26: }关键问题是最后的Update方法
DbSet对象并没有提供相应的接口,为什么呢?因为EF相信自己的Self Tracking能力。也就是说,EF认为把一个entity从context中加载出来,做一些变更,然后直接SaveChanges就可以了,不需要特意提供一个Update方法。
但是这里有一个前提,就是“entity是从context中加载出来”。如果entity是新new出来的呢?比如在MVC里,entity很可能是ModelBinder帮我们new出来的,context对它一无所知,直接SaveChanges显然不会有任何效果。
那么如何让context可以理解一个新new出来的entity呢?这要从EF处理entity状态开始说起。
EF定义了如下几种State(注意这个枚举是Flag)

             1:          2: public enum EntityState         3: {         4:   Detached = 1,         5:   Unchanged = 2,         6:   Added = 4,         7:   Deleted = 8,         8:   Modified = 16,         9: } 
其中Detached状态,就是entity还没有attach到context(实际上是Attach到某个DbSet上)的状态。具体怎么做呢?直接上代码

             1: public void Update(TEntity entity)         2: {         3:   var entry = m_dbContext.Entry(entity);         4:   if (entry.State == EntityState.Detached)         5:   {         6:         //DbSet.Attach(entity);         7:         entry.State = EntityState.Modified;         8:   }         9:   m_dbContext.SaveChanges();      10: } 
可以看到上面的代码给出了两种办法,一种是直接修改entry的State,另一种是调用DbSet对象的Attach方法。
注意到DbContext.Entry方法取出的DbEntityEntry对象。利用这个对象可以做很多有用的事哦~~园子里的EF专家LingzhiSun有一篇blog,大家可以去读读。
不过这个实现有一个缺陷
我们上面谈到过,上面这个实现实际上是把entity attach到了对应的DbSet上。但是如果你的代码是类似如下的,就可能产生问题(没有亲试,感觉上是这样的= =)
         1: var heros = repository.FindAll();       2: var hero = heros.First(h => h.Id == 1);       3: var heroNew = new Hero       4: {       5:   Id = hero.Id,       6:   Name = hero.Name,       7:   Race = hero.Race       8: };       9: repository.Update(heroNew);应该是会抛出来一个异常说“An object with the same key already exists in the ObjectStateManager. The ObjectStateManager cannot track multiple objects with the same key.”
异常说的很明白,你的DbSet已经加载过一次id为1的对象了,当试图去attach另一个id为1的对象的时候EF就会无所适从。
那是不是说刚才给出的那个实现根本就行不通呢?不是的!事实上微软官方的文章上就是采用这种方法的。关键就在于当你尝试去attach一个entity的时候,要保证DbSet还没有加载过!我们看上面那篇微软的文章里是如何保证这一点的
         1: public class BlogController : Controller       2: {       3:   BlogContext db = new BlogContext();       4:         5:   //...       6:         7:          8:   public ActionResult Edit(int id, Blog blog)       9:   {    10:         try    11:         {    12:         db.Entry(blog).State = EntityState.Modified;    13:         db.SaveChanges();    14:    15:             return RedirectToAction("Index");    16:         }    17:         catch    18:         {    19:             return View();    20:         }    21:   }    22: }很明显,在执行Edit这个Action之前,DbSet没有加载过,因为MVC帮我们保证了DbContext实例是request结束就被销毁的.
也就是说,结论是使用这种Update实现方式对context的生命周期是有要求的.当然我的例子中context的生命周期也是per-request的所以没关系。
那么如果我们想使用其他的context生命周期管理方式呢?比如希望整个application只有一个context实例?
让我们来给出另一种实现
回过头来想一想在实现Update这个方法的时候我们最初遇到的问题:entity不是从context中加载的而是直接new出来的
那么我们手动的来加载一次就好了么,代码类似于这样
         1: public void Update(Hero entity)       2: {       3:   var entry = m_dbContext.Entry(entity);       4:   if (entry.State == EntityState.Detached)       5:   {       6:         Hero entityToUpdate = FindById(entity.Id);       7:         entityToUpdate.Id = entity.Id;       8:         entityToUpdate.Name = entity.Name;       9:         entityToUpdate.Race = entity.Race;    10:   }    11:   m_dbContext.SaveChanges();    12: }不过由于失去了泛型的优势,给每个domain model都要实现一个Update方法比较烦,可以用一些框架来解决这个问题,例如EmitMapper(园子里也讨论过这个东西)
         1: public void Update(TEntity entity)       2: {       3:   var entry = m_dbContext.Entry(entity);       4:   if (entry.State == EntityState.Detached)       5:   {       6:         var entityToUpdate = FindById(entity.Id);       7:         EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper<TEntity, TEntity>().Map(entity, entityToUpdate);       8:   }       9:   m_dbContext.SaveChanges();    10: }当然这个实现也有不好的地方例如说当domain里有一些跟ORM没关系的property时也会被EmitMapper改写掉。
下一个议题是领域对象的继承
让领域对象实现继承的好处是不言而喻的,可以使用到多态等OO带来的好处。相对的就对ORM提出了更高的要求。
我们知道映射对象树到数据库有三种经典的实现方式:Table Per Type、Table Per Hierarchy和Table Per Concrete class,这次我们来实践最简单的一种:Table Per Hierarchy。
回想我们上一次的类
         1: public class Hero : IEntity       2: {       3:   public int Id { get; set; }       4:   public string Name { get; set; }       5:   public bool IsSuperHero { get; set; }       6:   public virtual Race Race { get; set; }       7: }把它拆成两个有继承关系的类
         1: public class Hero : IEntity       2: {       3:   public int Id { get; set; }       4:   public string Name { get; set; }       5:   //public bool IsSuperHero { get; set; }       6:   public virtual Race Race { get; set; }       7: }       8: public class SuperHero : Hero       9: {    10:       11: }在EF Code First中这种单表继承的映射关系是这样来写的
         1: Map<Hero>(hero => hero.Requires(ColumnNameMappingStrategy.Value.To("IsSuperHero")).HasValue(false)).ToTable(tableNameMappingStrategy.To("Hero"));       2: Map<SuperHero>(hero => hero.Requires(ColumnNameMappingStrategy.Value.To("IsSuperHero")).HasValue(true)).ToTable(tableNameMappingStrategy.To("Hero"));另外两种方式的实现也不复杂,可以参考这里。这个实例还是CTP5的API,跟4.1最终版有些区别不过应该影响不大。
今天最后的议题是事物
可以用TransactionScope来管理,虽然看起来有些浪费,毕竟例子中不涉及Transaction传播,连DbContext都只有一个实例。代码如下

             1:          2: public ActionResult Edit(TEntity entity)         3: {         4:   try         5:   {         6:         using (var scope = new TransactionScope())         7:         {         8:             ModelRepository.Update(entity);         9:             scope.Complete();      10:         }      11:         return RedirectToAction("Index");      12:   }      13:   catch      14:   {      15:         return View();      16:   }      17: }Spring实际上也可以用AOP的方式管理TransactionScope。不过我倾向于手动管理Transaction。 
代码下载
本次的代码请参考这个changeset
今天就到这里-v-

来源:程序园用户自行投稿发布,如果侵权,请联系站长删除
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!
页: [1]
查看完整版本: Entity Framework 4.1 Code First学习之路(二)