o ޭh@sddlmZddlZddlZddlZddlmZddlmZddlmZm Z ddl m Z ddl m Z er@ddlmZeee fZGd d d ZeZdS) ) annotationsN) ContextVar)copy) TYPE_CHECKINGAny) expand_db_url)ConfigurationError)BaseDBAsyncClientc@seZdZUejdidZded<d=ddZd>d d Ze d?ddZ d@ddZ dAddZ d@ddZ d=ddZdBddZdCd#d$Zd=d%d&ZdDd(d)ZdDd*d+ZdEd-d.ZdFd0d1ZdGd3d4ZdHd6d7ZdIdJd:d;Zd` method while initialization. :raises ConfigurationError: If this property is accessed before calling the :meth:`Tortoise.init` method. NzDB configuration not initialised. Make sure to call Tortoise.init with a valid configuration before attempting to create connections.)rrrrrrr%s zConnectionHandler.db_configdict[str, BaseDBAsyncClient]cCs |jSr)r getrrrr _get_storage9s zConnectionHandler._get_storage new_storagecontextvars.TokencCs |j|Sr)r set)rr!rrr _set_storage<s zConnectionHandler._set_storagecCs t|Sr)rr rrrr _copy_storage@s zConnectionHandler._copy_storagecCs|dSr)r clearrrrr_clear_storageCsz ConnectionHandler._clear_storagedb_infodicttype[BaseDBAsyncClient]cCs\|dd}t|}zt|dr||}W|S|j}W|Sty-td|dw)Nengineget_client_classzBackend for engine "z" does not implement db client)r importlib import_modulehasattrr- client_classAttributeErrorr)rr( engine_str engine_moduler1rrr_discover_client_classFs      z(ConnectionHandler._discover_client_class conn_aliasstr str | dictcCs,z|j|WStytd|dw)Nz%Unable to get db settings for alias 'zD'. Please check if the config dict contains this alias and try again)rKeyErrorrrr6rrr _get_db_infoUs   zConnectionHandler._get_db_infocs0|jD]}||}|jr|IdHqdSr)rrr db_create)ralias connectionrrrr^s  z#ConnectionHandler._init_connectionsr cCsR||}t|trt|}||}|d}|d|i|di|}|S)N credentialsconnection_namer)r; isinstancer7rr5rr)rr6r(r1 db_paramsr>rrr_create_connectionds    z$ConnectionHandler._create_connectioncCs<|}z||WSty||}|||<|YSw)a Return the connection object for the given alias, creating it if needed. Used for accessing the low-level connection object (:class:`BaseDBAsyncClient`) for the given alias. :param conn_alias: The alias for which the connection has to be fetched :raises ConfigurationError: If the connection alias does not exist. )r r9rC)rr6storager>rrrrns    zConnectionHandler.getconn_objcCs|}|||<|j|S)a& Sets the given alias to the provided connection object. :param conn_alias: The alias to set the connection for. :param conn_obj: The connection object that needs to be set for this alias. .. note:: This method copies the storage from the `current context`, updates the ``conn_alias`` with the provided ``conn_obj`` and sets the updated storage in a `new context` and therefore returns a ``contextvars.Token`` in order to restore the original context storage. )r%r r#)rr6rE storage_copyrrrr#s  zConnectionHandler.setBaseDBAsyncClient | NonecCs||dS)ay Discards the given alias from the storage in the `current context`. :param conn_alias: The alias for which the connection object should be discarded. .. important:: Make sure to have called ``conn.close()`` for the provided alias before calling this method else there would be a connection leak (dangling connection). N)r popr:rrrdiscards zConnectionHandler.discardtokencCsB|}|j||}|D] \}}||vr|||<qdS)aB Reset the underlying storage to the previous context state. Resets the storage state to the `context` associated with the provided token. After resetting storage state, any additional `connections` created in the `old context` are copied into the `current context`. :param token: The token corresponding to the `context` to which the storage state has to be reset. Typically, this token is obtained by calling the :meth:`set` method of this class. N)r r resetitems)rrJcurrent_storage prev_storager=connrrrrKs zConnectionHandler.resetlist[BaseDBAsyncClient]csfddjDS)zOReturns a list of connection objects from the storage in the `current context`.csg|]}|qSr)r).0r=rrr sz)ConnectionHandler.all..)rrrrrallszConnectionHandler.allTrIcsFdd|D}tj|IdH|r|jD] }||qdSdS)a Closes all connections in the storage in the `current context`. All closed connections will be removed from the storage by default. :param discard: If ``False``, all connection objects are closed but `retained` in the storage. cSsg|]}|qSr)close)rQrOrrrrRsz/ConnectionHandler.close_all..N)rSasynciogatherrrI)rrItasksr=rrr close_alls   zConnectionHandler.close_allN)r r)rrrrr r)r r)r r)r!rr r")r(r)r r*)r6r7r r8)r6r7r r )r6r7rEr r r")r6r7r rG)rJr"r r)r rP)T)rIrr r)__name__ __module__ __qualname__ contextvarsrr __annotations__rrpropertyrr r$r%r'r5r;rrCrr#rIrKrSrXrrrrr s,              r ) __future__rrUr\r.rrtypingrr'tortoise.backends.base.config_generatorrtortoise.exceptionsrtortoise.backends.base.clientr r)r7rr connectionsrrrrs        9