ó H`¾Tc@sÛdZddlZddlmZddlmZmZddlmZddl m Z m Z m Z m Z mZmZmZmZdd lm Z d ejfd „ƒYZd efd „ƒYZdefd„ƒYZdS(sŸDefines instrumentation of instances. This module is usually not directly visible to user applications, but defines a large part of the ORM's interactivity. iÿÿÿÿNi(tutili(texct interfaces(t PathRegistry(tPASSIVE_NO_RESULTtSQL_OKt NEVER_SETt ATTR_WAS_SETtNO_VALUEtPASSIVE_NO_INITIALIZEtINIT_OKt PASSIVE_OFF(tbaset InstanceStatecBseZdZd-Zd-Zd-ZejZ d.Z d-Z d-Z e Ze Ze Ze ZeZd„Zejd„ƒZed„ƒZed„ƒZed„ƒZed„ƒZeejdƒd„ƒƒZeejdƒd „ƒƒZed „ƒZed „ƒZ ed „ƒZ!ejd „ƒZ"ejd„ƒZ#ejd„ƒZ$ed„ƒZ%d„Z&d„Z'd„Z(d„Z)ed„ƒZ*d„Z+d„Z,d„Z-d„Z.d„Z/d„Z0d„Z1d„Z2d„Z3e4d„ƒZ5d „Z6d!„Z7d"„Z8ed#„ƒZ9d$„Z:ed%„ƒZ;ed&„ƒZ<ed'„ƒZ=d(„Z>e e d)„Z?d*„Z@d-d+„ZAe4d-d,„ƒZBRS(/s‰tracks state information at the instance level. The :class:`.InstanceState` is a key object used by the SQLAlchemy ORM in order to track the state of an object; it is created the moment an object is instantiated, typically as a result of :term:`instrumentation` which SQLAlchemy applies to the ``__init__()`` method of the class. :class:`.InstanceState` is also a semi-public object, available for runtime inspection as to the state of a mapped instance, including information such as its current status within a particular :class:`.Session` and details about data on individual attributes. The public API in order to acquire a :class:`.InstanceState` object is to use the :func:`.inspect` system:: >>> from sqlalchemy import inspect >>> insp = inspect(some_mapped_object) .. seealso:: :ref:`core_inspection_toplevel` cCsC|j|_||_tj||jƒ|_i|_i|_dS(N( t __class__tclass_tmanagertweakreftreft_cleanuptobjt callablestcommitted_state(tselfRR((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt__init__@s    cs&tjt‡fd†ˆjDƒƒƒS(saReturn a namespace representing each attribute on the mapped object, including its current value and history. The returned object is an instance of :class:`.AttributeState`. This object allows inspection of the current data within an attribute as well as attribute history since the last flush. c3s$|]}|tˆ|ƒfVqdS(N(tAttributeState(t.0tkey(R(sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pys Us(RtImmutablePropertiestdictR(R((RsZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pytattrsGs  cCs|jdko|j S(syReturn true if the object is :term:`transient`. .. seealso:: :ref:`session_object_states` N(RtNonet _attached(R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt transientZs cCs|jdko|jS(sxReturn true if the object is :term:`pending`. .. seealso:: :ref:`session_object_states` N(RRR (R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pytpendingfs cCs|jdk o|jS(s~Return true if the object is :term:`persistent`. .. seealso:: :ref:`session_object_states` N(RRR (R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt persistentss cCs|jdk o|j S(sxReturn true if the object is :term:`detached`. .. seealso:: :ref:`session_object_states` N(RRR (R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pytdetacheds ssqlalchemy.orm.sessioncCs|jdk o|j|jkS(N(t session_idRt _sessions(Rt sessionlib((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyR ‹scCs |j|ƒS(s]Return the owning :class:`.Session` for this instance, or ``None`` if none available.(t_state_session(RR'((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pytsession‘scCs |jƒS(sMReturn the mapped object represented by this :class:`.InstanceState`.(R(R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pytobject˜scCs"|jdkrdS|jdSdS(sÖReturn the mapped identity of the mapped object. This is the primary key identity as persisted by the ORM which can always be passed directly to :meth:`.Query.get`. Returns ``None`` if the object has no primary key identity. .. note:: An object which is transient or pending does **not** have a mapped identity until it is flushed, even if its attributes include primary key values. iN(RR(R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pytidentityžscCs|jS(sõReturn the identity key for the mapped object. This is the key used to locate the object within the :attr:`.Session.identity_map` mapping. It contains the identity as returned by :attr:`.identity` within it. (R(R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt identity_key²s cCsiS(N((R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pytparentsÀscCsiS(N((R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt_pending_mutationsÄscCs |jjS(s8Return the :class:`.Mapper` used for this mapepd object.(Rtmapper(R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyR/ÈscCs t|jƒS(s¯Return ``True`` if this object has an identity key. This should always have the same value as the expression ``state.persistent or state.detached``. (tboolR(R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt has_identityÍscCsd|_|_dS(N(RR%t _strong_obj(R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt_detach×scCs|jƒ|`dS(N(R3R(R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt_disposeÚs cCsE|jƒ}|r"|j|ƒni|_d|_|_|`dS(N(t_instance_dicttdiscardRRR%R2R(RRt instance_dict((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyRÞs   cCsdS(N(R(R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyRçscCs-|jƒ}|dk r%tj|ƒSiSdS(sReturn the instance dict used by the object. Under normal circumstances, this is always synonymous with the ``__dict__`` attribute of the mapped object, unless an alternative instrumentation system has been configured. In the case that the actual object has been garbage collected, this accessor returns a blank dictionary. N(RRR R7(Rto((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyRês   cOs~|d|d|d}}}|j}|jj|||ƒy|j|d|ŽSWn |jj|||ƒ‚nXdS(Niii(Rtdispatchtinitt original_initt init_failure(tmixedtkwargsRtinstancetargsR((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt_initialize_instanceýs  cCs |j|jj||j|ƒS(N(Rtimplt get_historyR(RRtpassive((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyRC scCs|j|jS(N(RRB(RR((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pytget_impl scCs-||jkr"tƒ|j|sRR.tmodifiedtexpiredRRR-t load_optionsRt load_pathR( scommitted_states_pending_mutationssmodifiedsexpireds callablesskeysparentss load_optionssclass_(RtupdateRMt serializeRt _serialize(Rt state_dict((RsZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt __getstate__s   cCsG|d}|dk r=tj||jƒ|_|j|_nd|_|d|_|jdiƒ|_|jdiƒ|_ |jdiƒ|_ |jdt ƒ|_ |jdt ƒ|_ |jdiƒ|_|jjgd D]"}||krá|||f^qáƒd |kr/tj|d ƒ|_n|d |||ƒdS(NR?RRR.R-RJRKRRRLRMR(skeys load_options(RRRRRRRtgetRR.R-tFalseRJRKRRHRNRt deserializeRM(RRQtinstRI((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt __setstate__$s(      # cCs#|jj|ƒj||jƒdS(saSet this attribute to an empty value or collection, based on the AttributeImpl in use.N(RREt initializeR(RR((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt _initializeCscCsb|j|dƒ}|dk rK|j|jjrK|j|jj|ƒn|jj|dƒdS(sKRemove the given attribute and any callables associated with it.N(tpopRRRBt collectiont_invalidate_collectionR(Rtdict_Rtold((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt_resetIscCs!|j|dƒ||j|Îs(RzRqR(R((RsZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyt_unloaded_non_objectËs cCs8tg|jjƒD]\}}||kr|^qƒS(s"Return the set of keys which are 'expired' to be loaded by the manager's deferred scalar loader, assuming no pending changes. see also the ``unmodified`` collection which is intersected against this set when a refresh operation occurs. (RvRtitems(RRItv((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyRpÒs cCsdS(N(R(R((sZ/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/state.pyR5ÞscCsI|js dS|j|jks%|r–|rƒ|tkrY|j|krY||j}qYn|dttfkrƒ|j|ƒ}qƒn||j|j s :ÿÿ-P