ó
‹EYc	@s
dd
lm
Z
ddlmZmZmZ
ddlmZm
Z
ddl	m
Z

dg
Zdef
d„ƒ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_sessioncBsGeZ
dZdZdd
„
Zd„Zd„Zd„Zdd„
Z	RS(stProvides scoped management of :class:`.Session` objects.

    See :ref:`unitofwork_contextual` for a tutorial.

    cCs7|
|_|r$t
|
|ƒ|_nt|
ƒ
|_d
S(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_factoryR
tregistryR(tselfRt	scopefunc((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyt__init__s	
c
Ks‰|
r{|
jd
t
ƒ}|dk	rk|jjƒrEtjdƒ
‚
qx|j|
}|jj|ƒ

|Sq…|j|
Sn
|jƒSdS(sÎ
Return the current :class:`.Session`, creating it
        using the :attr:`.scoped_session.session_factory` if not present.

        :param \**kw: Keyword arguments will be passed to the
         :attr:`.scoped_session.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((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyt__call__5s






c


Cs3|jj
ƒr"|jƒjƒ
n|jjƒ
d
S(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	((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pytremovePs


c
Ks0|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((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyRas

cs&d
tf
‡‡
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(t
stinstancetownertmapper(t	query_clsR	(sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyt__get__‰s





(t__name__t
__module__R%((R$R	(sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyRˆs
(
tobject(R	R$R((R$R	sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pytquery_propertyps
N(
R&R't__doc__RRRRRRR)(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyRs			c
s‡f
d
†}
|
S(Nc
st|j
ƒˆƒ|
|ŽS(
N(tgetattrR(R	targsR(
tname(sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pytdoœs
((R-R.((
R-sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyt
instrument›s
c
s+‡f
d
†}
‡f
d†}t||
ƒS(Ncst|j
ƒˆ|
ƒ
dS(
N(tsetattrR(R	tattr(
R-(sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyR¥s
c

st|j
ƒˆƒS(
N(R+R(
R	(
R-(sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pytget¨s
(
tproperty(R-RR2((
R-sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pytmakeprop¤s
tbindtdirtytdeletedtnewtidentity_mapt	is_activet	autoflushtno_autoflushtinfoc
s‡f
d
†}
t|
ƒ
S(Nc
stt
ˆƒ|
|ŽS(
N(R+R(tclsR,R(
R-(sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyR.³s
(
tclassmethod(R-R.((
R-sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pytclslevel²s
t	close_alltobject_sessiontidentity_keyN(	sbindsdirtysdeletedsnewsidentity_maps	is_actives	autoflushsno_autoflushsinfo(s	close_allsobject_sessionsidentity_key(tRRtutilR
RRRRRRt__all__R(Rt
ScopedSessionR/tpublic_methodstmethR0R4tpropR@(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/sqlalchemy/orm/scoping.pyt<module>s 


	†