lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-09-20 02:29:39 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update db.Fast

Browse Source
This commit is contained in:
sunkaixuna
2021-11-23 18:12:05 +08:00
parent 8c9aef965c
commit cc06d5902c
2 changed files with 14 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
Src/Asp.Net/SqlServerTest/Demo/Demo8_Saveable.cs
View File

@@ -36,7 +36,10 @@ namespace OrmTest
x.AsUpdateable.ExecuteCommand(); x.AsUpdateable.ExecuteCommand();
x.AsInsertable.ExecuteCommand(); x.AsInsertable.ExecuteCommand();
var x2 = db.Storageable<Order>(new Order() { Id = 0, Name = "jack" }).ToStorage();
x2.BulkCopy();
x2.BulkUpdate();
Console.WriteLine(""); Console.WriteLine("");
Console.WriteLine("#### Saveable End ####"); Console.WriteLine("#### Saveable End ####");
} }

18
Src/Asp.Net/SqlSugar/Abstract/FastestProvider/FastestProvider.cs
View File

@@ -79,7 +79,7 @@ namespace SqlSugar
#region Core #region Core
private async Task<int> _BulkUpdate(List<T> datas, string[] whereColumns, string[] updateColumns) private async Task<int> _BulkUpdate(List<T> datas, string[] whereColumns, string[] updateColumns)
{ {
Begin(datas); Begin(datas,false);
Check.Exception(whereColumns == null || whereColumns.Count() == 0, "where columns count=0 or need primary key"); Check.Exception(whereColumns == null || whereColumns.Count() == 0, "where columns count=0 or need primary key");
Check.Exception(updateColumns == null || updateColumns.Count() == 0, "set columns count=0"); Check.Exception(updateColumns == null || updateColumns.Count() == 0, "set columns count=0");
var isAuto = this.context.CurrentConnectionConfig.IsAutoCloseConnection; var isAuto = this.context.CurrentConnectionConfig.IsAutoCloseConnection;
@@ -94,38 +94,40 @@ namespace SqlSugar
this.context.DbMaintenance.DropTable(dt.TableName); this.context.DbMaintenance.DropTable(dt.TableName);
this.context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto; this.context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto;
buider.CloseDb(); buider.CloseDb();
End(datas); End(datas, false);
return result; return result;
} }
private async Task<int> _BulkCopy(List<T> datas) private async Task<int> _BulkCopy(List<T> datas)
{ {
Begin(datas); Begin(datas,true);
DataTable dt = ToDdateTable(datas); DataTable dt = ToDdateTable(datas);
IFastBuilder buider =GetBuider(); IFastBuilder buider =GetBuider();
buider.Context = context; buider.Context = context;
var result = await buider.ExecuteBulkCopyAsync(dt); var result = await buider.ExecuteBulkCopyAsync(dt);
End(datas); End(datas,true);
return result; return result;
} }
#endregion #endregion
#region AOP #region AOP
private void End(List<T> datas) private void End(List<T> datas,bool isAdd)
{ {
var title = isAdd ? "BulkCopy" : "BulkUpdate";
this.context.Ado.IsEnableLogEvent = isLog; this.context.Ado.IsEnableLogEvent = isLog;
if (this.context.CurrentConnectionConfig?.AopEvents?.OnLogExecuted != null) if (this.context.CurrentConnectionConfig?.AopEvents?.OnLogExecuted != null)
{ {
this.context.CurrentConnectionConfig?.AopEvents?.OnLogExecuted($"End bulkcopy name:{entityInfo.DbTableName} ,count: {datas.Count},current time: {DateTime.Now}" , new SugarParameter[] { }); this.context.CurrentConnectionConfig?.AopEvents?.OnLogExecuted($"End {title} name:{entityInfo.DbTableName} ,count: {datas.Count},current time: {DateTime.Now}" , new SugarParameter[] { });
} }
} }
private void Begin(List<T> datas) private void Begin(List<T> datas,bool isAdd)
{ {
var title = isAdd ? "BulkCopy" : "BulkUpdate";
isLog = this.context.Ado.IsEnableLogEvent; isLog = this.context.Ado.IsEnableLogEvent;
this.context.Ado.IsEnableLogEvent = false; this.context.Ado.IsEnableLogEvent = false;
if (this.context.CurrentConnectionConfig?.AopEvents?.OnLogExecuting != null) if (this.context.CurrentConnectionConfig?.AopEvents?.OnLogExecuting != null)
{ {
this.context.CurrentConnectionConfig?.AopEvents?.OnLogExecuting($"Begin bulkcopy name:{entityInfo.DbTableName} ,count: {datas.Count},current time: {DateTime.Now} ", new SugarParameter[] { }); this.context.CurrentConnectionConfig?.AopEvents?.OnLogExecuting($"Begin {title} name:{entityInfo.DbTableName} ,count: {datas.Count},current time: {DateTime.Now} ", new SugarParameter[] { });
} }
} }
#endregion #endregion