lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2026-02-26 21:53:04 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Batch tracing is asynchronous

Browse Source
This commit is contained in:
sunkaixuan
2023-03-12 12:06:47 +08:00
parent 5a6e22c8f1
commit 69d4e34e98
2 changed files with 44 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -50,6 +50,45 @@ namespace SqlSugar
}
return trakRows;
}
private async Task<int> DatasTrackingExecommandAsync()
{
var trakRows = 0;
try
{
if (this.Context.Ado.IsNoTran())
{
await this.Context.Ado.BeginTranAsync();
}
int i = 0;
foreach (var item in this.UpdateObjs)
{
var newUpdateable = this.Clone();
(newUpdateable as UpdateableProvider<T>).UpdateObjs = new[] { item };
newUpdateable.UpdateBuilder.IsListUpdate = null;
newUpdateable.UpdateBuilder.DbColumnInfoList =
newUpdateable.UpdateBuilder.DbColumnInfoList.Where(it => it.TableId == i).ToList();
AppendTracking(item, newUpdateable);
if (newUpdateable.UpdateBuilder.DbColumnInfoList?.Any() == true)
{
trakRows +=await newUpdateable.ExecuteCommandAsync();
}
++i;
}
if (this.Context.Ado.IsNoTran())
{
await this.Context.Ado.CommitTranAsync();
}
}
catch (Exception)
{
if (this.Context.Ado.IsNoTran())
{
await this.Context.Ado.RollbackTranAsync();
}
throw;
}
return trakRows;
}
private bool UpdateObjectNotWhere()
{
return this.Context.CurrentConnectionConfig.DbType != DbType.MySql

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

@@ -116,6 +116,11 @@ namespace SqlSugar
public virtual async Task<int> ExecuteCommandAsync()
{
if (this.IsTrakingDatas())
{
int trakRows =await DatasTrackingExecommandAsync();
return trakRows;
}
string sql = _ExecuteCommand();
if (string.IsNullOrEmpty(sql))
{