Csla.Data.SqlClient.Fx/ConnectionManager.cs

Go to the documentation of this file.

//-----------------------------------------------------------------------
// <copyright file="ConnectionManager.cs" company="Marimer LLC">
//     Copyright (c) Marimer LLC. All rights reserved.
//     Website: https://cslanet.com
// </copyright>
// <summary>Provides an automated way to reuse open</summary>
//-----------------------------------------------------------------------
using System;
using Csla.Configuration;
using System.Data;
#if NETFX
using System.Data.SqlClient;
#else
using Microsoft.Data.SqlClient;
#endif
using Csla.Properties;
 
namespace Csla.Data.SqlClient
{
  [Obsolete("Use dependency injection instead", false)]
  public class ConnectionManager : IDisposable
  {
    private static readonly object _lock = new object();
    private readonly string _connectionString;
    private readonly string _label;
 
    public static ConnectionManager GetManager(string database)
    {
      return GetManager(database, true);
    }
 
    public static ConnectionManager GetManager(string database, string label)
    {
      return GetManager(database, true, label);
    }
 
    public static ConnectionManager GetManager(string database, bool isDatabaseName)
    {
      return GetManager(database, isDatabaseName, "default");
    }
 
    public static ConnectionManager GetManager(string database, bool isDatabaseName, string label)
    {
      if (isDatabaseName)
      {
        var connection = ConfigurationManager.ConnectionStrings[database];
        if (connection == null)
          throw new ConfigurationErrorsException(String.Format(Resources.DatabaseNameNotFound, database));
 
        var conn = ConfigurationManager.ConnectionStrings[database].ConnectionString;
        if (string.IsNullOrEmpty(conn))
          throw new ConfigurationErrorsException(String.Format(Resources.DatabaseNameNotFound, database));
        database = conn;
      }
 
      ConnectionManager mgr = null;
      var ctxName = GetContextName(database, label);
      lock (_lock)
      {
        var cached = ApplicationContext.LocalContext.GetValueOrNull(ctxName);
        if (cached != null)
        {
          mgr = (ConnectionManager)cached;
          mgr.AddRef();
        }
      }
 
      if (mgr == null)
      {
        mgr = new ConnectionManager(database, label);
        lock (_lock)
        {
          ApplicationContext.LocalContext[ctxName] = mgr;
          mgr.AddRef();
        }
      }
      return mgr;
    }
 
    private ConnectionManager(string connectionString, string label)
    {
      _label = label;
      _connectionString = connectionString;
 
      Connection = new SqlConnection(connectionString);
      Connection.Open();
    }
 
    private static string GetContextName(string connectionString, string label)
    {
      return "__db:" + label + "-" + connectionString;
    }
 
    public IDbConnection Connection { get; }
 
    public int RefCount { get; private set; }
 
    private void AddRef()
    {
      RefCount += 1;
    }
 
    private void DeRef()
    {
      RefCount -= 1;
      if (RefCount == 0)
      {
        Connection.Close();
        Connection.Dispose();
        lock (_lock)
          ApplicationContext.LocalContext.Remove(GetContextName(_connectionString, _label));
      }
    }
 
    public void Dispose()
    {
      Dispose(true);
      GC.SuppressFinalize(this);
    }
 
    protected virtual void Dispose(bool p)
    {
      DeRef();
    }
  }
}