Csla.Data.EFCore.Shared/DbContextManager.cs

Go to the documentation of this file.

//-----------------------------------------------------------------------
// <copyright file="DbContextManager.cs" company="Marimer LLC">
//     Copyright (c) Marimer LLC. All rights reserved.
//     Website: https://cslanet.com
// </copyright>
// <summary>Provides an automated way to reuse </summary>
//-----------------------------------------------------------------------
using System;
using Microsoft.EntityFrameworkCore;
 
namespace Csla.Data.EntityFrameworkCore
{
  [Obsolete("Use dependency injection instead", false)]
  public class DbContextManager<C> : IDisposable where C : DbContext
  {
    private static object _lock = new object();
    private C _context;
    private string _label;
    private string _contextLabel;
 
 
    public static DbContextManager<C> GetManager()
    {
      return GetManager(string.Empty);
    }
 
    public static DbContextManager<C> GetManager(string database)
    {
      return GetManager(database, "default");
    }
 
    public static DbContextManager<C> GetManager(string database, string label)
    {
      DbContextManager<C> mgr = null;
      var contextLabel = GetContextName(database, label);
      lock (_lock)
      {
        if (ApplicationContext.LocalContext.Contains(contextLabel))
        {
          mgr = (DbContextManager<C>)(ApplicationContext.LocalContext[contextLabel]);
          mgr.AddRef();
        }
      }
 
      if (mgr == null)
      {
        mgr = new DbContextManager<C>(database, label);
        lock (_lock)
        {
          Csla.
          ApplicationContext.LocalContext[contextLabel] = mgr;
          mgr.AddRef();
        }
      }
      return mgr;
    }
 
    private DbContextManager(string database, string label)
    {
      _contextLabel = GetContextName(database, label);
      _label = label;
      if (string.IsNullOrEmpty(database))
        _context = (C)(Activator.CreateInstance(typeof(C)));
      else
        _context = (C)(Activator.CreateInstance(typeof(C), database));
    }
 
    private static string GetContextName(string database, string label)
    {
      return "__dbctx:" + label + "-" + database;
    }
 
 
    public C DbContext
    {
      get { return _context; }
    }
 
    private int _refCount;
 
    public int RefCount
    {
      get { return _refCount; }
    }
 
    private void AddRef()
    {
      _refCount += 1;
    }
 
    private void DeRef()
    {
      lock (_lock)
      {
        _refCount -= 1;
        if (_refCount == 0)
        {
          _context.Dispose();
          ApplicationContext.LocalContext.Remove(_contextLabel);
        }
      }
    }
 
    public void Dispose()
    {
      Dispose(true);
      GC.SuppressFinalize(this);
    }
 
    protected virtual void Dispose(bool p)
    {
      DeRef();
    }
  }
}