diff options
| author | Mike Bayer <mike_mp@zzzcomputing.com> | 2014-07-15 13:20:55 -0400 |
|---|---|---|
| committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2014-07-15 13:20:55 -0400 |
| commit | 61384fd0e52932cf4a01654990963cc45c45dca2 (patch) | |
| tree | 260b1fac04e6f23765dcd53a4640a6bf2b7465e5 /lib/sqlalchemy | |
| parent | 3d7b18863813d98c66d76c5fbbba037d1ed18930 (diff) | |
| download | sqlalchemy-61384fd0e52932cf4a01654990963cc45c45dca2.tar.gz | |
- Fixed a regression caused by :ticket:`2976` released in 0.9.4 where
the "outer join" propagation along a chain of joined eager loads
would incorrectly convert an "inner join" along a sibling join path
into an outer join as well, when only descendant paths should be
receiving the "outer join" propagation; additionally, fixed related
issue where "nested" join propagation would take place inappropriately
between two sibling join paths.
this is accomplished by re-introducing the removed flag "allow_innerjoin",
now inverted and named "chained_from_outerjoin". Propagating this flag
allows us to know when we have encountered an outerjoin along a load
path, without confusing it for state obtained from a sibling path.
fixes #3131
ref #2976
Diffstat (limited to 'lib/sqlalchemy')
| -rw-r--r-- | lib/sqlalchemy/orm/strategies.py | 30 |
1 files changed, 19 insertions, 11 deletions
diff --git a/lib/sqlalchemy/orm/strategies.py b/lib/sqlalchemy/orm/strategies.py index f2d4935d7..b9de68f4b 100644 --- a/lib/sqlalchemy/orm/strategies.py +++ b/lib/sqlalchemy/orm/strategies.py @@ -1047,6 +1047,7 @@ class JoinedLoader(AbstractRelationshipLoader): def setup_query(self, context, entity, path, loadopt, adapter, \ column_collection=None, parentmapper=None, + chained_from_outerjoin=False, **kwargs): """Add a left outer join to the statement that's being constructed.""" @@ -1076,10 +1077,11 @@ class JoinedLoader(AbstractRelationshipLoader): elif path.contains_mapper(self.mapper): return - clauses, adapter, add_to_collection = self._generate_row_adapter( - context, entity, path, loadopt, adapter, - column_collection, parentmapper - ) + clauses, adapter, add_to_collection, chained_from_outerjoin = \ + self._generate_row_adapter( + context, entity, path, loadopt, adapter, + column_collection, parentmapper, chained_from_outerjoin + ) with_poly_info = path.get( context.attributes, @@ -1101,7 +1103,8 @@ class JoinedLoader(AbstractRelationshipLoader): path, clauses, parentmapper=self.mapper, - column_collection=add_to_collection) + column_collection=add_to_collection, + chained_from_outerjoin=chained_from_outerjoin) if with_poly_info is not None and \ None in set(context.secondary_columns): @@ -1179,7 +1182,7 @@ class JoinedLoader(AbstractRelationshipLoader): def _generate_row_adapter(self, context, entity, path, loadopt, adapter, - column_collection, parentmapper + column_collection, parentmapper, chained_from_outerjoin ): with_poly_info = path.get( context.attributes, @@ -1208,20 +1211,25 @@ class JoinedLoader(AbstractRelationshipLoader): else self.parent_property.innerjoin ) + if not innerjoin: + # if this is an outer join, all non-nested eager joins from + # this path must also be outer joins + chained_from_outerjoin = True + context.create_eager_joins.append( (self._create_eager_join, context, entity, path, adapter, - parentmapper, clauses, innerjoin) + parentmapper, clauses, innerjoin, chained_from_outerjoin) ) add_to_collection = context.secondary_columns path.set(context.attributes, "eager_row_processor", clauses) - return clauses, adapter, add_to_collection + return clauses, adapter, add_to_collection, chained_from_outerjoin def _create_eager_join(self, context, entity, path, adapter, parentmapper, - clauses, innerjoin): + clauses, innerjoin, chained_from_outerjoin): if parentmapper is None: localparent = entity.mapper @@ -1276,7 +1284,7 @@ class JoinedLoader(AbstractRelationshipLoader): join_to_outer = innerjoin and isinstance(towrap, sql.Join) and towrap.isouter - if join_to_outer and innerjoin == 'nested': + if chained_from_outerjoin and join_to_outer and innerjoin == 'nested': inner = orm_util.join( towrap.right, clauses.aliased_class, @@ -1292,7 +1300,7 @@ class JoinedLoader(AbstractRelationshipLoader): ) eagerjoin._target_adapter = inner._target_adapter else: - if join_to_outer: + if chained_from_outerjoin: innerjoin = False eagerjoin = orm_util.join( towrap, |
