Elephant.Database 0.3.2

About

Contains various EF Core related database helpers.

DbSetExtensions

Clear(): Remove all entities from that DbSet.

GenericCrud

Task<List<TEntity>> All(CancellationToken cancellationToken);

// Example usage: await myRepository.All(1, QueryTrackingBehavior.NoTracking, CancellationToken.None, x => x.CustomersCrossOrders, x => x.CustomersCrossAddresses);
Task<List<TEntity>> All(QueryTrackingBehavior queryTrackingBehavior = QueryTrackingBehavior.TrackAll, CancellationToken cancellationToken = default, params Expression<Func<TEntity, object>>[] includes);

Task<TEntity?> ById(object id, CancellationToken cancellationToken);

Task<int> Count(CancellationToken cancellationToken);

Task<int> Count(Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken);

void Delete(object id);

Task<ResponseWrapper<int>> DeleteAndSave(object id, CancellationToken cancellationToken);

Task<bool> HasAny(CancellationToken cancellationToken);

Task<bool> HasAny(Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken);

Task Insert(TEntity obj, CancellationToken cancellationToken);

Task Insert(ICollection<TEntity> objects, CancellationToken cancellationToken);

Task<ResponseWrapper<int>> InsertAndSave(TEntity obj, CancellationToken cancellationToken);

Task<ResponseWrapper<int>> Save(CancellationToken cancellationToken);

void Update(TEntity obj);

void Update(ICollection<TEntity> objects);

Task<ResponseWrapper<int>> UpdateAndSave(TEntity obj, CancellationToken cancellationToken);

Task DeleteAllAndResetAutoIncrement(CancellationToken cancellationToken = default, string schema = "dbo");

// Transactions:

Task<IDbContextTransaction> BeginTransactionAsync(CancellationToken cancellationToken);

Task CommitTransactionAsyncAndDispose(IDbContextTransaction? transaction, CancellationToken cancellationToken);

Task RollbackTransactionAsyncAndDispose(IDbContextTransaction? transaction, CancellationToken cancellationToken);

Example IContext transaction implementation

// Usings
using Elephant.Database;
using Microsoft.AspNetCore.Identity.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Storage;

// Inside your DbContext or IdentityDbContext class:

/// <inheritdoc/>
public async Task<IDbContextTransaction> BeginTransaction(CancellationToken cancellationToken)
{
	return await Database.BeginTransactionAsync(cancellationToken);
}

/// <inheritdoc/>
public async Task CommitTransactionAndDispose(IDbContextTransaction? transaction, CancellationToken cancellationToken)
{
	if (transaction == null)
		return;

	await Database.CommitTransactionAsync(cancellationToken);
	await transaction.DisposeAsync();
}

/// <inheritdoc/>
public async Task RollbackTransactionAndDispose(IDbContextTransaction? transaction, CancellationToken cancellationToken)
{
	if (transaction == null)
		return;

	await Database.RollbackTransactionAsync(cancellationToken);
	await transaction.DisposeAsync();
}

Example transaction in your service

using (IDbContextTransaction transaction = await _customerRepository.BeginTransaction(cancellationToken))
{
    try
    {
        // Your code here.
    }
    catch (Exception exception)
    {
        _logger.LogError($"An error occurred. Rolling back changes. Exception: {exception}".);
        await _customerRepository.RollbackTransactionAndDispose(transaction, cancellationToken);
        return;
    }

    // Perform CRUD actions or whatever.
	await _customerRepository.Save(cancellationToken);
	await _customerRepository.CommitTransactionAndDispose(transaction, cancellationToken);
}

QueryableExtensions

IQueryable<T> AsTracking<T>(this IQueryable<T> source, bool isTracked) { .. }

IQueryable<T> OrderByColumn<T>(this IQueryable<T> source, string columnName, ListSortDirection sortDirection = ListSortDirection.Ascending) { .. }

IQueryable<T> OrderByColumn<T>(this IQueryable<T> source, string columnName, bool isAscending = true) { .. }