Ссылка на ITVF вызывает исключение «вторая операция началась в этом контексте до завершения предыдущей операции» - PullRequest
Новая
       55

Ссылка на ITVF вызывает исключение «вторая операция началась в этом контексте до завершения предыдущей операции»

0 голосов
/ 25 октября 2018

Я пытаюсь сослаться на встроенную табличную функцию (ITVF) в запросе Linq: 

var results = await (
    from v in _context.Vehicles
    from r in _context.UnitRepairStatus(v.VehicleNumber) <-- ITVF reference
    orderby v.VehicleNumber
    select new FooViewModel { 
            ID = v.ID, 
            VehicleNumber = v.VehicleNumber,
            InRepair = Convert.ToBoolean(r.InRepair) <-- ITFV field
        }
    ).ToListAsync();

Когда запрос выполняется, он генерирует ошибку:

InvalidOperationException: вторая операция началась в этом контексте перед завершением предыдущей операции.Не гарантируется, что все члены экземпляра будут поточно-ориентированными.

с указанием кода:

System.Linq.AsyncEnumerable.Aggregate_ (IAsyncEnumerable source, TAccumulate seed, Funcаккумулятор, Func resultSelector, CancellationToken cancellationToken) MyApplication.Controllers.VehiclesController.Foo () в VehiclesController.cs 

                var results = await (

Если удалить ссылку ITFV, запрос будет работать как ожидалось 

var results = await (
    from v in _context.Vehicles
    orderby v.VehicleNumber
    select new FooViewModel { 
            ID = v.ID, 
            VehicleNumber = v.VehicleNumber,
            InRepair = False <-- dummy value
        }
    ).ToListAsync();

Почему это происходит, когда я добавляю ссылку на ITVF?Как мне решить эту проблему?

Код

UnitRepairStatus ITVF: 

CREATE FUNCTION dbo.UnitRepairStatus(
  @unit_number varchar(18)
)
RETURNS TABLE
AS

RETURN

  SELECT  h.InRepair
  -- connects to a second database on same server
  --  shouldn't be an issue, but mentioning it in case it might be
  FROM    Schema2..Unit u
  INNER JOIN Schema2..History h on u.ID = h.UnitID
  WHERE   u.UnitNumber = @unit_number

UnitRepairStatus Модель: 

public class UnitRepairStatus
{
    public string UnitNumber { get; set; }
    public int? InRepair { get; set; }
}

MyDatabaseDbContextDbContext: 

public class MyDatabaseDbContext : DbContext
{

    public MyDatabaseDbContext(DbContextOptions<MyDatabaseDbContext> options) : base(options) {}
...

    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        ...
        modelBuilder.Query<UnitRepairStatus>();
    }

    public IQueryable<UnitRepairStatus> UnitRepairStatus(string unitNumber) =>
        Query<UnitRepairStatus>().FromSql($"SELECT * FROM UnitRepairStatus({unitNumber})");

}

FooViewModel ViewModel: 

public class FooViewModel
{
    public int ID { get; set; }
    public string VehicleNumber { get; set; }
    public bool InRepair { get; set; }
}

VehiclesController конструктор: 

public VehiclesController(
    ILogger<VehiclesController> logger, 
    MyDatabaseDbContext context
)
{
    _logger = logger;
    _context = context;
}

VehiclesController Foo метод: 

public async Task<IActionResult> Foo()
{

    List<FooViewModel> model = null;

    try
    {
        var results = await (  <-- line referenced in error message
            from v in _context.Vehicles
            from r in _context.UnitRepairStatus(v.VehicleNumber)
            orderby v.VehicleNumber
            select new FooViewModel { 
                    ID = v.ID, 
                    VehicleNumber = v.VehicleNumber,
                    InRepair = Convert.ToBoolean(r.InRepair)
                }
            ).ToListAsync();

    }
    catch (Exception e)
    {
        _logger.LogError(e.Message);
        throw;
    }

    return View(model);

}

Ссылка:

1 Ответ

0 голосов
/ 25 октября 2018

Извините, моя вина.Техника ответа на ваш предыдущий вопрос применима для вызова ITVF с постоянными / переменными параметрами, но не с коррелированными подзапросами, как в вашем случае (и мой неправильный пример).

Решение состоит в том, чтобы удалить параметр ITVFи расширьте результат, включив в него и этот столбец (фактически превратив его в представление без параметров): 

CREATE FUNCTION dbo.UnitRepairStatus()
RETURNS TABLE
AS
RETURN
  SELECT u.UnitNumber, h.InRepair
  FROM    Schema2.Unit u
  INNER JOIN Schema2.History h on u.ID = h.UnitID

Также удалите параметр из метода контекста: 

public IQueryable<UnitRepairStatus> UnitRepairStatus() =>
    Query<UnitRepairStatus>().FromSql("SELECT * FROM UnitRepairStatus()");

и измените LINQзапрос на использование соединения: 

var results = await (
    from v in _context.Vehicles
    join r in _context.UnitRepairStatus() on v.VehicleNumber equals r.UnitNumber // <---
    orderby v.VehicleNumber
    select new FooViewModel { 
        ID = v.ID, 
        VehicleNumber = v.VehicleNumber,
        InRepair = Convert.ToBoolean(r.InRepair)
    }
).ToListAsync();

Теперь он должен транслироваться и выполняться на стороне сервера и успешно реализовываться на клиенте.

Проблема с оригинальным подходом заключалась в том, что EF Core молча переключил выполнение запроса на оценку клиента (ненавидят это), а затем включил защиту для выполнения нескольких асинхронных операций в одном и том же контексте.

...