Update sqlite

This commit is contained in:
sunkaixuan
2024-02-14 23:26:48 +08:00
parent dfaa108ffa
commit 88733d4413
2 changed files with 15 additions and 4 deletions

View File

@@ -78,9 +78,9 @@ namespace SqlSugar
{
if (this.Context?.CurrentConnectionConfig?.MoreSettings?.IsCorrectErrorSqlParameterName == true)
{
foreach (var item in dictionary)
foreach (DataRow item in dt.Rows)
{
cmd.CommandText = this.Context.Insertable(item).AS(dt.TableName).ToSqlString().Replace(";SELECT LAST_INSERT_ROWID();", "");
cmd.CommandText = this.Context.Insertable(UtilMethods.DataRowToDictionary(item)).AS(dt.TableName).ToSqlString().Replace(";SELECT LAST_INSERT_ROWID();", "");
i += await cmd.ExecuteNonQueryAsync();
}
}
@@ -117,9 +117,9 @@ namespace SqlSugar
{
if (this.Context?.CurrentConnectionConfig?.MoreSettings?.IsCorrectErrorSqlParameterName == true)
{
foreach (var item in dictionary)
foreach (DataRow item in dt.Rows)
{
cmd.CommandText = this.Context.Updateable(item)
cmd.CommandText = this.Context.Updateable(UtilMethods.DataRowToDictionary(item))
.WhereColumns(whereColums)
.UpdateColumns(updateColums)
.AS(dt.TableName).ToSqlString();

View File

@@ -18,7 +18,18 @@ namespace SqlSugar
{
public class UtilMethods
{
public static Dictionary<string, object> DataRowToDictionary(DataRow row)
{
Dictionary<string, object> dictionary = new Dictionary<string, object>();
// 遍历所有列并将其添加到字典中
foreach (DataColumn column in row.Table.Columns)
{
dictionary.Add(column.ColumnName, row[column]);
}
return dictionary;
}
public static IEnumerable<T> BuildTree<T>(ISqlSugarClient db,IEnumerable<T> list, string idName, string pIdName, string childName, object rootValue)
{
var entityInfo = db.EntityMaintenance.GetEntityInfo<T>(); ;