Synchronization code

This commit is contained in:
sunkaixuan
2024-02-15 00:05:59 +08:00
parent 087cf7474b
commit 4f1ce8344e
2 changed files with 6 additions and 1 deletions

View File

@@ -138,12 +138,14 @@ namespace SqlSugar
public int BulkUpdate(DataTable dataTable, string[] whereColumns)
{
string[] updateColumns = dataTable.Columns.Cast<DataColumn>().Select(it => it.ColumnName).Where(it => !whereColumns.Any(z => z.EqualCase(it))).ToArray();
whereColumns = dataTable.Columns.Cast<DataColumn>().Select(it => it.ColumnName).Where(it => whereColumns.Any(z => z.EqualCase(it))).ToArray();
Check.ExceptionEasy(this.AsName.IsNullOrEmpty(), "need .AS(tablaeName) ", "需要 .AS(tablaeName) 设置表名");
return BulkUpdateAsync(this.AsName, dataTable, whereColumns, updateColumns).ConfigureAwait(true).GetAwaiter().GetResult();
}
public Task<int> BulkUpdateAsync(DataTable dataTable, string[] whereColumns)
{
string[] updateColumns = dataTable.Columns.Cast<DataColumn>().Select(it => it.ColumnName).Where(it => !whereColumns.Any(z => z.EqualCase(it))).ToArray();
whereColumns = dataTable.Columns.Cast<DataColumn>().Select(it => it.ColumnName).Where(it => whereColumns.Any(z => z.EqualCase(it))).ToArray();
Check.ExceptionEasy(this.AsName.IsNullOrEmpty(), "need .AS(tablaeName) ", "需要 .AS(tablaeName) 设置表名");
return BulkUpdateAsync(this.AsName, dataTable, whereColumns, updateColumns);
}

View File

@@ -25,7 +25,10 @@ namespace SqlSugar
// 遍历所有列并将其添加到字典中
foreach (DataColumn column in row.Table.Columns)
{
dictionary.Add(column.ColumnName, row[column]);
if (column.ColumnName != "Items" && column.DataType.Name.IsCollectionsList() == false)
{
dictionary.Add(column.ColumnName, row[column]);
}
}
return dictionary;