From dccd6b95544b2947acfa590dac50a8ddc956f57d Mon Sep 17 00:00:00 2001
From: Tanvir Ahmad Arjel <tanvirarjel@outlook.com>
Date: Fri, 12 Nov 2021 23:16:20 +0600
Subject: [PATCH] v5.8.0 has been released.

1. EF Core 6.0 support has been added.
2. ExistsByIdAsync method has been added.
---
 .../Controllers/EmployeeController.cs         |  1 +
 ...anvirArjel.EFCore.GenericRepository.csproj |  5 ++-
 .../Extensions/SqlQueryExtensions.cs          |  4 +-
 .../IQueryRepository.cs                       | 11 +++++
 .../QueryRepository.cs                        | 41 +++++++++++++++++++
 .../TanvirArjel.EFCore.QueryRepository.csproj |  7 ++--
 6 files changed, 62 insertions(+), 7 deletions(-)

diff --git a/demo/AspNetCore5.0/Controllers/EmployeeController.cs b/demo/AspNetCore5.0/Controllers/EmployeeController.cs
index 1009061..af1fb16 100644
--- a/demo/AspNetCore5.0/Controllers/EmployeeController.cs
+++ b/demo/AspNetCore5.0/Controllers/EmployeeController.cs
@@ -52,6 +52,7 @@ public async Task<IActionResult> Details(long? id)
                 return NotFound();
             }
             Employee employee = await _repository.GetByIdAsync<Employee>(id);
+            bool isExistent = await _repository.ExistsByIdAsync<Employee>(id);
             if (employee == null)
             {
                 return NotFound();
diff --git a/src/TanvirArjel.EFCore.GenericRepository/TanvirArjel.EFCore.GenericRepository.csproj b/src/TanvirArjel.EFCore.GenericRepository/TanvirArjel.EFCore.GenericRepository.csproj
index bd7399b..3830b34 100644
--- a/src/TanvirArjel.EFCore.GenericRepository/TanvirArjel.EFCore.GenericRepository.csproj
+++ b/src/TanvirArjel.EFCore.GenericRepository/TanvirArjel.EFCore.GenericRepository.csproj
@@ -44,8 +44,9 @@
 		<PackageTags>EFCore, RepositoryLayer, GenericRepository, UnitOfWork, .NET, .NETCore, ASP.NETCore</PackageTags>
 		<PackageReleaseNotes>
 			1. EF Core 6.0 support has been added.
+			2. ExistsByIdAsync method has been added.
 		</PackageReleaseNotes>
-		<Version>5.7.0</Version>
+		<Version>5.8.0</Version>
 		<PackageLicenseFile>LICENSE</PackageLicenseFile>
 		<PackageIcon>icon.png</PackageIcon>
 		<Authors>TanvirArjel</Authors>
@@ -74,7 +75,7 @@
 	</ItemGroup>
 
 	<ItemGroup Condition="'$(TargetFramework)' == 'net6.0'">
-		<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="6.0.0-*" />
+		<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="6.0.*" />
 	</ItemGroup>
 
 	<ItemGroup Condition="'$(TargetFramework)' == 'net5.0'">
diff --git a/src/TanvirArjel.EFCore.QueryRepository/Extensions/SqlQueryExtensions.cs b/src/TanvirArjel.EFCore.QueryRepository/Extensions/SqlQueryExtensions.cs
index 0b3ea85..f501e51 100644
--- a/src/TanvirArjel.EFCore.QueryRepository/Extensions/SqlQueryExtensions.cs
+++ b/src/TanvirArjel.EFCore.QueryRepository/Extensions/SqlQueryExtensions.cs
@@ -58,7 +58,7 @@ public static async Task<List<T>> GetFromQueryAsync<T>(
 
             List<T> list = new List<T>();
             T obj = default;
-            while (result.Read())
+            while (await result.ReadAsync(cancellationToken))
             {
                 if (!(typeof(T).IsPrimitive || typeof(T).Equals(typeof(string))))
                 {
@@ -94,7 +94,7 @@ private static async Task<List<T>> GetFromQueryAsync2<T>(
 
             List<T> list = new List<T>();
             T t = default;
-            while (dr.Read())
+            while (await dr.ReadAsync(cancellationToken))
             {
                 if (!(typeof(T).IsPrimitive || typeof(T).Equals(typeof(string))))
                 {
diff --git a/src/TanvirArjel.EFCore.QueryRepository/IQueryRepository.cs b/src/TanvirArjel.EFCore.QueryRepository/IQueryRepository.cs
index af650a1..75db97d 100644
--- a/src/TanvirArjel.EFCore.QueryRepository/IQueryRepository.cs
+++ b/src/TanvirArjel.EFCore.QueryRepository/IQueryRepository.cs
@@ -441,6 +441,17 @@ Task<bool> ExistsAsync<TEntity>(CancellationToken cancellationToken = default)
         Task<bool> ExistsAsync<TEntity>(Expression<Func<TEntity, bool>> condition, CancellationToken cancellationToken = default)
             where TEntity : class;
 
+        /// <summary>
+        /// This method takes primary key value of the entity whose existence be determined
+        /// and returns <see cref="Task"/> of <see cref="bool"/>.
+        /// </summary>
+        /// <typeparam name="TEntity">The type of the entity.</typeparam>
+        /// <param name="id">The primary key value of the entity whose the existence will checked.</param>
+        /// <param name="cancellationToken"> A <see cref="CancellationToken"/> to observe while waiting for the task to complete.</param>
+        /// <returns>Returns <see cref="bool"/>.</returns>
+        Task<bool> ExistsByIdAsync<TEntity>(object id, CancellationToken cancellationToken = default)
+            where TEntity : class;
+
         /// <summary>
         /// This method returns all count in <see cref="int"/> type.
         /// </summary>
diff --git a/src/TanvirArjel.EFCore.QueryRepository/QueryRepository.cs b/src/TanvirArjel.EFCore.QueryRepository/QueryRepository.cs
index ada70fb..5e910bb 100644
--- a/src/TanvirArjel.EFCore.QueryRepository/QueryRepository.cs
+++ b/src/TanvirArjel.EFCore.QueryRepository/QueryRepository.cs
@@ -529,6 +529,47 @@ public async Task<bool> ExistsAsync<T>(Expression<Func<T, bool>> condition, Canc
             return isExists;
         }
 
+        public async Task<bool> ExistsByIdAsync<T>(object id, CancellationToken cancellationToken = default)
+           where T : class
+        {
+            if (id == null)
+            {
+                throw new ArgumentNullException(nameof(id));
+            }
+
+            IEntityType entityType = _dbContext.Model.FindEntityType(typeof(T));
+
+            string primaryKeyName = entityType.FindPrimaryKey().Properties.Select(p => p.Name).FirstOrDefault();
+            Type primaryKeyType = entityType.FindPrimaryKey().Properties.Select(p => p.ClrType).FirstOrDefault();
+
+            if (primaryKeyName == null || primaryKeyType == null)
+            {
+                throw new ArgumentException("Entity does not have any primary key defined", nameof(id));
+            }
+
+            object primayKeyValue = null;
+
+            try
+            {
+                primayKeyValue = Convert.ChangeType(id, primaryKeyType, CultureInfo.InvariantCulture);
+            }
+            catch (Exception)
+            {
+                throw new ArgumentException($"You can not assign a value of type {id.GetType()} to a property of type {primaryKeyType}");
+            }
+
+            ParameterExpression pe = Expression.Parameter(typeof(T), "entity");
+            MemberExpression me = Expression.Property(pe, primaryKeyName);
+            ConstantExpression constant = Expression.Constant(primayKeyValue, primaryKeyType);
+            BinaryExpression body = Expression.Equal(me, constant);
+            Expression<Func<T, bool>> expressionTree = Expression.Lambda<Func<T, bool>>(body, new[] { pe });
+
+            IQueryable<T> query = _dbContext.Set<T>();
+
+            bool isExistent = await query.AnyAsync(expressionTree, cancellationToken).ConfigureAwait(false);
+            return isExistent;
+        }
+
         public async Task<int> GetCountAsync<T>(CancellationToken cancellationToken = default)
             where T : class
         {
diff --git a/src/TanvirArjel.EFCore.QueryRepository/TanvirArjel.EFCore.QueryRepository.csproj b/src/TanvirArjel.EFCore.QueryRepository/TanvirArjel.EFCore.QueryRepository.csproj
index 4e9382d..056bd76 100644
--- a/src/TanvirArjel.EFCore.QueryRepository/TanvirArjel.EFCore.QueryRepository.csproj
+++ b/src/TanvirArjel.EFCore.QueryRepository/TanvirArjel.EFCore.QueryRepository.csproj
@@ -39,9 +39,10 @@
 		<RepositoryType>Git</RepositoryType>
 		<PackageTags>EFCore, RepositoryLayer, GenericRepository, QueryRepository, .NET, .NETCore, ASP.NETCore</PackageTags>
 		<PackageReleaseNotes>
-			1. This is the initial release of the library.
+			1. EF Core 6.0 support has been added.
+			2. ExistsByIdAsync method has been added.
 		</PackageReleaseNotes>
-		<Version>1.0.0</Version>
+		<Version>1.1.0</Version>
 		<PackageLicenseFile>LICENSE</PackageLicenseFile>
 		<PackageIcon>icon.png</PackageIcon>
 		<Authors>TanvirArjel</Authors>
@@ -70,7 +71,7 @@
 	</ItemGroup>
 
 	<ItemGroup Condition="'$(TargetFramework)' == 'net6.0'">
-		<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="6.0.0-*" />
+		<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="6.0.*" />
 	</ItemGroup>
 
 	<ItemGroup Condition="'$(TargetFramework)' == 'net5.0'">