Skip to content

Commit 25ff3db

Browse files
committed
Remove excessive rowIdAlias parameter in Loader
1 parent 2345bb4 commit 25ff3db

File tree

2 files changed

+10
-12
lines changed

2 files changed

+10
-12
lines changed

src/NHibernate/Async/Loader/Loader.cs

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -588,7 +588,6 @@ private async Task<object[]> GetRowAsync(DbDataReader rs, ILoadable[] persisters
588588
{
589589
cancellationToken.ThrowIfCancellationRequested();
590590
int cols = persisters.Length;
591-
IEntityAliases[] descriptors = EntityAliases;
592591

593592
if (Log.IsDebugEnabled())
594593
{
@@ -635,7 +634,7 @@ private async Task<object[]> GetRowAsync(DbDataReader rs, ILoadable[] persisters
635634
else
636635
{
637636
obj =
638-
await (InstanceNotYetLoadedAsync(rs, i, persister, key, lockModes[i], descriptors[i].RowIdAlias, optionalObjectKey,
637+
await (InstanceNotYetLoadedAsync(rs, i, persister, key, lockModes[i], optionalObjectKey,
639638
optionalObject, hydratedObjects, session, cancellationToken)).ConfigureAwait(false);
640639
}
641640
// #1226: Even if it is already loaded, if it can be loaded from an association with a property ref, make
@@ -683,7 +682,7 @@ private async Task InstanceAlreadyLoadedAsync(DbDataReader rs, int i, IEntityPer
683682
/// The entity instance is not in the session cache
684683
/// </summary>
685684
private async Task<object> InstanceNotYetLoadedAsync(DbDataReader dr, int i, ILoadable persister, EntityKey key, LockMode lockMode,
686-
string rowIdAlias, EntityKey optionalObjectKey, object optionalObject,
685+
EntityKey optionalObjectKey, object optionalObject,
687686
IList hydratedObjects, ISessionImplementor session, CancellationToken cancellationToken)
688687
{
689688
cancellationToken.ThrowIfCancellationRequested();
@@ -707,7 +706,7 @@ private async Task<object> InstanceNotYetLoadedAsync(DbDataReader dr, int i, ILo
707706
// (but don't yet initialize the object itself)
708707
// note that we acquired LockMode.READ even if it was not requested
709708
LockMode acquiredLockMode = lockMode == LockMode.None ? LockMode.Read : lockMode;
710-
await (LoadFromResultSetAsync(dr, i, obj, instanceClass, key, rowIdAlias, acquiredLockMode, persister, session, cancellationToken)).ConfigureAwait(false);
709+
await (LoadFromResultSetAsync(dr, i, obj, instanceClass, key, acquiredLockMode, persister, session, cancellationToken)).ConfigureAwait(false);
711710

712711
// materialize associations (and initialize the object) later
713712
hydratedObjects.Add(obj);
@@ -721,7 +720,7 @@ private async Task<object> InstanceNotYetLoadedAsync(DbDataReader dr, int i, ILo
721720
/// and pass the hydrated state to the session.
722721
/// </summary>
723722
private async Task LoadFromResultSetAsync(DbDataReader rs, int i, object obj, string instanceClass, EntityKey key,
724-
string rowIdAlias, LockMode lockMode, ILoadable rootPersister,
723+
LockMode lockMode, ILoadable rootPersister,
725724
ISessionImplementor session, CancellationToken cancellationToken)
726725
{
727726
cancellationToken.ThrowIfCancellationRequested();
@@ -750,7 +749,7 @@ private async Task LoadFromResultSetAsync(DbDataReader rs, int i, object obj, st
750749

751750
object[] values = await (persister.HydrateAsync(rs, id, obj, rootPersister, cols, eagerPropertyFetch, session, cancellationToken)).ConfigureAwait(false);
752751

753-
object rowId = persister.HasRowId ? rs[rowIdAlias] : null;
752+
object rowId = persister.HasRowId ? rs[EntityAliases[i].RowIdAlias] : null;
754753

755754
TwoPhaseLoad.PostHydrate(persister, id, values, rowId, obj, lockMode, !eagerPropertyFetch, session);
756755
}

src/NHibernate/Loader/Loader.cs

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -919,7 +919,6 @@ private object[] GetRow(DbDataReader rs, ILoadable[] persisters, EntityKey[] key
919919
ISessionImplementor session, bool mustLoadMissingEntity)
920920
{
921921
int cols = persisters.Length;
922-
IEntityAliases[] descriptors = EntityAliases;
923922

924923
if (Log.IsDebugEnabled())
925924
{
@@ -966,7 +965,7 @@ private object[] GetRow(DbDataReader rs, ILoadable[] persisters, EntityKey[] key
966965
else
967966
{
968967
obj =
969-
InstanceNotYetLoaded(rs, i, persister, key, lockModes[i], descriptors[i].RowIdAlias, optionalObjectKey,
968+
InstanceNotYetLoaded(rs, i, persister, key, lockModes[i], optionalObjectKey,
970969
optionalObject, hydratedObjects, session);
971970
}
972971
// #1226: Even if it is already loaded, if it can be loaded from an association with a property ref, make
@@ -1045,7 +1044,7 @@ private void CacheByUniqueKey(int i, IEntityPersister persister, object obj, ISe
10451044
/// The entity instance is not in the session cache
10461045
/// </summary>
10471046
private object InstanceNotYetLoaded(DbDataReader dr, int i, ILoadable persister, EntityKey key, LockMode lockMode,
1048-
string rowIdAlias, EntityKey optionalObjectKey, object optionalObject,
1047+
EntityKey optionalObjectKey, object optionalObject,
10491048
IList hydratedObjects, ISessionImplementor session)
10501049
{
10511050
object obj;
@@ -1068,7 +1067,7 @@ private object InstanceNotYetLoaded(DbDataReader dr, int i, ILoadable persister,
10681067
// (but don't yet initialize the object itself)
10691068
// note that we acquired LockMode.READ even if it was not requested
10701069
LockMode acquiredLockMode = lockMode == LockMode.None ? LockMode.Read : lockMode;
1071-
LoadFromResultSet(dr, i, obj, instanceClass, key, rowIdAlias, acquiredLockMode, persister, session);
1070+
LoadFromResultSet(dr, i, obj, instanceClass, key, acquiredLockMode, persister, session);
10721071

10731072
// materialize associations (and initialize the object) later
10741073
hydratedObjects.Add(obj);
@@ -1093,7 +1092,7 @@ private bool IsEagerPropertyFetchEnabled(int i)
10931092
/// and pass the hydrated state to the session.
10941093
/// </summary>
10951094
private void LoadFromResultSet(DbDataReader rs, int i, object obj, string instanceClass, EntityKey key,
1096-
string rowIdAlias, LockMode lockMode, ILoadable rootPersister,
1095+
LockMode lockMode, ILoadable rootPersister,
10971096
ISessionImplementor session)
10981097
{
10991098
object id = key.Identifier;
@@ -1121,7 +1120,7 @@ private void LoadFromResultSet(DbDataReader rs, int i, object obj, string instan
11211120

11221121
object[] values = persister.Hydrate(rs, id, obj, rootPersister, cols, eagerPropertyFetch, session);
11231122

1124-
object rowId = persister.HasRowId ? rs[rowIdAlias] : null;
1123+
object rowId = persister.HasRowId ? rs[EntityAliases[i].RowIdAlias] : null;
11251124

11261125
TwoPhaseLoad.PostHydrate(persister, id, values, rowId, obj, lockMode, !eagerPropertyFetch, session);
11271126
}

0 commit comments

Comments
 (0)