tk/FreeSql
1
0
Fork 0
mirror of https://github.com/nsnail/FreeSql.git synced 2025-04-22 18:52:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

update demo

Browse Source
This commit is contained in:
2881099 2023-11-10 00:56:30 +08:00
parent 930f8f46e9
commit a4dca34547
2 changed files with 38 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

71
Examples/base_entity/Program.cs
View File

@ -1877,41 +1877,42 @@ var sql11111 = fsql.Select<Class1111>()
}).Where(a => a.ConcurrentDictionarys.Length > 0).ToArray();
#region pgsql poco
//fsql.Aop.ParseExpression += (_, e) =>
//{
// //解析 POCO Jsonb a.Customer.Name
// if (e.Expression is MemberExpression memExp)
// {
// var parentMemExps = new Stack<MemberExpression>();
// parentMemExps.Push(memExp);
// while (true)
// {
// switch (memExp.Expression.NodeType)
// {
// case ExpressionType.MemberAccess:
// memExp = memExp.Expression as MemberExpression;
// if (memExp == null) return;
// parentMemExps.Push(memExp);
// break;
// case ExpressionType.Parameter:
// var tb = fsql.CodeFirst.GetTableByEntity(memExp.Expression.Type);
// if (tb == null) return;
// if (tb.ColumnsByCs.TryGetValue(parentMemExps.Pop().Member.Name, out var trycol) == false) return;
// if (new[] { typeof(JToken), typeof(JObject), typeof(JArray) }.Contains(trycol.Attribute.MapType.NullableTypeOrThis()) == false) return;
// var tmpcol = tb.ColumnsByPosition.OrderBy(a => a.Attribute.Name.Length).First();
// var result = e.FreeParse(Expression.MakeMemberAccess(memExp.Expression, tb.Properties[tmpcol.CsName]));
// result = result.Replace(tmpcol.Attribute.Name, trycol.Attribute.Name);
// while (parentMemExps.Any())
// {
// memExp = parentMemExps.Pop();
// result = $"{result}->>'{memExp.Member.Name}'";
// }
// e.Result = result;
// return;
// }
// }
// }
//};
fsql.Aop.ParseExpression += (_, e) =>
{
if (e.Expression.IsParameter() == false) return;
//解析 POCO Jsonb a.Customer.Name
if (e.Expression is MemberExpression memExp)
{
var parentMemExps = new Stack<MemberExpression>();
parentMemExps.Push(memExp);
while (true)
{
switch (memExp.Expression.NodeType)
{
case ExpressionType.MemberAccess:
memExp = memExp.Expression as MemberExpression;
if (memExp == null) return;
parentMemExps.Push(memExp);
break;
case ExpressionType.Parameter:
var tb = fsql.CodeFirst.GetTableByEntity(memExp.Expression.Type);
if (tb == null) return;
if (tb.ColumnsByCs.TryGetValue(parentMemExps.Pop().Member.Name, out var trycol) == false) return;
if (new[] { typeof(JToken), typeof(JObject), typeof(JArray) }.Contains(trycol.Attribute.MapType.NullableTypeOrThis()) == false) return;
var tmpcol = tb.ColumnsByPosition.OrderBy(a => a.Attribute.Name.Length).First();
var result = e.FreeParse(Expression.MakeMemberAccess(memExp.Expression, tb.Properties[tmpcol.CsName]));
result = result.Replace(tmpcol.Attribute.Name, trycol.Attribute.Name);
while (parentMemExps.Any())
{
memExp = parentMemExps.Pop();
result = $"{result}->>'{memExp.Member.Name}'";
}
e.Result = result;
return;
}
}
}
};
//void RegisterPocoType(Type pocoType)
//{

1
FreeSql.Tests/FreeSql.Tests/Issues/1549.cs
View File

@ -20,6 +20,7 @@ namespace FreeSql.Tests.Issues
RegisterPocoType(typeof(Customer)); //注删 POCO 类型
fsql.Aop.ParseExpression += (_, e) =>
{
if (e.Expression.IsParameter() == false) return;
//解析 POCO Jsonb a.Customer.Name
if (e.Expression is MemberExpression memExp)
{