lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-11-08 10:24:55 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update db.Merge

Browse Source
This commit is contained in:
sunkaixuan
2025-10-28 19:35:34 +08:00
parent b981f88fa0
commit 1e27cd5329
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
Src/Asp.NetCore2/SqlSugar/Abstract/FastestProvider/FastestProvider.cs
View File

@@ -246,12 +246,15 @@ namespace SqlSugar
}
public async Task<int> BulkMergeAsync(List<T> datas, Expression<Func<T, object>> whereColumnsExp, Expression<Func<T, object>> updateColumnsExp)
{
{
var columnInfos = this.context.EntityMaintenance.GetEntityInfo<T>().Columns;
// 1. 获取 whereColumns
var whereColumns =ExpressionTool.GetNewExpressionItemListNew((whereColumnsExp as LambdaExpression).Body).Select(it=>it.Key).ToArray();
// 2. 获取 updateColumns
var updateColumns = ExpressionTool.GetNewExpressionItemListNew((updateColumnsExp as LambdaExpression).Body).Select(it => it.Key).ToArray();
var updateColumns = ExpressionTool.GetNewExpressionItemListNew((updateColumnsExp as LambdaExpression).Body).Select(it => it.Key).ToArray();
updateColumns = updateColumns.Select(s =>
columnInfos.Where(ec => ec.DbColumnName.EqualCase(s)|| ec.PropertyName.EqualCase(s)).FirstOrDefault()?.DbColumnName ?? s).ToArray();
// 3. 调用 BulkMergeAsync
return await BulkMergeAsync(datas, whereColumns, updateColumns);
}