使用Entity Framework 4.1和父/子关系的存储库模式

22 浏览
0 Comments

使用Entity Framework 4.1和父/子关系的存储库模式

我对存储库模式仍然有些困惑。我想使用这种模式的主要原因是避免从领域中调用EF 4.1特定的数据访问操作。我宁愿从IRepository接口调用通用的CRUD操作。这将使测试更容易,并且如果将来必须更改数据访问框架,我将能够在不重构大量代码的情况下进行更改。

这是我的情况的一个例子:

数据库中有3个表:GroupPersonGroupPersonMapGroupPersonMap是一个链接表,只包含GroupPerson的主键。我使用VS 2010设计器创建了3个表的EF模型。EF足够聪明,会假设GroupPersonMap是一个链接表,所以不会在设计器中显示它。我希望使用现有的领域对象,而不是EF生成的类,所以我关闭了模型的代码生成。

与EF模型匹配的现有类如下所示:

public class Group
{
   public int GroupId { get; set; }
   public string Name { get; set; }
   public virtual ICollection People { get; set; }
}
public class Person
{
   public int PersonId {get; set; }
   public string FirstName { get; set; }
   public virtual ICollection Groups { get; set; }
}

我有一个通用的存储库接口:

public interface IRepository where T: class
{
    IQueryable GetAll();
    T Add(T entity);
    T Update(T entity);
    void Delete(T entity);
    void Save()
}

和一个通用的EF存储库:

public class EF4Repository : IRepository where T: class
{
    public DbContext Context { get; private set; }
    private DbSet _dbSet;
    public EF4Repository(string connectionString)
    {
        Context = new DbContext(connectionString);
        _dbSet = Context.Set();
    }
    public EF4Repository(DbContext context)
    {
        Context = context;
        _dbSet = Context.Set();
    }
    public IQueryable GetAll()
    {
        // code
    }
    public T Insert(T entity)
    {
        // code
    }
    public T Update(T entity)
    {
        Context.Entry(entity).State = System.Data.EntityState.Modified;
        Context.SaveChanges();
    }
    public void Delete(T entity)
    {
        // code
    }
    public void Save()
    {
        // code
    }
}

现在假设我只想将现有的Group映射到现有的Person。我必须做类似以下的事情:

        EFRepository groupRepository = new EFRepository("name=connString");
        EFRepository personRepository = new EFRepository("name=connString");
        var group = groupRepository.GetAll().Where(g => g.GroupId == 5).First();
        var person = personRepository.GetAll().Where(p => p.PersonId == 2).First();
        group.People.Add(person);
        groupRepository.Update(group);

但是这不起作用,因为EF认为Person是新的,并且将尝试将Person重新插入数据库,这将导致主键约束错误。我必须使用DbSetAttach方法告诉EFPerson已经存在于数据库中,所以只需在GroupPersonMap表中创建一个映射即可。

所以为了将Person附加到上下文中,我现在必须在我的IRepository中添加一个Attach方法:

public interface IRepository where T: class
{
    // existing methods
    T Attach(T entity);
}

为了解决主键约束错误:

EFRepository groupRepository = new EFRepository("name=connString");
EFRepository personRepository = new EFRepository(groupRepository.Context);
var group = groupRepository.GetAll().Where(g => g.GroupId == 5).First();
var person = personRepository.GetAll().Where(p => p.PersonId == 2).First();
personRepository.Attach(person);
group.People.Add(person);
groupRepository.Update(group);

修复了。现在我还必须处理另一个问题,即每次创建Group/Person映射时都会在数据库中更新Group。这是因为在我的EFRepository.Update()方法中,实体状态被明确设置为Modified。我必须将Group的状态设置为Unchanged,以防止修改Group表。

为了解决这个问题,我必须在我的IRepository中添加某种Update重载,它不会更新根实体,或者在这种情况下不会更新Group

public interface IRepository where T: class
{
    // existing methods
    T Update(T entity, bool updateRootEntity);
}

Update方法的EF4实现可能如下所示:

T Update(T entity, bool updateRootEntity)
{
   if (updateRootEntity)
      Context.Entry(entity).State = System.Data.EntityState.Modified;
   else
      Context.Entry(entity).State = System.Data.EntityState.Unchanged;
    Context.SaveChanges();
}

我的问题是:我这样做对吗?随着我开始使用EF和存储库模式,我的存储库开始看起来很EF中心化。谢谢阅读这篇长篇文章。

0