From 351a28f606e23ea54622c8f3201eb6685876d669 Mon Sep 17 00:00:00 2001 From: sunkaixuan <610262374@qq.com> Date: Thu, 1 May 2025 17:48:24 +0800 Subject: [PATCH] Update mongodb --- .../MongoDb.Ado.data/MongoDbCommand.cs | 18 +++++++++++------- 1 file changed, 11 insertions(+), 7 deletions(-) diff --git a/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs b/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs index ccc1c0e19..abc9ed4f3 100644 --- a/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs +++ b/Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs @@ -95,7 +95,7 @@ namespace MongoDb.Ado.data var update = updateCommand["update"].AsBsonDocument; var options = updateCommand.Contains("options") ? updateCommand["options"].AsBsonDocument : null; - var updateResult = collection.UpdateOne(filter, update); // 单个更新 + var updateResult = collection.UpdateMany(filter, update); // 单个更新 totals+=(int)updateResult.ModifiedCount; // 返回修改的文档数 } return documents.Count; // 返回插入成功的文档数 @@ -113,12 +113,16 @@ namespace MongoDb.Ado.data if (operation == "deletemany") { - // 处理删除多个文档操作 - var deleteCommand = BsonDocument.Parse(json); - var filter = deleteCommand["filter"].AsBsonDocument; - - var deleteResult = collection.DeleteMany(filter); // 多个删除 - return (int)deleteResult.DeletedCount; // 返回删除的文档数 + var totals = 0; + // 处理插入多条记录操作 + var documents = BsonSerializer.Deserialize>(json); // 假设 json + foreach (var updateCommand in documents) + { + var filter = updateCommand["filter"].AsBsonDocument; + var updateResult = collection.DeleteMany(filter); // 单个更新 + totals += (int)updateResult.DeletedCount; // 返回修改的文档数 + } + return documents.Count; // 返回插入成功的文档数 } if (operation == "find")