summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/orm/decl_base.py
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2022-09-26 14:38:44 -0400
committermike bayer <mike_mp@zzzcomputing.com>2022-10-06 00:36:25 +0000
commit276349200c486eee108471b888acfc47ea19201b (patch)
tree7441fa3219f21b18c6e532bd85b25c2bbdae86f8 /lib/sqlalchemy/orm/decl_base.py
parent566cccc8645be99a23811c39d43481d7248628b0 (diff)
downloadsqlalchemy-276349200c486eee108471b888acfc47ea19201b.tar.gz
implement write-only colletions, typing for dynamic
For 2.0, we provide a truly "larger than memory collection" implementation, a write-only collection that will never under any circumstances implicitly load the entire collection, even during flush. This is essentially a much more "strict" version of the "dynamic" loader, which in fact has a lot of scenarios that it loads the full backing collection into memory, mostly defeating its purpose. Typing constructs are added that support both the new feature WriteOnlyMapping as well as the legacy feature DynamicMapping. These have been integrated with "annotion based mapping" so that relationship() uses these annotations to configure the loader strategy as well. additional changes: * the docs triggered a conflict in hybrid's "transformers" section, this section is hard-coded to Query using a pattern that doesnt seem to have any use and isn't part of the current select() interface, so just removed this section * As the docs for WriteOnlyMapping are very long, collections.rst is broken up into two pages now. Fixes: #6229 Fixes: #7123 Change-Id: I6929f3da6e441cad92285e7309030a9bac4e429d
Diffstat (limited to 'lib/sqlalchemy/orm/decl_base.py')
-rw-r--r--lib/sqlalchemy/orm/decl_base.py19
1 files changed, 14 insertions, 5 deletions
diff --git a/lib/sqlalchemy/orm/decl_base.py b/lib/sqlalchemy/orm/decl_base.py
index a383e92ca..eed04025d 100644
--- a/lib/sqlalchemy/orm/decl_base.py
+++ b/lib/sqlalchemy/orm/decl_base.py
@@ -420,7 +420,7 @@ class _ClassScanMapperConfig(_MapperConfig):
registry: _RegistryType
clsdict_view: _ClassDict
- collected_annotations: Dict[str, Tuple[Any, Any, bool]]
+ collected_annotations: Dict[str, Tuple[Any, Any, Any, bool]]
collected_attributes: Dict[str, Any]
local_table: Optional[FromClause]
persist_selectable: Optional[FromClause]
@@ -997,6 +997,7 @@ class _ClassScanMapperConfig(_MapperConfig):
(key, mapped_anno if mapped_anno else raw_anno)
for key, (
raw_anno,
+ mapped_container,
mapped_anno,
is_dc,
) in self.collected_annotations.items()
@@ -1075,7 +1076,7 @@ class _ClassScanMapperConfig(_MapperConfig):
is_dataclass_field = False
is_dataclass_field = False
- extracted_mapped_annotation = _extract_mapped_subtype(
+ extracted = _extract_mapped_subtype(
raw_annotation,
self.cls,
name,
@@ -1086,10 +1087,13 @@ class _ClassScanMapperConfig(_MapperConfig):
and not is_dataclass, # self.allow_dataclass_fields,
)
- if extracted_mapped_annotation is None:
+ if extracted is None:
# ClassVar can come out here
return attr_value
- elif attr_value is None:
+
+ extracted_mapped_annotation, mapped_container = extracted
+
+ if attr_value is None:
for elem in typing_get_args(extracted_mapped_annotation):
# look in Annotated[...] for an ORM construct,
# such as Annotated[int, mapped_column(primary_key=True)]
@@ -1098,6 +1102,7 @@ class _ClassScanMapperConfig(_MapperConfig):
self.collected_annotations[name] = (
raw_annotation,
+ mapped_container,
extracted_mapped_annotation,
is_dataclass,
)
@@ -1252,13 +1257,17 @@ class _ClassScanMapperConfig(_MapperConfig):
if isinstance(value, _IntrospectsAnnotations):
(
annotation,
+ mapped_container,
extracted_mapped_annotation,
is_dataclass,
- ) = self.collected_annotations.get(k, (None, None, False))
+ ) = self.collected_annotations.get(
+ k, (None, None, None, False)
+ )
value.declarative_scan(
self.registry,
cls,
k,
+ mapped_container,
annotation,
extracted_mapped_annotation,
is_dataclass,