AyCode.Core/AyCode.Database/DataLayers/AcDalBase.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using AyCode.Core.Helpers;
using AyCode.Database.DbContexts;
using AyCode.Database.Extensions;
using AyCode.Interfaces.Entities;
using AyCode.Utils.Extensions;
using Microsoft.EntityFrameworkCore;

namespace AyCode.Database.DataLayers;

public abstract class AcDalBase<TDbContext> : IAcDalBase<TDbContext> where TDbContext : AcDbContextBase
{
    public string Name { get; private set; }

    public bool AutoCloseSession { get; set; }

    public TDbContext Context { get; private set; }

    //protected AcDalBase()
    //{
    //    Name = $"{GetType().Name}";
    //}

    protected AcDalBase() : this(Activator.CreateInstance<TDbContext>())
    { }

    protected AcDalBase(TDbContext ctx)
    {
        Context = ctx;

        if (Context.Name.IsNullOrWhiteSpace())
            Context.Name = Context.GetType().Name;

        Name = $"{GetType().Name}, {Context.Name}";
    }

    public TDbContext CreateDbContext()
    {
        return Activator.CreateInstance<TDbContext>();
    }

    public void CloseDbContext(ref TDbContext? ctx)
    {
        ctx?.Dispose();
        ctx = null;
    }

    public Task<TResultType> SessionAsync<TResultType>(Func<TDbContext, TResultType> callback)
        => this.SessionAsync<TDbContext, TResultType>(callback);

    public Task<IEnumerable<TEntity>> SessionAsync<TEntity>(Func<TDbContext, IQueryable<TEntity>> callback) where TEntity : IEntity
        => this.SessionAsync<TDbContext, TEntity>(callback);

    public TResultType Session<TResultType>(Func<TDbContext, TResultType> callback)
        => this.Session<TDbContext, TResultType>(callback);

    public IEnumerable<TEntity> Session<TEntity>(Func<TDbContext, IQueryable<TEntity>> callback) where TEntity : IEntity
        => this.Session<TDbContext, TEntity>(callback);

    public Task<bool> TransactionAsync(Func<TDbContext, bool> callbackTransactionBody, bool throwException = false)
        => this.TransactionAsync<TDbContext>(callbackTransactionBody, throwException);

    public bool Transaction(Func<TDbContext, bool> callbackTransactionBody, bool throwException = false)
        => this.Transaction<TDbContext>(callbackTransactionBody, throwException);

    public override string ToString()
    {
        return Name;
    }

    //public void Dispose()
    //{
    //    Ctx?.Dispose();
    //    Ctx = null;

    //    //CloseDbContext(ref Ctx);
    //}
}