summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/orm
diff options
context:
space:
mode:
authormike bayer <mike_mp@zzzcomputing.com>2021-03-17 18:28:30 +0000
committerGerrit Code Review <gerrit@ci3.zzzcomputing.com>2021-03-17 18:28:30 +0000
commitb646c1e65df05210b71d364b3ccfef5109557277 (patch)
tree7c5b87624de5c7822bf66073e322fd38c728dd63 /lib/sqlalchemy/orm
parent266ffe9b0c70cb7794379a77077a801689fcb97a (diff)
parent5f9c45400556f821550e7a39331f1bd5af5a34ce (diff)
downloadsqlalchemy-b646c1e65df05210b71d364b3ccfef5109557277.tar.gz
Merge "Use explicit names for mapper _get_clause parameters"
Diffstat (limited to 'lib/sqlalchemy/orm')
-rw-r--r--lib/sqlalchemy/orm/loading.py8
-rw-r--r--lib/sqlalchemy/orm/mapper.py7
-rw-r--r--lib/sqlalchemy/orm/strategies.py2
3 files changed, 15 insertions, 2 deletions
diff --git a/lib/sqlalchemy/orm/loading.py b/lib/sqlalchemy/orm/loading.py
index 24751bf1d..4a90caeff 100644
--- a/lib/sqlalchemy/orm/loading.py
+++ b/lib/sqlalchemy/orm/loading.py
@@ -436,6 +436,14 @@ def load_on_pk_identity(
lambda q: q.where(
sql_util._deep_annotate(_get_clause, {"_orm_adapt": True})
),
+ # this track_on will allow the lambda to refresh if
+ # _get_clause goes stale due to reconfigured mapper.
+ # however, it's not needed as the lambda otherwise tracks
+ # on the SQL cache key of the expression. the main thing
+ # is that the bindparam.key stays the same if the cache key
+ # stays the same, as we are referring to the .key explicitly
+ # in the params.
+ # track_on=[id(_get_clause)]
)
else:
q._where_criteria = (
diff --git a/lib/sqlalchemy/orm/mapper.py b/lib/sqlalchemy/orm/mapper.py
index fe425301a..93f4c87a1 100644
--- a/lib/sqlalchemy/orm/mapper.py
+++ b/lib/sqlalchemy/orm/mapper.py
@@ -2569,8 +2569,11 @@ class Mapper(
"""
params = [
- (primary_key, sql.bindparam(None, type_=primary_key.type))
- for primary_key in self.primary_key
+ (
+ primary_key,
+ sql.bindparam("pk_%d" % idx, type_=primary_key.type),
+ )
+ for idx, primary_key in enumerate(self.primary_key, 1)
]
return (
sql.and_(*[k == v for (k, v) in params]),
diff --git a/lib/sqlalchemy/orm/strategies.py b/lib/sqlalchemy/orm/strategies.py
index 51f75baf3..339a5bcf1 100644
--- a/lib/sqlalchemy/orm/strategies.py
+++ b/lib/sqlalchemy/orm/strategies.py
@@ -672,6 +672,7 @@ class LazyLoader(AbstractRelationshipLoader, util.MemoizedSlots):
and self.entity._get_clause[0].compare(
self._lazywhere,
use_proxies=True,
+ compare_keys=False,
equivalents=self.mapper._equivalent_columns,
)
)
@@ -2535,6 +2536,7 @@ class SelectInLoader(PostLoader, util.MemoizedSlots):
self.omit_join = self.parent._get_clause[0].compare(
lazyloader._rev_lazywhere,
use_proxies=True,
+ compare_keys=False,
equivalents=self.parent._equivalent_columns,
)