From bf1b72cd644711ef9995cc1720dff6a39fdd3e12 Mon Sep 17 00:00:00 2001
From: sunkaixuan <610262374@qq.com>
Date: Wed, 25 Jun 2025 14:33:11 +0800
Subject: [PATCH] Update mongodb demo

---
 Src/Asp.NetCore2/MongoDbTest/AdoTest.cs       |  1 -
 .../MongoDbTest/DBHelper/DbHelper.cs          |  2 +-
 .../MongoDbTest/OrmTest/OrmTest.cs            |  3 +-
 .../MongoDbTest/UnitTest/Cases.cs             |  3 +-
 .../MongoDbTest/UnitTest/Delete.cs            |  2 +-
 .../MongoDbTest/UnitTest/Insert.cs            |  2 +-
 .../MongoDbTest/UnitTest/InsertOrUpdate.cs    |  2 +-
 .../MongoDbTest/UnitTest/QueryJson.cs         |  2 +-
 .../MongoDbTest/UnitTest/QueryJsonArray.cs    |  2 +-
 .../MongoDbTest/UnitTest/QueryLeftJoin.cs     | 50 +++++++++++++++++++
 .../MongoDbTest/UnitTest/QuerySelect.cs       |  5 +-
 .../MongoDbTest/UnitTest/QuerySingle.cs       |  2 +-
 .../MongoDbTest/UnitTest/QueryWhere.cs        |  2 +-
 .../MongoDbTest/UnitTest/Update.cs            |  2 +-
 14 files changed, 64 insertions(+), 16 deletions(-)
 create mode 100644 Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryLeftJoin.cs

diff --git a/Src/Asp.NetCore2/MongoDbTest/AdoTest.cs b/Src/Asp.NetCore2/MongoDbTest/AdoTest.cs
index 2ce35e069..f76abc721 100644
--- a/Src/Asp.NetCore2/MongoDbTest/AdoTest.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/AdoTest.cs
@@ -1,7 +1,6 @@
 using MongoDb.Ado.data;
 using MongoDB.Bson;
 using MongoDB.Driver;
-using MongoDbTest.DBHelper;
 using System;
 using System.Collections.Generic;
 using System.Data;
diff --git a/Src/Asp.NetCore2/MongoDbTest/DBHelper/DbHelper.cs b/Src/Asp.NetCore2/MongoDbTest/DBHelper/DbHelper.cs
index e96e0dbd3..faef6637b 100644
--- a/Src/Asp.NetCore2/MongoDbTest/DBHelper/DbHelper.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/DBHelper/DbHelper.cs
@@ -5,7 +5,7 @@ using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 
-namespace MongoDbTest.DBHelper
+namespace MongoDbTest 
 {
     /// <summary>
     /// Helper class for database operations
diff --git a/Src/Asp.NetCore2/MongoDbTest/OrmTest/OrmTest.cs b/Src/Asp.NetCore2/MongoDbTest/OrmTest/OrmTest.cs
index d41f1974e..8df9f6905 100644
--- a/Src/Asp.NetCore2/MongoDbTest/OrmTest/OrmTest.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/OrmTest/OrmTest.cs
@@ -1,5 +1,4 @@
-using MongoDbTest.DBHelper;
-using SqlSugar;
+using SqlSugar;
 using System;
 using System.Collections.Generic;
 using System.Data;
diff --git a/Src/Asp.NetCore2/MongoDbTest/UnitTest/Cases.cs b/Src/Asp.NetCore2/MongoDbTest/UnitTest/Cases.cs
index 51de962a0..4d55a5c2e 100644
--- a/Src/Asp.NetCore2/MongoDbTest/UnitTest/Cases.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/UnitTest/Cases.cs
@@ -14,7 +14,8 @@ namespace MongoDbTest
             QuerySingle.Init();
             QueryWhere.Init();
             QuerySelect.Init();
-            QueryJson.Init(); 
+            QueryJson.Init();
+            QueryLeftJoin.Init();
             QueryJsonArray.Init();
             Insert.Init();
             Update.Init();
diff --git a/Src/Asp.NetCore2/MongoDbTest/UnitTest/Delete.cs b/Src/Asp.NetCore2/MongoDbTest/UnitTest/Delete.cs
index 9e0e9c330..67f2073be 100644
--- a/Src/Asp.NetCore2/MongoDbTest/UnitTest/Delete.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/UnitTest/Delete.cs
@@ -11,7 +11,7 @@ namespace MongoDbTest
     {
         internal static void Init()
         {
-            var db = DBHelper.DbHelper.GetNewDb();
+            var db = DbHelper.GetNewDb();
             db.CodeFirst.InitTables<Student>();
             db.DbMaintenance.TruncateTable<Student>();
             var id=db.Insertable(new Student() { Age = 1, Name = "11", SchoolId = "111", CreateDateTime = DateTime.Now.AddDays(1) }).ExecuteReturnPkList<string>();
diff --git a/Src/Asp.NetCore2/MongoDbTest/UnitTest/Insert.cs b/Src/Asp.NetCore2/MongoDbTest/UnitTest/Insert.cs
index 65814a3c4..c13f461eb 100644
--- a/Src/Asp.NetCore2/MongoDbTest/UnitTest/Insert.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/UnitTest/Insert.cs
@@ -12,7 +12,7 @@ namespace MongoDbTest
     {
         internal static void Init()
         {
-            var db = DBHelper.DbHelper.GetNewDb();
+            var db = DbHelper.GetNewDb();
             db.CodeFirst.InitTables<Student>();
             db.DbMaintenance.TruncateTable<Student>();
 
diff --git a/Src/Asp.NetCore2/MongoDbTest/UnitTest/InsertOrUpdate.cs b/Src/Asp.NetCore2/MongoDbTest/UnitTest/InsertOrUpdate.cs
index fdbef910e..181e5a3a8 100644
--- a/Src/Asp.NetCore2/MongoDbTest/UnitTest/InsertOrUpdate.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/UnitTest/InsertOrUpdate.cs
@@ -13,7 +13,7 @@ namespace MongoDbTest
     {
         internal static void Init()
         {
-            var db = DBHelper.DbHelper.GetNewDb();
+            var db = DbHelper.GetNewDb();
             db.CodeFirst.InitTables<Student>();
             db.DbMaintenance.TruncateTable<Student>();
             db.Storageable(new Student() { Name = "a", SchoolId = "1", CreateDateTime = DateTime.Now })
diff --git a/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryJson.cs b/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryJson.cs
index eec63b64b..38d8d9574 100644
--- a/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryJson.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryJson.cs
@@ -11,7 +11,7 @@ namespace MongoDbTest
     {
         internal static void Init()
         {
-            var db = DBHelper.DbHelper.GetNewDb();
+            var db =  DbHelper.GetNewDb();
             db.CodeFirst.InitTables<Student>();
             db.DbMaintenance.TruncateTable<Student>();
             db.Insertable(new Book() { Price = 1, CreateTime = DateTime.Now }).ExecuteCommand();
diff --git a/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryJsonArray.cs b/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryJsonArray.cs
index 64893d97f..acfe6b5ac 100644
--- a/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryJsonArray.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryJsonArray.cs
@@ -11,7 +11,7 @@ namespace MongoDbTest
     {
         internal static void Init()
         {
-            var db = DBHelper.DbHelper.GetNewDb();
+            var db = DbHelper.GetNewDb();
             db.CodeFirst.InitTables<Student>();
             db.DbMaintenance.TruncateTable<Student>();
             db.Insertable(new Student() { Age = 1, Name = "tom", SchoolId = "a", Book = new List<Book>() { new Book() { CreateTime = DateTime.Now, Price = 21 } } }).ExecuteCommand();
diff --git a/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryLeftJoin.cs b/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryLeftJoin.cs
new file mode 100644
index 000000000..c2429190a
--- /dev/null
+++ b/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryLeftJoin.cs
@@ -0,0 +1,50 @@
+using MongoDB.Bson;
+using SqlSugar.MongoDb;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MongoDbTest 
+{
+    internal class QueryLeftJoin
+    {
+        internal static void Init()
+        {
+            var db = DbHelper.GetNewDb();
+            db.DbMaintenance.TruncateTable<School, School>(); 
+            // 添加学校数据
+            var school = new School { Name = "TestSchool" };
+            var ids=db.Insertable(school).ExecuteReturnPkList<string>(); 
+            // 添加学生数据，SchoolId 关联学校
+            var student = new Student { Name = "TestStudent", SchoolId = ids.Last() }; 
+            db.Insertable(student).ExecuteCommand();
+            // 添加学生数据，SchoolId 关联学校并且没有学校
+            var student2 = new Student { Name = "TestStudent", SchoolId =
+               ObjectId.GenerateNewId().ToString()
+            }; 
+            db.Insertable(student2).ExecuteCommand();
+
+            //var list=db.Queryable<Student>()
+            //    .LeftJoin<School>((x, y) => x.SchoolId == y.Id)
+            //    .Where((x,y)=>x.Name =="a"||y.Name=="a")
+            //    .Select(x => new
+            //    {
+            //        id=x.Name
+            //    }).ToList();
+        }
+        [SqlSugar.SugarTable("UnitStudent123131")]
+        public class Student : MongoDbBase
+        {
+            public string Name { get; set; }
+
+            public string SchoolId { get; set; }
+        }
+        [SqlSugar.SugarTable("UnitSchool123131")]
+        public class School : MongoDbBase
+        {
+            public string Name { get; set; }
+        }
+    }
+}
diff --git a/Src/Asp.NetCore2/MongoDbTest/UnitTest/QuerySelect.cs b/Src/Asp.NetCore2/MongoDbTest/UnitTest/QuerySelect.cs
index b5a819f2a..0dcda77d4 100644
--- a/Src/Asp.NetCore2/MongoDbTest/UnitTest/QuerySelect.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/UnitTest/QuerySelect.cs
@@ -1,7 +1,6 @@
 using MongoDB.Bson;
 using MongoDB.Driver;
-using MongoDB.Driver.Linq;
-using MongoDbTest.DBHelper;
+using MongoDB.Driver.Linq; 
 using SqlSugar;
 using SqlSugar.MongoDb;
 using System;
@@ -16,7 +15,7 @@ namespace MongoDbTest
     {
         internal static void Init()
         { 
-            var db = DBHelper.DbHelper.GetNewDb();
+            var db =DbHelper.GetNewDb();
             db.CodeFirst.InitTables<Student>();
             db.DbMaintenance.TruncateTable<Student>();
             var dt = DateTime.Now;
diff --git a/Src/Asp.NetCore2/MongoDbTest/UnitTest/QuerySingle.cs b/Src/Asp.NetCore2/MongoDbTest/UnitTest/QuerySingle.cs
index 479e5bebf..fb2872780 100644
--- a/Src/Asp.NetCore2/MongoDbTest/UnitTest/QuerySingle.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/UnitTest/QuerySingle.cs
@@ -13,7 +13,7 @@ namespace MongoDbTest
     {
         public static void Init() 
         {
-            var db = DBHelper.DbHelper.GetNewDb();
+            var db = DbHelper.GetNewDb();
 
             db.CodeFirst.InitTables<Student>();
             db.CodeFirst.InitTables<School>();
diff --git a/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryWhere.cs b/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryWhere.cs
index 348dfd2e2..e239fcaca 100644
--- a/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryWhere.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryWhere.cs
@@ -13,7 +13,7 @@ namespace MongoDbTest
         public static void Init()
         {
             //创建DB
-            var db = DBHelper.DbHelper.GetNewDb();
+            var db = DbHelper.GetNewDb();
 
             //初始化数据
             InitializeStudentData(db);
diff --git a/Src/Asp.NetCore2/MongoDbTest/UnitTest/Update.cs b/Src/Asp.NetCore2/MongoDbTest/UnitTest/Update.cs
index 3969868cc..fa8102729 100644
--- a/Src/Asp.NetCore2/MongoDbTest/UnitTest/Update.cs
+++ b/Src/Asp.NetCore2/MongoDbTest/UnitTest/Update.cs
@@ -11,7 +11,7 @@ namespace MongoDbTest
     {
         internal static void Init()
         {
-            var db = DBHelper.DbHelper.GetNewDb();
+            var db = DbHelper.GetNewDb();
             db.CodeFirst.InitTables<Student>();
             db.DbMaintenance.TruncateTable<Student>();
             db.Insertable(new Student() { Age = 1, Name = "11", SchoolId = "111", CreateDateTime = DateTime.Now }).ExecuteCommandAsync().GetAwaiter().GetResult();