Browse Source

Refactor `UpdateNavigationEntries` method to improve performance.

pull/23329/head
maliming 1 year ago
parent
commit
d51c565a1f
No known key found for this signature in database GPG Key ID: A646B9CB645ECEA4
  1. 14
      framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/ChangeTrackers/AbpEfCoreNavigationHelper.cs
  2. 59
      framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/ChangeTrackers/AbpEntityEntry.cs

14
framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/ChangeTrackers/AbpEfCoreNavigationHelper.cs

@ -60,7 +60,7 @@ public class AbpEfCoreNavigationHelper : ITransientDependency
return; return;
} }
var foreignKeys = entityEntry.Metadata.GetForeignKeys().ToList(); var foreignKeys = entityEntry.Metadata.GetForeignKeys();
foreach (var foreignKey in foreignKeys) foreach (var foreignKey in foreignKeys)
{ {
var principal = stateManager.FindPrincipal(internalEntityEntityEntry, foreignKey); var principal = stateManager.FindPrincipal(internalEntityEntityEntry, foreignKey);
@ -75,7 +75,11 @@ public class AbpEfCoreNavigationHelper : ITransientDependency
continue; continue;
} }
abpEntityEntry.UpdateNavigationEntries(); if (checkEntityEntryState && entityEntry.State == EntityState.Unchanged)
{
abpEntityEntry.UpdateNavigationEntries(entityEntry, foreignKey);
}
if (!abpEntityEntry.IsModified && (!checkEntityEntryState || IsEntityEntryChanged(entityEntry))) if (!abpEntityEntry.IsModified && (!checkEntityEntryState || IsEntityEntryChanged(entityEntry)))
{ {
abpEntityEntry.IsModified = true; abpEntityEntry.IsModified = true;
@ -115,7 +119,11 @@ public class AbpEfCoreNavigationHelper : ITransientDependency
continue; continue;
} }
abpEntityEntry.UpdateNavigationEntries(); if (checkEntityEntryState && entityEntry.State == EntityState.Unchanged)
{
abpEntityEntry.UpdateNavigationEntries(entityEntry, inverseForeignKey);
}
if (!abpEntityEntry.IsModified && (!checkEntityEntryState || IsEntityEntryChanged(entityEntry))) if (!abpEntityEntry.IsModified && (!checkEntityEntryState || IsEntityEntryChanged(entityEntry)))
{ {
abpEntityEntry.IsModified = true; abpEntityEntry.IsModified = true;

59
framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/ChangeTrackers/AbpEntityEntry.cs

@ -1,8 +1,9 @@
using System.Collections; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.ChangeTracking; using Microsoft.EntityFrameworkCore.ChangeTracking;
using Microsoft.EntityFrameworkCore.Metadata;
namespace Volo.Abp.EntityFrameworkCore.ChangeTrackers; namespace Volo.Abp.EntityFrameworkCore.ChangeTrackers;
@ -31,42 +32,34 @@ public class AbpEntityEntry
NavigationEntries = EntityEntry.Navigations.Select(x => new AbpNavigationEntry(x, x.Metadata.Name)).ToList(); NavigationEntries = EntityEntry.Navigations.Select(x => new AbpNavigationEntry(x, x.Metadata.Name)).ToList();
} }
public void UpdateNavigationEntries() public void UpdateNavigationEntries(EntityEntry entityEntry, IForeignKey foreignKey)
{ {
var entityEntryNavigationEntry = NavigationEntries.FirstOrDefault(x => x.NavigationEntry.Metadata is INavigation navigationMetadata && navigationMetadata.ForeignKey == foreignKey) ??
NavigationEntries.FirstOrDefault(x => x.NavigationEntry.Metadata is ISkipNavigation skipNavigationMetadata && skipNavigationMetadata.ForeignKey == foreignKey);
foreach (var navigationEntry in NavigationEntries) foreach (var navigationEntry in NavigationEntries)
{ {
if (IsModified || if (IsModified ||
EntityEntry.State == EntityState.Modified || EntityEntry.State == EntityState.Modified ||
navigationEntry.IsModified || navigationEntry.IsModified)
navigationEntry.NavigationEntry.IsModified)
{ {
continue; continue;
} }
var currentValue = AbpNavigationEntry.GetOriginalValue(navigationEntry.NavigationEntry.CurrentValue); var currentValue = navigationEntry.NavigationEntry.CurrentValue;
if (currentValue == null) if (currentValue == null)
{ {
continue; continue;
} }
switch (navigationEntry.OriginalValue)
{
case null:
navigationEntry.OriginalValue = currentValue;
break;
case IEnumerable originalValueCollection when currentValue is IEnumerable currentValueCollection:
{
var existingList = originalValueCollection.Cast<object?>().ToList();
var newList = currentValueCollection.Cast<object?>().ToList();
if (newList.Count > existingList.Count)
{
navigationEntry.OriginalValue = currentValue;
}
break; if (navigationEntry.NavigationEntry is CollectionEntry && navigationEntry == entityEntryNavigationEntry)
} {
default: navigationEntry.OriginalValue ??= new List<object>();
navigationEntry.OriginalValue = currentValue; var ls = navigationEntry.OriginalValue.As<List<object>>();
break; ls.Add(entityEntry.Entity);
}
else
{
navigationEntry.OriginalValue = currentValue;
} }
} }
} }
@ -80,7 +73,7 @@ public class AbpNavigationEntry
public bool IsModified { get; set; } public bool IsModified { get; set; }
public List<object>? OriginalValue { get; set; } public object? OriginalValue { get; set; }
public object? CurrentValue => NavigationEntry.CurrentValue; public object? CurrentValue => NavigationEntry.CurrentValue;
@ -88,21 +81,11 @@ public class AbpNavigationEntry
{ {
NavigationEntry = navigationEntry; NavigationEntry = navigationEntry;
Name = name; Name = name;
OriginalValue = GetOriginalValue(navigationEntry.CurrentValue); if (navigationEntry.CurrentValue != null)
}
public static List<object>? GetOriginalValue(object? currentValue)
{
if (currentValue is null)
{ {
return null; OriginalValue = navigationEntry is CollectionEntry collection
? collection.CurrentValue!.Cast<object>().ToList()
: navigationEntry.CurrentValue;
} }
if (currentValue is IEnumerable enumerable)
{
return enumerable.Cast<object>().ToList();
}
return new List<object> { currentValue };
} }
} }

Loading…
Cancel
Save