σ H`ΎTc @sddlmZddlmZmZmZddlmZmZddl m Z dgZ de fd„ƒYZ e Zd„Zx'e jD]Zee eeeƒƒqŠWd „Zx$dD]Zee eeeƒƒqΊWd„Zx$dD]Zee eeeƒƒqκWdS(i(texc(tScopedRegistrytThreadLocalRegistrytwarni(t class_mapperR(tSessiontscoped_sessioncBsAeZdZdd„Zd„Zd„Zd„Zdd„ZRS(stProvides scoped management of :class:`.Session` objects. See :ref:`unitofwork_contextual` for a tutorial. cCs7||_|r$t||ƒ|_nt|ƒ|_dS(sΡConstruct a new :class:`.scoped_session`. :param session_factory: a factory to create new :class:`.Session` instances. This is usually, but not necessarily, an instance of :class:`.sessionmaker`. :param scopefunc: optional function which defines the current scope. If not passed, the :class:`.scoped_session` object assumes "thread-local" scope, and will use a Python ``threading.local()`` in order to maintain the current :class:`.Session`. If passed, the function should return a hashable token; this token will be used as the key in a dictionary in order to store and retrieve the current :class:`.Session`. N(tsession_factoryRtregistryR(tselfRt scopefunc((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyt__init__s cKs‰|r{|jdtƒ}|dk rk|jjƒrEtjdƒ‚qx|j|}|jj|ƒ|Sq…|j|Sn |jƒSdS(sžReturn the current :class:`.Session`, creating it using the session factory if not present. :param \**kw: Keyword arguments will be passed to the session factory callable, if an existing :class:`.Session` is not present. If the :class:`.Session` is present and keyword arguments have been passed, :exc:`~sqlalchemy.exc.InvalidRequestError` is raised. tscopesEScoped session is already present; no new arguments may be specified.N( tpoptFalsetNoneRthastsa_exctInvalidRequestErrorRtset(R tkwR tsess((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyt__call__.s   cCs3|jjƒr"|jƒjƒn|jjƒdS(sζDispose of the current :class:`.Session`, if present. This will first call :meth:`.Session.close` method on the current :class:`.Session`, which releases any existing transactional/connection resources still being held; transactions specifically are rolled back. The :class:`.Session` is then discarded. Upon next usage within the same scope, the :class:`.scoped_session` will produce a new :class:`.Session` object. N(RRtclosetclear(R ((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pytremoveIs cKs0|jjƒrtdƒn|jj|dS(sreconfigure the :class:`.sessionmaker` used by this :class:`.scoped_session`. See :meth:`.sessionmaker.configure`. stAt least one scoped session is already present. configure() can not affect sessions that have already been created.N(RRRRt configure(R tkwargs((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyRZs cs&dtf‡‡fd†ƒY}|ƒS(s"return a class property which produces a :class:`.Query` object against the class and the current :class:`.Session` when called. e.g.:: Session = scoped_session(sessionmaker()) class MyClass(object): query = Session.query_property() # after mappers are defined result = MyClass.query.filter(MyClass.name=='foo').all() Produces instances of the session's configured query class by default. To override and use a custom implementation, provide a ``query_cls`` callable. The callable will be invoked with the class's mapper as a positional argument and a session keyword argument. There is no limit to the number of query properties placed on a class. tquerycseZ‡‡fd†ZRS(csdyHt|ƒ}|rGˆr1ˆ|dˆjƒƒSˆjƒj|ƒSnWntjk r_dSXdS(Ntsession(RRRtorm_exctUnmappedClassErrorR(tstinstancetownertmapper(t query_clsR (s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyt__get__‚s (t__name__t __module__R%((R R$(s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyRs(tobject(R R$R((R R$s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pytquery_propertyis N( R&R't__doc__RR RRRR)(((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyRs     cs‡fd†}|S(Ncst|jƒˆƒ||ŽS(N(tgetattrR(R targsR(tname(s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pytdo•s((R-R.((R-s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyt instrument”scs+‡fd†}‡fd†}t||ƒS(Ncst|jƒˆ|ƒdS(N(tsetattrR(R tattr(R-(s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyRžscst|jƒˆƒS(N(R+R(R (R-(s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pytget‘s(tproperty(R-RR2((R-s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pytmakepropstbindtdirtytdeletedtnewt identity_mapt is_activet autoflusht no_autoflushtinfocs‡fd†}t|ƒS(Ncsttˆƒ||ŽS(N(R+R(tclsR,R(R-(s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyR.¬s(t classmethod(R-R.((R-s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pytclslevel«st close_alltobject_sessiont identity_keyN( R5R6R7snewR9R:R;R<sinfo(RARBRC(tRRtutilRRRRRRRt__all__R(Rt ScopedSessionR/tpublic_methodstmethR0R4tpropR@(((s\/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyts