diff --git a/framework/src/Volo.Abp.Ddd.Domain/Volo/Abp/Domain/Repositories/RepositoryAsyncExtensions.cs b/framework/src/Volo.Abp.Ddd.Domain/Volo/Abp/Domain/Repositories/RepositoryAsyncExtensions.cs index 7cddb753c9..f6191a152f 100644 --- a/framework/src/Volo.Abp.Ddd.Domain/Volo/Abp/Domain/Repositories/RepositoryAsyncExtensions.cs +++ b/framework/src/Volo.Abp.Ddd.Domain/Volo/Abp/Domain/Repositories/RepositoryAsyncExtensions.cs @@ -1,5 +1,5 @@ using System; -using System.Linq; +using System.Collections.Generic; using System.Linq.Expressions; using System.Threading; using System.Threading.Tasks; @@ -10,6 +10,41 @@ namespace Volo.Abp.Domain.Repositories { public static class RepositoryAsyncExtensions { + #region Contains + + public static Task ContainsAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] T item, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.ContainsAsync(repository, item, cancellationToken); + } + + #endregion + + #region Any/All + + public static Task AnyAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> predicate, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.AnyAsync(repository, predicate, cancellationToken); + } + + public static Task AllAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> predicate, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.AllAsync(repository, predicate, cancellationToken); + } + + #endregion + #region Count/LongCount public static Task CountAsync( @@ -17,10 +52,7 @@ namespace Volo.Abp.Domain.Repositories CancellationToken cancellationToken = default) where T : class, IEntity { - return repository.AsyncExecuter.CountAsync( - repository, - cancellationToken - ); + return repository.AsyncExecuter.CountAsync(repository, cancellationToken); } public static Task CountAsync( @@ -29,11 +61,379 @@ namespace Volo.Abp.Domain.Repositories CancellationToken cancellationToken = default) where T : class, IEntity { - return repository.AsyncExecuter.CountAsync( - repository, - predicate, - cancellationToken - ); + return repository.AsyncExecuter.CountAsync(repository, predicate, cancellationToken); + } + + public static Task LongCountAsync( + [NotNull] this IReadOnlyRepository repository, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.LongCountAsync(repository, cancellationToken); + } + + public static Task LongCountAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> predicate, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.LongCountAsync(repository, predicate, cancellationToken); + } + + #endregion + + #region First/FirstOrDefault + + public static Task FirstAsync( + [NotNull] this IReadOnlyRepository repository, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.FirstAsync(repository, cancellationToken); + } + + public static Task FirstAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> predicate, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.FirstAsync(repository, predicate, cancellationToken); + } + + public static Task FirstOrDefaultAsync( + [NotNull] this IReadOnlyRepository repository, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.FirstOrDefaultAsync(repository, cancellationToken); + } + + public static Task FirstOrDefaultAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> predicate, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.FirstOrDefaultAsync(repository, predicate, cancellationToken); + } + + #endregion + + #region Last/LastOrDefault + + public static Task LastAsync( + [NotNull] this IReadOnlyRepository repository, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.LastAsync(repository, cancellationToken); + } + + public static Task LastAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> predicate, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.LastAsync(repository, predicate, cancellationToken); + } + + public static Task LastOrDefaultAsync( + [NotNull] this IReadOnlyRepository repository, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.LastOrDefaultAsync(repository, cancellationToken); + } + + public static Task LastOrDefaultAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> predicate, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.LastOrDefaultAsync(repository, predicate, cancellationToken); + } + + #endregion + + #region Single/SingleOrDefault + + public static Task SingleAsync( + [NotNull] this IReadOnlyRepository repository, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SingleAsync(repository, cancellationToken); + } + + public static Task SingleAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> predicate, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SingleAsync(repository, predicate, cancellationToken); + } + + public static Task SingleOrDefaultAsync( + [NotNull] this IReadOnlyRepository repository, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SingleOrDefaultAsync(repository, cancellationToken); + } + + public static Task SingleOrDefaultAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> predicate, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SingleOrDefaultAsync(repository, predicate, cancellationToken); + } + + #endregion + + #region Min + + public static Task MinAsync( + [NotNull] this IReadOnlyRepository repository, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.MinAsync(repository, cancellationToken); + } + + public static Task MinAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.MinAsync(repository, selector, cancellationToken); + } + + #endregion + + #region Max + + public static Task MaxAsync( + [NotNull] this IReadOnlyRepository repository, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.MaxAsync(repository, cancellationToken); + } + + public static Task MaxAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.MaxAsync(repository, selector, cancellationToken); + } + + #endregion + + #region Sum + + public static Task SumAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SumAsync(repository, selector, cancellationToken); + } + + public static Task SumAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SumAsync(repository, selector, cancellationToken); + } + + public static Task SumAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SumAsync(repository, selector, cancellationToken); + } + + public static Task SumAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SumAsync(repository, selector, cancellationToken); + } + + public static Task SumAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SumAsync(repository, selector, cancellationToken); + } + + public static Task SumAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SumAsync(repository, selector, cancellationToken); + } + + public static Task SumAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SumAsync(repository, selector, cancellationToken); + } + + public static Task SumAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SumAsync(repository, selector, cancellationToken); + } + + public static Task SumAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SumAsync(repository, selector, cancellationToken); + } + + public static Task SumAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.SumAsync(repository, selector, cancellationToken); + } + + #endregion + + #region Average + + public static Task AverageAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.AverageAsync(repository, selector, cancellationToken); + } + + public static Task AverageAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.AverageAsync(repository, selector, cancellationToken); + } + + public static Task AverageAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.AverageAsync(repository, selector, cancellationToken); + } + + public static Task AverageAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.AverageAsync(repository, selector, cancellationToken); + } + + public static Task AverageAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.AverageAsync(repository, selector, cancellationToken); + } + + public static Task AverageAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.AverageAsync(repository, selector, cancellationToken); + } + + public static Task AverageAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.AverageAsync(repository, selector, cancellationToken); + } + + public static Task AverageAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.AverageAsync(repository, selector, cancellationToken); + } + + public static Task AverageAsync( + [NotNull] this IReadOnlyRepository repository, + [NotNull] Expression> selector, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.AverageAsync(repository, selector, cancellationToken); + } + + #endregion + + #region ToList/Array + + public static Task> ToListAsync( + [NotNull] this IReadOnlyRepository repository, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.ToListAsync(repository, cancellationToken); + } + + public static Task ToArrayAsync( + [NotNull] this IReadOnlyRepository repository, + CancellationToken cancellationToken = default) + where T : class, IEntity + { + return repository.AsyncExecuter.ToArrayAsync(repository, cancellationToken); } #endregion