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

-

Browse Source
This commit is contained in:
sunkaixuna
2021-11-18 00:33:00 +08:00
parent 4e9fb057e9
commit 9f2bae2a57
1 changed files with 18 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -18,31 +18,39 @@ namespace SqlSugar
} }
public int BulkCopy(List<T> datas) public int BulkCopy(List<T> datas)
{ {
return BulkCopyAsync(datas).GetAwaiter().GetResult(); return BulkCopyAsync(datas).ConfigureAwait(true).GetAwaiter().GetResult();
} }
public async Task<int> BulkCopyAsync(List<T> datas) public async Task<int> BulkCopyAsync(List<T> datas)
{ {
DataTable dt = ToDdateTable(datas);
DataTable tempDataTable = ReflectionInoCore<DataTable>.GetInstance().GetOrCreate("BulkCopyAsync" + typeof(T).FullName,()=> queryable.Where(it=>false).ToDataTable()); IFastBuilder buider = new SqlServerFastBuilder();
buider.Context = context;
var result = await buider.ExecuteBulkCopyAsync(dt);
return result;
}
private DataTable ToDdateTable(List<T> datas)
{
DataTable tempDataTable = ReflectionInoCore<DataTable>.GetInstance().GetOrCreate("BulkCopyAsync" + typeof(T).FullName, () => queryable.Where(it => false).ToDataTable());
var dt = new DataTable(); var dt = new DataTable();
foreach (DataColumn item in tempDataTable.Columns) foreach (DataColumn item in tempDataTable.Columns)
{ {
dt.Columns.Add(item.ColumnName,item.DataType); dt.Columns.Add(item.ColumnName, item.DataType);
} }
var entityInfo = this.context.EntityMaintenance.GetEntityInfo<T>(); var entityInfo = this.context.EntityMaintenance.GetEntityInfo<T>();
dt.TableName =queryable.SqlBuilder.GetTranslationTableName(entityInfo.DbTableName); dt.TableName = queryable.SqlBuilder.GetTranslationTableName(entityInfo.DbTableName);
var columns = entityInfo.Columns; var columns = entityInfo.Columns;
foreach (var item in datas) foreach (var item in datas)
{ {
var dr = dt.NewRow(); var dr = dt.NewRow();
foreach (var column in columns) foreach (var column in columns)
{ {
if (column.IsIgnore || column.IsOnlyIgnoreInsert) if (column.IsIgnore || column.IsOnlyIgnoreInsert)
{ {
continue; continue;
} }
var name = column.DbColumnName; var name = column.DbColumnName;
if (name == null) if (name == null)
{ {
name = column.PropertyName; name = column.PropertyName;
} }
@@ -51,12 +59,9 @@ namespace SqlSugar
} }
dt.Rows.Add(dr); dt.Rows.Add(dr);
} }
IFastBuilder buider = new SqlServerFastBuilder();
buider.Context = context;
var result= await buider.ExecuteBulkCopyAsync(dt);
return result;
}
return dt;
}
private object ValueConverter(EntityColumnInfo columnInfo,object value) private object ValueConverter(EntityColumnInfo columnInfo,object value)
{ {
if (value == null) if (value == null)