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

var result = db.Updateable(updateObj)

Browse Source 
.PageSize(1).EnableFilter().ExecuteCommand()
This commit is contained in:
sunkaixuan
2023-09-10 00:17:18 +08:00
parent ac7d88d762
commit 09598877b4
4 changed files with 124 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
Src/Asp.NetCore2/SqlSugar/Abstract/SqlBuilderProvider/UpdateBuilder.cs
View File

@@ -26,6 +26,7 @@ namespace SqlSugar
public string TableWithString { get; set; }
public List<DbColumnInfo> DbColumnInfoList { get; set; }
public List<string> WhereValues { get; set; }
public string AppendWhere { get; set; }
public List<KeyValuePair<string, string>> SetValues { get; set; }
public bool IsNoUpdateNull { get; set; }
public bool IsNoUpdateDefaultValue { get; set; }

105
Src/Asp.NetCore2/SqlSugar/Abstract/UpdateProvider/UpdateableFilter.cs Normal file
View File

@@ -0,0 +1,105 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace SqlSugar
{
public class UpdateableFilter<T> where T : class, new()
{
public T[] DataList { get; set; }
public SqlSugarProvider Context { get; set; }
public int PageSize { get; internal set; }
public string TableName { get; internal set; }
public bool IsEnableDiffLogEvent { get; internal set; }
public DiffLogModel DiffModel { get; internal set; }
public List<string> UpdateColumns { get; internal set; }
public int ExecuteCommand()
{
if (DataList.Count() == 1 && DataList.First() == null)
{
return 0;
}
PageSize = 1;
var result = 0;
var isNoTran = this.Context.Ado.IsNoTran();
try
{
if (isNoTran)
{
this.Context.Ado.BeginTran();
}
this.Context.Utilities.PageEach(DataList, PageSize, pageItem =>
{
result += SetFilterSql(this.Context.Updateable(pageItem.First()).AS(TableName).EnableDiffLogEventIF(IsEnableDiffLogEvent, DiffModel).UpdateColumns(UpdateColumns.ToArray())).ExecuteCommand();
});
if (isNoTran)
{
this.Context.Ado.CommitTran();
}
}
catch (Exception)
{
if (isNoTran)
{
this.Context.Ado.RollbackTran();
}
throw;
}
return result;
}
public async Task<int> ExecuteCommandAsync()
{
if (DataList.Count() == 1 && DataList.First() == null)
{
return 0;
}
PageSize = 1;
var result = 0;
var isNoTran = this.Context.Ado.IsNoTran();
try
{
if (isNoTran)
{
await this.Context.Ado.BeginTranAsync();
}
await this.Context.Utilities.PageEachAsync(DataList, PageSize, async pageItem =>
{
result += await SetFilterSql(this.Context.Updateable(pageItem.First()).AS(TableName).EnableDiffLogEventIF(IsEnableDiffLogEvent, DiffModel).UpdateColumns(UpdateColumns.ToArray())).ExecuteCommandAsync();
});
if (isNoTran)
{
await this.Context.Ado.CommitTranAsync();
}
}
catch (Exception)
{
if (isNoTran)
{
await this.Context.Ado.RollbackTranAsync();
}
throw;
}
return result;
}
private IUpdateable<T> SetFilterSql(IUpdateable<T> updateable)
{
var queryable = this.Context.Queryable<T>();
queryable.QueryBuilder.LambdaExpressions.ParameterIndex = 10000;
var sqlobj=queryable.ToSql();
var sql= UtilMethods.RemoveBeforeFirstWhere(sqlobj.Key);
updateable.UpdateBuilder.AppendWhere = sql;
if (sqlobj.Value != null)
{
updateable.UpdateBuilder.Parameters.AddRange(sqlobj.Value);
}
return updateable;
}
}
}

14
Src/Asp.NetCore2/SqlSugar/Abstract/UpdateProvider/UpdateablePage.cs
View File

@@ -15,6 +15,20 @@ namespace SqlSugar
public bool IsEnableDiffLogEvent { get; internal set; }
public DiffLogModel DiffModel { get; internal set; }
public List<string> UpdateColumns { get; internal set; }
public UpdateableFilter<T> EnableFilter()
{
return new UpdateableFilter<T>()
{
Context= Context,
DataList= DataList,
DiffModel= DiffModel,
IsEnableDiffLogEvent= IsEnableDiffLogEvent,
PageSize=PageSize,
TableName=TableName,
UpdateColumns=UpdateColumns
};
}
public int ExecuteCommand()
{
if (DataList.Count() == 1 && DataList.First() == null)

4
Src/Asp.NetCore2/SqlSugar/Abstract/UpdateProvider/UpdateableProvider.cs
View File

@@ -104,6 +104,10 @@ namespace SqlSugar
return trakRows;
}
string sql = _ExecuteCommand();
if (this.UpdateBuilder.AppendWhere.HasValue())
{
sql += " AND "+ this.UpdateBuilder.AppendWhere;
}
if (string.IsNullOrEmpty(sql))
{
return 0;