From 329fa3e5019473e6e1fe9c8a4f4b722ee50a9b0f Mon Sep 17 00:00:00 2001
From: ahmetfarukulu <ahmetfarukulu@gmail.com>
Date: Thu, 7 Mar 2024 15:07:04 +0300
Subject: [PATCH] Mongo repository SessionHandle null check added for
 DeleteDirectAsync method

---
 .../Repositories/MongoDB/MongoDbRepository.cs | 20 ++++++++++++++-----
 1 file changed, 15 insertions(+), 5 deletions(-)

diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/MongoDbRepository.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/MongoDbRepository.cs
index 443d8f89d3..45629f76e5 100644
--- a/framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/MongoDbRepository.cs
+++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/MongoDbRepository.cs
@@ -507,11 +507,21 @@ public class MongoDbRepository<TMongoDbContext, TEntity>
         var dbContext = await GetDbContextAsync(cancellationToken);
         var collection = dbContext.Collection<TEntity>();
 
-        await collection.DeleteManyAsync(
-            dbContext.SessionHandle,
-            Builders<TEntity>.Filter.Where(predicate),
-            cancellationToken: cancellationToken
-        );
+        if (dbContext.SessionHandle != null)
+        {
+            await collection.DeleteManyAsync(
+                dbContext.SessionHandle,
+                Builders<TEntity>.Filter.Where(predicate),
+                cancellationToken: cancellationToken
+            );
+        }
+        else
+        {
+            await collection.DeleteManyAsync(
+                Builders<TEntity>.Filter.Where(predicate),
+                cancellationToken: cancellationToken
+            );
+        }
     }
 
     [Obsolete("Use GetQueryableAsync method.")]