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

update db.Fastest

Browse Source
This commit is contained in:
sunkaixuna
2021-11-18 20:34:22 +08:00
parent 6072c31362
commit 22596374e6
2 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -18,7 +18,8 @@ namespace SqlSugar
this.queryable = this.context.Queryable<T>(); this.queryable = this.context.Queryable<T>();
entityInfo=this.context.EntityMaintenance.GetEntityInfo<T>(); entityInfo=this.context.EntityMaintenance.GetEntityInfo<T>();
} }
#region Api
#region BulkCopy
public int BulkCopy(List<T> datas) public int BulkCopy(List<T> datas)
{ {
return BulkCopyAsync(datas).ConfigureAwait(true).GetAwaiter().GetResult(); return BulkCopyAsync(datas).ConfigureAwait(true).GetAwaiter().GetResult();
@@ -31,6 +32,9 @@ namespace SqlSugar
var result = await buider.ExecuteBulkCopyAsync(dt); var result = await buider.ExecuteBulkCopyAsync(dt);
return result; return result;
} }
#endregion
#region BulkUpdate
public int BulkUpdate(List<T> datas) public int BulkUpdate(List<T> datas)
{ {
return BulkUpdateAsync(datas).ConfigureAwait(true).GetAwaiter().GetResult(); return BulkUpdateAsync(datas).ConfigureAwait(true).GetAwaiter().GetResult();
@@ -41,6 +45,10 @@ namespace SqlSugar
var updateColumns = entityInfo.Columns.Where(it => !it.IsPrimarykey&&!it.IsIdentity&&!it.IsOnlyIgnoreUpdate&&!it.IsIgnore).Select(it => it.DbColumnName ?? it.PropertyName).ToArray(); var updateColumns = entityInfo.Columns.Where(it => !it.IsPrimarykey&&!it.IsIdentity&&!it.IsOnlyIgnoreUpdate&&!it.IsIgnore).Select(it => it.DbColumnName ?? it.PropertyName).ToArray();
return await BulkUpdateAsync(datas,whereColumns,updateColumns); return await BulkUpdateAsync(datas,whereColumns,updateColumns);
} }
public int BulkUpdate(List<T> datas, string[] whereColumns, string[] updateColumns)
{
return BulkUpdateAsync(datas,whereColumns,updateColumns).ConfigureAwait(true).GetAwaiter().GetResult();
}
public async Task<int> BulkUpdateAsync(List<T> datas,string [] whereColumns,string [] updateColumns) public async Task<int> BulkUpdateAsync(List<T> datas,string [] whereColumns,string [] updateColumns)
{ {
var isAuto = this.context.CurrentConnectionConfig.IsAutoCloseConnection; var isAuto = this.context.CurrentConnectionConfig.IsAutoCloseConnection;

4
Src/Asp.Net/SqlSugar/Interface/IFastest.cs
View File

@@ -8,9 +8,13 @@ namespace SqlSugar
public interface IFastest<T> public interface IFastest<T>
{ {
IFastest<T> AS(string tableName); IFastest<T> AS(string tableName);
int BulkCopy(List<T> datas); int BulkCopy(List<T> datas);
Task<int> BulkCopyAsync(List<T> datas); Task<int> BulkCopyAsync(List<T> datas);
int BulkUpdate(List<T> datas); int BulkUpdate(List<T> datas);
Task<int> BulkUpdateAsync(List<T> datas); Task<int> BulkUpdateAsync(List<T> datas);
int BulkUpdate(List<T> datas, string[] whereColumns, string[] updateColumns);
Task<int> BulkUpdateAsync(List<T> datas, string[] whereColumns, string[] updateColumns);
} }
} }