U
|
¸ý°d̼ ã @ sö d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd l
|
m Z dd
|
l
|
m Z dd l
|
m Z d dlmZ d d lmZ d dlmZ G dd dZG dd deZG dd deZG dd deZG dd deZe ee ee eiZdS )z Relationship dependencies.
|
|
é )Ú annotationsé )Ú
|
attributes)Úexc)Úsync)Ú
|
unitofwork)Úutil)Ú
|
MANYTOMANY)Ú MANYTOONE)Ú ONETOMANYé )Úsqlc @ s e Zd Zdd Zedd Zdd Zdd Zd d
|
Zd d Z d d Z
|
dd Z dd Z dd Z dd Zdd Zdd Zdd Zd%d d Zd d! Zd"d# Zd$S )&ÚDependencyProcessorc C s¶ || _ |j| _|j| _|j| _|j| _|j| _|j| _|j| _|j| _|j | _ | jr^t
|
j | _ nt
|
j | _ | jrvt
|
j | _nt
|
j | _d| jj|jf | _|j| _| j js²t d| j ¡d S )Nz%s_%sz|Can't build a DependencyProcessor for relationship %s. No target attributes to populate between parent and child are present)ÚpropÚcascadeÚmapperÚparentÚ secondaryÚ directionÚ post_updateÚpassive_deletesÚpassive_updatesÚenable_typechecksr ÚPASSIVE_NO_INITIALIZEÚ_passive_delete_flagÚ PASSIVE_OFFÚ_passive_update_flagÚ _sort_keyÚkeyÚsort_keyÚsynchronize_pairsÚsa_excÚ ArgumentError)Úselfr © r$ úPd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/orm/dependency.pyÚ__init__ s0
|
|
þÿz DependencyProcessor.__init__c C s t |j |S ©N)Ú_direction_to_processorr )Úclsr r$ r$ r% Úfrom_relationship; s z%DependencyProcessor.from_relationshipc C s | j j | j¡ |¡S )z¤return True if the given object instance has a parent,
|
according to the ``InstrumentedAttribute`` handled by this
|
``DependencyProcessor``.
|
|
)r Z class_managerÚget_implr Ú hasparent©r# Ústater$ r$ r% r, ? s z DependencyProcessor.hasparentc C s | | d¡ dS )zestablish actions and dependencies related to a flush.
|
|
These actions will operate on all relevant states in
|
the aggregate.
|
|
TN)Úregister_preprocessor©r# Úuowr$ r$ r% Úper_property_preprocessorsG s z.DependencyProcessor.per_property_preprocessorsc C sz t || dd¡}t || dd¡}t || jj¡}t || jj¡}t || jj¡}t || jj¡}| |||||||¡ d S ©NFT)r Ú
|
ProcessAllÚ SaveUpdateAllr Úprimary_base_mapperr Ú DeleteAllÚper_property_dependencies)r# r1 Ú
|
after_saveÚ before_deleteÚ parent_savesÚ child_savesÚparent_deletesÚ child_deletesr$ r$ r% Úper_property_flush_actionsP s6 ÿ ÿ ÿ ÿùz.DependencyProcessor.per_property_flush_actionsc C sô | j j}t ||¡}t ||¡}|r<t || dd¡}d|_nt || dd¡}d|_||jkr||jksjt|df|dfg} d}
|
nd}
|
|s°t || j j
|
¡} d } }| |jkrÖd} n&t || j j
|
¡} d } }| |jkrÖd} |D ]}|j | j j ||j|rþ| jntj¡}|sqÚ|r8t || d|¡}| rZt ||¡} n"t || d|¡}| rZt ||¡} |
|
rÆg } |D ]\\}}||jkrd}n6|j| \}}|r¨t ||¡df}nt ||¡df}| |¡ qh| D ]"\}}| || | |||||¡ qÊqÚdS )zèestablish actions and dependencies related to a flush.
|
|
These actions will operate on all relevant states
|
individually. This occurs only if there are cycles
|
in the 'aggregated' version of events.
|
|
TFN)NN)r r6 r r5 r7 r4 ÚdisabledZcyclesÚAssertionErrorr Ú base_mapperÚmanagerr ÚimplZget_all_pendingÚdictr r r Z ProcessStateZ DeleteStateZSaveUpdateStateÚstatesÚappendÚper_state_dependencies)r# r1 rF ÚisdeleteZchild_base_mapperr< r> r: r9 Z child_actionsZchild_in_cyclesr; r= Zparent_in_cyclesr. Zsum_Z child_stateÚchildÚ child_actionÚdeletedZlistonlyÚ childisdeleter$ r$ r% Úper_state_flush_actionsl s
|
ÿ
|
|
|
ÿû
|
þ
|
þ øz+DependencyProcessor.per_state_flush_actionsc C s dS ©NFr$ ©r# Ú uowcommitrF r$ r$ r% Úpresort_deletesÜ s z#DependencyProcessor.presort_deletesc C s dS rO r$ rP r$ r$ r% Ú presort_savesß s z!DependencyProcessor.presort_savesc C s d S r' r$ rP r$ r$ r% Úprocess_deletesâ s z#DependencyProcessor.process_deletesc C s d S r' r$ rP r$ r$ r% Ú process_saveså s z!DependencyProcessor.process_savesc C sp |r
|
| j rtj}n| jtkr$tj}ntj}|D ]&}| || j|¡}|r.| ¡ s. dS q.|on| j
|
j on| j |j kS )NT)r r r r r
|
ZPASSIVE_NO_FETCH_RELATEDr Úget_attribute_historyr Úemptyr Z_is_self_referentialr Zmappers)r# rQ rF rI ÚpassiveÚsÚhistoryr$ r$ r% Úprop_has_changesè s
|
|
ÿ
|
ýz$DependencyProcessor.prop_has_changesc C s | j jr$|d kr$t d| j f ¡nn|d k r| jj|| j ds| jj|ddrtt d|j| j | jj| jd ¡n t d|j| j | jjd ¡d S )Nz-Can't flush None value found in collection %s)Zallow_subtypesTaE Attempting to flush an item of type %(x)s as a member of collection "%(y)s". Expected an object of type %(z)s or a polymorphic subclass of this type. If %(x)s is a subclass of %(z)s, configure mapper "%(zm)s" to load this subtype polymorphically, or set enable_typechecks=False to allow any subtype to be accepted for flush. )ÚxÚyÚzZzmzAttempting to flush an item of type %(x)s as a member of collection "%(y)s". Expected an object of type %(z)s or a polymorphic subclass of this type.)r\ r] r^ )r Úuselistr Z
|
FlushErrorr Z_canloadr Úclass_r- r$ r$ r% Ú_verify_canload s8 ÿÿ ÿ
|
ü÷ÿýûÿz#DependencyProcessor._verify_canloadc C s
|
t d S r' ©ÚNotImplementedError)r# r. rJ ÚassociationrowÚ clearkeysrQ r$ r$ r% Ú _synchronize, s z DependencyProcessor._synchronizec C s> | j js d S tt| jgdd | j jD }| d|ft¡S )Nc S s g | ]
|
}|j qS r$ )r )Ú.0Úpr$ r$ r% Ú
|
<listcomp>4 s zCDependencyProcessor._get_reversed_processed_set.<locals>.<listcomp>Z reverse_key)r Ú_reverse_propertyÚtupleÚsortedr ÚmemoÚset)r# r1 Z process_keyr$ r$ r% Ú_get_reversed_processed_set/ s ÿz/DependencyProcessor._get_reversed_processed_setFc C s8 |D ].}|r|d k r| |dd | jjD ¡ q4qd S )Nc S s g | ] \}}|qS r$ r$ )rg ÚlÚrr$ r$ r% ri < s z4DependencyProcessor._post_update.<locals>.<listcomp>)Zregister_post_updater r )r# r. rQ ÚrelatedÚ is_m2o_deleter\ r$ r$ r% Ú _post_update8 s ÿz DependencyProcessor._post_updatec C s
|
t d S r' rb ©r# rQ r. r$ r$ r% Ú _pks_changed@ s z DependencyProcessor._pks_changedc C s d| j j| jf S )Nz%s(%s))Ú __class__Ú__name__r )r# r$ r$ r% Ú__repr__C s z DependencyProcessor.__repr__N)F)rx Ú
|
__module__Ú __qualname__r& Ú classmethodr* r, r2 r? rN rR rS rT rU r[ ra rf ro rt rv ry r$ r$ r$ r% r s$
|
p)
|
r c @ sL e Zd Zdd Zdd Zdd Zdd Zd d
|
Zd d Zd d Z dd Z
|
dS )Ú OneToManyDPc
|
|
C s | j r\t || jjd¡}t || jjd¡} |j ||f||f||f|| f| |f| |fg¡ n6|j ||f||f||f||f||f||f||fg¡ d S r3 ©r r Ú PostUpdateAllr r6 Ú dependenciesÚupdate)
|
r# r1 r; r< r= r> r9 r: Úchild_post_updatesÚchild_pre_updatesr$ r$ r% r8 H s<
|
ÿ ÿúÿ ùÿz%OneToManyDP.per_property_dependenciesc C sä | j r¤t || jjd¡} t || jjd¡}
|
|sl|rL|j ||f|| fg¡ q¢|j ||f||f|| fg¡ qà|r|j ||
|
f|
|
|fg¡ qà|j ||
|
f|
|
|fg¡ n<|sÈ|j ||f||f||fg¡ n|j ||f||fg¡ d S r3 r~ ) r# r1 Ú save_parentÚ delete_parentrK r9 r: rI rM r r r$ r$ r% rH q sZ ÿ ÿþÿýÿþÿþÿýÿÿz"OneToManyDP.per_state_dependenciesc C s¨ | j j o| jdk }|D ]}| || j| j¡}|r|jD ]<}|d k r:| |¡dkr:| j jrl|j |dd q:| |¡ q:|r|j
|
D ] }|d k r|j |d| j d qqd S )NÚallFT©rI Údelete©Ú operationr ) r r r rV r r rL r, Ú delete_orphanÚregister_objectÚ unchangedr ©r# rQ rF Úshould_null_fksr. rZ rJ r$ r$ r% rR ´ s, ÿ ÿ
|
|
ÿzOneToManyDP.presort_deletesc C sV | d| ft¡}| jj o$| jdk }|D ]$}| ||¡}|rF| jrNtj}ntj }|
|
|| j |¡}|r|j D ] } | d k rp|j | dd| jd qp| |j ¡ |jD ]r} | jjsÊ|rÈ|j | dd| jd q¤| | ¡dkr¤|j | dd| jd | j d| ¡D ]\}
|
} } } |j | dd qúq¤|r*|r*|jD ](} | d k r&|j | d| jd
|
| jd q&q*d S ) NÚchildren_addedr TÚadd)Z cancel_deleter r Fr ©rI r r r z pk changer )rm rn r r r rv r r r r rV r Úaddedr r r rL r, r Úcascade_iteratorr )r# rQ rF r r r. Ú pks_changedrX rZ rJ ÚcÚmÚst_Údct_r$ r$ r% rS Ï sh
|
|
þ
|
|
|
ü
|
üü ÿ
|
|
ûzOneToManyDP.presort_savesc
|
C sî | j s| jdksê| d| ft¡}|D ]Ä}| || j| j¡}|r$|jD ]H}|d k rD| |¡dkrD| ||d d|d¡ | j rD|rD|
|
|||g¡ qD| j s| j j s$t|j |¡D ]:}|d k r¬| ||d d|d¡ | j r¬|r¬|
|
|||g¡ q¬q$d S )Nr r FT)r r rm rn rV r r rL r, rf rt r r r Ú
|
difference)r# rQ rF r r. rZ rJ r$ r$ r% rT sV ÿ
|
ÿ þ ÿ
|
|
ÿ ÿ
|
ÿzOneToManyDP.process_deletesc
|
C sÚ | j j o| jdk }|D ]º}| || jtj¡}|r|jD ]6}| ||d d|d¡ |d k r:| j r:|
|
|||g¡ q:|j D ].}|rx| j jsx| |¡sx| ||d d|d¡ qx| ||¡r|jD ]}| ||d d|d¡ qºqd S )Nr FT)r r r rV r r r r rf r rt rL r, rv r r r$ r$ r% rU 9 s\
|
|
þ ÿ
|
ÿ
|
ÿþý ÿ
|
ÿzOneToManyDP.process_savesc C sp |}|}| |¡ |d ks*| js.| |¡r.d S |rHt || j| jj¡ n$t || j || j| jj|| j
|
oh|¡ d S r' ) ra r Ú
|
is_deletedr Úclearr r r Úpopulater r ) r# r. rJ rd re rQ r ÚsourceÚdestr$ r$ r% rf [ s(
|
ÿÿùzOneToManyDP._synchronizec C s t ||| j| jj¡S r' ©r Úsource_modifiedr r r ru r$ r$ r% rv r s ÿzOneToManyDP._pks_changedN) rx rz r{ r8 rH rR rS rT rU rf rv r$ r$ r$ r% r} G s )C>,"r} c @ sN e Zd Zdd Zdd Zdd Zdd Zd d
|
Zd d Zd d Z dddZ
|
dS )Ú ManyToOneDPc C s. t | |¡ | jjD ]}|j t|¡ qd S r' )r r& r Zself_and_descendantsZ_dependency_processorsrG ÚDetectKeySwitch)r# r r r$ r$ r% r& y s zManyToOneDP.__init__c
|
|
C s | j rbt || jjd¡}t || jjd¡} |j ||f||f||f|| f|| f| |f| |fg¡ n$|j ||f||f||f||fg¡ d S r3 ©r r r r r6 r r )
|
r# r1 r; r< r= r> r9 r: Úparent_post_updatesÚparent_pre_updatesr$ r$ r% r8 ~ s8 ÿ ÿùÿ üÿz%ManyToOneDP.per_property_dependenciesc C sÜ | j r|sZt || jjd¡} |r:|j || f| |fg¡ q|j ||f||f|| fg¡ qØt || jjd¡}
|
|j ||
|
f|
|
|f|
|
|fg¡ nL|sÂ|s®|j ||f||fg¡ qØ|j ||fg¡ n|rØ|j ||fg¡ d S r3 r¤ ) r# r1 r r
rK r9 r: rI rM r¥ r¦ r$ r$ r% rH ¦ sL ÿþÿýÿ ÿýÿÿz"ManyToOneDP.per_state_dependenciesc C s¤ | j js| j jr |D ]}| || j| j¡}|r| j jr@| ¡ }n| ¡ }|D ]P}|d krZqL|j|dd| j d | j
|
d|¡}|D ]\}} }
|
} |j|
|
dd qqLqd S )NTr r r ) r r r rV r r ÚsumZ non_deletedr r r r ) r# rQ rF r. rZ ZtodeleterJ Útr r r r r$ r$ r% rR à s. ÿ
|
üzManyToOneDP.presort_deletesc C s |D ]}|j |d| jd | jjr| || j| j¡}|r|jD ]T}| |¡dkr>|j |dd| jd | j
|
d|¡}|D ]\}}} }
|
|j | dd qvq>qd S )Nr r FTr r r ) r r r r rV r r rL r, r r ) r# rQ rF r. rZ rJ r¨ r r r r r$ r$ r% rS ø s( ÿ
|
üzManyToOneDP.presort_savesc C sn | j rj| jjsj| jdksj|D ]L}| |d d d|¡ |r | j r | || j| j¡}|r | j||| ¡ dd q d S )Nr T)rs )
|
r r r r rf rV r r rt r§ )r# rQ rF r. rZ r$ r$ r% rT s* ÿþý
|
ÿ ÿzManyToOneDP.process_deletesc
|
C s~ |D ]t}| || jtj¡}|r|jrF|jD ]}| ||d d|d¡ q*n|jr`| |d d d|d¡ | jr| ||| ¡ ¡ qd S )NFr Tr )
|
rV r r r r rf rL r rt r§ )r# rQ rF r. rZ rJ r$ r$ r% rU " s8 ÿ
|
ÿ ÿzManyToOneDP.process_savesNc C s¦ |d ks| j s | |¡r d S |d k rX|d k rX|j |¡sXt dt |¡|| jf ¡ d S |sd|d krzt
|
|| j | jj ¡ n(| |¡ t || j|| j | jj |d¡ d S )NúGObject of type %s not in session, %s operation along '%s' won't proceedF)r r ÚsessionÚ_contains_stater ÚwarnÚ
|
mapperutilÚstate_class_strr r r r r ra r r ©r# r. rJ rd re rQ r r$ r$ r% rf 4 s< ÿÿÿþ
|
ýþÿ
|
ùzManyToOneDP._synchronize)N) rx rz r{ r& r8 rH rR rS rT rU rf r$ r$ r$ r% r¢ x s (: ùr¢ c @ sh e Zd ZdZdd Zdd Zdd Zdd Zd
|
d Zd d Z dd Z
|
dd Z dd Z dd Z dd ZdS )r£ a For many-to-one relationships with no one-to-many backref,
|
searches for parents through the unit of work when a primary
|
key has changed and updates them.
|
|
Theoretically, this approach could be expanded to support transparent
|
deletion of objects referenced via many-to-one as well, although
|
the current attribute system doesn't do enough bookkeeping for this
|
to be efficient.
|
|
c C s< | j jr,| jrd S ddd | j jD kr,d S | | d¡ d S )NFc s s | ] }|j V qd S r' )r )rg r r$ r$ r% Ú <genexpr>n s ÿz=DetectKeySwitch.per_property_preprocessors.<locals>.<genexpr>)r rj r r/ r0 r$ r$ r% r2 i s þz*DetectKeySwitch.per_property_preprocessorsc C s6 t || jj¡}t || dd¡}|j ||fg¡ d S rO )r r5 r rB r4 r r )r# r1 r; r9 r$ r$ r% r? v s z*DetectKeySwitch.per_property_flush_actionsc C s d S r' r$ )r# r1 rF rI r$ r$ r% rN { s z'DetectKeySwitch.per_state_flush_actionsc C s d S r' r$ rP r$ r$ r% rR ~ s z DetectKeySwitch.presort_deletesc C s | j s| ||¡ d S r' )r Ú_process_key_switches)r# r1 rF r$ r$ r% rS s z DetectKeySwitch.presort_savesc C s" |s | j r | ||¡}t|S dS rO )r Ú_key_switchersÚbool)r# r1 rF rI Údr$ r$ r% r[ s
|
z DetectKeySwitch.prop_has_changesc C s dst d S rO )rA rP r$ r$ r% rT s z DetectKeySwitch.process_deletesc C s | j s
|
t| ||¡ d S r' )r rA r± rP r$ r$ r% rU s
|
z DetectKeySwitch.process_savesc C sZ | d| fdd ¡\}}| |¡}|D ].}||kr&| ||¡rJ| |¡ q&| |¡ q&|S )NZ pk_switchersc S s t t fS r' )rn r$ r$ r$ r% Ú<lambda> ó z0DetectKeySwitch._key_switchers.<locals>.<lambda>)rm Úunionrv r )r# r1 rF ZswitchedZ notswitchedZ allstatesrY r$ r$ r% r² s ÿ
|
z DetectKeySwitch._key_switchersc
|
C sÈ | ||¡}|rÄ|jj ¡ D ]¦}t|j| jjs2q |j}| | j ¡j
|
||| j d}|t j k r |d k r | jjr||srq |d }n|}t |¡}||kr | |d| j¡ t || j|| j| jj|| j¡ q d S )N)rX r F)r² rª Z identity_mapZ
|
all_statesÚ
|
issubclassr` r rE r+ r Úgetr r ZPASSIVE_NO_RESULTr r_ Zinstance_stater r r r r r ) r# ZdeplistrQ Z switchersr. Zdict_rr Z related_objZ related_stater$ r$ r% r± § sH ÿÿþ
|
|
ÿùz%DetectKeySwitch._process_key_switchesc C s t |jo t ||| j| jj¡S r' )r³ r r r¡ r r r ru r$ r$ r% rv Ì s ÿz DetectKeySwitch._pks_changedN)rx rz r{ Ú__doc__r2 r? rN rR rS r[ rT rU r² r± rv r$ r$ r$ r% r£ ] s %r£ c @ sT e Zd Zdd Zdd Zdd Zdd Zd d
|
Zd d Zd d Z dd Z
|
dd Z dS )Ú ManyToManyDPc
|
C s: |j ||f||f||f||f||f||f||fg¡ d S r' ©r r )r# r1 r; r< r= r> r9 r: r$ r$ r% r8 Ó s ôÿz&ManyToManyDP.per_property_dependenciesc C sX |s<|r"|j ||f||fg¡ qT|j ||f||fg¡ n|j ||f||fg¡ d S r' r¼ ) r# r1 r r
rK r9 r: rI rM r$ r$ r% rH ï s ÿÿÿz#ManyToManyDP.per_state_dependenciesc C s& | j s"|D ]}| || j| j¡ q
|
d S r' )r rV r r )r# rQ rF r. r$ r$ r% rR s ÿz ManyToManyDP.presort_deletesc
|
C s¶ | j s.|D ]"}| ||¡r
|
| || jtj¡}q
|
| jjs:d S |D ]r}| || jtj¡}|r>|j D ]P}|
|
|¡dkr^|j |dd| j d | j d|¡D ]\}}}} |j |dd qq^q>d S )NFTr r r )r rv rV r r r r r r rL r, r r r r )
|
r# rQ rF r. rZ rJ r r r r r$ r$ r% rS s< ÿ ÿ
|
ü ÿzManyToManyDP.presort_savesc
|
sÎ g }g }g }| |¡}t }|D ] | | j| j¡}|r | ¡ D ]F} | d ksB|d k rd | f|krdqBi }
|
| | |
|
d|d¡s~qB| |
|
¡ qB| fdd| ¡ D ¡ q |d k rº| |¡ | ||||¡ d S )NFr c 3 s | ]}| fV qd S r' r$ ©rg r ©r. r$ r% r° U s z/ManyToManyDP.process_deletes.<locals>.<genexpr>)
|
ro rn rV r r Z non_addedrf rG r Ú _run_crud) r# rQ rF Úsecondary_deleteÚsecondary_insertÚsecondary_updateÚ processedÚtmprZ rJ rd r$ r¾ r% rT 6 sN
|
ÿ ÿ
|
ÿú
|
ÿz ManyToManyDP.process_deletesc
|
s g }g }g }| |¡}t }|D ]: | j o8| | ¡}|rFtj} ntj} | | j| ¡}
|
|
|
r |
|
j D ]>} |d k r | f|krqfi } |
|
| | d|d¡sqf| | ¡ qf|
|
j D ]>} |d k rÆ | f|krÆq¬i } |
|
| | d|d¡sàq¬| | ¡ q¬| fdd|
|
j |
|
j D ¡ |r |
|
jD ]D} i } t | j| d| jj¡ t | | j| d| jj¡ | | ¡ qq |d k rr| |¡ | ||||¡ d S )NFr r c 3 s | ]}| fV qd S r' r$ r½ r¾ r$ r% r° s z-ManyToManyDP.process_saves.<locals>.<genexpr>Úold_)ro rn r rv r r r rV r r rf rG rL r r r r r r r Úsecondary_synchronize_pairsr¿ ) r# rQ rF rÀ rÁ r rà rÄ Zneed_cascade_pksrX rZ rJ rd r$ r¾ r% rU ^ s
|
|
ÿ
|
ÿ
|
ú
|
ûû
|
|
ÿzManyToManyDP.process_savesc s |j | j¡}|r|d | j ¡ tj fdd| jjD ¡}| ||¡}|
|
¡ r|j t |krt d| jjt ||j f ¡|rö|d | j ¡ tj fdd| jjD ¡}| ||¡}|
|
¡ rö|j t |kröt d| jjt ||j f ¡|r| j ¡ }| ||¡ d S )Nr c s, g | ]$}|j kr|tj|j |jd kqS )©Útype_©r r Z bindparamÚtyper½ ©rd r$ r% ri ¯ s
|
þz*ManyToManyDP._run_crud.<locals>.<listcomp>zRDELETE statement on table '%s' expected to delete %d row(s); Only %d were matched.c s0 g | ](}|j kr|tjd |j |jdkqS )rÅ rÇ rÉ r½ rË r$ r% ri É s
|
þzRUPDATE statement on table '%s' expected to update %d row(s); Only %d were matched.)Z transactionÚ
|
connectionr r r Úwherer Úand_r ÚexecuteZ supports_sane_multi_rowcountZrowcountÚlenr ZStaleDataErrorÚ descriptionr Úinsert)r# rQ rÁ r rÀ rÌ Z statementÚresultr$ rË r% r¿ ¦ s`
|
|
þÿÿ ÿ þýþÿ
|
|
|
þÿÿ ÿ þýþÿ
|
|
zManyToManyDP._run_crudc C s | |¡ |d krdS |d k rP|j |¡sP|jsLt dt |¡|| jf ¡ dS t
|
|| j || jj ¡ t
|
|| j || jj¡ dS )NFr© T)ra rª r« rL r r¬ r r® r r Z populate_dictr r r rÆ r¯ r$ r$ r% rf ã s0
|
þÿ ÿüzManyToManyDP._synchronizec C s t ||| j| jj¡S r' r ru r$ r$ r% rv s ÿzManyToManyDP._pks_changedN) rx rz r{ r8 rH rR rS rT rU r¿ rf rv r$ r$ r$ r% r» Ò s "(H=!r» N)rº Ú
|
__future__r Ú r r r r r r Z
|
interfacesr r
|
r r! r r r} r¢ r£ r» r( r$ r$ r$ r% Ú<module>
|
s> , 3 fu ; ý
|
