MongoDB Linq запрос в C# с фильтрами

Question

Я пытаюсь выполнить запрос LINQ для нескольких коллекций Mon go. Все коллекции должны быть объединены на основе ApplicationId, и должно быть выполнено внешнее соединение - так, чтобы лица, которые не имеют статусов, также возвращались. Часть JOIN и все вокруг нее работает как положено. Проблема в том, что когда я добавляю фильтр в одну из коллекций, все это ломается

An exception of type 'System.ArgumentException' occurred in System.Linq.Expressions.dll but was not handled in user code: 'Expression of type 'System.Collections.Generic.IEnumerable`1[CDM.Person]' cannot be used for parameter of type 'System.Linq.IQueryable`1[CDM.Person]' of method 'System.Linq.IQueryable`1[CDM.Person] Where[Person](System.Linq.IQueryable`1[CDM.Person], System.Linq.Expressions.Expression`1[System.Func`2[CDM.Person,System.Boolean]])''

Вот мой запрос

var applications = _dbContext.GetCollection<Application>(typeof(Application).Name).AsQueryable().Where(
                x => x.OrganizationID == TokenContext.OrganizationID);

var persons = _dbContext.GetCollection<Person>(typeof(Person).Name).AsQueryable().Where(p =>p.FirstName == "j");
var statuses = _dbContext.GetCollection<ApplicationStatus>(typeof(ApplicationStatus).Name).AsQueryable();
var mortgages = _dbContext.GetCollection<Mortgage>(typeof(Mortgage).Name).AsQueryable();

            var statusQuery = from a in applications
                                join p in persons on a.ApplicationID equals p.ApplicationID 
                                join s in statuses on a.ApplicationID equals s.ApplicationID into pas
                                join m in mortgages on a.ApplicationID equals m.ApplicationID into morgs
                                from subWHatever in pas.DefaultIfEmpty()
                              select new ApplicationStatusProjection
                              {
                                  ApplicationId = a.ApplicationID,
                                  FirstName = p.FirstName,
                                  LastName = p.Surname,
                                  Prefix = p.Prefix,
                                  DateOfBirth = p.DateOfBirth,
                                  Initials = p.Initials,
                                  PostalCode = p.Addresses.First().PostalCode,
                                  MortgageAmount = morgs.Sum(i => i.MortgageTotal) ?? 0,
                                  StatusExpireAt = subWHatever.ExpireAt ?? DateTime.MinValue,
                                  StatusMessageText = subWHatever.MessageText ?? "",
                                  StatusMessage = subWHatever.MessageStatus ?? ""

                              };

            if (!String.IsNullOrEmpty(orderBy))
            {
                statusQuery = statusQuery?.OrderBy(orderBy);
            }

            if (nrOfRecords != null)
            {
                statusQuery = statusQuery?.Take(nrOfRecords.Value);
            }

            // Execute the query
            var result = statusQuery?.ToList();
            return result;

Я следовал рекомендациям здесь https://mongodb.github.io/mongo-csharp-driver/2.6/reference/driver/crud/linq/ и я тоже попробовал это

var statusQuery = 
    from a in applications
       join p in persons on a.ApplicationID equals p.ApplicationID into pa
    from paObject in pa.DefaultIfEmpty()
       join s in statuses on paObject.ApplicationID equals s.ApplicationID into pas

Но я получил ту же ошибку, что и раньше.

Заранее спасибо.

Answer 1

Итак, после майских испытаний я обнаружил, что вы не можете фильтровать перед объединением из-за того, как запрос LINQ транслируется в запрос Mon go. Решением этой проблемы является последующая фильтрация объекта statusQuery. В этом случае фильтрация должна выполняться на проецируемом объекте (поэтому необходим новый фильтр). Посмотрите ниже, как я решил это:

 //get collections
            var applications = _dbContext.GetCollection<Application>(typeof(Application).Name).AsQueryable().Where(
                x => x.OrganizationID == TokenContext.OrganizationID);
            var persons = _dbContext.GetCollection<Person>(typeof(Person).Name).AsQueryable();
            var statuses = _dbContext.GetCollection<ApplicationStatus>(typeof(ApplicationStatus).Name).AsQueryable();
            var mortgages = _dbContext.GetCollection<Mortgage>(typeof(Mortgage).Name).AsQueryable();

            //query
            var query = from a in applications
                              join p in persons on a.ApplicationID equals p.ApplicationID
                              join s in statuses on a.ApplicationID equals s.ApplicationID into applicationStatusView
                              join m in mortgages on a.ApplicationID equals m.ApplicationID into morgs
                              from subStatus in applicationStatusView.DefaultIfEmpty()
                              select new ApplicationStatusProjection
                              {
                                  ApplicationId = a.ApplicationID,
                                  FirstName = p.FirstName,
                                  LastName = p.Surname,
                                  Prefix = p.Prefix,
                                  DateOfBirth = p.DateOfBirth,
                                  Initials = p.Initials,
                                  Addresses = p.Addresses ?? new List<Address>(),
                                  PostalCode = p.Addresses.First().PostalCode,
                                  MortgageAmount = morgs.Sum(i => i.MortgageTotal) ?? 0,
                                  StatusExpireAt = subStatus.ExpireAt ?? DateTime.MinValue,
                                  StatusMessageText = subStatus.MessageText ?? "",
                                  StatusMessage = subStatus.MessageStatus ?? "",
                                  StatusDate = subStatus.StatusDate

                              };

            //filter & order
            var filteredResult = ApplyFilters(query, searchCriteria);

            if (!String.IsNullOrEmpty(orderBy))
            {
                filteredResult = filteredResult?.OrderBy(orderBy);
            }

            if (nrOfRecords != null)
            {
                filteredResult = filteredResult?.Take(nrOfRecords.Value);
            }

            // Execute the query
            var result = filteredResult?.ToList();
            return result;

И применение фильтров (возможно, есть более разумный способ сделать это):

 private IQueryable<ApplicationStatusProjection> ApplyFilters(IQueryable<ApplicationStatusProjection> query, ApplicationStatusProjectionSearch searchCriteria)
        {
            if (!string.IsNullOrEmpty(searchCriteria.FirstName))
            {
                query = query.Where(x => x.FirstName.ToLower().StartsWith(searchCriteria.FirstName));
            }

            if (!string.IsNullOrEmpty(searchCriteria.LastName))
            {
                query = query.Where(x => x.LastName.ToLower().StartsWith(searchCriteria.LastName));
            }

            if (!string.IsNullOrEmpty(searchCriteria.PostalCode))
            {
                query = query.Where(x => x.Addresses.Any(a => a.PostalCode.ToLower().StartsWith(searchCriteria.PostalCode)));
            }
//other irrelevant filters
            return query;
}