?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/sqlalchemy/dialects/sqlite/__pycache__/aiosqlite.cpython-39.pyc
???????
a ��Jh�/ � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddlm Z dd l m Z dd l m Z dd l mZ dd lmZ dd lmZ G dd� d�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� d�ZG dd� de�ZG dd� de �ZeZdS ) a� .. dialect:: sqlite+aiosqlite :name: aiosqlite :dbapi: aiosqlite :connectstring: sqlite+aiosqlite:///file_path :url: https://pypi.org/project/aiosqlite/ The aiosqlite dialect provides support for the SQLAlchemy asyncio interface running on top of pysqlite. aiosqlite is a wrapper around pysqlite that uses a background thread for each connection. It does not actually use non-blocking IO, as SQLite databases are not socket-based. However it does provide a working asyncio interface that's useful for testing and prototyping purposes. Using a special asyncio mediation layer, the aiosqlite dialect is usable as the backend for the :ref:`SQLAlchemy asyncio <asyncio_toplevel>` extension package. This dialect should normally be used only with the :func:`_asyncio.create_async_engine` engine creation function:: from sqlalchemy.ext.asyncio import create_async_engine engine = create_async_engine("sqlite+aiosqlite:///filename") The URL passes through all arguments to the ``pysqlite`` driver, so all connection arguments are the same as they are for that of :ref:`pysqlite`. .. _aiosqlite_udfs: User-Defined Functions ---------------------- aiosqlite extends pysqlite to support async, so we can create our own user-defined functions (UDFs) in Python and use them directly in SQLite queries as described here: :ref:`pysqlite_udfs`. .. _aiosqlite_serializable: Serializable isolation / Savepoints / Transactional DDL (asyncio version) ------------------------------------------------------------------------- A newly revised version of this important section is now available at the top level of the SQLAlchemy SQLite documentation, in the section :ref:`sqlite_transactions`. .. _aiosqlite_pooling: Pooling Behavior ---------------- The SQLAlchemy ``aiosqlite`` DBAPI establishes the connection pool differently based on the kind of SQLite database that's requested: * When a ``:memory:`` SQLite database is specified, the dialect by default will use :class:`.StaticPool`. This pool maintains a single connection, so that all access to the engine use the same ``:memory:`` database. * When a file-based database is specified, the dialect will use :class:`.AsyncAdaptedQueuePool` as the source of connections. .. versionchanged:: 2.0.38 SQLite file database engines now use :class:`.AsyncAdaptedQueuePool` by default. Previously, :class:`.NullPool` were used. The :class:`.NullPool` class may be used by specifying it via the :paramref:`_sa.create_engine.poolclass` parameter. � N)�deque)�partial� )�SQLiteExecutionContext)�SQLiteDialect_pysqlite� )�pool)�util)�AdaptedConnection)�await_fallback)� await_onlyc @ s` e Zd ZdZdZdd� Zdd� Zddd �Zd d � Zd d � Z dd� Z dd� Z ddd�Z dd� Z dS )�AsyncAdapt_aiosqlite_cursor)�_adapt_connection� _connection� description�await_�_rows� arraysize�rowcount� lastrowidFc C s4 || _ |j| _|j| _d| _d| _d | _t� | _d S )Nr ���)r r r r r r r r )�selfZadapt_connection� r �Y/home/agenciai/.local/lib/python3.9/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.py�__init__p s z$AsyncAdapt_aiosqlite_cursor.__init__c C s | j �� d S �N)r �clear�r r r r �closey s z!AsyncAdapt_aiosqlite_cursor.closeNc C s� z�| � | j�� �}|d u r,| � |�|�� n| � |�||�� |jrt|j| _d | _| _| js�t| � |� � ��| _ nd | _|j| _|j| _| js�| � |� � � n|| _ W n0 t y� } z| j�|� W Y d }~n d }~0 0 d S )Nr )r r �cursor�executer r r � server_sider �fetchallr r �_cursor� Exceptionr �_handle_exception)r � operation� parametersr# �errorr r r r | s$ z#AsyncAdapt_aiosqlite_cursor.executec C s� zJ| � | j�� �}| � |�||�� d | _|j| _|j| _| � |�� � W n0 tyz } z| j � |� W Y d }~n d }~0 0 d S r ) r r r � executemanyr r r r r$ r r% )r r& Zseq_of_parametersr# r( r r r r) � s z'AsyncAdapt_aiosqlite_cursor.executemanyc G s d S r r )r Z inputsizesr r r � setinputsizes� s z)AsyncAdapt_aiosqlite_cursor.setinputsizesc c s | j r| j �� V q d S r �r �popleftr r r r �__iter__� s z$AsyncAdapt_aiosqlite_cursor.__iter__c C s | j r| j �� S d S d S r r+ r r r r �fetchone� s z$AsyncAdapt_aiosqlite_cursor.fetchonec s4 |d u r| j }| j� � fdd�tt|t� ���D �S )Nc s g | ] }� � � �qS r )r, )�.0�_��rrr r � <listcomp>� � z9AsyncAdapt_aiosqlite_cursor.fetchmany.<locals>.<listcomp>)r r �range�min�len�r �sizer r1 r � fetchmany� s z%AsyncAdapt_aiosqlite_cursor.fetchmanyc C s t | j�}| j�� |S r )�listr r )r �retvalr r r r" � s z$AsyncAdapt_aiosqlite_cursor.fetchall)N)N)�__name__� __module__� __qualname__� __slots__r! r r r r) r* r- r. r: r" r r r r r _ s r c sF e Zd ZdZdZ� fdd�Zdd� Zdd� Zdd d �Zd d � Z � Z S )� AsyncAdapt_aiosqlite_ss_cursorr# Tc s t � j|i |�� d | _d S r )�superr r# )r �arg�kw�� __class__r r r � s z'AsyncAdapt_aiosqlite_ss_cursor.__init__c C s$ | j d ur | �| j �� � d | _ d S r )r# r r r r r r r � s z$AsyncAdapt_aiosqlite_ss_cursor.closec C s | � | j�� �S r )r r# r. r r r r r. � s z'AsyncAdapt_aiosqlite_ss_cursor.fetchoneNc C s" |d u r| j }| �| jj|d��S )N)r9 )r r r# r: r8 r r r r: � s z(AsyncAdapt_aiosqlite_ss_cursor.fetchmanyc C s | � | j�� �S r )r r# r" r r r r r" � s z'AsyncAdapt_aiosqlite_ss_cursor.fetchall)N) r= r> r? r@ r! r r r. r: r" � __classcell__r r rE r rA � s rA c @ st e Zd Zee�ZdZdd� Zedd� �Z e j dd� �Z dd� Z dd d �Z d d � Z dd� Zdd� Zdd� Zdd� ZdS )� AsyncAdapt_aiosqlite_connection)�dbapic C s || _ || _d S r )rI r )r rI � connectionr r r r � s z(AsyncAdapt_aiosqlite_connection.__init__c C s | j jS r )r �isolation_levelr r r r rK � s z/AsyncAdapt_aiosqlite_connection.isolation_levelc C sv dd� }t || jj|�}t�� �� }| jj�||f� z | �|�W S t yp } z| � |� W Y d }~n d }~0 0 d S )Nc S s || _ d S r )rK )rJ �valuer r r �set_iso� s z@AsyncAdapt_aiosqlite_connection.isolation_level.<locals>.set_iso) r r Z_conn�asyncio�get_event_loop� create_futureZ_tx� put_nowaitr r$ r% )r rL rM �function�futurer( r r r rK � s c O sP z | � | jj|i |��� W n. tyJ } z| �|� W Y d }~n d }~0 0 d S r )r r �create_functionr$ r% )r �argsrD r( r r r rT � s z/AsyncAdapt_aiosqlite_connection.create_functionFc C s |r t | �S t| �S d S r )rA r )r r! r r r r � s z&AsyncAdapt_aiosqlite_connection.cursorc O s | � | jj|i |���S r )r r r )r rU rD r r r r s z'AsyncAdapt_aiosqlite_connection.executec C sH z| � | j�� � W n. tyB } z| �|� W Y d }~n d }~0 0 d S r )r r �rollbackr$ r% �r r( r r r rV s z(AsyncAdapt_aiosqlite_connection.rollbackc C sH z| � | j�� � W n. tyB } z| �|� W Y d }~n d }~0 0 d S r )r r �commitr$ r% rW r r r rX s z&AsyncAdapt_aiosqlite_connection.commitc C sX z| � | j�� � W n> ty& Y n. tyR } z| �|� W Y d }~n d }~0 0 d S r )r r r � ValueErrorr$ r% rW r r r r s z%AsyncAdapt_aiosqlite_connection.closec C s2 t |t�r*|jd dkr*| jj�d�|�n|�d S )Nr �no active connection)� isinstancerY rU rI �sqlite�OperationalErrorrW r r r r% # s � ���z1AsyncAdapt_aiosqlite_connection._handle_exceptionN)F)r= r> r? � staticmethodr r r@ r �propertyrK �setterrT r r rV rX r r% r r r r rH � s rH c @ s e Zd ZdZee�ZdS )�'AsyncAdaptFallback_aiosqlite_connectionr N)r= r> r? r@ r^ r r r r r r ra / s ra c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�AsyncAdapt_aiosqlite_dbapic C s || _ || _d| _| �� d S )NZqmark)� aiosqliter\ Z paramstyle�_init_dbapi_attributes)r rc r\ r r r r 6 s z#AsyncAdapt_aiosqlite_dbapi.__init__c C s^ dD ]}t | |t| j|�� qdD ]}t | |t| j|�� q"dD ]}t | |t| j|�� q@d S )N)Z DatabaseError�ErrorZIntegrityErrorZNotSupportedErrorr] ZProgrammingErrorZsqlite_versionZsqlite_version_info)ZPARSE_COLNAMESZPARSE_DECLTYPES)�Binary)�setattr�getattrrc r\ )r �namer r r rd < s z1AsyncAdapt_aiosqlite_dbapi._init_dbapi_attributesc O sn |� dd�}|� dd �}|r,||i |��}n| jj|i |��}d|_t�|�r\t| t|��S t| t |��S d S )N�async_fallbackFZasync_creator_fnT) �poprc �connect�daemonr Zasboolra r rH r )r rC rD rj Z creator_fnrJ r r r rl O s ��z"AsyncAdapt_aiosqlite_dbapi.connectN)r= r> r? r rd rl r r r r rb 5 s rb c @ s e Zd Zdd� ZdS )� SQLiteExecutionContext_aiosqlitec C s | j jdd�S )NT)r! )Z_dbapi_connectionr r r r r �create_server_side_cursorg s z:SQLiteExecutionContext_aiosqlite.create_server_side_cursorN)r= r> r? ro r r r r rn f s rn c sP e Zd ZdZdZdZdZeZe dd� �Z e dd� �Z � fdd�Z d d � Z � ZS ) �SQLiteDialect_aiosqliterc Tc C s t td�td��S )Nrc Zsqlite3)rb � __import__)�clsr r r � import_dbapiu s �z$SQLiteDialect_aiosqlite.import_dbapic C s | � |�rtjS tjS d S r )Z_is_url_file_dbr ZAsyncAdaptedQueuePoolZ StaticPool)rr �urlr r r �get_pool_class{ s z&SQLiteDialect_aiosqlite.get_pool_classc s. t || jj�r dt|�v r dS t� �|||�S )NrZ T)r[ rI r] �strrB � is_disconnect)r �erJ r rE r r rw � s � �z%SQLiteDialect_aiosqlite.is_disconnectc C s |j S r )r )r rJ r r r �get_driver_connection� s z-SQLiteDialect_aiosqlite.get_driver_connection)r= r> r? ZdriverZsupports_statement_cache�is_asyncZ supports_server_side_cursorsrn Zexecution_ctx_cls� classmethodrs ru rw ry rG r r rE r rp k s rp )�__doc__rN � collectionsr � functoolsr �baser Zpysqliter � r r Zenginer Zutil.concurrencyr r r rA rH ra rb rn rp �dialectr r r r �<module> s$ H ] W1#
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????