|
@ -11,6 +11,7 @@ namespace SqlSugar |
|
|
private SqlSugarProvider context; |
|
|
private SqlSugarProvider context; |
|
|
private ISugarQueryable<T> queryable; |
|
|
private ISugarQueryable<T> queryable; |
|
|
private EntityInfo entityInfo { get; set; } |
|
|
private EntityInfo entityInfo { get; set; } |
|
|
|
|
|
public bool isLog; |
|
|
public FastestProvider(SqlSugarProvider sqlSugarProvider) |
|
|
public FastestProvider(SqlSugarProvider sqlSugarProvider) |
|
|
{ |
|
|
{ |
|
|
this.context = sqlSugarProvider; |
|
|
this.context = sqlSugarProvider; |
|
@ -78,6 +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); |
|
|
var isAuto = this.context.CurrentConnectionConfig.IsAutoCloseConnection; |
|
|
var isAuto = this.context.CurrentConnectionConfig.IsAutoCloseConnection; |
|
|
this.context.CurrentConnectionConfig.IsAutoCloseConnection = false; |
|
|
this.context.CurrentConnectionConfig.IsAutoCloseConnection = false; |
|
|
DataTable dt = ToDdateTable(datas); |
|
|
DataTable dt = ToDdateTable(datas); |
|
@ -89,17 +91,41 @@ namespace SqlSugar |
|
|
var result = await buider.UpdateByTempAsync(GetTableName(), dt.TableName, updateColumns, whereColumns); |
|
|
var result = await buider.UpdateByTempAsync(GetTableName(), dt.TableName, updateColumns, whereColumns); |
|
|
this.context.DbMaintenance.DropTable(dt.TableName); |
|
|
this.context.DbMaintenance.DropTable(dt.TableName); |
|
|
this.context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto; |
|
|
this.context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto; |
|
|
|
|
|
End(datas); |
|
|
return result; |
|
|
return result; |
|
|
} |
|
|
} |
|
|
private async Task<int> _BulkCopy(List<T> datas) |
|
|
private async Task<int> _BulkCopy(List<T> datas) |
|
|
{ |
|
|
{ |
|
|
|
|
|
Begin(datas); |
|
|
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); |
|
|
return result; |
|
|
return result; |
|
|
} |
|
|
} |
|
|
#endregion
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
|
|
#region AOP
|
|
|
|
|
|
private void End(List<T> datas) |
|
|
|
|
|
{ |
|
|
|
|
|
this.context.Ado.IsEnableLogEvent = isLog; |
|
|
|
|
|
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[] { }); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private void Begin(List<T> datas) |
|
|
|
|
|
{ |
|
|
|
|
|
isLog = this.context.Ado.IsEnableLogEvent; |
|
|
|
|
|
this.context.Ado.IsEnableLogEvent = false; |
|
|
|
|
|
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[] { }); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|