U
|
¸ý°dO% ã @ s$ d dl mZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlm Z d d lm
|
Z
|
d d
|
lm Z d d lm Z d d lm Z d d lmZ d dlZddlmZ ddlmZ e rØddlmZ ddlmZ ededZededZG dd dZ G dd de Z d d d d d d!Z dS )"é )Ú annotations)ÚAny)Úcast)ÚDict)ÚIterable)ÚIterator)ÚList)ÚNoReturn)ÚOptional)ÚSet)ÚTuple)Ú TYPE_CHECKING)ÚTypeVarNé )Úutilé )Úexc)Ú_IdentityKeyType)Ú InstanceStateÚ_T)ÚboundÚ_Oc @ sl e Zd ZU ded< ded< ded< ddd d
|
Zddd d Zd dddZdddddZdddddZdddddZ dd dd d Z
|
dDdd d d!d"d#Z dd$dd%d&Z d'dd(d)Z d*dd+d,Zd-d$dd.d/Zdddd0d1Zdddd2d3Zdddd4d5d6Zdddd7d8Zdddd9d:Zddd;d<Zddd=d>Zdddd?d@ZdAddBdCZd S )EÚ IdentityMapzweakref.ref[IdentityMap]Ú_wrz Dict[_IdentityKeyType[Any], Any]Ú_dictzSet[InstanceState[Any]]Ú _modifiedÚNone©Úreturnc C s i | _ t | _t | ¡| _d S ©N)r Úsetr ÚweakrefÚrefr ©Úself© r% úNd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/orm/identity.pyÚ__init__+ s zIdentityMap.__init__c C s
|
t | _d S r )Ú_killedÚ_add_unpresentr# r% r% r& Ú_kill0 s zIdentityMap._killúList[InstanceState[Any]]c C s
|
t d S r ©ÚNotImplementedErrorr# r% r% r& Ú
|
all_states3 s zIdentityMap.all_statesúInstanceState[Any]Úbool©Ústater c C s
|
t d S r r, ©r$ r2 r% r% r& Úcontains_state6 s zIdentityMap.contains_stateú_IdentityKeyType[Any]©Úkeyr c C s
|
t d S r r, ©r$ r7 r% r% r& Ú __contains__9 s zIdentityMap.__contains__c C s
|
t d S r r, r3 r% r% r& Ú safe_discard< s zIdentityMap.safe_discardú_IdentityKeyType[_O]r c C s
|
t d S r r, r8 r% r% r& Ú __getitem__? s zIdentityMap.__getitem__Nú Optional[_O]©r7 Údefaultr c C s
|
t d S r r, )r$ r7 r? r% r% r& ÚgetB s zIdentityMap.getúOptional[InstanceState[_O]]c C s
|
t d S r r, r8 r% r% r& Úfast_get_stateG s zIdentityMap.fast_get_statez Iterable[_IdentityKeyType[Any]]c C s
|
| j ¡ S r )r Úkeysr# r% r% r& rC L s zIdentityMap.keyszIterable[object]c C s
|
t d S r r, r# r% r% r& ÚvaluesO s zIdentityMap.valuesúInstanceState[_O]c C s
|
t d S r r, r3 r% r% r& ÚreplaceR s zIdentityMap.replacec C s
|
t d S r r, r3 r% r% r& ÚaddU s zIdentityMap.addc C s
|
t d S r r, r3 r% r% r& Ú _fast_discardX s zIdentityMap._fast_discard©r2 r7 r c C s | |¡ dS )zUoptional inlined form of add() which can assume item isn't present
|
in the mapN)rG ©r$ r2 r7 r% r% r& r) [ s zIdentityMap._add_unpresentc C s | j |_|jr| j |¡ d S r )r Ú_instance_dictÚmodifiedr rG r3 r% r% r& Ú_manage_incoming_stateb s z"IdentityMap._manage_incoming_statec C s |` |jr| j |¡ d S r )rK rL r Údiscardr3 r% r% r& Ú_manage_removed_stateh s z!IdentityMap._manage_removed_statec C s | j S r )r r# r% r% r& Ú _dirty_statesm s zIdentityMap._dirty_statesc C s
|
t | jS )z[return True if any InstanceStates present have been marked
|
as 'modified'.
|
|
)r0 r r# r% r% r& Úcheck_modifiedp s zIdentityMap.check_modifiedc C s || kS r r% r8 r% r% r& Úhas_keyw s zIdentityMap.has_keyÚintc C s
|
t | jS r )Úlenr r# r% r% r& Ú__len__z s zIdentityMap.__len__)N)Ú__name__Ú
|
__module__Ú __qualname__Ú__annotations__r' r* r. r4 r9 r: r< r@ rB rC rD rF rG rH r) rM rO rP rQ rR rU r% r% r% r& r % s2
|
ÿr c @ s e Zd ZU ded< dddddZdd dd
|
d Zd d d ddZd dd ddZd d d ddZd dddddZ dddddZ
|
d4dd d d d d Z d!d"d#d$Z d%d"d&d'Z d(d"d)d*Zd+d"d,d-Zd dd d.d/Zd dd d0d1Zd dd d2d3Zd S )5ÚWeakInstanceDictz/Dict[_IdentityKeyType[Any], InstanceState[Any]]r r; r r6 c C s, t d| j| }| ¡ }|d kr(t||S ©NrE )r r ÚobjÚKeyError©r$ r7 r2 Úor% r% r& r< s
|
z WeakInstanceDict.__getitem__r5 r0 c C sL z(|| j kr | j | }| ¡ }nW dS W n tk
|
r> Y dS X |d k S d S ©NF)r r\ r] r^ r% r% r& r9 s
|
|
|
|
z WeakInstanceDict.__contains__r/ r1 c C sR |j | jkrJtr |j d k s tz| j|j |kW S tk
|
rF Y dS X ndS d S r` )r7 r r ÚAssertionErrorr] r3 r% r% r& r4 s
|
z WeakInstanceDict.contains_statez Optional[InstanceState[Any]]c C s |j d k st|j | jkrbz| j|j }}W n tk
|
rF d }Y qfX ||k r\| |¡ qfd S nd }|| j|j < | |¡ |S r )r7 ra r r] rO rM )r$ r2 ÚexistingZexisting_non_noner% r% r& rF s
|
|
zWeakInstanceDict.replacec C s |j }|d k st|| jkrxz| j| }W n tk
|
r> Y n:X ||k rt| ¡ }|d k rxt dt |¡|j f ¡ndS || j|< | |¡ dS )NzZCan't attach instance %s; another instance with key %s is already present in this session.FT)
|
r7 ra r r] r\ Úsa_excÚInvalidRequestErrorÚorm_utilÚ state_strrM )r$ r2 r7 Zexisting_stater_ r% r% r& rG µ s&
|
ýÿ
|
|
zWeakInstanceDict.addr rI c C s || j |< | j|_d S r )r r rK rJ r% r% r& r) Ï s
|
z WeakInstanceDict._add_unpresentrA c C s | j |¡S r )r r@ r8 r% r% r& rB Ö s z WeakInstanceDict.fast_get_stateNr= r> c C sX || j kr|S ztd| j | }W n tk
|
r: | Y S X | ¡ }|d krP|S |S d S r[ )r r r] r\ )r$ r7 r? r2 r_ r% r% r& r@ Û s
|
|
zWeakInstanceDict.getz6List[Tuple[_IdentityKeyType[Any], InstanceState[Any]]]r c C sJ | ¡ }g }|D ]4}| ¡ }|j}|d k s.t|d k r| ||f¡ q|S r )r. r\ r7 ra Úappend)r$ rD Úresultr2 Úvaluer7 r% r% r& Úitemsë s zWeakInstanceDict.itemsz List[object]c C s4 | ¡ }g }|D ] }| ¡ }|d k r| |¡ q|S r )r. r\ rg )r$ rD rh r2 ri r% r% r& rD ö s zWeakInstanceDict.valuesz Iterator[_IdentityKeyType[Any]]c C s t | ¡ S r )ÚiterrC r# r% r% r& Ú__iter__ s zWeakInstanceDict.__iter__r+ c C s t | j ¡ S r )Úlistr rD r# r% r% r& r. s zWeakInstanceDict.all_statesc C sP |j }|d k stz| j| }W n tk
|
r4 Y nX ||krL| j |d ¡ d S r )r7 ra r r] Úpop©r$ r2 r7 Ústr% r% r& rH s z WeakInstanceDict._fast_discardc C s | |¡ d S r )r: r3 r% r% r& rN s zWeakInstanceDict.discardc C sd |j }|| jkr`|d k s tz| j| }W n tk
|
r> Y n"X ||kr`| j |d ¡ | |¡ d S r )r7 r ra r] rn rO ro r% r% r& r: s
|
z WeakInstanceDict.safe_discard)N)rV rW rX rY r< r9 r4 rF rG r) rB r@ rj rD rl r. rH rN r: r% r% r% r& rZ ~ s"
|
ÿ
|
rZ r/ r5 r rI c C s t jdt | ¡ ddd S )NzObject %s cannot be converted to 'persistent' state, as this identity map is no longer valid. Has the owning Session been closed?Zlkrp)Úcode)rc rd re rf )r2 r7 r% r% r& r( & s þür( ) Ú
|
__future__r Útypingr r r r r r r r
|
r r r r r! Ú r re r rc Ú_typingr r2 r r Úobjectr r rZ r( r% r% r% r& Ú<module> s0 Y )
|
