lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-09-22 20:13:41 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update mongodb

Browse Source
This commit is contained in:
sunkaixuan
2025-06-27 18:58:08 +08:00
parent 7c8129e4c1
commit efd2df5e18
2 changed files with 40 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
Src/Asp.NetCore2/MongoDbTest/UnitTest/QueryLeftJoin.cs
View File

@@ -58,11 +58,11 @@ namespace MongoDbTest
]");
//var list = db.Queryable<Student>()
// .LeftJoin<School>((x, y) => x.SchoolId == y.Id)
// .Select((x,y) => new
// .LeftJoin<School>((x, y) => x.SchoolId == y.Id)
// .Select((x, y) => new
// {
// StudentName= x.Name,
// SchoolName= y.Name
// StudentName = x.Name,
// SchoolName = y.Name
// }).ToList();
}
[SqlSugar.SugarTable("UnitStudent123131")]

46
Src/Asp.NetCore2/SqlSugar.MongoDbCore/ExpToSql/VisitorItems/FieldPathExtractor.cs
View File

@@ -1,9 +1,11 @@
using MongoDB.Bson;
using Dm;
using MongoDB.Bson;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Security.Cryptography.X509Certificates;
using System.Text;
namespace SqlSugar.MongoDb
@@ -100,19 +102,43 @@ namespace SqlSugar.MongoDb
{
_visitorContext.ExpType = typeof(MemberExpression);
}
if (parts.Count == 1 && expr is ParameterExpression parameter)
string resultString = null;
if (parts.Count == 1 && expr is ParameterExpression parameter&& _context?.context != null)
{
if (_context?.context != null)
var entityInfo = _context.context.EntityMaintenance.GetEntityInfo(parameter.Type);
var columnInfo = entityInfo.Columns.FirstOrDefault(s => s.PropertyName == parts.First());
if (columnInfo != null)
{
var entityInfo = _context.context.EntityMaintenance.GetEntityInfo(parameter.Type);
var columnInfo = entityInfo.Columns.FirstOrDefault(s => s.PropertyName == parts.First());
if (columnInfo != null)
{
return UtilMethods.MyCreate(columnInfo.DbColumnName);
}
resultString = columnInfo.DbColumnName;
}
else
{
resultString = string.Join(".", parts);
}
}
return UtilMethods.MyCreate(string.Join(".", parts));
else
{
resultString = string.Join(".", parts);
}
var isJoin = this._context.queryBuilder.IsSingle()==false;
var shortName = ((ParameterExpression)expr)?.Name;
var joinInfo = this._context.queryBuilder.JoinQueryInfos.FirstOrDefault(it => it.ShortName.EqualCase(shortName));
var isObj = false;
if (joinInfo != null)
{
shortName = $"{joinInfo.ShortName}.";
if (this._context.resolveType.IsIn(ResolveExpressType.SelectSingle,ResolveExpressType.SelectMultiple))
{
// 构造 $ifNull 表达式
var columnString = $"{{ \"$ifNull\": [\"${joinInfo.ShortName}.{resultString}\", null] }}";
resultString = columnString;
isObj = true;
}
}
if (isObj)
return BsonDocument.Parse(resultString);
else
return UtilMethods.MyCreate(resultString);
}
}