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

Update split table

Browse Source
This commit is contained in:
sunkaixuan
2025-04-16 17:02:48 +08:00
parent c0ab5ec96f
commit e1142cf89b
1 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
Src/Asp.NetCore2/SqlSugar/Abstract/UpdateProvider/SplitTableUpdateByObjectProvider.cs
View File

@@ -24,6 +24,8 @@ namespace SqlSugar
List<GroupModel> groupModels;
int result;
GroupDataList(UpdateObjects, out groupModels, out result);
var dataEvent = this.Context.CurrentConnectionConfig.AopEvents?.DataExecuting;
this.Context.Aop.DataExecuting = null;
foreach (var item in groupModels.GroupBy(it => it.GroupName))
{
var addList = item.Select(it => it.Item).ToList();
@@ -46,7 +48,8 @@ namespace SqlSugar
.IgnoreColumns(this.updateobj.UpdateBuilder.IsNoUpdateNull, this.updateobj.UpdateBuilder.IsOffIdentity, this.updateobj.UpdateBuilder.IsNoUpdateDefaultValue)
.IgnoreColumns(GetIgnoreColumns()).AS(item.Key).ExecuteCommandWithOptLock(isThrowError);
}
}
}
this.Context.Aop.DataExecuting = dataEvent;
return result;
}
public int ExecuteCommand()
@@ -57,12 +60,15 @@ namespace SqlSugar
foreach (var item in groupModels.GroupBy(it => it.GroupName))
{
var addList = item.Select(it => it.Item).ToList();
var dataEvent = this.Context.CurrentConnectionConfig.AopEvents?.DataExecuting;
this.Context.Aop.DataExecuting = null;
result += this.Context.Updateable(addList)
.EnableDiffLogEventIF(this.IsEnableDiffLogEvent, this.BusinessData)
.WhereColumns(this.WhereColumns?.ToArray())
.UpdateColumns(updateobj.UpdateBuilder.UpdateColumns?.ToArray())
.IgnoreColumns(this.updateobj.UpdateBuilder.IsNoUpdateNull, this.updateobj.UpdateBuilder.IsOffIdentity,this.updateobj.UpdateBuilder.IsNoUpdateDefaultValue)
.IgnoreColumns(GetIgnoreColumns()).AS(item.Key).ExecuteCommand();
.IgnoreColumns(GetIgnoreColumns()).AS(item.Key).ExecuteCommand();
this.Context.Aop.DataExecuting = dataEvent;
}
return result;
}
@@ -76,12 +82,15 @@ namespace SqlSugar
foreach (var item in groupModels.GroupBy(it => it.GroupName))
{
var addList = item.Select(it => it.Item).ToList();
var dataEvent = this.Context.CurrentConnectionConfig.AopEvents?.DataExecuting;
this.Context.Aop.DataExecuting = null;
result += await this.Context.Updateable(addList)
.WhereColumns(this.WhereColumns?.ToArray())
.EnableDiffLogEventIF(this.IsEnableDiffLogEvent, this.BusinessData)
.UpdateColumns(updateobj.UpdateBuilder.UpdateColumns?.ToArray())
.IgnoreColumns(this.updateobj.UpdateBuilder.IsNoUpdateNull, this.updateobj.UpdateBuilder.IsOffIdentity, this.updateobj.UpdateBuilder.IsNoUpdateDefaultValue)
.IgnoreColumns(GetIgnoreColumns()).AS(item.Key).ExecuteCommandAsync();
this.Context.Aop.DataExecuting = dataEvent;
}
return result;
}
@@ -90,6 +99,8 @@ namespace SqlSugar
List<GroupModel> groupModels;
int result;
GroupDataList(UpdateObjects, out groupModels, out result);
var dataEvent = this.Context.CurrentConnectionConfig.AopEvents?.DataExecuting;
this.Context.Aop.DataExecuting = null;
foreach (var item in groupModels.GroupBy(it => it.GroupName))
{
var addList = item.Select(it => it.Item).ToList();
@@ -113,7 +124,8 @@ namespace SqlSugar
.IgnoreColumns(this.updateobj.UpdateBuilder.IsNoUpdateNull, this.updateobj.UpdateBuilder.IsOffIdentity, this.updateobj.UpdateBuilder.IsNoUpdateDefaultValue)
.IgnoreColumns(GetIgnoreColumns()).AS(item.Key).ExecuteCommandWithOptLockAsync(isThrowError);
}
}
}
this.Context.Aop.DataExecuting = dataEvent;
return result;
}
private string [] GetIgnoreColumns()