Merge pull request #9332 from abpframework/liangshiwei/repository

Added RepositoryAsyncExtensions.AnyAsync() without predicate parameter

framework/src/Volo.Abp.Ddd.Domain/Volo/Abp/Domain/Repositories/RepositoryAsyncExtensions.cs

@@ -26,6 +26,15 @@ namespace Volo.Abp.Domain.Repositories
 
         #region Any/All
 
+        public static async Task<bool> AnyAsync<T>(
+            [NotNull] this IReadOnlyRepository<T> repository,
+            CancellationToken cancellationToken = default)
+            where T : class, IEntity
+        {
+            var queryable = await repository.GetQueryableAsync();
+            return await repository.AsyncExecuter.AnyAsync(queryable, cancellationToken);
+        }
+
         public static async Task<bool> AnyAsync<T>(
             [NotNull] this IReadOnlyRepository<T> repository,
             [NotNull] Expression<Func<T, bool>> predicate,

framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/EfCoreAsyncQueryableProvider.cs

@@ -23,6 +23,11 @@ namespace Volo.Abp.EntityFrameworkCore
             return queryable.ContainsAsync(item, cancellationToken);
         }
 
+        public Task<bool> AnyAsync<T>(IQueryable<T> queryable, CancellationToken cancellationToken = default)
+        {
+            return queryable.AnyAsync(cancellationToken);
+        }
+
         public Task<bool> AnyAsync<T>(IQueryable<T> queryable, Expression<Func<T, bool>> predicate, CancellationToken cancellationToken = default)
         {
             return queryable.AnyAsync(predicate, cancellationToken);

framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/MongoDbAsyncQueryableProvider.cs

@@ -29,6 +29,11 @@ namespace Volo.Abp.MongoDB
             return Task.FromResult(GetMongoQueryable(queryable).Contains(item));
         }
 
+        public Task<bool> AnyAsync<T>(IQueryable<T> queryable, CancellationToken cancellationToken = default)
+        {
+            return GetMongoQueryable(queryable).AnyAsync(cancellationToken);
+        }
+
         public Task<bool> AnyAsync<T>(IQueryable<T> queryable, Expression<Func<T, bool>> predicate, CancellationToken cancellationToken = default)
         {
             return GetMongoQueryable(queryable).AnyAsync(predicate, cancellationToken);

framework/src/Volo.Abp.Threading/Volo/Abp/Linq/AsyncQueryableExecuter.cs

@@ -30,6 +30,14 @@ namespace Volo.Abp.Linq
                 : Task.FromResult(queryable.Contains(item));
         }
 
+        public Task<bool> AnyAsync<T>(IQueryable<T> queryable,  CancellationToken cancellationToken = default)
+        {
+            var provider = FindProvider(queryable);
+            return provider != null
+                ? provider.AnyAsync(queryable, cancellationToken)
+                : Task.FromResult(queryable.Any());
+        }
+
         public Task<bool> AnyAsync<T>(IQueryable<T> queryable, Expression<Func<T, bool>> predicate, CancellationToken cancellationToken = default)
         {
             var provider = FindProvider(queryable);

framework/src/Volo.Abp.Threading/Volo/Abp/Linq/IAsyncQueryableExecuter.cs

@@ -21,6 +21,10 @@ namespace Volo.Abp.Linq
 
         #region Any/All
 
+        Task<bool> AnyAsync<T>(
+            [NotNull] IQueryable<T> queryable,
+            CancellationToken cancellationToken = default);
+
         Task<bool> AnyAsync<T>(
             [NotNull] IQueryable<T> queryable,
             [NotNull] Expression<Func<T, bool>> predicate,

framework/src/Volo.Abp.Threading/Volo/Abp/Linq/IAsyncQueryableProvider.cs

@@ -23,6 +23,10 @@ namespace Volo.Abp.Linq
 
         #region Any/All
 
+        Task<bool> AnyAsync<T>(
+            [NotNull] IQueryable<T> queryable,
+            CancellationToken cancellationToken = default);
+
         Task<bool> AnyAsync<T>(
             [NotNull] IQueryable<T> queryable,
             [NotNull] Expression<Func<T, bool>> predicate,