如何使用表达式执行连接

Question

我正在为我的项目使用实体框架包装器。如果我只使用一个表进行 CRUD 操作，它工作正常，但不幸的是我无法连接两个表。

我看到有人建议包含我也无法使用。

reference

我也有this，但我听不懂。

我在下面分享我的 BaseRepository 类

 public class BaseRepository<T> : IBaseRepository<T> where T : class
 {
    private IUnitOfWork unitOfWork;
    private DbSet<T> dbSet;

    public BaseRepository(IUnitOfWork unitOfWork)
    {
        this.unitOfWork = unitOfWork;
        this.dbSet = unitOfWork.DbContext.Set<T>();
    }

    public virtual IEnumerable<T> Get(Expression<Func<T, bool>> filter = null, Func<IQueryable<T>, IOrderedQueryable<T>> orderBy = null, string includeProperties = "")
    {
        IQueryable<T> query = dbSet;

        if (filter != null)
        {
            query = query.Where(filter);
        }

        foreach (var includeProperty in includeProperties.Split
            (new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries))
        {
            query = query.Include(includeProperty);
        }

        if (orderBy != null)
        {
            return orderBy(query).ToList();
        }
        else
        {
            return query.ToList();
        }
    }

    public virtual IEnumerable<T> Get()
    {
        return dbSet.ToList();
    }

    public virtual IEnumerable<T> Get(Expression<Func<T, bool>> predicate)
    {
        return dbSet.Where(predicate);
    }

    public virtual T Get(object id)
    {
        return dbSet.Find(id);
    }

    public virtual IQueryable<T> Where(Expression<Func<T, bool>> predicate)
    {
        return dbSet.Where(predicate);
    }

    public virtual IQueryable<T> Query()
    {
        return dbSet;
    }

    public bool Any(Expression<Func<T, bool>> predicate)
    {
        return dbSet.Any(predicate);
    }

    public T First(Expression<Func<T, bool>> predicate)
    {
        return dbSet.First(predicate);
    }

    public T FirstOrDefault(Expression<Func<T, bool>> predicate)
    {
        return dbSet.FirstOrDefault(predicate);
    }

    public virtual void Insert(T entity)
    {
        dbSet.Add(entity);
    }

    public virtual void Update(T entity)
    {

        if (unitOfWork.DbContext.Entry(entity).State == EntityState.Detached)
        {
            dbSet.Attach(entity);
        }

        unitOfWork.DbContext.Entry(entity).State = EntityState.Modified;
    }

    public virtual void Delete(object id)
    {
        T entityToDelete = dbSet.Find(id);
        Delete(entityToDelete);
    }

    public virtual void Delete(T entity)
    {
        if (unitOfWork.DbContext.Entry(entity).State == EntityState.Detached)
        {
            dbSet.Attach(entity);
        }
        dbSet.Remove(entity);
    }

    private bool disposed = false;

    protected virtual void Dispose(bool disposing)
    {
        if (!this.disposed)
        {
            if (disposing)
            {
                unitOfWork.DbContext.Dispose();
            }
        }
        this.disposed = true;
    }

    public void Dispose()
    {
        Dispose(true);
        GC.SuppressFinalize(this);
    }

    public IEnumerable<T> ExecWithStoreProcedure(string query, params object[] parameters)
    {
        return unitOfWork.DbContext.Database.SqlQuery<T>(query, parameters);
    }
}

请让我知道我需要在 BaseRepository 中执行哪些更改，以便我可以执行加入。

Answer 1

好的...所以，查看您的基础存储库，您似乎已经做好了准备。我最好的猜测是您只是对使用存储库模式感到困惑。因此，您向我们展示了采用 <T> 类型的 BaseRepository。您的特定存储库是如何创建的？例如，您必须拥有 AccountRepository 或 ContactRepository，它们需要在 UnitOfWork 类中使用类似这样的通用基础存储库：

private IBaseRepository<Account> _accountRepository;    
    public IBaseRepository<Account> AccountRepository
    {
        get { return _accountRepository ?? (_accountRepository = new BaseRepository<Account>(_databaseFactory)); }
    }

您可以如下调用：

private IBaseRepository<Account> accountRepo { get { return UnitOfWork.AccountRepository; } }

并像 accountRepo.Get() 一样使用它，它会为您提供所有帐户的列表。

如果这是您使用存储库的方式，那么您只需添加其他实体的存储库即可：

private IBaseRepository<Contact> contactRepo { get { return UnitOfWork.ContactRepository; } }

并执行如下加入：

return (from c in contactRepo.GetAll()
            join a in accountRepo.GetAll() on c.AccountId equals a.AccountId
            where a.Name == "Test Account Name"
            select c).ToList();

上面将为您提供属于 Name = "Test Account Name" 的帐户的所有联系人。

让我知道它是如何为你工作的。