Umbraco-CMS/src/Umbraco.Tests/Testing/TestDatabase.cs

using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Linq.Expressions;
using System.Threading.Tasks;
using Moq;
using NPoco;
using NPoco.DatabaseTypes;
using NPoco.Linq;
using Umbraco.Core.Persistence;
using Umbraco.Core.Persistence.SqlSyntax;

namespace Umbraco.Tests.Testing
{
    /// <summary>
    /// An implementation of <see cref="IUmbracoDatabase"/> for tests.
    /// </summary>
    /// <remarks>
    /// <para>Supports writing to the database, and logs Sql statements.</para>
    /// <para>Cannot support reading from the database, and throws.</para>
    /// <para>Tries to pretend it supports transactions, connections, etc. as best as possible.</para>
    /// </remarks>
    public class TestDatabase : IUmbracoDatabase
    {
        /// <summary>
        /// Initializes a new instance of the <see cref="TestDatabase"/> class.
        /// </summary>
        /// <remarks>
        /// <para>When both parameters are supplied, they should of course be consistent.</para>
        /// </remarks>
        public TestDatabase(DatabaseType databaseType = null, ISqlSyntaxProvider syntaxProvider = null)
        {
            DatabaseType = databaseType ?? new SqlServerCEDatabaseType();
            SqlContext = new SqlContext(syntaxProvider ?? new SqlCeSyntaxProvider(), DatabaseType, Mock.Of<IPocoDataFactory>());
        }

        /// <summary>
        /// Represents a database operation.
        /// </summary>
        public class Operation
        {
            public Operation(string text)
            {
                Text = text;
            }

            public Operation(string text, string sql)
                : this(text)
            {
                Sql = sql;
            }

            public Operation(string text, string sql, params object[] args)
                : this(text, sql)
            {
                Args = args;
            }

            /// <summary>
            /// Gets the operation text.
            /// </summary>
            public string Text { get; }

            /// <summary>
            /// Gets the operation Sql statement.
            /// </summary>
            public string Sql { get; }

            /// <summary>
            /// Gets the operation Sql arguments.
            /// </summary>
            public object[] Args { get; }
        }

        /// <summary>
        /// Gets the database operations.
        /// </summary>
        public List<Operation> Operations { get; } = new List<Operation>();

        #region Connection, Transaction and Stuff

        public void Dispose()
        { }

        public IDatabase OpenSharedConnection()
        {
            return this;
        }

        public void CloseSharedConnection()
        { }

        public int OneTimeCommandTimeout { get; set; }
        public MapperCollection Mappers { get; set; }
        public IPocoDataFactory PocoDataFactory { get; set; }
        public DatabaseType DatabaseType { get; }
        public List<IInterceptor> Interceptors { get; }
        public string ConnectionString { get; }

        public DbConnection Connection { get; }
        public DbTransaction Transaction { get; }
        public IDictionary<string, object> Data { get; }
        public ISqlContext SqlContext { get; }
        public string InstanceId { get; }
        public bool InTransaction { get; }
        public bool EnableSqlCount { get; set; }
        public int SqlCount { get; }
        public int BulkInsertRecords<T>(IEnumerable<T> records, bool useNativeBulkInsert = true) => throw new NotImplementedException();

        public DbParameter CreateParameter()
        {
            throw new NotImplementedException();
        }

        public void AddParameter(DbCommand cmd, object value)
        {
            throw new NotImplementedException();
        }

        public DbCommand CreateCommand(DbConnection connection, CommandType commandType, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public ITransaction GetTransaction()
        {
            throw new NotImplementedException();
        }

        public ITransaction GetTransaction(IsolationLevel isolationLevel)
        {
            throw new NotImplementedException();
        }

        public void SetTransaction(DbTransaction tran)
        {
            throw new NotImplementedException();
        }

        public void BeginTransaction()
        {
            Operations.Add(new Operation("BEGIN"));
        }

        public void BeginTransaction(IsolationLevel isolationLevel)
        {
            Operations.Add(new Operation("BEGIN " + isolationLevel));
        }

        public void AbortTransaction()
        {
            Operations.Add(new Operation("ABORT"));
        }

        public void CompleteTransaction()
        {
            Operations.Add(new Operation("COMMIT"));
        }

        #endregion

        #region Writes

        public int Execute(string sql, params object[] args)
        {
            Operations.Add(new Operation("EXECUTE", sql, args));
            return default;
        }

        public int Execute(Sql sql)
        {
            Operations.Add(new Operation("EXECUTE", sql.SQL, sql.Arguments));
            return default;
        }

        public int Execute(string sql, CommandType commandType, params object[] args)
        {
            Operations.Add(new Operation("EXECUTE", sql, args));
            return default;
        }

        public T ExecuteScalar<T>(string sql, params object[] args)
        {
            Operations.Add(new Operation("EXECUTE SCALAR", sql, args));
            return default;
        }

        public T ExecuteScalar<T>(Sql sql)
        {
            Operations.Add(new Operation("EXECUTE SCALAR", sql.SQL, sql.Arguments));
            return default;
        }

        public T ExecuteScalar<T>(string sql, CommandType commandType, params object[] args)
        {
            Operations.Add(new Operation("EXECUTE SCALAR", sql, args));
            return default;
        }

        public Task<T> ExecuteScalarAsync<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Task<T> ExecuteScalarAsync<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public Task<int> ExecuteAsync(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Task<int> ExecuteAsync(Sql sql)
        {
            throw new NotImplementedException();
        }

        public object Insert<T>(string tableName, string primaryKeyName, bool autoIncrement, T poco)
        {
            throw new NotImplementedException();
        }

        public object Insert<T>(string tableName, string primaryKeyName, T poco)
        {
            throw new NotImplementedException();
        }

        public object Insert<T>(T poco)
        {
            throw new NotImplementedException();
        }

        public Task<object> InsertAsync<T>(T poco)
        {
            throw new NotImplementedException();
        }

        public Task<int> InsertBatchAsync<T>(IEnumerable<T> pocos, BatchOptions options = null) => throw new NotImplementedException();

        public Task<int> UpdateAsync(object poco)
        {
            throw new NotImplementedException();
        }

        public Task<int> UpdateAsync(object poco, IEnumerable<string> columns)
        {
            throw new NotImplementedException();
        }

        public Task<int> UpdateAsync<T>(T poco, Expression<Func<T, object>> fields)
        {
            throw new NotImplementedException();
        }

        public Task<int> UpdateBatchAsync<T>(IEnumerable<UpdateBatch<T>> pocos, BatchOptions options = null) => throw new NotImplementedException();

        public Task<int> DeleteAsync(object poco)
        {
            throw new NotImplementedException();
        }

        public IAsyncUpdateQueryProvider<T> UpdateManyAsync<T>() => throw new NotImplementedException();

        public IAsyncDeleteQueryProvider<T> DeleteManyAsync<T>() => throw new NotImplementedException();

        public void InsertBulk<T>(IEnumerable<T> pocos)
        {
            throw new NotImplementedException();
        }

        int IDatabase.InsertBatch<T>(IEnumerable<T> pocos, BatchOptions options) => throw new NotImplementedException();

        public void InsertBatch<T>(IEnumerable<T> pocos, BatchOptions options = null)
        {
            throw new NotImplementedException();
        }

        public int Update(string tableName, string primaryKeyName, object poco, object primaryKeyValue)
        {
            throw new NotImplementedException();
        }

        public int Update(string tableName, string primaryKeyName, object poco)
        {
            throw new NotImplementedException();
        }

        public int Update(string tableName, string primaryKeyName, object poco, object primaryKeyValue, IEnumerable<string> columns)
        {
            throw new NotImplementedException();
        }

        public int Update(string tableName, string primaryKeyName, object poco, IEnumerable<string> columns)
        {
            throw new NotImplementedException();
        }

        public int Update(object poco, IEnumerable<string> columns)
        {
            throw new NotImplementedException();
        }

        public int Update(object poco, object primaryKeyValue, IEnumerable<string> columns)
        {
            throw new NotImplementedException();
        }

        public int Update(object poco)
        {
            throw new NotImplementedException();
        }

        public int Update<T>(T poco, Expression<Func<T, object>> fields)
        {
            throw new NotImplementedException();
        }

        public int Update(object poco, object primaryKeyValue)
        {
            throw new NotImplementedException();
        }

        public int Update<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public int Update<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public int UpdateBatch<T>(IEnumerable<UpdateBatch<T>> pocos, BatchOptions options = null) => throw new NotImplementedException();

        public IUpdateQueryProvider<T> UpdateMany<T>()
        {
            throw new NotImplementedException();
        }

        public int Delete(string tableName, string primaryKeyName, object poco)
        {
            throw new NotImplementedException();
        }

        public int Delete(string tableName, string primaryKeyName, object poco, object primaryKeyValue)
        {
            throw new NotImplementedException();
        }

        public int Delete(object poco)
        {
            throw new NotImplementedException();
        }

        public int Delete<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public int Delete<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public int Delete<T>(object pocoOrPrimaryKey)
        {
            throw new NotImplementedException();
        }

        public IDeleteQueryProvider<T> DeleteMany<T>()
        {
            throw new NotImplementedException();
        }

        public void Save<T>(T poco)
        {
            throw new NotImplementedException();
        }

        public bool IsNew<T>(T poco)
        {
            throw new NotImplementedException();
        }

        #endregion

        #region Reads (not implemented)

        public List<object> Fetch(Type type, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public List<object> Fetch(Type type, Sql Sql)
        {
            throw new NotImplementedException();
        }

        public IEnumerable<object> Query(Type type, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public IEnumerable<object> Query(Type type, Sql Sql)
        {
            throw new NotImplementedException();
        }

        public List<T> Fetch<T>()
        {
            throw new NotImplementedException();
        }

        public List<T> Fetch<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public List<T> Fetch<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public List<T> Fetch<T>(long page, long itemsPerPage, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public List<T> Fetch<T>(long page, long itemsPerPage, Sql sql)
        {
            throw new NotImplementedException();
        }

        public Page<T> Page<T>(long page, long itemsPerPage, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Page<T> Page<T>(long page, long itemsPerPage, Sql sql)
        {
            throw new NotImplementedException();
        }

        public List<T> SkipTake<T>(long skip, long take, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public List<T> SkipTake<T>(long skip, long take, Sql sql)
        {
            throw new NotImplementedException();
        }

        public List<T> FetchOneToMany<T>(Expression<Func<T, IList>> many, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public List<T> FetchOneToMany<T>(Expression<Func<T, IList>> many, Sql sql)
        {
            throw new NotImplementedException();
        }

        public List<T> FetchOneToMany<T>(Expression<Func<T, IList>> many, Func<T, object> idFunc, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public List<T> FetchOneToMany<T>(Expression<Func<T, IList>> many, Func<T, object> idFunc, Sql sql)
        {
            throw new NotImplementedException();
        }

        public IEnumerable<T> Query<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public IEnumerable<T> Query<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public IQueryProviderWithIncludes<T> Query<T>()
        {
            throw new NotImplementedException();
        }

        public T SingleById<T>(object primaryKey)
        {
            throw new NotImplementedException();
        }

        public T Single<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public T SingleInto<T>(T instance, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public T SingleOrDefaultById<T>(object primaryKey)
        {
            throw new NotImplementedException();
        }

        public T SingleOrDefault<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public T SingleOrDefaultInto<T>(T instance, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public T First<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public T FirstInto<T>(T instance, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public T FirstOrDefault<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public T FirstOrDefaultInto<T>(T instance, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public T Single<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public T SingleInto<T>(T instance, Sql sql)
        {
            throw new NotImplementedException();
        }

        public T SingleOrDefault<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public T SingleOrDefaultInto<T>(T instance, Sql sql)
        {
            throw new NotImplementedException();
        }

        public T First<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public T FirstInto<T>(T instance, Sql sql)
        {
            throw new NotImplementedException();
        }

        public T FirstOrDefault<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public T FirstOrDefaultInto<T>(T instance, Sql sql)
        {
            throw new NotImplementedException();
        }

        public Dictionary<TKey, TValue> Dictionary<TKey, TValue>(Sql Sql)
        {
            throw new NotImplementedException();
        }

        public Dictionary<TKey, TValue> Dictionary<TKey, TValue>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public bool Exists<T>(object primaryKey)
        {
            throw new NotImplementedException();
        }

        public TRet FetchMultiple<T1, T2, TRet>(Func<List<T1>, List<T2>, TRet> cb, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public TRet FetchMultiple<T1, T2, T3, TRet>(Func<List<T1>, List<T2>, List<T3>, TRet> cb, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public TRet FetchMultiple<T1, T2, T3, T4, TRet>(Func<List<T1>, List<T2>, List<T3>, List<T4>, TRet> cb, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public TRet FetchMultiple<T1, T2, TRet>(Func<List<T1>, List<T2>, TRet> cb, Sql sql)
        {
            throw new NotImplementedException();
        }

        public TRet FetchMultiple<T1, T2, T3, TRet>(Func<List<T1>, List<T2>, List<T3>, TRet> cb, Sql sql)
        {
            throw new NotImplementedException();
        }

        public TRet FetchMultiple<T1, T2, T3, T4, TRet>(Func<List<T1>, List<T2>, List<T3>, List<T4>, TRet> cb, Sql sql)
        {
            throw new NotImplementedException();
        }

        public Tuple<List<T1>, List<T2>> FetchMultiple<T1, T2>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Tuple<List<T1>, List<T2>, List<T3>> FetchMultiple<T1, T2, T3>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Tuple<List<T1>, List<T2>, List<T3>, List<T4>> FetchMultiple<T1, T2, T3, T4>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Tuple<List<T1>, List<T2>> FetchMultiple<T1, T2>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public Tuple<List<T1>, List<T2>, List<T3>> FetchMultiple<T1, T2, T3>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public Tuple<List<T1>, List<T2>, List<T3>, List<T4>> FetchMultiple<T1, T2, T3, T4>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public Task<T> SingleAsync<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Task<T> SingleAsync<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public Task<T> SingleOrDefaultAsync<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Task<T> SingleOrDefaultAsync<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public Task<T> SingleByIdAsync<T>(object primaryKey)
        {
            throw new NotImplementedException();
        }

        public Task<T> SingleOrDefaultByIdAsync<T>(object primaryKey)
        {
            throw new NotImplementedException();
        }

        public Task<T> FirstAsync<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Task<T> FirstAsync<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public Task<T> FirstOrDefaultAsync<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Task<T> FirstOrDefaultAsync<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public Task<IEnumerable<T>> QueryAsync<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Task<IEnumerable<T>> QueryAsync<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public IAsyncQueryProviderWithIncludes<T> QueryAsync<T>() => throw new NotImplementedException();

        public Task<List<T>> FetchAsync<T>(string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Task<List<T>> FetchAsync<T>(Sql sql)
        {
            throw new NotImplementedException();
        }

        public Task<List<T>> FetchAsync<T>()
        {
            throw new NotImplementedException();
        }

        public Task<Page<T>> PageAsync<T>(long page, long itemsPerPage, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Task<Page<T>> PageAsync<T>(long page, long itemsPerPage, Sql sql)
        {
            throw new NotImplementedException();
        }

        public Task<List<T>> FetchAsync<T>(long page, long itemsPerPage, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Task<List<T>> FetchAsync<T>(long page, long itemsPerPage, Sql sql)
        {
            throw new NotImplementedException();
        }

        public Task<List<T>> SkipTakeAsync<T>(long skip, long take, string sql, params object[] args)
        {
            throw new NotImplementedException();
        }

        public Task<List<T>> SkipTakeAsync<T>(long skip, long take, Sql sql)
        {
            throw new NotImplementedException();
        }

        #endregion

        #region Stuff

        public void BuildPageQueries<T>(long skip, long take, string sql, ref object[] args, out string sqlCount, out string sqlPage)
        {
            throw new NotImplementedException();
        }

        #endregion
    }
}