From 08116a9254a32c20f58956c147277a60ba7a889c Mon Sep 17 00:00:00 2001
From: sunkaixuan <610262374@qq.com>
Date: Sun, 4 May 2025 21:33:52 +0800
Subject: [PATCH] Update Mongodb

---
 .../MongoDb.Ado.data/MongoDb.Ado.data.csproj             | 1 +
 Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs      | 9 +++++----
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDb.Ado.data.csproj b/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDb.Ado.data.csproj
index 340978a1c..064ad98cf 100644
--- a/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDb.Ado.data.csproj
+++ b/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDb.Ado.data.csproj
@@ -6,6 +6,7 @@
 
   <ItemGroup>
     <PackageReference Include="MongoDB.Driver" Version="3.3.0" />
+    <PackageReference Include="System.Data.Common" Version="4.3.0" />
   </ItemGroup>
 
 </Project>
diff --git a/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs b/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs
index bc4a784b6..f5fc3a2d6 100644
--- a/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs
+++ b/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs
@@ -8,6 +8,7 @@ using MongoDB.Bson.Serialization;
 using System.Collections.Generic;
 using System.Xml.Linq;
 using System.Threading.Tasks;
+using System.Threading;
 
 namespace MongoDb.Ado.data
 {
@@ -78,25 +79,25 @@ namespace MongoDb.Ado.data
             return new DbDataReaderFactory().Handle(operation, collection, json);
         }
 
-        public new Task<int> ExecuteNonQueryAsync()
+        public override Task<int> ExecuteNonQueryAsync(CancellationToken cancellationToken)
         {
             var (operation, collectionName, json) = ParseCommand(_commandText);
             var collection = GetCollection(collectionName);
             return ExecuteHandlerFactoryAsync.HandlerAsync(operation, json, collection);
         }
-        public new Task<object> ExecuteScalarAsync()
+        public override Task<object> ExecuteScalarAsync(CancellationToken cancellationToken)
         {
             var (operation, collectionName, json) = ParseCommand(_commandText);
             var collection = GetCollection(collectionName);
             return new ExecuteScalarHandlerAsync().HandleAsync(operation, collection, json);
         }
-        public new Task<DbDataReader> ExecuteReaderAsync()
+        public override Task<DbDataReader> ExecuteReaderAsync(CancellationToken cancellationToken)
         {
             var (operation, collectionName, json) = ParseCommand(_commandText);
             var collection = GetCollection(collectionName);
             return new DbDataReaderFactoryAsync().HandleAsync(operation, collection, json);
         }
-        protected  Task<DbDataReader> ExecuteDbDataReaderAsync(CommandBehavior behavior)
+        protected override  Task<DbDataReader> ExecuteDbDataReaderAsync(CommandBehavior behavior,CancellationToken cancellationToken)
         {
             return ExecuteReaderAsync();
         }