o
    9âfÀ  ã                   @   sT   d dl Z d dlmZ d dlmZ ddlmZ ddlmZ dZ	G d	d
„ d
eƒZ
e
ZdS )é    N)Ú
TextClause©ÚAsyncAdaptedQueuePoolé   )ÚAsyncAdapt_asynch_dbapié   )ÚClickHouseDialect_native)r   r   r   Nc                   @   sN   e Zd ZdZdZdZedd„ ƒZedd„ ƒZddd	„Z	ddd„Z
ddd„Zd
S )ÚClickHouseDialect_asynchÚasynchTc                 C   s   t tƒS ©N)r   r
   )Úcls© r   úb/var/www/Datamplify/venv/lib/python3.10/site-packages/clickhouse_sqlalchemy/drivers/asynch/base.pyÚimport_dbapi   s   z%ClickHouseDialect_asynch.import_dbapic                 C   s   t S r   r   )r   Úurlr   r   r   Úget_pool_class   s   z'ClickHouseDialect_asynch.get_pool_classFc                 K   s,   t |tƒr	t|ƒ}|r|jn|j}|||ƒS r   )Ú
isinstanceÚstrr   ÚscalarÚexecute)ÚselfÚ
connectionÚsqlr   ÚkwargsÚfr   r   r   Ú_execute   s   

z!ClickHouseDialect_asynch._executeNc                 C   ó   |  |||¡ d S r   )r   ©r   ÚcursorÚ	statementÚ
parametersÚcontextr   r   r   Ú
do_execute#   ó   z#ClickHouseDialect_asynch.do_executec                 C   r   r   )Úexecutemanyr   r   r   r   Údo_executemany&   r#   z'ClickHouseDialect_asynch.do_executemany)Fr   )Ú__name__Ú
__module__Ú__qualname__ÚdriverÚis_asyncÚsupports_statement_cacheÚclassmethodr   r   r   r"   r%   r   r   r   r   r	      s    



r	   )r
   Úsqlalchemy.sql.elementsr   Úsqlalchemy.poolr   Ú	connectorr   Únative.baser   ÚVERSIONr	   Údialectr   r   r   r   Ú<module>   s    