o
    h                     @   s$   d dl Z dd Zdd Zdd ZdS )    Nc                 C      d | ddS )Nz"{}""z""formatreplace)ident r   a/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/asyncpg/utils.py_quote_ident      r
   c                 C   r   )Nz'{}''z''r   )stringr   r   r	   _quote_literal   r   r   c                    s   |  |I dH }g }| D ]#}|jdr!d|jdd  }n|j}|dt|jt| q~dd t|dd	D }| j	d
jd
|dg|R  I dH  td fdd|S )z&Safely inline arguments to query text.Nz[]_z{}.{}c                 S   s   g | ]
\}}d  ||qS )zquote_literal(${}::{}::text))r   ).0itr   r   r	   
<listcomp>%   s    z_mogrify.<locals>.<listcomp>   )startzSELECT {cols}z, )colsz	\$(\d+)\bc                    s4    t | dd  d ur t | dd  S dS )Nr   NULL)intgroup)m	textifiedr   r	   <lambda>.   s   z_mogrify.<locals>.<lambda>)prepareget_parametersnameendswithappendr   r
   schema	enumeratefetchrowjoinresub)connqueryargsps
paramtypesr   pnamer   r   r   r	   _mogrify   s0   

r0   )r(   r
   r   r0   r   r   r   r	   <module>   s   