SqlServerIntCrud.cs

using AO.Models.Enums;
using AO.Models.Interfaces;
using Dapper.CX.Abstract;
using Dapper.CX.Classes;
using System;
using System.Data;
using System.Linq.Expressions;
using System.Threading.Tasks;

namespace Dapper.CX.SqlServer.Extensions.Int
{
    public static partial class SqlServerIntCrud
    {
        private static SqlCrudProvider<int> GetProvider() => new SqlServerCrudProvider<int>(id => Convert.ToInt32(id));

        public static async Task<TModel> GetAsync<TModel>(this IDbConnection connection, int id, IDbTransaction txn = null, IUserBase user = null)
        {
            return await GetProvider().GetAsync<TModel>(connection, id, txn, user);
        }

        public static async Task<TModel> GetWhereAsync<TModel>(this IDbConnection connection, object criteria, IDbTransaction txn = null, IUserBase user = null)
        {
            return await GetProvider().GetWhereAsync<TModel>(connection, criteria, txn, user);
        }

        public static async Task<TModel> GetWhereAsync<TModel>(this IDbConnection connection, IUserBase user, params Expression<Func<TModel, bool>>[] criteria)
        {
            return await GetProvider().GetWhereAsync(connection, user, criteria);
        }

        public static async Task<TModel> GetWhereAsync<TModel>(this IDbConnection connection, IDbTransaction txn, params Expression<Func<TModel, bool>>[] criteria)
        {
            return await GetProvider().GetWhereAsync(connection, txn, criteria);
        }

        public static async Task<TModel> GetWhereAsync<TModel>(this IDbConnection connection, IUserBase user, IDbTransaction txn, params Expression<Func<TModel, bool>>[] criteria)
        {
            return await GetProvider().GetWhereAsync(connection, user, txn, criteria);
        }

        public static async Task<TModel> GetWhereAsync<TModel>(this IDbConnection connection, params Expression<Func<TModel, bool>>[] criteria)
        {
            return await GetProvider().GetWhereAsync(connection, criteria);
        }

        public static async Task<TModel> GetWhereAsync<TModel>(this IDbConnection connection, Expression<Func<TModel, bool>>[] criteria, IUserBase user = null, IDbTransaction txn = null)
        {
            return await GetProvider().GetWhereAsync(connection, criteria, user, txn);
        }

        public static async Task<int> InsertAsync<TModel>(this IDbConnection connection, TModel model, bool getIdentity = true, IDbTransaction txn = null, IUserBase user = null)
        {
            return await GetProvider().InsertAsync(connection, model, getIdentity, txn, user);
        }

        public static async Task UpdateAsync<TModel>(this IDbConnection connection, TModel model, ChangeTracker<TModel> changeTracker = null, IDbTransaction txn = null, IUserBase user = null)
        {
            await GetProvider().UpdateAsync(connection, model, changeTracker, txn);
        }

        public static async Task DeleteAsync<TModel>(this IDbConnection connection, int id, IDbTransaction txn = null, IUserBase user = null)
        {
            await GetProvider().DeleteAsync<TModel>(connection, id, txn, user);
        }

        public static async Task<int> SaveAsync<TModel>(this IDbConnection connection, TModel model, ChangeTracker<TModel> changeTracker = null, IDbTransaction txn = null, IUserBase user = null, Action<SaveAction, TModel> onSave = null)
        {
            return await GetProvider().SaveAsync(connection, model, changeTracker, txn, user, onSave);
        }

        public static async Task<int> MergeAsync<TModel>(this IDbConnection connection, TModel model, ChangeTracker<TModel> changeTracker = null, IDbTransaction txn = null, IUserBase user = null, Action<SaveAction, TModel> onSave = null)
        {
            return await GetProvider().MergeAsync(connection, model, changeTracker, txn, user, onSave);
        }

        public static async Task<bool> ExistsAsync<TModel>(this IDbConnection connection, int id)
        {
            return await GetProvider().ExistsAsync<TModel>(connection, id);
        }

        public static async Task<bool> ExistsWhereAsync<TModel>(this IDbConnection connection, object criteria, IDbTransaction txn = null)
        {
            return await GetProvider().ExistsWhereAsync<TModel>(connection, criteria, txn);
        }
    }
}