- ActiveDatabaseContext

Author: eben-roux

Shuttle.Core.Data.Tests/DatabaseContextCacheFixture.cs

@@ -0,0 +1,39 @@
+using System.Data;
+using Moq;
+using NUnit.Framework;
+
+namespace Shuttle.Core.Data.Tests
+{
+    public class DatabaseContextCacheFixture : Fixture
+    {
+        [Test]
+        public void Should_be_able_to_use_different_contexts()
+        {
+            var cache = new DatabaseContextCache();
+
+            DatabaseContext.Assign(cache);
+
+            var context1 = new DatabaseContext("mock-1", new Mock<IDbConnection>().Object, new Mock<IDbCommandFactory>().Object).WithName("mock-1");
+
+            Assert.That(cache.Current.Key, Is.EqualTo(context1.Key));
+
+            var context2 = new DatabaseContext("mock-2", new Mock<IDbConnection>().Object, new Mock<IDbCommandFactory>().Object).WithName("mock-2");
+
+            Assert.That(cache.Current.Key, Is.EqualTo(context2.Key));
+
+            using (cache.Use("mock-1"))
+            {
+                Assert.That(cache.Current.Key, Is.EqualTo(context1.Key));
+            }
+
+            Assert.That(cache.Current.Key, Is.EqualTo(context2.Key));
+
+            using (cache.Use(context1))
+            {
+                Assert.That(cache.Current.Key, Is.EqualTo(context1.Key));
+            }
+
+            Assert.That(cache.Current.Key, Is.EqualTo(context2.Key));
+        }
+    }
+}

Shuttle.Core.Data/.build/package.nuspec

@@ -28,7 +28,7 @@
         <dependency id="Shuttle.Core.Logging" version="{Shuttle.Core.Logging-version}" />
       </group>
 
-      <group targetFramework="netcoreapp2.0">
+      <group targetFramework="netcoreapp2.1">
         <dependency id="System.Configuration.ConfigurationManager" version="{System.Configuration.ConfigurationManager-version}" />
         <dependency id="Shuttle.Core.Configuration" version="{Shuttle.Core.Configuration-version}" />
         <dependency id="Shuttle.Core.Container" version="{Shuttle.Core.Container-version}" />

Shuttle.Core.Data/ActiveDatabaseContext.cs

@@ -0,0 +1,29 @@
+using System;
+using Shuttle.Core.Contract;
+
+namespace Shuttle.Core.Data
+{
+    public class ActiveDatabaseContext : IDisposable
+    {
+        private readonly IDatabaseContextCache _databaseContextCache;
+        private readonly IDatabaseContext _current;
+
+        public ActiveDatabaseContext(IDatabaseContextCache databaseContextCache, IDatabaseContext current)
+        {
+            Guard.AgainstNull(databaseContextCache, nameof(databaseContextCache));
+
+            _databaseContextCache = databaseContextCache;
+            _current = current;
+        }
+
+        public void Dispose()
+        {
+            if (_current == null)
+            {
+                return;
+            }
+
+            _databaseContextCache.Use(_current);
+        }
+    }
+}