jellyfin-server/Emby.Server.Implementations/Data/BaseSqliteRepository.cs

using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using MediaBrowser.Model.Logging;
using SQLitePCL.pretty;
using System.Linq;
using SQLitePCL;

namespace Emby.Server.Implementations.Data
{
    public abstract class BaseSqliteRepository : IDisposable
    {
        protected string DbFilePath { get; set; }
        protected SemaphoreSlim WriteLock = new SemaphoreSlim(1, 1);
        protected ILogger Logger { get; private set; }

        protected BaseSqliteRepository(ILogger logger)
        {
            Logger = logger;
        }

        protected virtual bool EnableConnectionPooling
        {
            get { return true; }
        }

        static BaseSqliteRepository()
        {
            SQLite3.EnableSharedCache = false;

            int rc = raw.sqlite3_config(raw.SQLITE_CONFIG_MEMSTATUS, 0);
            //CheckOk(rc);
        }

        protected virtual SQLiteDatabaseConnection CreateConnection(bool isReadOnly = false)
        {
            ConnectionFlags connectionFlags;

            //isReadOnly = false;

            if (isReadOnly)
            {
                connectionFlags = ConnectionFlags.ReadOnly;
                //connectionFlags = ConnectionFlags.Create;
                //connectionFlags |= ConnectionFlags.ReadWrite;
            }
            else
            {
                connectionFlags = ConnectionFlags.Create;
                connectionFlags |= ConnectionFlags.ReadWrite;
            }

            if (EnableConnectionPooling)
            {
                connectionFlags |= ConnectionFlags.SharedCached;
            }
            else
            {
                connectionFlags |= ConnectionFlags.PrivateCache;
            }

            connectionFlags |= ConnectionFlags.NoMutex;

            var db = SQLite3.Open(DbFilePath, connectionFlags, null);

            var queries = new[]
            {
                "PRAGMA page_size=4096",
                "PRAGMA journal_mode=WAL",
                "PRAGMA temp_store=memory",
                "PRAGMA synchronous=Normal",
                //"PRAGMA cache size=-10000"
                };

            //foreach (var query in queries)
            //{
            //    db.Execute(query);
            //}

            db.ExecuteAll(string.Join(";", queries));

            return db;
        }

        internal static void CheckOk(int rc)
        {
            string msg = "";

            if (raw.SQLITE_OK != rc)
            {
                throw CreateException((ErrorCode)rc, msg);
            }
        }

        internal static Exception CreateException(ErrorCode rc, string msg)
        {
            var exp = new Exception(msg);

            return exp;
        }

        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);
        }

        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()
        {

        }

        protected List<string> GetColumnNames(IDatabaseConnection connection, string table)
        {
            var list = new List<string>();

            foreach (var row in connection.Query("PRAGMA table_info(" + table + ")"))
            {
                if (row[1].SQLiteType != SQLiteType.Null)
                {
                    var name = row[1].ToString();

                    list.Add(name);
                }
            }

            return list;
        }

        protected void AddColumn(IDatabaseConnection connection, string table, string columnName, string type, List<string> existingColumnNames)
        {
            if (existingColumnNames.Contains(columnName, StringComparer.OrdinalIgnoreCase))
            {
                return;
            }

            connection.ExecuteAll(string.Join(";", new string[]
            {
                "alter table " + table,
                "add column " + columnName + " " + type + " NULL"
            }));
        }
    }
}