summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2014-07-15 13:20:55 -0400
committerMike Bayer <mike_mp@zzzcomputing.com>2014-07-15 13:20:55 -0400
commit61384fd0e52932cf4a01654990963cc45c45dca2 (patch)
tree260b1fac04e6f23765dcd53a4640a6bf2b7465e5 /lib/sqlalchemy
parent3d7b18863813d98c66d76c5fbbba037d1ed18930 (diff)
downloadsqlalchemy-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.py30
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,