Я не обязательно думаю, что вы не должны использовать свойство навигации здесь. Они являются виртуальными, и запрос генерируется на основе оператора Linq.
Я также не думаю, что отдельная модель DTO имеет смысл в этом случае. Я предполагаю, что, поскольку вы упомянули свойство навигации, у вас есть отношение «1-много». Я предполагаю, что автомобиль должен быть запланирован с набором ремонтов. Если это так, то, возможно, GroupJoin будет работать. Поддерживается EF: https://docs.microsoft.com/en-us/dotnet/framework/data/adonet/ef/language-reference/supported-and-unsupported-linq-methods-linq-to-entities
Я добавил свойство для проведения ремонта Транспортного средства :
public IEnumerable<ServiceInterval> RepairsToSchedule { get; set; }
Тогда запрос выглядит примерно так:
public static IQueryable<Vehicle> GetVehicles()
{
return _context.Vehicles
.Where(v => v.Schedule && !v.Suspend)
.GroupJoin(_context.ServiceIntervals,
v => v.Id,
si => si.VehicleId,
(v, si) => SetServiceIntervals(v, si));
}
Я использовал приведенный ниже статический метод для добавления ServiceIntervals к Vehicle :
private static Vehicle SetServiceIntervals(Vehicle v, IEnumerable<ServiceInterval> si)
{
v.RepairsToSchedule = si;
return v;
}
Весь исходный код приведен ниже:
Отредактировано: с поправкой на две отдельные базы данных (заметка на одном сервере)
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Diagnostics;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
namespace StackoverFlow
{
class Program
{
private static FakeDatabaseContext _context = new FakeDatabaseContext();
private static FakeDatabaseContext2 _context2 = new FakeDatabaseContext2();
static void Main(string[] args)
{
CleanContext();
LoadContext();
foreach (var vehicle in GetVehicles())
{
Console.WriteLine(JsonConvert.SerializeObject(vehicle, Formatting.Indented));
Console.WriteLine();
}
Console.ReadKey();
}
public static IQueryable<Vehicle> GetVehicles()
{
return _context.Vehicles
.Where(v => v.Schedule && !v.Suspend)
.GroupJoin(_context.ServiceIntervals(new DateTime(), new DateTime()),
v => v.Id,
si => si.VehicleId,
(v, si) => SetServiceIntervals(v, si));
}
private static Vehicle SetServiceIntervals(Vehicle v, IEnumerable<ServiceInterval> si)
{
v.RepairsToSchedule = si;
return v;
}
#region EF Context
public class FakeDatabaseContext : DbContext
{
public DbSet<Vehicle> Vehicles { get; set; }
private DbSet<ServiceInterval> _serviceIntervals { get; set; }
public IQueryable<ServiceInterval> ServiceIntervals(DateTime startingDate, DateTime endingDate)
{
return _serviceIntervals.FromSql($@"
SELECT *
FROM Stackoverflow2.dbo.ServiceIntervals"
);
}
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{
optionsBuilder.UseSqlServer(
@"Server=(localdb)\mssqllocaldb;Database=Stackoverflow;Integrated Security=True");
optionsBuilder
.ConfigureWarnings(w => w.Throw(RelationalEventId.QueryClientEvaluationWarning));
}
}
// Used to load a seperate database
public class FakeDatabaseContext2 : DbContext
{
public DbSet<ServiceInterval> ServiceIntervals { get; set; }
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{
optionsBuilder.UseSqlServer(
@"Server=(localdb)\mssqllocaldb;Database=Stackoverflow2;Integrated Security=True");
optionsBuilder
.ConfigureWarnings(w => w.Throw(RelationalEventId.QueryClientEvaluationWarning));
}
}
public class Vehicle
{
public string Id { get; set; }
public bool Schedule { get; set; }
public bool Suspend { get; set; }
public IEnumerable<ServiceInterval> RepairsToSchedule { get; set; }
}
public class ServiceInterval
{
public string Id { get; set; }
public string VehicleId { get; set; }
}
#endregion EF Context
#region Seed methods
private static Random _random = new Random();
private static bool _randomBool => _random.Next() % 2 == 1;
private static void LoadContext()
{
var maxVehicles = 10;
for (int i = 1; i < maxVehicles; i++)
{
_context.Vehicles.Add(new Vehicle { Id = i.ToString(), Schedule = _randomBool, Suspend = _randomBool });
for (int o = 1; o < _random.Next(10); o++)
{
_context2.ServiceIntervals.Add(new ServiceInterval { Id = ((maxVehicles * i) + o).ToString(), VehicleId = i.ToString() });
}
};
_context.SaveChanges();
_context2.SaveChanges();
}
private static void CleanContext()
{
_context.Vehicles.RemoveRange(_context.Vehicles.ToArray());
_context2.ServiceIntervals.RemoveRange(_context2.ServiceIntervals.ToArray());
_context.SaveChanges();
_context2.SaveChanges();
}
#endregion Seed methods
}
}
IntelliTrace показало, что этот запрос был выполнен:
SELECT [v].[Id], [v].[Schedule], [v].[Suspend], [si].[Id], [si].[VehicleId]
FROM [Vehicles] AS [v]
LEFT JOIN (
SELECT *
FROM Stackoverflow2.dbo.ServiceIntervals
) AS [si] ON [v].[Id] = [si].[VehicleId]
WHERE ([v].[Schedule] = 1) AND ([v].[Suspend] = 0)
ORDER BY [v].[Id]
Я проверял это несколько раз, и все, кажется, работает нормально.
~ Приветствия
Примечания к проекту установки:
- Это консольное приложение .NET Core 2.1
- Install-Package Microsoft.EntityFrameworkCore -Version 2.2.6
- Install-Package Microsoft.EntityFrameworkCore.Design -Version 2.2.6
- Install-Package Microsoft.EntityFrameworkCore.SqlServer -Version 2.2.6
- Install-Package Microsoft.EntityFrameworkCore.SqlServer.Design -Version 1.1.6
- Откройте окно cmd и перейдите в папку проекта
- Запустить в консоли: dotnet ef миграций добавить InitialCreate
- Запуск в консоли: обновление базы данных dotnet ef