重構LINQ to Entities查詢與設變量和子查詢

Question

我希望能夠以某種方式打破了下面的代碼：

return from e in _context.Employees 
     let HasWatchedAllVideos = 
     (
      from ev in _context.EmployeeVideos 
      where ev.EmployeeId == e.Id && ev.EndTime.HasValue 
      select ev.Id 
     ).Count() == _context.Videos.Count() 
     let EndTime = HasWatchedAllVideos ? 
     (
      from ev in _context.EmployeeVideos 
      where ev.EmployeeId == e.Id 
      select ev.EndTime 
     ).Max() : null 
     let StartTime = 
     (
      from ev in _context.EmployeeVideos 
      where ev.EmployeeId == e.Id 
      select ev.StartTime 
     ).Min() 
     select new EmployeeListItem 
     { 
      Id = e.Id, 
      FirstName = e.FirstName, 
      LastName = e.LastName, 
      Company = e.Company, 
      HasWatchedAllVideos = HasWatchedAllVideos, 
      StartTime = StartTime, 
      EndTime = EndTime 
     }; 

例如，我正在尋找一種方式來分解出：

let HasWatchedAllVideos = 
(
    from ev in _context.EmployeeVideos 
    where ev.EmployeeId == e.Id && ev.EndTime.HasValue 
    select ev.Id 
).Count() == _context.Videos.Count() 

爲一個單獨的方法爲可重用性的目的，但我無法弄清楚如何去做這件事。我曾嘗試過：

private bool HasWatchedAllVideos(int employeeId) 
{ 
    return (from ev in _context.EmployeeVideos 
      where ev.EmployeeId == employeeId && ev.EndTime.HasValue 
      select ev.Id 
      ).Count() == _context.Videos.Count(); 
} 

這給了我舊的最愛'LINQ to Entities does not recognized the method'exception。

Answer 1

這個問題可能不會得到很多的行動，所以我發佈一個相關的問題是幫助我試圖找到一個更好的解決方案：

refactoring LINQ IQueryable expression to remove duplicated portions of queries

下面是我的特殊變異代碼的溶液：

public class AdaTrainingService : ADATraining.Web.Models.IAdaTrainingService, IDisposable 
{ 
    private ADATrainingEntities _context = new ADATrainingEntities(); 

    public IQueryable<EmployeeListItem> GetEmployeeListing() 
    { 
     return from e in _context.Employees 
       join evsws in EmployeeVideoAggregatesView() on e.Id equals evsws.EmployeeId 
       select new EmployeeListItem 
       { 
        Id = e.Id, 
        FirstName = e.FirstName, 
        LastName = e.LastName, 
        Company = e.Company, 
        HasWatchedAllVideos = evsws.HasWatchedAllVideos, 
        StartTime = evsws.StartTime, 
        EndTime = evsws.EndTime 
       }; 
    } 

    private class EmployeeVideoSeriesWatchingStats 
    { 
     public int EmployeeId { get; set; } 
     public DateTime? StartTime { get; set; } 
     public DateTime? EndTime { get; set; } 
     public bool HasWatchedAllVideos { get; set; } 
    } 

    private IQueryable<EmployeeVideoSeriesWatchingStats> EmployeeVideoAggregatesView() 
    { 
     return from ev in _context.EmployeeVideos 
       group ev by ev.EmployeeId into myGroup 
       select new EmployeeVideoSeriesWatchingStats 
       { 
        EmployeeId = myGroup.Key, 
        StartTime = myGroup.Min(x => x.StartTime), 
        EndTime = myGroup.Max(x => x.EndTime), 
        HasWatchedAllVideos = myGroup.Count() == _context.Videos.Count() 
       }; 
    } 

    public void Dispose() 
    { 
     _context.Dispose(); 
    } 
} 

- UPDATE 5/13/2011 -

上面的例子進行內加入並不會活像K中要包括所有員工即使EmployeeVideoAggregatesView（）不返回任何結果的情況下，這樣允許左外連接，我不得不調整一下代碼：重構的

public IQueryable<EmployeeDetails> GetEmployeeListing() 
{ 
    return from e in _context.Employees 
      join evsws in EmployeeVideoAggregatesView() on e.Id equals evsws.EmployeeId into myJoin 
      from mj in myJoin.DefaultIfEmpty() 
      select new EmployeeDetails 
      { 
       Id = e.Id, 
       FirstName = e.FirstName, 
       LastName = e.LastName, 
       Company = e.Company, 
       BadgeNumber = e.BadgeNumber, 
       Title = e.Title, 
       HasWatchedAllVideos = (mj.HasWatchedAllVideos == null) ? false : mj.HasWatchedAllVideos, 
       StartTime = mj.StartTime, 
       EndTime = mj.EndTime 
      }; 
} 

Answer 2

// don't count every time 
var totalCount = _context.Videos.Count(); 

from e in _context.Employees 
let HasWatchedAllVideos = 
    totalCount == 
    _context.EmployeeVideos.Count(ev => ev.EmployeeId == e.Id && ev.EndTime.HasValue) 

// count just once per employee 
let employeeVideos = _context.EmployeeVideos.Count(ev => ev.EmployeeId == e.Id) 

let EndTime = HasWatchedAllVideos ? employeeVideos.Max() : null 
let StartTime = HasWatchedAllVideos ? employeeVideos.Min() : null 

select new EmployeeListItem 
{ 
    Id = e.Id, 
    FirstName = e.FirstName, 
    LastName = e.LastName, 
    Company = e.Company, 
    HasWatchedAllVideos = HasWatchedAllVideos, 
    StartTime = StartTime, 
    EndTime = EndTime 
};