ToSingleWithNoLockAsync predicate added

Author: enisgurkann

EnLock/EnExtention.cs

@@ -86,7 +86,7 @@ public static async Task<T> ToFirstOrDefaultWithNoLockAsync<T>(this IQueryable<T
             }
             return result;
         }
-        public static async Task<T> ToFirstWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
+        public static async Task<T> ToFirstWithNoLockAsync<T>(this IQueryable<T> query,Expression<Func<T, bool>> predicate,  CancellationToken cancellationToken = default)
         {
             T result = default;
             using (var scope = new TransactionScope(TransactionScopeOption.Required,
@@ -95,6 +95,21 @@ public static async Task<T> ToFirstWithNoLockAsync<T>(this IQueryable<T> query,
                                         IsolationLevel = System.Transactions.IsolationLevel.ReadUncommitted
                                     },
                                     TransactionScopeAsyncFlowOption.Enabled))
+            {
+                result = await query.FirstAsync(predicate,cancellationToken);
+                scope.Complete();
+            }
+            return result;
+        }
+        public static async Task<T> ToFirstWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
+        {
+            T result = default;
+            using (var scope = new TransactionScope(TransactionScopeOption.Required,
+                       new TransactionOptions()
+                       {
+                           IsolationLevel = System.Transactions.IsolationLevel.ReadUncommitted
+                       },
+                       TransactionScopeAsyncFlowOption.Enabled))
             {
                 result = await query.FirstAsync(cancellationToken);
                 scope.Complete();
@@ -116,5 +131,21 @@ public static async Task<T> ToSingleWithNoLockAsync<T>(this IQueryable<T> query,
             }
             return result;
         }
+        
+        public static async Task<T> ToSingleWithNoLockAsync<T>(this IQueryable<T> query, Expression<Func<T, bool>> predicate, CancellationToken cancellationToken = default)
+        {
+            T result = default;
+            using (var scope = new TransactionScope(TransactionScopeOption.Required,
+                       new TransactionOptions()
+                       {
+                           IsolationLevel = System.Transactions.IsolationLevel.ReadUncommitted
+                       },
+                       TransactionScopeAsyncFlowOption.Enabled))
+            {
+                result = await query.SingleAsync(predicate,cancellationToken);
+                scope.Complete();
+            }
+            return result;
+        }
     }
 }

EnLock/EnLock.csproj

@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <TargetFramework>netstandard2.0</TargetFramework>
-    <Nullable>enable</Nullable>
+    <Nullable>disable</Nullable>
     <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
     <PackageId>ENLOCK</PackageId>
     <Title>ENLOCK</Title>
@@ -18,7 +18,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Microsoft.EntityFrameworkCore" Version="3.0.1" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore" Version="2.2.6" />
   </ItemGroup>
 
 </Project>