mirror of
https://github.com/jellyfin/jellyfin.git
synced 2024-09-07 03:48:06 +02:00
216 lines
6.8 KiB
C#
216 lines
6.8 KiB
C#
#nullable disable
|
|
|
|
#pragma warning disable CS1591
|
|
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using Jellyfin.Extensions;
|
|
using Microsoft.Data.Sqlite;
|
|
using Microsoft.Extensions.Logging;
|
|
|
|
namespace Emby.Server.Implementations.Data
|
|
{
|
|
public abstract class BaseSqliteRepository : IDisposable
|
|
{
|
|
private bool _disposed = false;
|
|
|
|
/// <summary>
|
|
/// Initializes a new instance of the <see cref="BaseSqliteRepository"/> class.
|
|
/// </summary>
|
|
/// <param name="logger">The logger.</param>
|
|
protected BaseSqliteRepository(ILogger<BaseSqliteRepository> logger)
|
|
{
|
|
Logger = logger;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Gets or sets the path to the DB file.
|
|
/// </summary>
|
|
protected string DbFilePath { get; set; }
|
|
|
|
/// <summary>
|
|
/// Gets or sets the number of write connections to create.
|
|
/// </summary>
|
|
/// <value>Path to the DB file.</value>
|
|
protected int WriteConnectionsCount { get; set; } = 1;
|
|
|
|
/// <summary>
|
|
/// Gets or sets the number of read connections to create.
|
|
/// </summary>
|
|
protected int ReadConnectionsCount { get; set; } = 1;
|
|
|
|
/// <summary>
|
|
/// Gets the logger.
|
|
/// </summary>
|
|
/// <value>The logger.</value>
|
|
protected ILogger<BaseSqliteRepository> Logger { get; }
|
|
|
|
/// <summary>
|
|
/// Gets the cache size.
|
|
/// </summary>
|
|
/// <value>The cache size or null.</value>
|
|
protected virtual int? CacheSize => null;
|
|
|
|
/// <summary>
|
|
/// Gets the locking mode. <see href="https://www.sqlite.org/pragma.html#pragma_locking_mode" />.
|
|
/// </summary>
|
|
protected virtual string LockingMode => "NORMAL";
|
|
|
|
/// <summary>
|
|
/// Gets the journal mode. <see href="https://www.sqlite.org/pragma.html#pragma_journal_mode" />.
|
|
/// </summary>
|
|
/// <value>The journal mode.</value>
|
|
protected virtual string JournalMode => "WAL";
|
|
|
|
/// <summary>
|
|
/// Gets the journal size limit. <see href="https://www.sqlite.org/pragma.html#pragma_journal_size_limit" />.
|
|
/// The default (-1) is overriden to prevent unconstrained WAL size, as reported by users.
|
|
/// </summary>
|
|
/// <value>The journal size limit.</value>
|
|
protected virtual int? JournalSizeLimit => 134_217_728; // 128MiB
|
|
|
|
/// <summary>
|
|
/// Gets the page size.
|
|
/// </summary>
|
|
/// <value>The page size or null.</value>
|
|
protected virtual int? PageSize => null;
|
|
|
|
/// <summary>
|
|
/// Gets the temp store mode.
|
|
/// </summary>
|
|
/// <value>The temp store mode.</value>
|
|
/// <see cref="TempStoreMode"/>
|
|
protected virtual TempStoreMode TempStore => TempStoreMode.Memory;
|
|
|
|
/// <summary>
|
|
/// Gets the synchronous mode.
|
|
/// </summary>
|
|
/// <value>The synchronous mode or null.</value>
|
|
/// <see cref="SynchronousMode"/>
|
|
protected virtual SynchronousMode? Synchronous => SynchronousMode.Normal;
|
|
|
|
public virtual void Initialize()
|
|
{
|
|
// Configuration and pragmas can affect VACUUM so it needs to be last.
|
|
using (var connection = GetConnection())
|
|
{
|
|
connection.Execute("VACUUM");
|
|
}
|
|
}
|
|
|
|
protected SqliteConnection GetConnection()
|
|
{
|
|
var connection = new SqliteConnection($"Filename={DbFilePath}");
|
|
connection.Open();
|
|
|
|
if (CacheSize.HasValue)
|
|
{
|
|
connection.Execute("PRAGMA cache_size=" + CacheSize.Value);
|
|
}
|
|
|
|
if (!string.IsNullOrWhiteSpace(LockingMode))
|
|
{
|
|
connection.Execute("PRAGMA locking_mode=" + LockingMode);
|
|
}
|
|
|
|
if (!string.IsNullOrWhiteSpace(JournalMode))
|
|
{
|
|
connection.Execute("PRAGMA journal_mode=" + JournalMode);
|
|
}
|
|
|
|
if (JournalSizeLimit.HasValue)
|
|
{
|
|
connection.Execute("PRAGMA journal_size_limit=" + JournalSizeLimit.Value);
|
|
}
|
|
|
|
if (Synchronous.HasValue)
|
|
{
|
|
connection.Execute("PRAGMA synchronous=" + (int)Synchronous.Value);
|
|
}
|
|
|
|
if (PageSize.HasValue)
|
|
{
|
|
connection.Execute("PRAGMA page_size=" + PageSize.Value);
|
|
}
|
|
|
|
connection.Execute("PRAGMA temp_store=" + (int)TempStore);
|
|
|
|
return connection;
|
|
}
|
|
|
|
public SqliteCommand PrepareStatement(SqliteConnection connection, string sql)
|
|
{
|
|
var command = connection.CreateCommand();
|
|
command.CommandText = sql;
|
|
return command;
|
|
}
|
|
|
|
protected bool TableExists(SqliteConnection connection, string name)
|
|
{
|
|
using var statement = PrepareStatement(connection, "select DISTINCT tbl_name from sqlite_master");
|
|
foreach (var row in statement.ExecuteQuery())
|
|
{
|
|
if (string.Equals(name, row.GetString(0), StringComparison.OrdinalIgnoreCase))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
protected List<string> GetColumnNames(SqliteConnection connection, string table)
|
|
{
|
|
var columnNames = new List<string>();
|
|
|
|
foreach (var row in connection.Query("PRAGMA table_info(" + table + ")"))
|
|
{
|
|
if (row.TryGetString(1, out var columnName))
|
|
{
|
|
columnNames.Add(columnName);
|
|
}
|
|
}
|
|
|
|
return columnNames;
|
|
}
|
|
|
|
protected void AddColumn(SqliteConnection connection, string table, string columnName, string type, List<string> existingColumnNames)
|
|
{
|
|
if (existingColumnNames.Contains(columnName, StringComparison.OrdinalIgnoreCase))
|
|
{
|
|
return;
|
|
}
|
|
|
|
connection.Execute("alter table " + table + " add column " + columnName + " " + type + " NULL");
|
|
}
|
|
|
|
protected void CheckDisposed()
|
|
{
|
|
if (_disposed)
|
|
{
|
|
throw new ObjectDisposedException(GetType().Name, "Object has been disposed and cannot be accessed.");
|
|
}
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public void Dispose()
|
|
{
|
|
Dispose(true);
|
|
GC.SuppressFinalize(this);
|
|
}
|
|
|
|
/// <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 (_disposed)
|
|
{
|
|
return;
|
|
}
|
|
|
|
_disposed = true;
|
|
}
|
|
}
|
|
}
|