Правильное использование зависимостей, введенных DbContext для запроса базы данных - PullRequest
Новая
       19

Правильное использование зависимостей, введенных DbContext для запроса базы данных

0 голосов
/ 11 марта 2019

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

public void ConfigureServices(IServiceCollection services)
{
    services.AddDbContextPool<JobTrackingContext>(options => options.UseNpgsql(connection));
    services.AddScoped<IJobRepository, JobRepository>();
}

Затем я определяю мой JobTrackingContext следующим образом: 

public JobTrackingContext(DbContextOptions<JobTrackingContext> options)
            : base(options)
{
    public DbSet<Job> Jobs { get; set; }
}

Теперь я могу определить хранилище для фактического создания / редактирования / удаления заданий: 

 public class JobRepository : GenericRepository<Job, long>, IJobRepository
{
        private Job currentJob;
        public JobRepository(JobTrackingContext jobTrackingContext, JobTrackingSettings settings)
        : base(jobTrackingContext)
    {
        _settings = settings;
    }
        public async Task StartSync(JobType jobType, JobTriggerType jobTriggerType)
        {
            var tempJob = new Job(jobType, jobTriggerType);
            await _dbContext.Jobs.AddAsync(tempJob);
            await _dbContext.SaveChangesAsync();
        }
}

И весь этот код создается после Post-запроса к этому API: 

public async void Post()
{
    _logger.LogDebug("Going to start account sync");
    await _jobRepository.StartSync(JobType.ZRequestSync, JobTriggerType.Scheduled);
    try
    {
        await _sync.StartAsync();
        await _jobRepository.ChangeSyncStatus(JobStatusType.Finished);
    }
    catch (Exception e)
    {
        _logger.LogError(e, "Error occured during sync :(");
        await _jobRepository.ChangeSyncStatus(JobStatusType.Failed);
    }
}

Тем не менее, когда я делаю это, я получаю исключение с сообщением Reset() called on connector with state Connecting. Я не понимаю, откуда это. Когда я не использую внедренную версию, а вместо этого делаю это: 

using (var c = new JobTrackingContext())
{
    var job = new Job(jobType, jobTriggerType)
    await c.Jobs.AddAsync(job);
    await c.SaveChangesAsync();
}

Кажется, все работает нормально. Кажется, что контекст становится слишком рано. Но как я могу предотвратить это и / или что мне не хватает?

Полный стек: 

    System.ObjectDisposedException
  HResult=0x80131622
  Message=Cannot access a disposed object. A common cause of this error is disposing a context that was resolved from dependency injection and then later trying to use the same context instance elsewhere in your application. This may occur if you are calling Dispose() on the context, or wrapping the context in a using statement. If you are using dependency injection, you should let the dependency injection container take care of disposing context instances.
  Source=Microsoft.EntityFrameworkCore
  StackTrace:
   at Microsoft.EntityFrameworkCore.DbContext.CheckDisposed()
   at Microsoft.EntityFrameworkCore.DbContext.get_DbContextDependencies()
   at Microsoft.EntityFrameworkCore.DbContext.<SaveChangesAsync>d__52.MoveNext()
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter1.GetResult()
   at ZShared.JobRepository.<StartSync>d__4.MoveNext() in C:\Users\richa\Documents\Codes\Company\Product\Shared\Folder\JobRepository.cs:line 38
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at ZAccountSyncService.AccountSyncController.<Post>d__4.MoveNext() in C:\Users\richa\Documents\Code\Company\Product\SubProduct\AccountSyncController.cs:line 32
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state)
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Threading.ThreadPoolWorkQueue.Dispatch()

1 Ответ

1 голос
/ 11 марта 2019

Суть проблемы заключается в объявлении вашего AccountSyncController.Post метода. У вас есть async void Post() вместо async Task Post().

Когда задачи нет, запросу нечего ждать и он завершается до завершения вызова метода _sync.StartAsync(). С завершением запроса приходит и конец срока действия. По окончании срока службы все экземпляры с ограниченным сроком службы удаляются. Таким образом, ваш контекст удаляется до вызова метода SaveChanges. И это причина вашего исключения.

...