lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2026-02-27 16:50:33 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update Mongodb

Browse Source
This commit is contained in:
sunkaixuan
2025-05-02 15:42:18 +08:00
parent bad7a86c23
commit 54264afde5
2 changed files with 16 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
Src/Asp.NetCore2/MongoDb.Ado.data/ExecuteNonQueryItems/ExecuteHandlerFactory.cs
View File

@@ -1,4 +1,6 @@
using MongoDb.Ado.data; using MongoDb.Ado.data;
using MongoDB.Bson;
using MongoDB.Driver;
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Text; using System.Text;
@@ -17,5 +19,17 @@ namespace MongoDb.Ado.data
{ "deletemany", new DeleteManyHandler() }, { "deletemany", new DeleteManyHandler() },
{ "find", new NonFindHandler() } { "find", new NonFindHandler() }
}; };
public static int Handler(string operation, string json, IMongoCollection<BsonDocument> collection)
{
var handlers = ExecuteHandlerFactory.Items;
if (!handlers.TryGetValue(operation, out var handler))
throw new NotSupportedException($"不支持的操作类型: {operation}");
return handler.Handle(collection, json);
}
} }
} }

8
Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs
View File

@@ -58,13 +58,7 @@ namespace MongoDb.Ado.data
{ {
var (operation, collectionName, json) = ParseCommand(_commandText); var (operation, collectionName, json) = ParseCommand(_commandText);
var collection = GetCollection(collectionName); var collection = GetCollection(collectionName);
return ExecuteHandlerFactory.Handler(operation, json, collection);
var handlers = ExecuteHandlerFactory.Items;
if (!handlers.TryGetValue(operation, out var handler))
throw new NotSupportedException($"不支持的操作类型: {operation}");
return handler.Handle(collection, json);
} }
public override object ExecuteScalar() public override object ExecuteScalar()