lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-08-25 01:14:33 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update i gnoring NULL columns supports batch

Browse Source
This commit is contained in:
sunkaixuan 2023-03-12 12:25:50 +08:00
parent 69d4e34e98
commit 76c7a2f757
2 changed files with 23 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
Src/Asp.Net/SqlSugar/Abstract/UpdateProvider/UpdateableHelper.cs
View File

@ -11,6 +11,11 @@ namespace SqlSugar
{ {
public partial class UpdateableProvider<T> : IUpdateable<T> where T : class, new() public partial class UpdateableProvider<T> : IUpdateable<T> where T : class, new()
{ {
private bool IsUpdateNullByList()
{
return this.UpdateObjs.Count() > 1 && (this.UpdateBuilder.IsNoUpdateNull || this.UpdateBuilder.IsNoUpdateDefaultValue);
}
private int DatasTrackingExecommand() private int DatasTrackingExecommand()
{ {
var trakRows = 0; var trakRows = 0;
@ -97,22 +102,25 @@ namespace SqlSugar
} }
private void AppendTracking(T item, IUpdateable<T> newUpdateable) private void AppendTracking(T item, IUpdateable<T> newUpdateable)
{ {
var trackingData = this.Context.TempItems.FirstOrDefault(it => it.Key.StartsWith("Tracking_" + item.GetHashCode())); if (IsTrakingData() || IsTrakingDatas())
var diffColumns = FastCopy.GetDiff(item, (T)trackingData.Value);
if (diffColumns.Count > 0)
{ {
var pks = EntityInfo.Columns var trackingData = this.Context.TempItems.FirstOrDefault(it => it.Key.StartsWith("Tracking_" + item.GetHashCode()));
.Where(it => it.IsPrimarykey).Select(it => it.PropertyName).ToList(); var diffColumns = FastCopy.GetDiff(item, (T)trackingData.Value);
diffColumns = diffColumns.Where(it => !pks.Contains(it)).ToList();
if (diffColumns.Count > 0) if (diffColumns.Count > 0)
{ {
newUpdateable.UpdateColumns(diffColumns.ToArray()); var pks = EntityInfo.Columns
.Where(it => it.IsPrimarykey).Select(it => it.PropertyName).ToList();
diffColumns = diffColumns.Where(it => !pks.Contains(it)).ToList();
if (diffColumns.Count > 0)
{
newUpdateable.UpdateColumns(diffColumns.ToArray());
}
}
else
{
(newUpdateable as UpdateableProvider<T>).UpdateObjs = new T[] { null };
newUpdateable.UpdateBuilder.DbColumnInfoList = new List<DbColumnInfo>();
} }
}
else
{
(newUpdateable as UpdateableProvider<T>).UpdateObjs = new T[] { null };
newUpdateable.UpdateBuilder.DbColumnInfoList = new List<DbColumnInfo>();
} }
} }
private void AppendSets() private void AppendSets()

5
Src/Asp.Net/SqlSugar/Abstract/UpdateProvider/UpdateableProvider.cs
View File

@ -80,7 +80,7 @@ namespace SqlSugar
public virtual int ExecuteCommand() public virtual int ExecuteCommand()
{ {
if (this.IsTrakingDatas()) if (this.IsTrakingDatas() || IsUpdateNullByList())
{ {
int trakRows = DatasTrackingExecommand(); int trakRows = DatasTrackingExecommand();
return trakRows; return trakRows;
@ -95,6 +95,7 @@ namespace SqlSugar
return result; return result;
} }
public bool ExecuteCommandHasChange() public bool ExecuteCommandHasChange()
{ {
return this.ExecuteCommand() > 0; return this.ExecuteCommand() > 0;
@ -277,7 +278,7 @@ namespace SqlSugar
public IUpdateable<T> IgnoreColumns(bool ignoreAllNullColumns, bool isOffIdentity = false, bool ignoreAllDefaultValue = false) public IUpdateable<T> IgnoreColumns(bool ignoreAllNullColumns, bool isOffIdentity = false, bool ignoreAllDefaultValue = false)
{ {
Check.Exception(this.UpdateObjs.Count() > 1 && ignoreAllNullColumns, ErrorMessage.GetThrowMessage("ignoreNullColumn NoSupport batch insert", "ignoreNullColumn 不支持批量操作")); //Check.Exception(this.UpdateObjs.Count() > 1 && ignoreAllNullColumns, ErrorMessage.GetThrowMessage("ignoreNullColumn NoSupport batch insert", "ignoreNullColumn 不支持批量操作"));
UpdateBuilder.IsOffIdentity = isOffIdentity; UpdateBuilder.IsOffIdentity = isOffIdentity;
if (this.UpdateBuilder.LambdaExpressions == null) if (this.UpdateBuilder.LambdaExpressions == null)
this.UpdateBuilder.LambdaExpressions = InstanceFactory.GetLambdaExpressions(this.Context.CurrentConnectionConfig); this.UpdateBuilder.LambdaExpressions = InstanceFactory.GetLambdaExpressions(this.Context.CurrentConnectionConfig);