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

Update UpdateNavManyToMany.cs

Browse Source 
修复：多对多关联更新时无法清空主体实体对应的中间表记录。
This commit is contained in:
zhyifei
2022-09-01 09:42:15 +08:00
committed by GitHub
parent a71ed91ac6
commit 82ba3fb717
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
Src/Asp.NetCore2/SqlSugar/Abstract/ExecuteNavProvider/UpdateNavManyToMany.cs
View File

@@ -28,6 +28,7 @@ namespace SqlSugar
.Where(it => it.IsPrimarykey && !it.IsIdentity && it.OracleSequenceName.IsNullOrEmpty()).FirstOrDefault(); .Where(it => it.IsPrimarykey && !it.IsIdentity && it.OracleSequenceName.IsNullOrEmpty()).FirstOrDefault();
Check.Exception(mappingA == null || mappingB == null, $"Navigate property {name} error ", $"导航属性{name}配置错误"); Check.Exception(mappingA == null || mappingB == null, $"Navigate property {name} error ", $"导航属性{name}配置错误");
List<Dictionary<string, object>> mappgingTables = new List<Dictionary<string, object>>(); List<Dictionary<string, object>> mappgingTables = new List<Dictionary<string, object>>();
var ids=new List<object>();
foreach (var item in parentList) foreach (var item in parentList)
{ {
var items = parentNavigateProperty.PropertyInfo.GetValue(item); var items = parentNavigateProperty.PropertyInfo.GetValue(item);
@@ -41,6 +42,10 @@ namespace SqlSugar
_ParentList = children.Cast<object>().ToList(); _ParentList = children.Cast<object>().ToList();
} }
var parentId = parentPkColumn.PropertyInfo.GetValue(item); var parentId = parentPkColumn.PropertyInfo.GetValue(item);
if (!ids.Contains(parentId))
{
ids.Add(parentId);
}
foreach (var child in children) foreach (var child in children)
{ {
var chidId = thisPkColumn.PropertyInfo.GetValue(child); var chidId = thisPkColumn.PropertyInfo.GetValue(child);
@@ -54,7 +59,6 @@ namespace SqlSugar
mappgingTables.Add(keyValuePairs); mappgingTables.Add(keyValuePairs);
} }
} }
var ids = mappgingTables.Select(x => x[mappingA.DbColumnName]).ToList();
this._Context.Deleteable<object>().AS(mappingEntity.DbTableName).In(mappingA.DbColumnName, ids).ExecuteCommand(); this._Context.Deleteable<object>().AS(mappingEntity.DbTableName).In(mappingA.DbColumnName, ids).ExecuteCommand();
this._Context.Insertable(mappgingTables).AS(mappingEntity.DbTableName).ExecuteCommand(); this._Context.Insertable(mappgingTables).AS(mappingEntity.DbTableName).ExecuteCommand();
_ParentEntity = thisEntity; _ParentEntity = thisEntity;