Skip to content

Skip Topological sorting if not required #2006

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 4 commits into from
Feb 17, 2019
Merged
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
90 changes: 58 additions & 32 deletions src/NHibernate/Loader/JoinWalker.cs
Original file line number Diff line number Diff line change
Expand Up @@ -121,8 +121,6 @@ public class DependentAlias
public string[] DependsOn { get; set; }
}

readonly List<DependentAlias> _dependentAliases = new List<DependentAlias>();

protected JoinWalker(ISessionFactoryImplementor factory, IDictionary<string, IFilter> enabledFilters)
{
this.factory = factory;
Expand Down Expand Up @@ -181,7 +179,7 @@ private void AddAssociationToJoinTree(IAssociationType type, string[] aliasedLhs
enabledFilters,
GetSelectMode(path));
assoc.ValidateJoin(path);
AddAssociation(subalias, assoc);
AddAssociation(assoc);

int nextDepth = currentDepth + 1;

Expand All @@ -204,10 +202,20 @@ protected virtual SelectMode GetSelectMode(string path)
return SelectMode.Undefined;
}

private static int[] GetTopologicalSortOrder(List<DependentAlias> fields)
/// <summary>
/// Returns null if sorting is not required, otherwise list of indexes in sorted order
/// </summary>
private static int[] GetTopologicalSortOrder(IList<OuterJoinableAssociation> associations)
{
if (associations.Count < 2)
return null;

var fields = GetDependentAliases(associations);
if (!fields.Exists(a => a.DependsOn?.Length > 0))
return null;

TopologicalSorter g = new TopologicalSorter(fields.Count);
Dictionary<string, int> indexes = new Dictionary<string, int>(StringComparer.OrdinalIgnoreCase);
Dictionary<string, int> indexes = new Dictionary<string, int>(fields.Count, StringComparer.OrdinalIgnoreCase);

// add vertices
for (int i = 0; i < fields.Count; i++)
Expand Down Expand Up @@ -236,31 +244,41 @@ private static int[] GetTopologicalSortOrder(List<DependentAlias> fields)
return g.Sort();
}

/// <summary>
/// Adds an association and extracts the aliases the association's 'with clause' is dependent on
/// </summary>
private void AddAssociation(string subalias, OuterJoinableAssociation association)
private static List<DependentAlias> GetDependentAliases(IList<OuterJoinableAssociation> associations)
{
var dependentAlias = new DependentAlias
{
Alias = subalias,
};
_dependentAliases.Add(dependentAlias);
var dependentAliases = new List<DependentAlias>(associations.Count);

var on = association.On.ToString();
if (!string.IsNullOrEmpty(on))
foreach (var association in associations)
{
var dependencies = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
foreach (Match match in aliasRegex.Matches(on))
var dependentAlias = new DependentAlias
{
Alias = association.RHSAlias,
};

dependentAliases.Add(dependentAlias);

var on = association.On.ToString();
if (!string.IsNullOrEmpty(on))
{
string alias = match.Value;
if (string.Equals(alias, subalias, StringComparison.OrdinalIgnoreCase))
continue;
dependencies.Add(alias);
var dependencies = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
foreach (Match match in aliasRegex.Matches(on))
{
string alias = match.Value;
if (string.Equals(alias, dependentAlias.Alias, StringComparison.OrdinalIgnoreCase))
continue;
dependencies.Add(alias);
}
dependentAlias.DependsOn = dependencies.ToArray();
}
dependentAlias.DependsOn = dependencies.ToArray();
}
return dependentAliases;
}

/// <summary>
/// Adds an association
/// </summary>
private void AddAssociation(OuterJoinableAssociation association)
{
associations.Add(association);
}

Expand Down Expand Up @@ -360,7 +378,7 @@ internal void AddExplicitEntityJoinAssociation(
Factory,
enabledFilters,
GetSelectMode(path));
AddAssociation(tableAlias, assoc);
AddAssociation(assoc);
}

private void WalkEntityAssociationTree(IAssociationType associationType, IOuterJoinLoadable persister,
Expand Down Expand Up @@ -799,16 +817,9 @@ protected SqlString MergeOrderings(string ass, string orderBy) {
/// </summary>
protected JoinFragment MergeOuterJoins(IList<OuterJoinableAssociation> associations)
{
IList<OuterJoinableAssociation> sortedAssociations = new List<OuterJoinableAssociation>();

var indices = GetTopologicalSortOrder(_dependentAliases);
for (int index = indices.Length - 1; index >= 0; index--)
{
sortedAssociations.Add(associations[indices[index]]);
}

JoinFragment outerjoin = Dialect.CreateOuterJoinFragment();

var sortedAssociations = GetSortedAssociations(associations);
OuterJoinableAssociation last = null;
foreach (OuterJoinableAssociation oj in sortedAssociations)
{
Expand Down Expand Up @@ -840,6 +851,21 @@ protected JoinFragment MergeOuterJoins(IList<OuterJoinableAssociation> associati
return outerjoin;
}

private IList<OuterJoinableAssociation> GetSortedAssociations(IList<OuterJoinableAssociation> associations)
{
var indexes = GetTopologicalSortOrder(associations);
if (indexes == null)
return associations;

var sortedAssociations = new List<OuterJoinableAssociation>(associations.Count);
for (int index = indexes.Length - 1; index >= 0; index--)
{
sortedAssociations.Add(associations[indexes[index]]);
}

return sortedAssociations;
}

/// <summary>
/// Count the number of instances of IJoinable which are actually
/// also instances of ILoadable, or are one-to-many associations
Expand Down