U أد a!<م@sّddlmZddlmZddlmZddlmZddlmZddlm Z ddlm Z dd lmZdd l mZeje ddd dgddddddddddddgdddddd d!d"gd#چGd$d%„d%eƒƒZGd&d'„d'ƒZGd(d)„d)eeƒZd*d+„Zd,d-„Zee_d.S)/é)عengine)عresult)عReversibleProxy)عStartableContexté)عutil)عobject_session)عSession)عstate)عgreenlet_spawnz:class:`_orm.Session`z:class:`_asyncio.AsyncSession`rZidentity_keyع__contains__ع__iter__عaddZadd_allZexpireZ expire_allZexpungeZexpunge_allZget_bindZis_modifiedZin_transactionZin_nested_transactionZdirtyZdeletedعnewZidentity_mapع is_activeZ autoflushZno_autoflushعinfo)Zclassmethodsعmethodsع attributesc@sôeZdZdZdZdZd2dd„Zd3dd„Zdd „Zde j dfd d„Zde j dfdd „Zd4dd„Z de j dfdd„Zdd„Zd5dd„Zd6dd„Zdd„Zdd„Zdd„Zd d!„Zd"d#„Zd$d%„Zd&d'„Zd(d)„Zed*d+„ƒZd,d-„Zd.d/„Zd0d1„ZdS)7عAsyncSessionzKAsyncio version of :class:`_orm.Session`. .. versionadded:: 1.4 )عbindsعbindعsync_sessionع_proxiedZ_slots_dispatchNcKs^d|d<|r||_t |،}|r8||_dd„| ،Dƒ}| tf||dœ|—ژ،|_|_dS)NTعfuturecSsi|]\}}|t |،“qS©)rع_get_sync_engine_or_connection)ع.0عkeyعbrrْ_C:\Users\vtejo\AppData\Local\Temp\pip-unpacked-wheel-nyjtotrf\sqlalchemy\ext\asyncio\session.pyع Jsےz)AsyncSession.__init__..)rr) rrrrعitemsع_assign_proxiedr rr)عselfrrعkwrrrع__init__Bs ‏ےzAsyncSession.__init__cأst|jj|||dچIdHS)aTExpire and refresh the attributes on the given instance. A query will be issued to the database and all attributes will be refreshed with their current database value. This is the async version of the :meth:`_orm.Session.refresh` method. See that method for a complete description of all options. )عattribute_namesعwith_for_updateN)rrعrefresh)r#عinstancer&r'rrrr(Ss üzAsyncSession.refreshcدst||jf|‍|ژIdHS)aInvoke the given sync callable passing sync self as the first argument. This method maintains the asyncio event loop all the way through to the database connection by running the given callable in a specially instrumented greenlet. E.g.:: with AsyncSession(async_engine) as session: await session.run_sync(some_business_method) .. note:: The provided callable is invoked inline within the asyncio event loop, and will block on traditional IO calls. IO within this callable should only call into SQLAlchemy's asyncio database APIs which will be properly adapted to the greenlet context. .. seealso:: :ref:`session_run_sync` N)rr)r#عfnعargr$rrrعrun_syncgszAsyncSession.run_synccثs2| ddi،}t|jj|f|||dœ|—ژIdHS)zQExecute a statement and return a buffered :class:`_engine.Result` object.Zprebuffer_rowsT©عparamsعexecution_optionsعbind_argumentsN)عunionrrعexecute)r#ع statementr.r/r0r$rrrr2‚s‏ûْzAsyncSession.executecثs(|j|f|||dœ|—ژIdH}| ،S)z/Execute a statement and return a scalar result.r-N)r2عscalar©r#r3r.r/r0r$rrrrr4کs ےüûzAsyncSession.scalarFc أs t|jj||||||dچIdHS)zjReturn an instance based on the given primary key identifier, or ``None`` if not found. )عoptionsعpopulate_existingr'عidentity_tokenN)rrعget)r#عentityعidentr6r7r'r8rrrr9«sùzAsyncSession.getcثs<| ddi،}t|jj|f|||dœ|—ژIdH}t |،S)zXExecute a statement and return a streaming :class:`_asyncio.AsyncResult` object.Zstream_resultsTr-N)r1rrr2ع_resultZAsyncResultr5rrrعstreamأs‏ûْzAsyncSession.streamcأst|jj|ƒIdHS)zِMark an instance as deleted. The database delete operation occurs upon ``flush()``. As this operation may need to cascade along unloaded relationships, it is awaitable to allow for those queries to take place. N)rrعdelete)r#r)rrrr>عs zAsyncSession.deleteTcأst|jj||dچIdHS)z~Copy the state of a given instance into a corresponding instance within this :class:`_asyncio.AsyncSession`. )عloadN)rrعmerge)r#r)r?rrrr@وs ےzAsyncSession.mergecأst|jj|dچIdHdS)zuFlush all the object changes to the database. .. seealso:: :meth:`_orm.Session.flush` )عobjectsN)rrعflush)r#rArrrrBïszAsyncSession.flushcCs$|j ،}|dk rt |،SdSdS)zءReturn the current root transaction in progress, if any. :return: an :class:`_asyncio.AsyncSessionTransaction` object, or ``None``. .. versionadded:: 1.4.18 N)rعget_transactionعAsyncSessionTransactionع_retrieve_proxy_for_target©r#عtransrrrrCùs zAsyncSession.get_transactioncCs$|j ،}|dk rt |،SdSdS)zأReturn the current nested transaction in progress, if any. :return: an :class:`_asyncio.AsyncSessionTransaction` object, or ``None``. .. versionadded:: 1.4.18 N)rعget_nested_transactionrDrErFrrrrHs z#AsyncSession.get_nested_transactioncأst|jjƒIdH}tj |،S)z‰Return a :class:`_asyncio.AsyncConnection` object corresponding to this :class:`.Session` object's transactional state. N)rrع connectionrZAsyncConnectionrE)r#Zsync_connectionrrrrIsےzAsyncSession.connectioncKst|ƒS)aوReturn an :class:`_asyncio.AsyncSessionTransaction` object. The underlying :class:`_orm.Session` will perform the "begin" action when the :class:`_asyncio.AsyncSessionTransaction` object is entered:: async with async_session.begin(): # .. ORM transaction is begun Note that database IO will not normally occur when the session-level transaction is begun, as database transactions begin on an on-demand basis. However, the begin block is async to accommodate for a :meth:`_orm.SessionEvents.after_transaction_create` event hook that may perform IO. For a general description of ORM begin, see :meth:`_orm.Session.begin`. ©rD©r#r$rrrعbegin#szAsyncSession.begincKst|ddچS)a:Return an :class:`_asyncio.AsyncSessionTransaction` object which will begin a "nested" transaction, e.g. SAVEPOINT. Behavior is the same as that of :meth:`_asyncio.AsyncSession.begin`. For a general description of ORM begin nested, see :meth:`_orm.Session.begin_nested`. T)عnestedrJrKrrrعbegin_nested:szAsyncSession.begin_nestedcأst|jjƒIdHS)z-Rollback the current transaction in progress.N)rrعrollback©r#rrrrOGszAsyncSession.rollbackcأst|jjƒIdHS)z+Commit the current transaction in progress.N)rrعcommitrPrrrrQKszAsyncSession.commitcأst|jjƒIdHS)aPClose out the transactional resources and ORM objects used by this :class:`_asyncio.AsyncSession`. This expunges all ORM objects associated with this :class:`_asyncio.AsyncSession`, ends any transaction in progress and :term:`releases` any :class:`_asyncio.AsyncConnection` objects which this :class:`_asyncio.AsyncSession` itself has checked out from associated :class:`_asyncio.AsyncEngine` objects. The operation then leaves the :class:`_asyncio.AsyncSession` in a state which it may be used again. .. tip:: The :meth:`_asyncio.AsyncSession.close` method **does not prevent the Session from being used again**. The :class:`_asyncio.AsyncSession` itself does not actually have a distinct "closed" state; it merely means the :class:`_asyncio.AsyncSession` will release all database connections and ORM objects. .. seealso:: :ref:`session_closing` - detail on the semantics of :meth:`_asyncio.AsyncSession.close` N)rrعcloserPrrrrROszAsyncSession.closecأst|jjƒIdHS)z2Close all :class:`_asyncio.AsyncSession` sessions.N)rrع close_allrPrrrrSmszAsyncSession.close_allcأs|S©NrrPrrrع __aenter__rszAsyncSession.__aenter__cأs| ،IdHdSrT)rR©r#عtype_عvalueع tracebackrrrع __aexit__uszAsyncSession.__aexit__cCst|ƒSrT)ع_AsyncSessionContextManagerrPrrrع_maker_context_managerxsz#AsyncSession._maker_context_manager)NN)NN)NFNN)T)N)ع__name__ع __module__ع__qualname__ع__doc__ع __slots__عdispatchr%r(r,rع EMPTY_DICTr2r4r9r=r>r@rBrCrHrIrLrNrOrQrRعclassmethodrSrUrZr\rrrrrsR ے û û ù û rc@s$eZdZdd„Zdd„Zdd„ZdS)r[cCs ||_dSrT)ع async_session)r#rerrrr%~sz$_AsyncSessionContextManager.__init__cأs"|j ،|_|j ،IdH|jSrT)rerLrGrUrPrrrrUپsz&_AsyncSessionContextManager.__aenter__cأs0|j |||،IdH|j |||،IdHdSrT)rGrZrerVrrrrZ†sz%_AsyncSessionContextManager.__aexit__N)r]r^r_r%rUrZrrrrr[}sr[c@sTeZdZdZdZddd„Zedd„ƒZdd „Zd d„Z dd „Z ddd„Zdd„ZdS)rDa²A wrapper for the ORM :class:`_orm.SessionTransaction` object. This object is provided so that a transaction-holding object for the :meth:`_asyncio.AsyncSession.begin` may be returned. The object supports both explicit calls to :meth:`_asyncio.AsyncSessionTransaction.commit` and :meth:`_asyncio.AsyncSessionTransaction.rollback`, as well as use as an async context manager. .. versionadded:: 1.4 )عsessionعsync_transactionrMFcCs||_||_d|_dSrT)rfrMrg)r#rfrMrrrr%‌sz AsyncSessionTransaction.__init__cCs| ،dk o| ،jSrT)ع_sync_transactionrrPrrrr¢s‏z!AsyncSessionTransaction.is_activecCs|js| ،|jSrT)rgZ_raise_for_not_startedrPrrrrh©sz)AsyncSessionTransaction._sync_transactioncأst| ،jƒIdHdS)z2Roll back this :class:`_asyncio.AsyncTransaction`.N)rrhrOrPrrrrO®sz AsyncSessionTransaction.rollbackcأst| ،jƒIdHdS)z/Commit this :class:`_asyncio.AsyncTransaction`.N)rrhrQrPrrrrQ²szAsyncSessionTransaction.commitcأs>| t|jr|jjjn|jjjƒIdH،|_|r:|j ،|SrT) r"rrMrfrrNrLrgع __enter__)r#Z is_ctxmanagerrrrعstart·sے‎ے zAsyncSessionTransaction.startcأst| ،j|||ƒIdHdSrT)rrhع__exit__rVrrrrZأsےz!AsyncSessionTransaction.__aexit__N)F)F) r]r^r_r`rar%عpropertyrrhrOrQrjrZrrrrrD‹s rDcCs t|ƒ}|dk rt|ƒSdSdS)a«Return the :class:`_asyncio.AsyncSession` to which the given instance belongs. This function makes use of the sync-API function :class:`_orm.object_session` to retrieve the :class:`_orm.Session` which refers to the given instance, and from there links it to the original :class:`_asyncio.AsyncSession`. If the :class:`_asyncio.AsyncSession` has been garbage collected, the return value is ``None``. This functionality is also available from the :attr:`_orm.InstanceState.async_session` accessor. :param instance: an ORM mapped instance :return: an :class:`_asyncio.AsyncSession` object, or ``None``. .. versionadded:: 1.4.18 N)rre)r)rfrrrعasync_object_sessionةsrmcCstj|ddچS)aReturn the :class:`_asyncio.AsyncSession` which is proxying the given :class:`_orm.Session` object, if any. :param session: a :class:`_orm.Session` instance. :return: a :class:`_asyncio.AsyncSession` instance, or ``None``. .. versionadded:: 1.4.18 F)Z regenerate)rrE)rfrrrreوs reN)عrrr<عbaserrrZormrr r Z_instance_stateZutil.concurrencyrZcreate_proxy_methodsrr[rDrmreZ_async_providerrrrrعsXôّيO>