101 lines
3.5 KiB
C#
101 lines
3.5 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using AyCode.Core.Extensions;
|
|
using AyCode.Core.Helpers;
|
|
using AyCode.Database.DbContexts;
|
|
using AyCode.Database.Extensions;
|
|
using AyCode.Entities;
|
|
using AyCode.Interfaces;
|
|
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; }
|
|
|
|
/// <summary>
|
|
/// Do not use it! Use Session or Transaction... - J.
|
|
/// </summary>
|
|
public TDbContext Context { get; private set; }
|
|
|
|
public Mutex MutextLock { get; } = new();
|
|
//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 TModelDto? GetModelDtoById<TModelDto, TEntity>(Guid id) where TModelDto : class, IAcModelDtoBase where TEntity : class, IEntity
|
|
=> Session(ctx => ctx.GetModelDtoById<TModelDto, TEntity>(id));
|
|
|
|
public Task<TModelDto?> GetModelDtoByIdAsync<TModelDto, TEntity>(Guid id) where TModelDto : class, IAcModelDtoBase where TEntity : class, IEntity
|
|
=> SessionAsync(ctx => ctx.GetModelDtoById<TModelDto, TEntity>(id));
|
|
|
|
public List<TModelDto> GetAllModelDto<TModelDto, TEntity>() where TModelDto : class, IAcModelDtoBase where TEntity : class, IEntity
|
|
=> Session(ctx => ctx.GetAllModelDto<TModelDto, TEntity>().ToList());
|
|
public Task<List<TModelDto>> GetAllModelDtoAsync<TModelDto, TEntity>() where TModelDto : class, IAcModelDtoBase where TEntity : class, IEntity
|
|
=> SessionAsync(ctx => ctx.GetAllModelDto<TModelDto, TEntity>().ToList());
|
|
|
|
|
|
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);
|
|
//}
|
|
} |