aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Core/Data/BaseSqliteRepository.cs
diff options
context:
space:
mode:
Diffstat (limited to 'Emby.Server.Core/Data/BaseSqliteRepository.cs')
-rw-r--r--Emby.Server.Core/Data/BaseSqliteRepository.cs114
1 files changed, 0 insertions, 114 deletions
diff --git a/Emby.Server.Core/Data/BaseSqliteRepository.cs b/Emby.Server.Core/Data/BaseSqliteRepository.cs
deleted file mode 100644
index 8d3cbe10a..000000000
--- a/Emby.Server.Core/Data/BaseSqliteRepository.cs
+++ /dev/null
@@ -1,114 +0,0 @@
-using System;
-using System.Data;
-using System.Threading;
-using System.Threading.Tasks;
-using MediaBrowser.Model.Logging;
-
-namespace Emby.Server.Core.Data
-{
- public abstract class BaseSqliteRepository : IDisposable
- {
- protected SemaphoreSlim WriteLock = new SemaphoreSlim(1, 1);
- protected readonly IDbConnector DbConnector;
- protected ILogger Logger;
-
- protected string DbFilePath { get; set; }
-
- protected BaseSqliteRepository(ILogManager logManager, IDbConnector dbConnector)
- {
- DbConnector = dbConnector;
- Logger = logManager.GetLogger(GetType().Name);
- }
-
- protected virtual bool EnableConnectionPooling
- {
- get { return true; }
- }
-
- protected virtual async Task<IDbConnection> CreateConnection(bool isReadOnly = false)
- {
- var connection = await DbConnector.Connect(DbFilePath, false, true).ConfigureAwait(false);
-
- connection.RunQueries(new[]
- {
- "pragma temp_store = memory"
-
- }, Logger);
-
- return connection;
- }
-
- private bool _disposed;
- protected void CheckDisposed()
- {
- if (_disposed)
- {
- throw new ObjectDisposedException(GetType().Name + " has been disposed and cannot be accessed.");
- }
- }
-
- public void Dispose()
- {
- _disposed = true;
- Dispose(true);
- GC.SuppressFinalize(this);
- }
-
- protected async Task Vacuum(IDbConnection connection)
- {
- CheckDisposed();
-
- await WriteLock.WaitAsync().ConfigureAwait(false);
-
- try
- {
- using (var cmd = connection.CreateCommand())
- {
- cmd.CommandText = "vacuum";
- cmd.ExecuteNonQuery();
- }
- }
- catch (Exception e)
- {
- Logger.ErrorException("Failed to vacuum:", e);
-
- throw;
- }
- finally
- {
- WriteLock.Release();
- }
- }
-
- private readonly object _disposeLock = new object();
-
- /// <summary>
- /// Releases unmanaged and - optionally - managed resources.
- /// </summary>
- /// <param name="dispose"><c>true</c> to release both managed and unmanaged resources; <c>false</c> to release only unmanaged resources.</param>
- protected virtual void Dispose(bool dispose)
- {
- if (dispose)
- {
- try
- {
- lock (_disposeLock)
- {
- WriteLock.Wait();
-
- CloseConnection();
- }
- }
- catch (Exception ex)
- {
- Logger.ErrorException("Error disposing database", ex);
- }
- }
- }
-
- protected virtual void CloseConnection()
- {
-
- }
- }
-} \ No newline at end of file