From 9cc2c3ee0dc6637423367e3d3f9c87b70f5ec007 Mon Sep 17 00:00:00 2001
From: sunkaixuan <610262374@qq.com>
Date: Fri, 2 May 2025 15:34:15 +0800
Subject: [PATCH] Update mongodb

---
 .../ExecuteScalarHandler.cs                   | 21 ++++++++-----------
 1 file changed, 9 insertions(+), 12 deletions(-)

diff --git a/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteScalarItems/ExecuteScalarHandler.cs b/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteScalarItems/ExecuteScalarHandler.cs
index b89820337..8a28d5aab 100644
--- a/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteScalarItems/ExecuteScalarHandler.cs
+++ b/Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteScalarItems/ExecuteScalarHandler.cs
@@ -9,19 +9,16 @@ namespace MongoDb.Ado.data
 {
     public class ExecuteScalarHandler
     {
-        public object Handle(IMongoCollection<BsonDocument> collection, string json)
+        public object Handle(string operation, IMongoCollection<BsonDocument> collection, string json)
         {
-            var filter = string.IsNullOrWhiteSpace(json) ? FilterDefinition<BsonDocument>.Empty : BsonDocument.Parse(json);
-            // 执行查询并限制返回一条记录
-            var document = collection.Find(filter).FirstOrDefault();
-
-            // 如果查询到结果且文档非空，则获取第一个字段的值
-            if (document != null && document.Elements.Any())
+            using (var dbReader = new DbDataReaderFactory().Handle(operation, collection, json))
             {
-                var firstElement = document.Elements.First();  // 获取第一个字段（列）
-                return firstElement.Value;  // 返回该字段的值
-            } 
-            return null; //  
-        } 
+                if (dbReader.Read())
+                {
+                   return dbReader.GetValue(0);
+                } 
+                return null; //  
+            }
+        }
     }
 }