codekingpro/portable-devtools
114k
1�
2 ��j�� � �" � % S r SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SS KJ3r4 SS5KJ r SS KJ r SS KJ
r
SS
KrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SSKJ r SS KJ r SS K J!r! S SKJr" S S KJ#r# S S KJ$r$ S S!K%J&r& S S"K%J'r' \ ( aZ SS#KJ(r( SS$KJ)r) SS%KJ*r* SS&K+J,r, SS'K+J-r- SS(KJ.r. SS)K/J0r0 SS*K1J2r2 SS+K3J4r4 SS,KJ5r5 SS-K6J7r7 SS.K8J9r9 S S/K:J;r; S S0K<J=r> S S1K<J?r? \ ( a S2\@S3' OS
rA\ ( d S
r> " S4 S5\'5 rB " S6 S7\'\ 5 rC\#R� " S8 S9\R� \\ 5 5 rF " S: S;5 rG " S< S=5 rHg
)>z�Defines instrumentation of instances.6 7This module is usually not directly visible to user applications, but8defines a large part of the ORM's interactivity.9 10� )� annotations)�Any)�Callable)�Dict)�Generic)�Iterable)�Optional)�Set)�Tuple)�
TYPE_CHECKING)�UnionN� )�base)�exc)�11interfaces)�_O)�is_collection_impl)� ATTR_WAS_SET)�INIT_OK)�LoaderCallableStatus)� NEVER_SET)�NO_VALUE)�PASSIVE_NO_INITIALIZE)�PASSIVE_NO_RESULT)� PASSIVE_OFF)�SQL_OK)� PathRegistry� )�12inspection)�util)�Literal)�Protocol)�_IdentityKeyType)�
_InstanceDict)�_LoaderCallable)�
AttributeImpl)�History)� PassiveFlag)�_AdaptedCollectionProtocol)� IdentityMap)� ClassManager)� ORMOption)�Mapper)�Session)�Row)�
async_session)� AsyncSessionz)weakref.WeakValueDictionary[int, Session]� _sessionsc � � \ rS rSrSS jrSrg)�_InstanceDictProto�P c � � g �N� ��selfs �ZD:\code\apps\devtools\python\user_packages\Python313\site-packages\sqlalchemy/orm/state.py�__call__�_InstanceDictProto.__call__Q s � �� r8 N)�return�Optional[IdentityMap])�__name__�13__module__� __qualname__�__firstlineno__r< �__static_attributes__r8 r> r; r4 r4 P s � �4r> r4 c �2 � \ rS rSrSr SS jrSrg)�_InstallLoaderCallableProto�T a14 used at result loading time to install a _LoaderCallable callable15upon a specific InstanceState, which will be used to populate an16attribute when that attribute is accessed.17 18Concrete examples are per-instance deferred column loaders and19relationship lazy loaders.20 21c � � g r7 r8 )r: �state�dict_�rows r; r< �$_InstallLoaderCallableProto.__call__^ s � �r> r8 N�rJ �InstanceState[_O]rK r$ rL zRow[Any]r? �None)rA rB rC rD �__doc__r< rE r8 r> r; rG rG T s, � ���&��/<��CK��
�r> rG c � � \ rS rSr% SrSrS\S' SrS\S' SrS \S22' Sr S\S ' S r23S
\S' \ R r
S\S' SrS\S' SrS\S' S\S' S\S' SrS\S' SrS\S' SrS\S ' SrS\S ' SrS\S ' S rS\S ' SrS!\S"' SrS#\S$' S%\S&' \( d S' rS(\S)' S*\S+' \( d \R6 r S_S, jr \R< S`S- j5 r \ SaS. j5 r!\ SaS/ j5 r"\ SaS0 j5 r#\ SaS1 j5 r$\ SaS2 j5 r%\ SaS3 j5 r&\RN \RP " S45 SaS5 j5 5 r)SbS6 jr*\ ScS7 j5 r+\ SdS8 j5 r,\ SeS9 j5 r-\ SfS: j5 r.\ SgS; j5 r/\R< ShS< j5 r0\R< SiS= j5 r1\R< SjS> j5 r2\R< SkS? j5 r3\ SaS@ j5 r4\5 Sl SmSA jj5 r6SnSoSB jjr7SpSC jr8SpSD jr9SqSE jr:\ SrSF j5 r;SsSG jr<StSH jr=SuSI jr>SvSJ jr?SwSK jr@SxSL jrASySM jrBSzSN jrC\5 S{SO j5 rD S|SP jrE Sl S}SQ jjrF S~SR jrG\ SSS j5 rHS�ST jrI\ SSU j5 rJ\ \R� " SVSW5 SSX j5 5 rL\ SSY j5 rM S� S�SZ jjrNS�S[ jrO Sn S�S\ jjrP\5 Sn S�S] jj5 rQS^rRg)��
InstanceState�c a� Tracks state information at the instance level.24 25The :class:`.InstanceState` is a key object used by the26SQLAlchemy ORM in order to track the state of an object;27it is created the moment an object is instantiated, typically28as a result of :term:`instrumentation` which SQLAlchemy applies29to the ``__init__()`` method of the class.30 31:class:`.InstanceState` is also a semi-public object,32available for runtime inspection as to the state of a33mapped instance, including information such as its current34status within a particular :class:`.Session` and details35about data on individual attributes. The public API36in order to acquire a :class:`.InstanceState` object37is to use the :func:`_sa.inspect` system::38 39 >>> from sqlalchemy import inspect40 >>> insp = inspect(some_mapped_object)41 >>> insp.attrs.nickname.history42 History(added=['new nickname'], unchanged=(), deleted=['nickname'])43 44.. seealso::45 46 :ref:`orm_mapper_inspection_instancestate`47 48)�__dict__� __weakref__�class_�manager�obj�committed_state�expired_attributes�ClassManager[_O]rX Nz
Optional[int]�49session_id� Optional[_IdentityKeyType[_O]]�key�runidr8 zTuple[ORMOption, ...]� load_optionsr � load_path� insert_orderzOptional[object]� _strong_obj�weakref.ref[_O]rY �Dict[str, Any]rZ F�bool�modified�expired�_deleted�
_load_pending� _orphaned_outside_of_sessionT� is_instance�object�identity_tokenzOptional[Dict[str, Any]]�_last_known_valuesr4 �_instance_dictc � � g)z+default 'weak reference' for _instance_dictNr8 r9 s r; rq � InstanceState._instance_dict� s � �r> �Set[str]r[ z:Dict[str, Callable[[InstanceState[_O], PassiveFlag], Any]]� callablesc � � UR U l X l [ R " XR50 5 U l 0 U l [ 5 U l g r7 )51� __class__rW rX �weakref�ref�_cleanuprY rZ �setr[ )r: rY rX s r; �__init__�InstanceState.__init__� s8 � ��m�m�� � � ��;�;�s�M�M�2��� !�� �"%�%�� r> c 52 � � [ R " U R Vs0 s H o[ X5 _M sn5 $ s snf )a) Return a namespace representing each attribute on53the mapped object, including its current value54and history.55 56The returned object is an instance of :class:`.AttributeState`.57This object allows inspection of the current data58within an attribute as well as attribute history59since the last flush.60 61)r �ReadOnlyPropertiesrX �AttributeState�r: r_ s r; �attrs�InstanceState.attrs� s8 � � �&�&�7;�|�|� D�|��.��+�
+�|� D�62� 63�� Ds �;c �N � U R SL =( a U R ( + $ )zeReturn ``True`` if the object is :term:`transient`.64 65.. seealso::66 67 :ref:`session_object_states`68 69N�r_ � _attachedr9 s r; � transient�InstanceState.transient� s � � �x�x�4� �6����$6�6r> c �D � U R SL =( a U R $ )zcReturn ``True`` if the object is :term:`pending`.70 71.. seealso::72 73 :ref:`session_object_states`74 75Nr� r9 s r; �pending�InstanceState.pending� s � � �x�x�4� �2�D�N�N�2r> c �j � U R SL=( a U R =( a U R $ )a` Return ``True`` if the object is :term:`deleted`.76 77An object that is in the deleted state is guaranteed to78not be within the :attr:`.Session.identity_map` of its parent79:class:`.Session`; however if the session's transaction is rolled80back, the object will be restored to the persistent state and81the identity map.82 83.. note::84 85 The :attr:`.InstanceState.deleted` attribute refers to a specific86 state of the object that occurs between the "persistent" and87 "detached" states; once the object is :term:`detached`, the88 :attr:`.InstanceState.deleted` attribute **no longer returns89 True**; in order to detect that a state was deleted, regardless90 of whether or not the object is associated with a91 :class:`.Session`, use the :attr:`.InstanceState.was_deleted`92 accessor.93 94.. versionadded: 1.195 96.. seealso::97 98 :ref:`session_object_states`99 100N�r_ r� rj r9 s r; �deleted�InstanceState.deleted� s% � �8 �x�x�t�#�H����H�4�=�=�Hr> c � � U R $ )a� Return True if this object is or was previously in the101"deleted" state and has not been reverted to persistent.102 103This flag returns True once the object was deleted in flush.104When the object is expunged from the session either explicitly105or via transaction commit and enters the "detached" state,106this flag will continue to report True.107 108.. seealso::109 110 :attr:`.InstanceState.deleted` - refers to the "deleted" state111 112 :func:`.orm.util.was_deleted` - standalone function113 114 :ref:`session_object_states`115 116)rj r9 s r; � was_deleted�InstanceState.was_deleted s � �& �}�}� r> c �t � U R SL=( a$ U R =( a U R ( + $ )z�Return ``True`` if the object is :term:`persistent`.117 118An object that is in the persistent state is guaranteed to119be within the :attr:`.Session.identity_map` of its parent120:class:`.Session`.121 122.. seealso::123 124 :ref:`session_object_states`125 126Nr� r9 s r; �127persistent�InstanceState.persistent) s( � � �x�x�t�#�L����L�t�}�}�;L�Lr> c �N � U R SL=( a U R ( + $ )zdReturn ``True`` if the object is :term:`detached`.128 129.. seealso::130 131 :ref:`session_object_states`132 133Nr� r9 s r; �detached�InstanceState.detached8 s � � �x�x�t�#�:�D�N�N�(:�:r> zsqlalchemy.orm.sessionc � � U R S L=( a1 U R [ R R R ; $ r7 )r] r � preloaded� orm_sessionr2 r9 s r; r� �InstanceState._attachedC s7 � �
�O�O�4� '�
H����4�>�>�#=�#=�#G�#G�G� 134r> c �P � U R nUc 0 =U l nX; a [ X!' gg)zdTrack the last known value of a particular key after expiration135operations.136 137.. versionadded:: 1.3138 139N)rp r )r: r_ �lkvs r; �_track_last_known_value�%InstanceState._track_last_known_valueK s2 � � �%�%�� �;�,.� .�D� #�c� �>� �C�H� r> c �n � U R ( a [ U R $ g! [ a gf = f)a� Return the owning :class:`.Session` for this instance,140or ``None`` if none available.141 142Note that the result here can in some cases be *different*143from that of ``obj in session``; an object that's been deleted144will report as not ``in session``, however if the transaction is145still in progress, this attribute will still refer to that session.146Only when the transaction is completed does the object become147fully detached under normal circumstances.148 149.. seealso::150 151 :attr:`_orm.InstanceState.async_session`152 153N)r] r2 �KeyErrorr9 s r; �session�InstanceState.sessionY s; � �" �?�?�
� �� � �1�1� �� �
���
�s �' �1544�4c �H � [ c gU R nUb [ U5 $ g)a� Return the owning :class:`_asyncio.AsyncSession` for this instance,155or ``None`` if none available.156 157This attribute is only non-None when the :mod:`sqlalchemy.ext.asyncio`158API is in use for this ORM object. The returned159:class:`_asyncio.AsyncSession` object will be a proxy for the160:class:`_orm.Session` object that would be returned from the161:attr:`_orm.InstanceState.session` attribute for this162:class:`_orm.InstanceState`.163 164.. versionadded:: 1.4.18165 166.. seealso::167 168 :ref:`asyncio_toplevel`169 170N)�_async_providerr� )r: �sesss r; r0 �InstanceState.async_sessionq s* � �& � "���|�|�� � �"�4�(� (�r> c �" � U R 5 $ )z~Return the mapped object represented by this171:class:`.InstanceState`.172 173Returns None if the object has been garbage collected174 175)rY r9 s r; rn �InstanceState.object� s � � �x�x�z�r> c �< � U R c gU R S $ )a� Return the mapped identity of the mapped object.176This is the primary key identity as persisted by the ORM177which can always be passed directly to178:meth:`_query.Query.get`.179 180Returns ``None`` if the object has no primary key identity.181 182.. note::183 An object which is :term:`transient` or :term:`pending`184 does **not** have a mapped identity until it is flushed,185 even if its attributes include primary key values.186 187Nr �r_ r9 s r; �identity�InstanceState.identity� s � � �8�8� ���8�8�A�;� r> c � � U R $ )z�Return the identity key for the mapped object.188 189This is the key used to locate the object within190the :attr:`.Session.identity_map` mapping. It contains191the identity as returned by :attr:`.identity` within it.192 193 194r� r9 s r; � identity_key�InstanceState.identity_key� s
� � �x�x�r> c � � 0 $ r7 r8 r9 s r; �parents�InstanceState.parents� � � �� r> c � � 0 $ r7 r8 r9 s r; �_pending_mutations� InstanceState._pending_mutations� r� r> c � � 0 $ r7 r8 r9 s r; �_empty_collections� InstanceState._empty_collections� r� r> c �. � U R R $ )z<Return the :class:`_orm.Mapper` used for this mapped object.)rX �mapperr9 s r; r� �InstanceState.mapper� s � � �|�|�"�"�"r> c �, � [ U R 5 $ )z�Return ``True`` if this object has an identity key.195 196This should always have the same value as the197expression ``state.persistent`` or ``state.detached``.198 199)rg r_ r9 s r; � has_identity�InstanceState.has_identity� s � � �D�H�H�~� r> c �R � UR R =( d S nUR R =( d S nUR R =( d S nUR R =( d S nU H� nUR200 n UR S L n201U202( + =( a U ( + n S Ul U( a UR ( a U?U ( a U( a Ub U" X(5 O1Ub U" X(5 O%U ( a Ub U" X(5 OU203( a Ub U" X(5 S Ul M� g r7 ) �dispatch�persistent_to_detached�deleted_to_detached�pending_to_transient�persistent_to_transientrj r_ r] rd ) r: �statesr� � to_transientr� r� r� r� rJ r� r� r� s r; �_detach_states� InstanceState._detach_states� s� � �
� � � 3� 3� ;�t� � &� .� .� B� B� J�d�� &� /� /� D� D� L�� � � � � 4� 4� <�� � �E��n�n�G��i�i�4�'�G� $��4�W��J� #�E� ��� � ��I�� �.�:�/��?��+�7�*�7�:��� 0� <�#�G�3�� 1� =�$�W�4� $�E� �) r> c �^ � U( a [ R U /U5 g S =U l U l g r7 )rS r� r] rd )r: r� s r; �_detach�InstanceState._detach� s& � � � � (� (�$��� 9�15� 5�D�O�d� .r> c �$ � U R 5 g r7 )r� r9 s r; �_dispose�InstanceState._dispose� s � � � � �r> c � � U R b eU R 5 nUc gAU R U R 5 S U l g)z�Force this InstanceState to act as though its weakref has204been GC'ed.205 206this is used for test code that has to test reactions to objects207being GC'ed. We can't reliably force GCs to happen under all208CI circumstances.209 210Nc � � g r7 r8 r8 r> r; �<lambda>�2InstanceState._force_dereference.<locals>.<lambda> s � �4r> )rd rY rz )r: rY s r; �_force_dereference� InstanceState._force_dereference sC � � � � �'�'�'��h�h�j�� �;� � � �
�
�d�h�h� � ��r> c �| � [ c gU R 5 nUb UR U 5 U ?S=U l U l g)z�Weakref callback cleanup.211 212This callable cleans out the state when it is being garbage213collected.214 215this _cleanup **assumes** that there are no strong refs to us!216Will not work otherwise!217 218N)�dictrq �
_fast_discardr] rd )r: ry �
instance_dicts r; rz �InstanceState._cleanup sE � � �<� � �+�+�-�
� � $� � '� '�� -��#� .2�1���$�*r> c �X � U R 5 nUb [ R " U5 $ 0 $ )aG Return the instance dict used by the object.219 220Under normal circumstances, this is always synonymous221with the ``__dict__`` attribute of the mapped object,222unless an alternative instrumentation system has been223configured.224 225In the case that the actual object has been garbage226collected, this accessor returns a blank dictionary.227 228)rY r r� )r: �os r; r� �InstanceState.dict8 s* � �
�H�H�J�� �=��%�%�a�(� (��Ir> c �B � U S U S U SS pCnUR nUR R X$U5 UR " U SS 0 UD6 g ! [ R229 " 5 UR R
X$U5 S S S 5 g ! , ( d f g = f= f)Nr r r )rX r� �init�
original_initr � safe_reraise� init_failure)�mixed�kwargsr: �instance�argsrX s r; �_initialize_instance�"InstanceState._initialize_instanceK s� � � $�Q�x��q��5���9����,�,����� � �d�&�1� B� � !� !�5���9� 7�� 7�� B��"�"�$�� � �-�-�d�&�A� %�$�$�$�s) �A �B �% B �B � 230B �B �B c �h � U R U R R X R U5 $ r7 )rX �impl� get_historyr� )r: r_ �passives r; r� �InstanceState.get_historyW s( � ��|�|�C� �%�%�1�1�$� � �7�K�Kr> c �4 � U R U R $ r7 )rX r� r� s r; �get_impl�InstanceState.get_implZ s � ��|�|�C� �%�%�%r> c �l � XR ; a [ 5 U R U' U R U $ r7 )r� �PendingCollectionr� s r; �_get_pending_mutation�#InstanceState._get_pending_mutation] s2 � � �-�-� -�+<�+>�D� #� #�C� (��&�&�s�+�+r> c �> ^ � T R 5 T R T R T R S.nUR U 4S jS 5 5 T R231 ( a T R232 R
5 US' T R R T U5 US' U$ )N)r� rW rZ r[ c 3 �j ># � U H( nUTR ; d M UTR U 4v � M* g 7fr7 )rU )�.0�kr: s �r; � <genexpr>�-InstanceState.__getstate__.<locals>.<genexpr>i s: �� � � 233� �� �D�M�M�!�
"�Q��
�
�a� � !� �s �3�3)234r� rh ri ru r_ r� ra rW r[ �inforb rX ) rY rW rZ r[ �updaterb � serializerX �235_serialize)r: �236state_dicts ` r; � __getstate__�InstanceState.__getstate__b s� �� � ���237��k�k� #� 3� 3�"&�"9�"9� &238�239� ��� 240� �241� 242� �>�>�&*�n�n�&>�&>�&@�J�{� #� $� � � 7� 7��j� I�243�9� ��r> c �l � US nUb7 [ R " X R 5 U l UR U l OS U l US U l UR
S0 5 U l UR
S0 5 U l UR
S0 5 U l UR
SS5 U l244 UR
S S5 U l S245U; a U R R US246 5 S U; a US U l US U l O S U; a US U l O[! 5 U l U R" R S
Vs/ s H nX1; d M247 X1U 4PM sn5 U R$ ( a U R$ S U l SU; a [( R* " US 5 U l US " XU5 g s snf )Nr� c � � g r7 r8 r8 r> r; r� �,InstanceState.__setstate__.<locals>.<lambda>� s � �tr> rW rZ r� r� rh Fri r� ru r[ )r_ ra r rb rX )rx ry rz rY rw rW �getrZ r� r� rh ri r� r� ru r[ r{ rU r_ ro r � deserializerb )r: r �instr� s r; � __setstate__�InstanceState.__setstate__� s� � ��*�%�� � � �{�{�4� � �7�D�H� �.�.�D�K�#�D�H�$�X�.�D�K� )�~�~�.?�� D�� �",�.�.�1E�r�"J�� �!�~�~�i��4�� �"���z�5�9��
�!�~�~�i��7�� � �Z� � �I�I� � �Z�� /� 0� �*� $� '� � 4�D�N�&0�1E�&F�D� #�#�z�1�*4�5I�*J��'�*-�%��'� �
�
� � � 1�
�0�A��?� #��q�M�"�0�
� 248� �8�8�"&�(�(�1�+�D� � �*� $� )� 5� 5�j��6M� N�D�N��9� �d�*�5��
s �= F1�249 250F1c �4 � UR US5 nU R U R nUb! [ U5 ( a UR U5 U R251 R
U5 U R ( a U R R US5 gg)z@Remove the given attribute and any252callables associated with it.N)�poprX r� r �_invalidate_collectionr[ �discardru )r: rK r_ �old� manager_impls r; �_reset�InstanceState._reset� sz � � �i�i��T�"���|�|�C�(�-�-� � �?� 1�,� ?� ?� � /� /�� 4� � � �'�'��,� �>�>� �N�N� � �s�D� )� r> c �Z � SUR ; a [ UR 5 U l g g �Nru )rU r� ru )r: �from_s r; �_copy_callables� InstanceState._copy_callables� s# � � �%�.�.� (� !�%�/�/� 2�D�N� )r> c � ^^^� UT R n[ U5 ( a Um SUUU4S jjnU$ SUU4S jjnU$ )Nc � >� SU R ; a 0 U l UR TS 5 nUb TR U5 TU R T' g r )rU ru r
r )rJ rK rL r �253fixed_impl�fnr_ s ���r; �
_set_callable�GInstanceState._instance_level_callable_processor.<locals>._set_callable� sI �� � �e�n�n�4�&(�E�O��i�i��T�*���?� �5�5�c�:�')�����$r> c �R >� SU R ; a 0 U l TU R T' g r )rU ru )rJ rK rL r r_ s ��r; r r � s& �� � �e�n�n�4�&(�E�O�')�����$r> rN )r� r )�clsrX r r_ r� r r s `` @r; �"_instance_level_callable_processor�0InstanceState._instance_level_callable_processor� s� �� � �s�|� � �� �d� #� #� �J�
*�(�
*�1>�
*�EM�
*��
*�
*�& � �
*�(�
*�1>�
*�EM�
*��
*�
*� � r> c �: � SU l U R ( a2 UR U 5 U R R 5 SU l S U l SU R ; a
U R S SU R ; a
U R S U R R U R R Vs/ s H o3R PM sn5 U R ( a9 U R R U R 5 H nU R U M U R R R U5 H% nUR U5 nSUR l M' U R$ ( a@ U R$ R U R$ Vs0 s H oDU; d M254 XAU _M sn5 U R R& R U5 H nX M U R R( R+ U S 5 g s snf s snf )NTFr� r� )ri rh r rZ �clearrd rU r[ r� rX �
_loader_implsr_ ru � intersection�_collection_impl_keysr
� _sa_adapter� invalidatedrp � _all_key_setr� �expire)r: rK � modified_setr� r� �255collectionr_ s r; �_expire�InstanceState._expire� s� � � �� � �=�=� � � �� &� � � � &� &� (� !�D�M� ��� �4�=�=� 0��
�
� 2�3� ��
�
� %��
�
�i�(� � � �&�&�"&�,�,�"<�"<� =�"<�$�X�X�"<� =� 256� �>�>� �,�,�9�9�$�.�.�I���N�N�1�%� J� � � �3�3�@�@��G�A� ���1� �J�15�J� "� "� .� H� � "� "� � #� #� *� *�&*�&=�&=�L�&=��e����!�H��&=�L�
� �<�<�,�,�9�9�%�@�C��257� A�
� � � � �$�$�T�4�0��=
>��0 Ms �9H�! H�. Hc �� � U R R SS 5 nU R nU GH nU R U R nUR258 ( aH U( a UR ( d Xe; a MM U R R U5 U( a Xe; a XV UR U[ 5 n[ U5 ( a U[ La UR U5 U R n U b Xi; a
U[ La X�U' U R R US 5 U( d M� UR US 5 GM U R R R! X5 g )Nr� )rU r ru rX r� �accepts_scalar_loader� callable_r[ �addr
r r r rp rZ r� r+ )259r: rK �attribute_names� no_loaderr� ru r_ r� r r� s260 r; �_expire_attributes� InstanceState._expire_attributes s � � �-�-�#�#�$8�$�?���N�N� �"�C��<�<��$�)�)�D��)�)� �$�.�.�C�4D� ��'�'�+�+�C�0� ��!1�!���)�)�C��*�C�!�$�'�'�C�x�,?��+�+�C�0��)�)�C���3�:�#�X�2E� �C�� � � � $� $�S�$� /��w�� � �C��&�' #�*
� � � � �$�$�T�;r> c �$ ^ � U[ - ( d [ $ T R R T R 5 nUR U 4S jU 5 5 nT R R T X25 T R R 5 [ $ )z�__call__ allows the InstanceState to act as a deferred261callable for loading expired attributes, which is also262serializable (picklable).263 264c 3 �| ># � U H1 nTR U R R ( a M- Uv � M3 g 7fr7 )rX r� �load_on_unexpire�r� �attrr: s �r; r� �.InstanceState._load_expired.<locals>.<genexpr>6 s2 �� � � #265� ���<�<��%�*�*�;�;�
�D� �� �,<� <)266r r r[ r& �267unmodified�268differencerX �expired_attribute_loaderr$ r )r: rJ r� �toloads ` r; �
_load_expired�InstanceState._load_expired) sz �� � �� �$� $��(�(�5�5�d�o�o�F���"�"� #269� �#270� 271��
� � �-�-�d�F�D�
� � �%�%�'��r> c �^ � [ U R 5 R U R 5 $ )z8Return the set of keys which have no uncommitted changes)r{ rX r@ rZ r9 s r; r? �InstanceState.unmodifiedF s$ � � �4�<�<� �+�+�D�,@�,@�A�Ar> c �| � [ U5 R U R 5 R U R 5 $ )z*Return self.unmodified.intersection(keys).)r{ r& rX r@ rZ )r: �keyss r; �unmodified_intersection�%InstanceState.unmodified_intersectionL s. � �
��I�
�\�$�,�,�
'�
�Z��,�,�
-� 272r> c � � [ U R 5 R U R 5 R U R 5 $ )z�Return the set of keys which do not have a loaded value.273 274This includes expired attributes and any other attribute that was never275populated or modified.276 277)r{ rX r@ rZ r� r9 s r; �unloaded�InstanceState.unloadedU s3 � �
�� � � �
�Z��,�,�
-�
�Z�� � �
"� 278r> z2.0zsThe :attr:`.InstanceState.unloaded_expirable` attribute is deprecated. Please use :attr:`.InstanceState.unloaded`.c � � U R $ )z�Synonymous with :attr:`.InstanceState.unloaded`.279 280This attribute was added as an implementation-specific detail at some281point and should be considered to be private.282 283)rL r9 s r; �unloaded_expirable� InstanceState.unloaded_expirablec s � � �}�}� r> c �b ^ � T R R U 4S jT R 5 5 $ )Nc 3 �| ># � U H1 nTR U R R ( d M- Uv � M3 g 7fr7 )rX r� r1 r; s �r; r� �5InstanceState._unloaded_non_object.<locals>.<genexpr>t s2 �� � � *284�$���|�|�D�!�&�&�<�<�
�D�$�r> )rL r& rX r9 s `r; �_unloaded_non_object�"InstanceState._unloaded_non_objectr s+ �� ��}�}�)�)� *285� � � �*286� 287� 288r> c �� � U( Ga# UR ( d g U( a3 UR U; a# [ R " SUR - 5 eUR U R ; d U( a� U( af [289 ( a [
U5 ( d eU[ L a UR U; a XR nUS [ [ 4; a UR U5 nX0R UR ' U R nUb" UR U; a [ XbR ' U R ( a
U R b U R ( Gd SU l
U R 5 nU( a1 [ UR 5 nUR R# U 5 OSnU R% 5 n U R ( a> X�l U( d1 [& U R n290U291R( c U292R+ 5 U cR U( aJ [. R0 " SU R2 UR < S[4 R6 " U 5 < S35 eg g g ! [, a Ncf = f)NzHCan't flag attribute '%s' modified; it's not present in the object stateTFz'Can't emit change event for attribute 'z' - parent object of type z has been garbage collected.) �send_modified_eventsr_ �sa_exc�InvalidRequestErrorrZ r r r r �copyrp r] rd rh rq rg � _modifiedr3 rY r2 � _transaction� _autobegin_tr� �orm_exc�ObjectDereferencedErrorrX r �state_class_str) r: rK r< �previousr- � is_userlandr� r� � has_modifiedr r� s r; �_modified_event� InstanceState._modified_eventz s� � � ��,�,���t�x�x�u� 4� �0�0�'�)-���2�� � �x�x�t� 3� 3�3�{� �$�}� 1�$� 7� 7�7� 7� �9�,� �8�8�u�,�',�X�X��H� ��h� �'B�B�#'�9�9�X�#6��19�$�$�T�X�X�.��)�)�C���4�8�8�s�?� (��H�H�
�
�O�O�� 0� 0� 8�� � � � �D�M� � /� /� 1�M� � #�M�$;�$;� <� � �'�'�+�+�D�1� $� �293 �8�8�:�D����#'� �294 $�3�"+�D�O�O�"<�� #�/�/�7� #� 0� 0� 2��|�� �5�5� �|�|�D�H�H�-�t�/C�/C�D�/I�K�� � !%�|�= BO��0 $� � � �s � I# �#295I0�/I0c �t � U H nU R R US5 M! SU l U R R [ U5 R
U5 5 U R ( aH [ U R 5 R
U5 R
U5 H nU R U M gg)a Commit attributes.296 297This is used by a partial-attribute load operation to mark committed298those attributes which were refreshed from the database.299 300Attributes marked as "expired" can potentially remain "expired" after301this step if a value was not populated in state.dict.302 303NF)rZ r
ri r[ �difference_updater{ r& ru )r: rK rH r_ s r; �_commit�InstanceState._commit� s� � � �C� � � � $� $�S�$� /� � �� � � � �1�1� ��I� "� "�5� )� 304� �>�>��D�N�N�#�0�0��6�C�C�E�J� � �N�N�3�'� K� r> c �, � U R X4/U5 g)a commit all attributes unconditionally.305 306This is used after a flush() or a full load/refresh307to remove all pending state from the instance.308 309 - all attributes are marked as "committed"310 - the "strong dirty reference" is removed311 - the "modified" flag is set to False312 - any "expired" markers for scalar attributes loaded are removed.313 - lazy load callables for objects / collections *stay*314 315Attributes marked as "expired" can potentially remain316"expired" after this step if a value was not populated in state.dict.317 318N)�_commit_all_states)r: rK r� s r; � _commit_all�InstanceState._commit_all� s � �$
� � �$� �� �?r> c �> � U H� u p4UR nUR R 5 SU; a US UR R U5 U( a, UR319 ( a UR R U5 S=Ul Ul SUl M� g)z.Mass / highly inlined version of commit_all().r� FN)320rU rZ r$ r[ rg rh r[ r ri rd )r: �iter_r� rJ rK r s r; rk � InstanceState._commit_all_states� s� � � "�L�E� � � �J� � !� !� '� '� )�#�z�1� � 3�4� � $� $� 6� 6�u� =� �� � � �'�'�/�/��6�-2� 2�E�N�U�]� $�E� � "r> )rp r� rd ru rW rZ ri r[ ro rb rX rh rY r� r] )rY r rX r\ )r? z'util.ReadOnlyProperties[AttributeState])r? rg )r_ �strr? rP )r? �Optional[Session])r? zOptional[AsyncSession])r? z Optional[_O])r? zOptional[Tuple[Any, ...]])r? r^ )r? z4Dict[int, Union[Literal[False], InstanceState[Any]]])r? z Dict[str, PendingCollection])r? z%Dict[str, _AdaptedCollectionProtocol])r? z321Mapper[_O])F)r� zIterable[InstanceState[_O]]r� r. r� rg r? rP r7 )r� rr r? rP �r? rP )ry re r? rP )r? r$ )r� r r� r r? rP )r_ rq r� r( r? r' )r_ rq r? r& )r_ rq r? r� )r? rf )r rf r? rP )rK r$ r_ rq r? rP )r �InstanceState[Any]r? rP )rX r\ r r% r_ r r? z _InstallLoaderCallableProto[_O])rK r$ r, zSet[InstanceState[Any]]r? rP )rK r$ r4 �
Iterable[str]r5 rg r? rP )rJ rO r� r( r? r )r? rt )rH ru r? rt )FF) rK r$ r< zOptional[AttributeImpl]ra r r- rg rb rg r? rP )rK r$ rH ru r? rP )rK r$ r� r@ r? rP )ro z2Iterable[Tuple[InstanceState[Any], _InstanceDict]]r� r@ r? rP )SrA rB rC rD rQ � __slots__�__annotations__r] r_ r` ra r �rootrb rc rd rh ri rj rk rl rm ro rp r rq r �322EMPTY_DICTru r| �memoized_propertyr� �propertyr� r� r� r� r� r� �non_memoized_property�preload_moduler� r� r� r0 rn r� r� r� r� r� r� r� � classmethodr� r� r� r� rz r� r� r� r� r� r r323 r r r! r. r6 rC r? rI rL �324deprecatedrO rT rd rh rl rk rE r8 r> r; rS rS c s � ��6�I� � � $�J�
�$�*.�C� '�.� �E�=� �*,�L�'�,� *� /� /�I�|�/�"&�L�-�&�$(�K�!�(� ��#�#��H�d��0��G�T��� �H�d�� �M�4� �).� �$�.� �K�� � !�N�F�!�37��0�7�&�&�� � � !� �� J�I� � ��O�O� �(� 325���
326� �
327� �7� �7� �3� �3� �I� �I�: � � � �( � M� � M� �;� �;� 328� � � ���1�2�329� 3� �330� � �� ��. �� ��6 �� �� � � � �& � � � � 331���� �� 332���� �� 333���� �� 334���#� �#� � � � � �335 #� #%�+�#%� �#%� � #%�336 337� #%� �#%�J6� � �22�: �� ��$338B�L�&�,�339 �<'6�R340*�3� � �&� �,;� �BE� � (� � � �801�"�01�2I�01�
�01�l � <� � <� '� <� � <�341 342� <�B �&� �1<� � � �: �B� �B�343344� � 345� � 346� � �_�_�
� C��347 � � � � �348� �349� !� !�
F� �F� &�F� � F�350 � F� �
F� 351�F�P(�< LP�@�"�@�3H�@�
�@�( � 04�%�A�%� -�%� 352� %� �%r> rS c � � \ rS rSr% SrSrS\S' S\S' SS jr\SS j5 r \SS353 j5 r354\SS j5 r SS jr S
r
g)r� i aj Provide an inspection interface corresponding355to a particular attribute on a particular mapped object.356 357The :class:`.AttributeState` object is accessed358via the :attr:`.InstanceState.attrs` collection359of a particular :class:`.InstanceState`::360 361 from sqlalchemy import inspect362 363 insp = inspect(some_mapped_object)364 attr_state = insp.attrs.some_attribute365 366�rJ r_ rt rJ rq r_ c � � Xl X l g r7 r� )r: rJ r_ s r; r| �AttributeState.__init__ s � ��367��r> c �j � U R R R U R [ 5 $ )z�The current value of this attribute as loaded from the database.368 369If the value has not been loaded, or is otherwise not present370in the object's dictionary, returns NO_VALUE.371 372)rJ r� r r_ r r9 s r; � loaded_value�AttributeState.loaded_value$ s# � � �z�z���"�"�4�8�8�X�6�6r> c �� � U R R U R R U R R 5 U R R373 5 $ )z�Return the value of this attribute.374 375This operation is equivalent to accessing the object's376attribute directly or via ``getattr()``, and will fire377off any pending loader callables if needed.378 379)rJ rX r_ �__get__rY rW r9 s r; �value�AttributeState.value. sD � � �z�z�!�!�$�(�(�+�3�3� �J�J�N�N� �d�j�j� /� /�380� 381r> c �V � U R R U R [ 5 $ )a� Return the current **pre-flush** change history for382this attribute, via the :class:`.History` interface.383 384This method will **not** emit loader callables if the value of the385attribute is unloaded.386 387.. note::388 389 The attribute history system tracks changes on a **per flush390 basis**. Each time the :class:`.Session` is flushed, the history391 of each attribute is reset to empty. The :class:`.Session` by392 default autoflushes each time a :class:`_query.Query` is invoked.393 For394 options on how to control this, see :ref:`session_flushing`.395 396 397.. seealso::398 399 :meth:`.AttributeState.load_history` - retrieve history400 using loader callables if the value is not locally present.401 402 :func:`.attributes.get_history` - underlying function403 404)rJ r� r_ r r9 s r; �history�AttributeState.history; s � �4 �z�z�%�%�d�h�h�0E�F�Fr> c �d � U R R U R [ [ - 5 $ )a� Return the current **pre-flush** change history for405this attribute, via the :class:`.History` interface.406 407This method **will** emit loader callables if the value of the408attribute is unloaded.409 410.. note::411 412 The attribute history system tracks changes on a **per flush413 basis**. Each time the :class:`.Session` is flushed, the history414 of each attribute is reset to empty. The :class:`.Session` by415 default autoflushes each time a :class:`_query.Query` is invoked.416 For417 options on how to control this, see :ref:`session_flushing`.418 419.. seealso::420 421 :attr:`.AttributeState.history`422 423 :func:`.attributes.get_history` - underlying function424 425)rJ r� r_ r r r9 s r; � load_history�AttributeState.load_historyW s$ � �. �z�z�%�%�d�h�h� �g�0E�F�Fr> )r_ rJ N)rJ rt r_ rq )r? r )r? r' )rA rB rC rD rQ rv rw r| r{ r� r� r� r� rE r8 r> r; r� r� sb � � � !�I� � � �H�� �7� �7� �426427� �428429� �G� �G�6Gr> r� c �Z � \ rS rSr% SrSrS\S' S\S' SS jrSS jrSS430 jr SS jr431S r g
)r� iq a A writable placeholder for an unloaded collection.432 433Stores items appended to and removed from a collection that has not yet434been loaded. When the collection is loaded, the changes stored in435PendingCollection are applied to it to produce the final result.436 437)�
deleted_items� added_itemszutil.IdentitySetr� zutil.OrderedIdentitySetr� c �l � [ R " 5 U l [ R " 5 U l g r7 )r � IdentitySetr� �OrderedIdentitySetr� r9 s r; r| �PendingCollection.__init__ s$ � � !� -� -� /��� �2�2�4��r> c �N � UR U R U R 5 $ r7 )�_merger� r� )r: r� s r; �merge_with_history�$PendingCollection.merge_with_history� s � ��~�~�d� .� .��0B�0B�C�Cr> c � � XR ; a U R R U5 g U R R U5 g r7 )r� �remover� r3 �r: r� s r; �append�PendingCollection.append� s6 � � �&�&� &� � � � %� %�e� ,� � � � � �� 'r> c � � XR ; a U R R U5 g U R R U5 g r7 )r� r� r� r3 r� s r; r� �PendingCollection.remove� s6 � � �$�$� $� � � � #� #�E� *� � � � "� "�5� )r> )r� r� Nrs )r� r' r? r' )r� r r? rP ) rA rB rC rD rQ rv rw r| r� r� r� rE r8 r> r; r� r� q s/ � �� 1�I�#�#�(�(�5�D�(� *r> r� )IrQ �438__future__r �typingr r r r r r r439 r r r
rx � r r r^ r �_typingr r r r r r r r r r r �
path_registryr rX r r � util.typingr! r" r# r$ r% �440attributesr& r' r( � collectionsr) r� r* �instrumentationr+ r, r� r- r� r. �enginer/ �ext.asyncio.sessionr0 r� r1 rw r2 r4 rG �_self_inspects�InspectionAttrInforS r� r� r8 r> r; �<module>r� s ��� #� � � � � � � � � � � � � � � � '� � � &� � � '� #� � � '� � � � !� "��)�&�(�)�#�!�7�%�-�%� � � �F�2��8�8� �I� � �O�5�� 5� �(�2�,� � ���e%�J�1�1�7�2�;� e%� �e%�P bG� bG�J *� *r>