use individual connections

1 files changed, 14 insertions, 2 deletions

diff --git a/MediaBrowser.Server.Implementations/Persistence/BaseSqliteRepository.cs b/MediaBrowser.Server.Implementations/Persistence/BaseSqliteRepository.cs
index 395907844..f9c892b76 100644
--- a/MediaBrowser.Server.Implementations/Persistence/BaseSqliteRepository.cs
+++ b/MediaBrowser.Server.Implementations/Persistence/BaseSqliteRepository.cs
@@ -9,13 +9,22 @@ namespace MediaBrowser.Server.Implementations.Persistence
     public abstract class BaseSqliteRepository : IDisposable
     {
         protected readonly SemaphoreSlim WriteLock = new SemaphoreSlim(1, 1);
+        protected readonly IDbConnector DbConnector;
         protected ILogger Logger;
 
-        protected BaseSqliteRepository(ILogManager logManager)
+        protected string DbFilePath { get; set; }
+
+        protected BaseSqliteRepository(ILogManager logManager, IDbConnector dbConnector)
         {
+            DbConnector = dbConnector;
             Logger = logManager.GetLogger(GetType().Name);
         }
 
+        protected Task<IDbConnection> CreateConnection(bool isReadOnly = false)
+        {
+            return DbConnector.Connect(DbFilePath, false, true);
+        }
+
         private bool _disposed;
         protected void CheckDisposed()
         {
@@ -84,6 +93,9 @@ namespace MediaBrowser.Server.Implementations.Persistence
             }
         }
 
-        protected abstract void CloseConnection();
+        protected virtual void CloseConnection()
+        {
+            
+        }
     }
 }