Update mongodb

Src/Asp.NetCore2/MongoDb.Ado.data/Common/MongoDbMethodUtils.cs

@@ -1,4 +1,5 @@
-using System;
+using MongoDb.Ado.Data.Common;
+using System;
 using System.Collections.Generic;
 using System.Text;
 using System.Threading.Tasks;
@@ -6,7 +7,41 @@ using System.Threading.Tasks;
 namespace MongoDb.Ado.data
 {
     public class MongoDbMethodUtils
-    { 
+    {
+        public static MongoParsedCommand ParseMongoCommand(string command)
+        {
+            if (string.IsNullOrWhiteSpace(command))
+                throw new ArgumentException("command is null or empty");
+
+            // 去掉前后空格与结尾分号
+            command = command.Trim().TrimEnd(';');
+
+            // 确保以 db. 开头
+            if (!command.StartsWith("db."))
+                throw new FormatException("Invalid command format. Must start with db.");
+
+            int dotIndex = command.IndexOf('.', 3); // 找 collection 之后的点
+            int parenIndex = command.IndexOf('(', dotIndex);
+            int braceIndex = command.IndexOf('{', parenIndex);
+
+            if (dotIndex == -1 || parenIndex == -1 || braceIndex == -1)
+                throw new FormatException("Command format not recognized.");
+
+            string collectionName = command.Substring(3, dotIndex - 3).Trim();
+            string operation = command.Substring(dotIndex + 1, parenIndex - dotIndex - 1).Trim();
+
+            string jsonPart = command.Substring(parenIndex + 1).Trim();
+            if (jsonPart.EndsWith(")"))
+                jsonPart = jsonPart.Substring(0, jsonPart.Length - 1);
+
+            return new MongoParsedCommand
+            {
+                CollectionName = collectionName,
+                Operation = operation,
+                Json = jsonPart
+            };
+        }
+
         public static void ValidateOperation(string operation)
         {
             if (ExecuteHandlerFactory.Items.TryGetValue(operation, out var handler))

Src/Asp.NetCore2/MongoDb.Ado.data/Common/MongoParsedCommand.cs

@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace MongoDb.Ado.Data.Common
+{
+    public class MongoParsedCommand
+    {
+        public string CollectionName { get; set; }
+        public string Operation { get; set; }
+        public string Json { get; set; }
+    }
+}
+
+

Src/Asp.NetCore2/MongoDb.Ado.data/MongoDbCommand.cs

@@ -120,6 +120,12 @@ namespace MongoDb.Ado.data
             if (string.IsNullOrWhiteSpace(cmd))
                 throw new InvalidOperationException("CommandText 不能为空。");
 
+            if (cmd.Trim().StartsWith("db.", StringComparison.OrdinalIgnoreCase)) 
+            {
+               var cmdInfo= MongoDbMethodUtils.ParseMongoCommand(cmd);
+                return (cmdInfo.Operation,cmdInfo.CollectionName,cmdInfo.Json);
+            }
+
             var parts = cmd.Trim().Split(new[] { ' ' }, 3, StringSplitOptions.RemoveEmptyEntries);
             if (parts.Length < 2)
                 throw new InvalidOperationException("命令格式错误，应为：操作 集合名 JSON过滤");

Src/Asp.NetCore2/MongoDbTest/UnitTest/Insert.cs

@@ -35,6 +35,16 @@ namespace MongoDbTest
             var data = new Student() { Age = 1, Name = "11", SchoolId = "111", CreateDateTime = DateTime.Now };
             db.Insertable(data).ExecuteCommandIdentityIntoEntity();
             Console.WriteLine(data.Id);//Get _id by ExecuteCommandIdentityIntoEntity
+
+            db.Ado.ExecuteCommand(@"db.UnitStudent1ddsfhssds3z1.insertMany([
+              {
+                Name: ""adfas"",
+                SchoolId: ""s"",
+                Age: 11,
+                CreateDateTime: ISODate(""2025-07-02T10:07:23.799Z"")
+              }])");
+            var list4=db.Queryable<Student>().Where(it => it.Name == "adfas").ToList();
+            if(list4.Count!=1) Cases.ThrowUnitError();
         }
         [SqlSugar.SugarTable("UnitStudent1ddsfhssds3z1")]
         public class Student : MongoDbBase