wx d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z dd lm
Z dd
l m
Z
d dlmZ d d lmZ d d lm
Z
ej ej d
G d de j Z G d dej Z G d de Z G d dee
Zd Z G d de ZdS )zDynamic collection API.
Dynamic collections act like Query() objects for read operations and support
basic add/delete mutation.
)
attributes)exc)
interfaces)
object_mapper)object_session)
properties)
strategies)util)Query )logdynamic)lazyc e Zd Zd ZdS )
DynaLoaderc ` d| _ | j s t j d| j z | j j t j t j fvr t j
d| j z t j | j |dt | j j | j j | j j d S )NTztOn relationship %s, 'dynamic' loaders cannot be used with many-to-one/one-to-one relationships and/or uselist=False.zOn relationship %s, 'dynamic' loaders cannot be used with many-to-one/one-to-one relationships and/or uselist=False. This warning will be an exception in a future release.) useobject
impl_class
target_mapperorder_by query_class)is_class_leveluselistr InvalidRequestErrorparent_property directionr ONETOMANY
MANYTOMANYr
warnr _register_attributeDynamicAttributeImplmapperr r )selfr" s j/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/orm/dynamic.pyinit_class_attributez DynaLoader.init_class_attribute s "| )!#'#78
!
+ !4
I" %)$89
& + .5)2 ,8
N)__name__
__module__ __qualname__r% r& r$ r r s#
r& r c Z e Zd ZdZdZdZdZdZ d fd Ze j
fdZ de j fdZ
ej d Zej d Z dd Z dd
Zd Zde j
dddfd Zd
Zd Ze j
fdZe j fdZe j
fdZe j
fdZe j
fdZ e j
fdZ xZ S )r! TFNc t t | j ||||fi | || _ || _ |st
| _ d S t | v r || _ d S t | | _ d S N)
superr! __init__r r
AppenderQueryr
AppenderMixinmromixin_user_query)
r# class_key typecallabledispatchr r r kw __class__s
r$ r/ z DynamicAttributeImpl.__init__E s 3"D))2 C x
35
+
= ,D
koo / /
/
/ *D / < added_plus_unchanged)r# r? r@ user_datarA historys r$ get_collectionz#DynamicAttributeImpl.get_collectiond sK ** 0//w??K K225'BBG/ /r& c @ t j | t j S r- )r Event OP_APPENDr# s r$
_append_tokenz"DynamicAttributeImpl._append_tokenq j&:;;;r& c @ t j | t j S r- )r rI OP_REMOVErK s r$
_remove_tokenz"DynamicAttributeImpl._remove_tokenu rM r& c || || }| | | j j D ]} ||||p| j }| j r-|-| t j | |d d S d S d S NT) _modified_event add_addedr7 appendrL trackparent sethasparentr instance_stater# r? r@ value initiatorcollection_historyfns r$ fire_append_eventz&DynamicAttributeImpl.fire_append_eventy s %!%!5!5eU!C!C $$U+++-& F FBBueY%D$2DEEEE M 1 j 7 > >t L L L L L M M 1 1r& c
|| || }| | | j r+|)| t j | |d | j j D ]} ||||p| j d S )NF) rS add_removedrV rW r rX r7 removerP rY s r$ fire_remove_eventz&DynamicAttributeImpl.fire_remove_event s %!%!5!5eU!C!C &&u--- N 1 j 7 > >u M M M-& > >B BueY <$*< = = = = > >r& c | j |j vr t | | |j | j < | || t j d|| j < |j | j S rR )r5 committed_stateCollectionHistoryrS r NEVER_SET)r# r? r@ s r$ rS z$DynamicAttributeImpl._modified_event sc 850 0 0.?e.L.LE !$( +
eT:+?@@@ dh$TX..r& c ` |r|j | j u rd S |r|d S |} t | }
|j r(t j | || } | || } |j s| j } n| | j } t j }
| |
} |
|
| }|
| }|
D ] }||v r| |||d | !|D ] }| |||d | d S )N)r\ )
parent_tokenlist has_identityr
IdentitySetrB rS r> union intersection
differencer^ rb )r# r? r@ rZ r[ rA check_oldpop_adaptiterable
new_valuesold_collectionr\ idset constants additionsremovalsmembers r$ setzDynamicAttributeImpl.set s /43DDD F 5= F(^^
F ! -dhhue.D.D E EN ! 1 1% ? ?! / ;NN + 1 1". N "//
;; E*%%00;; !,,Y77 F""&&'9 ' F " "#5
#
r& c t r- NotImplementedError)r# argskwargss r$ deletezDynamicAttributeImpl.delete s !###r& c t d )Nz7Dynamic attributes don't support collection population.r| )r# r? r@ rZ s r$ set_committed_valuez(DynamicAttributeImpl.set_committed_value s ! H
r& c V | || }| S r- )r<
as_historyr# r? r@ rA cs r$ get_historyz DynamicAttributeImpl.get_history s% ( ( 8 8||~~ r& c P | || }d |j D S )Nc : g | ]}t j | |fS r* )r rX ).0xs r$
z8DynamicAttributeImpl.get_all_pending.. s( GGGa*1--q1GGGr& )r< all_itemsr s r$ get_all_pendingz$DynamicAttributeImpl.get_all_pending s/
( ( 8 8GG1;GGGGr& c | j |j v r|j | j }nt | | }|j r!|t j z rt | || S |S )N)apply_to)r5 rd re rj r INIT_OK)r# r? rA r s r$ r< z,DynamicAttributeImpl._get_collection_history sf 8u, , ,%dh/AA!$..A 7Z-?#? $T51=== =Hr& c B || ur| |||| d S d S r- )r^ r# r? r@ rZ r[ rA s r$ rU zDynamicAttributeImpl.append 7 D " "5% B B B B B ! r& c B || ur| |||| d S d S r- )rb r s r$ ra zDynamicAttributeImpl.remove r r& c : | ||||| d S )N)rA )ra r s r$ rp zDynamicAttributeImpl.pop s&
E5%G DDDDDr& r- ) r' r( r) uses_objects default_accepts_scalar_loadersupports_population
collectionr r/ r PASSIVE_OFFrB r= rG r
memoized_propertyrL rP r^ rb rS rz r r r r r< rU ra rp
__classcell__r9 s @r$ r! r! > s& L$)! JG = = = = = =. )3(> 1 1 1 1 0 0 0 0 0
< < <
< < < BF M M M M BF > > > >
/
/
/" & 4 4 4 4l$ $ $
1;0F
%/$DH H H H 6@5K 7A6LC C C C 7A6LC C C C 7A6LE E E E E E E Er& r! c n e Zd ZdZ fdZd Z eed Zd Zd Zd Z d dZ
d Z d
Z d Z
xZS )
r1 Nc t t | |j d | x| _ }|| _ t | }|j | j j }|j
|j j |j
f| _
| |d | _ | j j r| j j | _ d S d S )NF)alias_secondary)r. r1 r/ r objinstanceattrr _propsr5 secondaryr"
selectable _from_obj _with_parent
_criterionr _order_by)r# r r? r r" propr9 s r$ r/ zAppenderMixin.__init__ s
mT""++D,>EEE#(99;;.
x((}TY]+ > % #k 4dn EDN ++He+LL 9 0 !Y /DNNN 0 0r& c t | j }|+| j r$|j r | j |v r| t j | j sd S |S r- )r r autoflushflushorm_utilrj r# sesss r$ sessionzAppenderMixin.session sf dm,,
%% JJLLL$T]33 4Kr& c d S r- r* )sr s r$ zAppenderMixin.- s T r& c | j }|Nt | j t j | j t j j S t | | S r- )
r iterr r< r rX r r= r> _cloner s r$ __iter__zAppenderMixin.__iter__/ sl | < 11 -dm<< 4
D))** *r& c | j }|O| j t j | j t j | S | | | S r- )
r r r< r rX r r= indexedr __getitem__)r# indexr s r$ r zAppenderMixin.__getitem__; sm | <944)$-880 genn
;;t$$0077 7r& c | j }|Nt | j t j | j t j j S | |
S r- ) r lenr r< r rX r r= r> r countr s r$ r zAppenderMixin.countE sp | < 11 -dm<< 4
;;t$$**,, ,r& c | j }|Ht | }|7t j dt j | d| j j d | j r"| | j j | }n |
| j j }| j |_ | j |_ | j
|_
|S )NzParent instance zh is not bound to a Session, and no contextual session is established; lazy load operation of attribute 'z' cannot proceed)r )r r orm_excDetachedInstanceErrorr instance_strr r5 r r queryr r r )r# r r r s r$ r zAppenderMixin._cloneQ s = <!(++D| 33 ,X6666
G 8$$TY%
deleted_items_reconcile_collection)r# r r? r colls r$ r/ zCollectionHistory.__init__ s
/ u--77>>D#'#:4#@#@D ' 3D !)!7D )-D & & &!%!8!:!:D # 6 8 8D #'#:#<# rl r rK s r$ rD z&CollectionHistory.added_plus_unchanged s$ D$**4+?@@AAAr& c t | j | j | j S r- )ri r> rl r r rK s r$ r zCollectionHistory.all_items sA " "4#7 8 8 > >"
r& c f | j rY| j | j }| j | j }| j | }n| j | j | j }}}t
j t | t | t | S r- ) r r> rn r r rm r Historyri )r# addeddeleted unchangeds r$ r z CollectionHistory.as_history s % $//0DEEE(55d6JKKG ,77@@II $" &9E
!$u++tIW
NNNr& c 6 t | j | S r- )ri r> )r# r s r$ r zCollectionHistory.indexed s D$%%e,,r& c : | j | d S r- )r> addr# rZ s r$ rT zCollectionHistory.add_added s U#####r& c || j v r | j | d S | j | d S r- )r> ra r r r s r$ r` z CollectionHistory.add_removed sJ D$ $ $ # #E * * * * * " "5 ) ) ) ) )r& r- ) r' r( r) r r/ r rD r r r rT r` r* r& r$ re re s NN / / / / B B XB
X
O O O- - -$ $ $* * * * *r& re N)r r r r r r r r r r
r r r r
class_loggerRelationshipProperty strategy_forAbstractRelationshipLoaderr
AttributeImplr! objectr1 r0 r3 re r* r& r$ r s0 --9-==
6
>=
>EE EE EE EE EE:3 EE EE EEP|
|
|
|
|
F |
|
|
~M M M M MM5 M M MB B B 3* 3* 3* 3* 3* 3* 3* 3* 3* 3*r&