o
    6	f5>                     @   s  d Z ddlZddlZddlmZmZ ddlmZmZm	Z	m
Z
mZmZmZ ddlmZ ddlmZ ddlmZmZ dd	lmZ dd
lmZ ddedee defddZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZedZ edZ!dS )z 
SQL composition utility module
    N)ABCabstractmethod)AnyIteratorIterableListOptionalSequenceUnion   )Escaping)AdaptContext)TransformerPyFormat)LiteralString)conn_encodingobjcontextreturnc                 C   s   t | |S )a  
    Adapt a Python object to a quoted SQL string.

    Use this function only if you absolutely want to convert a Python string to
    an SQL quoted literal to use e.g. to generate batch SQL and you won't have
    a connection available when you will need to use it.

    This function is relatively inefficient, because it doesn't cache the
    adaptation rules. If you pass a `!context` you can adapt the adaptation
    rules used, otherwise only global rules are used.

    )Literal	as_string)r   r    r   D/home/ertert/spirit/venv/lib/python3.10/site-packages/psycopg/sql.pyquote   s   r   c                   @   s   e Zd ZdZdefddZdefddZede	e
 defd	d
Zde	e
 defddZdddZdeddfddZdedefddZdedefddZdS )
ComposableaG  
    Abstract base class for objects that can be used to compose an SQL string.

    `!Composable` objects can be passed directly to
    `~psycopg.Cursor.execute()`, `~psycopg.Cursor.executemany()`,
    `~psycopg.Cursor.copy()` in place of the query string.

    `!Composable` objects can be joined using the ``+`` operator: the result
    will be a `Composed` instance containing the objects joined. The operator
    ``*`` is also supported with an integer argument: the result is a
    `!Composed` instance containing the left argument repeated as many times as
    requested.
    r   c                 C   s
   || _ d S N_objselfr   r   r   r   __init__2      
zComposable.__init__r   c                 C   s   | j j d| jdS )N())	__class____name__r   r   r   r   r   __repr__5   s   zComposable.__repr__r   c                 C   s   t )a~  
        Return the value of the object as bytes.

        :param context: the context to evaluate the object into.
        :type context: `connection` or `cursor`

        The method is automatically invoked by `~psycopg.Cursor.execute()`,
        `~psycopg.Cursor.executemany()`, `~psycopg.Cursor.copy()` if a
        `!Composable` is passed instead of the query string.

        )NotImplementedErrorr   r   r   r   r   as_bytes8   s   zComposable.as_bytesc                 C   sH   |r|j nd}t|}| |}t|tr||S t||d S )z
        Return the value of the object as string.

        :param context: the context to evaluate the string into.
        :type context: `connection` or `cursor`

        Nr   )
connectionr   r*   
isinstancebytesdecodecodecslookup)r   r   connencbr   r   r   r   G   s   


zComposable.as_stringotherComposedc                 C   s:   t |trt| g| S t |trt| gt|g S tS r   )r,   r5   r   NotImplementedr   r4   r   r   r   __add__X   s
   

zComposable.__add__nc                 C   s   t | g| S r   )r5   )r   r9   r   r   r   __mul__`   s   zComposable.__mul__c                 C   s   t | t |u o| j|jkS r   )typer   r7   r   r   r   __eq__c   s   zComposable.__eq__c                 C   s   |  | S r   )r<   r7   r   r   r   __ne__f   s   zComposable.__ne__N)r4   r   r   r5   )r%   
__module____qualname____doc__r   r    strr'   r   r   r   r-   r*   r   r8   intr:   boolr<   r=   r   r   r   r   r   #   s    
r   c                       s   e Zd ZU dZee ed< dee f fddZ	de
e defdd	Zdee fd
dZdedd fddZdedef dd fddZ  ZS )r5   a]  
    A `Composable` object made of a sequence of `!Composable`.

    The object is usually created using `!Composable` operators and methods.
    However it is possible to create a `!Composed` directly specifying a
    sequence of objects as arguments: if they are not `!Composable` they will
    be wrapped in a `Literal`.

    Example::

        >>> comp = sql.Composed(
        ...     [sql.SQL("INSERT INTO "), sql.Identifier("table")])
        >>> print(comp.as_string(conn))
        INSERT INTO "table"

    `!Composed` objects are iterable (so they can be used in `SQL.join` for
    instance).
    r   seqc                    s   dd |D }t  | d S )Nc                 S   s"   g | ]}t |tr|nt|qS r   )r,   r   r   .0r   r   r   r   
<listcomp>   s   " z%Composed.__init__.<locals>.<listcomp>)superr    )r   rD   r$   r   r   r       s   zComposed.__init__r   r   c                    s   d  fdd| jD S )N    c                 3   s    | ]}|  V  qd S r   )r*   rE   r   r   r   	<genexpr>   s    z$Composed.as_bytes.<locals>.<genexpr>)joinr   r)   r   rK   r   r*      s   zComposed.as_bytesc                 C   s
   t | jS r   )iterr   r&   r   r   r   __iter__   r!   zComposed.__iter__r4   c                 C   s8   t |trt| j|j S t |trt| j|g S tS r   )r,   r5   r   r   r6   r7   r   r   r   r8      s
   

zComposed.__add__joinerSQLc                 C   s:   t |tr
t|}nt |tstd|d|| jS )a~  
        Return a new `!Composed` interposing the `!joiner` with the `!Composed` items.

        The `!joiner` must be a `SQL` or a string which will be interpreted as
        an `SQL`.

        Example::

            >>> fields = sql.Identifier('foo') + sql.Identifier('bar')  # a Composed
            >>> print(fields.join(', ').as_string(conn))
            "foo", "bar"

        z5Composed.join() argument must be strings or SQL, got  instead)r,   rA   rQ   	TypeErrorrM   r   )r   rP   r   r   r   rM      s   


zComposed.join)r%   r>   r?   r@   r   r   __annotations__r	   r   r    r   r   r-   r*   r   rO   r8   r
   r   rM   __classcell__r   r   rI   r   r5   j   s   
 "r5   c                       s   e Zd ZU dZeed< e Zdef fddZ	de
e defdd	Zde
e defd
dZdededefddZdee defddZ  ZS )rQ   aF  
    A `Composable` representing a snippet of SQL statement.

    `!SQL` exposes `join()` and `format()` methods useful to create a template
    where to merge variable parts of a query (for instance field or table
    names).

    The `!obj` string doesn't undergo any form of escaping, so it is not
    suitable to represent variable identifiers or values: you should only use
    it to pass constant strings representing templates or snippets of SQL
    statements; use other objects such as `Identifier` or `Literal` to
    represent variable parts.

    Example::

        >>> query = sql.SQL("SELECT {0} FROM {1}").format(
        ...    sql.SQL(', ').join([sql.Identifier('foo'), sql.Identifier('bar')]),
        ...    sql.Identifier('table'))
        >>> print(query.as_string(conn))
        SELECT "foo", "bar" FROM "table"
    r   r   c                    s*   t  | t|tstd|dd S )Nz SQL values must be strings, got rR   )rH   r    r,   rA   rS   r   rI   r   r   r       s   
zSQL.__init__r   r   c                 C   s   | j S r   r   r)   r   r   r   r      s   zSQL.as_stringc                 C   s   d}|r	t |j}| j|S )Nzutf-8)r   r+   r   encode)r   r   r2   r   r   r   r*      s   
zSQL.as_bytesargskwargsc           	      O   s   g }d}| j | jD ]S\}}}}|rtd|rtd|r&|t| |du r+q| rA|r5td||t|  d}q|sW|du rKtd|||  |d7 }q|||  qt|S )a  
        Merge `Composable` objects into a template.

        :param args: parameters to replace to numbered (``{0}``, ``{1}``) or
            auto-numbered (``{}``) placeholders
        :param kwargs: parameters to replace to named (``{name}``) placeholders
        :return: the union of the `!SQL` string with placeholders replaced
        :rtype: `Composed`

        The method is similar to the Python `str.format()` method: the string
        template supports auto-numbered (``{}``), numbered (``{0}``,
        ``{1}``...), and named placeholders (``{name}``), with positional
        arguments replacing the numbered placeholders and keywords replacing
        the named ones. However placeholder modifiers (``{0!r}``, ``{0:<10}``)
        are not supported.

        If a `!Composable` objects is passed to the template it will be merged
        according to its `as_string()` method. If any other Python object is
        passed, it will be wrapped in a `Literal` object and so escaped
        according to SQL rules.

        Example::

            >>> print(sql.SQL("SELECT * FROM {} WHERE {} = %s")
            ...     .format(sql.Identifier('people'), sql.Identifier('id'))
            ...     .as_string(conn))
            SELECT * FROM "people" WHERE "id" = %s

            >>> print(sql.SQL("SELECT * FROM {tbl} WHERE name = {name}")
            ...     .format(tbl=sql.Identifier('people'), name="O'Rourke"))
            ...     .as_string(conn))
            SELECT * FROM "people" WHERE name = 'O''Rourke'

        r   z(no format specification supported by SQLz%no format conversion supported by SQLNz6cannot switch from automatic field numbering to manualz6cannot switch from manual field numbering to automaticr   )	
_formatterparser   
ValueErrorappendrQ   isdigitrB   r5   )	r   rW   rX   rvautonumprenamespecconvr   r   r   format   s6   #
z
SQL.formatrD   c                 C   s^   g }t |}z	|t| W n ty   Y t|S w |D ]}||  || qt|S )a  
        Join a sequence of `Composable`.

        :param seq: the elements to join.
        :type seq: iterable of `!Composable`

        Use the `!SQL` object's string to separate the elements in `!seq`.
        Note that `Composed` objects are iterable too, so they can be used as
        argument for this method.

        Example::

            >>> snip = sql.SQL(', ').join(
            ...     sql.Identifier(n) for n in ['foo', 'bar', 'baz'])
            >>> print(snip.as_string(conn))
            "foo", "bar", "baz"
        )rN   r\   nextStopIterationr5   )r   rD   r^   itir   r   r   rM     s   
zSQL.join)r%   r>   r?   r@   r   rT   string	FormatterrY   r    r   r   rA   r   r-   r*   r   r5   rd   r   r   rM   rU   r   r   rI   r   rQ      s   
 HrQ   c                       sX   e Zd ZU dZee ed< def fddZdefddZd	e	e
 defd
dZ  ZS )
Identifiera#  
    A `Composable` representing an SQL identifier or a dot-separated sequence.

    Identifiers usually represent names of database objects, such as tables or
    fields. PostgreSQL identifiers follow `different rules`__ than SQL string
    literals for escaping (e.g. they use double quotes instead of single).

    .. __: https://www.postgresql.org/docs/current/sql-syntax-lexical.html#         SQL-SYNTAX-IDENTIFIERS

    Example::

        >>> t1 = sql.Identifier("foo")
        >>> t2 = sql.Identifier("ba'r")
        >>> t3 = sql.Identifier('ba"z')
        >>> print(sql.SQL(', ').join([t1, t2, t3]).as_string(conn))
        "foo", "ba'r", "ba""z"

    Multiple strings can be passed to the object to represent a qualified name,
    i.e. a dot-separated sequence of identifiers.

    Example::

        >>> query = sql.SQL("SELECT {} FROM {}").format(
        ...     sql.Identifier("table", "field"),
        ...     sql.Identifier("schema", "table"))
        >>> print(query.as_string(conn))
        SELECT "table"."field" FROM "schema"."table"

    r   stringsc                    s@   t  | |std|D ]}t|tstd|dqd S )NzIdentifier cannot be emptyz*SQL identifier parts must be strings, got rR   )rH   r    rS   r,   rA   )r   rl   srI   r   r   r    ]  s   

zIdentifier.__init__r   c                 C   s"   | j j ddtt| j dS )Nr"   , r#   )r$   r%   rM   mapreprr   r&   r   r   r   r'   j  s   "zIdentifier.__repr__r   c                    sL   |r|j nd }|stdt|jt|  fdd| jD }d|S )Nz(a connection is necessary for Identifierc                    s   g | ]
} | qS r   )escape_identifierrV   )rF   rm   r2   escr   r   rG   s  s    z'Identifier.as_bytes.<locals>.<listcomp>   .)r+   r[   r   pgconnr   r   rM   )r   r   r1   escsr   rr   r   r*   m  s   

zIdentifier.as_bytes)r%   r>   r?   r@   r	   rA   rT   r    r'   r   r   r-   r*   rU   r   r   rI   r   rk   ;  s   
 rk   c                   @   s&   e Zd ZdZdee defddZdS )r   a  
    A `Composable` representing an SQL value to include in a query.

    Usually you will want to include placeholders in the query and pass values
    as `~cursor.execute()` arguments. If however you really really need to
    include a literal value in the query you can use this object.

    The string returned by `!as_string()` follows the normal :ref:`adaptation
    rules <types-adaptation>` for Python objects.

    Example::

        >>> s1 = sql.Literal("fo'o")
        >>> s2 = sql.Literal(42)
        >>> s3 = sql.Literal(date(2000, 1, 1))
        >>> print(sql.SQL(', ').join([s1, s2, s3]).as_string(conn))
        'fo''o', 42, '2000-01-01'::date

    r   r   c                 C   s   t |}|| jS r   )r   from_context
as_literalr   )r   r   txr   r   r   r*     s   
zLiteral.as_bytesN)r%   r>   r?   r@   r   r   r-   r*   r   r   r   r   r   w  s    r   c                       st   e Zd ZdZdejfdedeeef f fddZdefdd	Z	d
e
e defddZd
e
e defddZ  ZS )Placeholdera	  A `Composable` representing a placeholder for query parameters.

    If the name is specified, generate a named placeholder (e.g. ``%(name)s``,
    ``%(name)b``), otherwise generate a positional placeholder (e.g. ``%s``,
    ``%b``).

    The object is useful to generate SQL queries with a variable number of
    arguments.

    Examples::

        >>> names = ['foo', 'bar', 'baz']

        >>> q1 = sql.SQL("INSERT INTO my_table ({}) VALUES ({})").format(
        ...     sql.SQL(', ').join(map(sql.Identifier, names)),
        ...     sql.SQL(', ').join(sql.Placeholder() * len(names)))
        >>> print(q1.as_string(conn))
        INSERT INTO my_table ("foo", "bar", "baz") VALUES (%s, %s, %s)

        >>> q2 = sql.SQL("INSERT INTO my_table ({}) VALUES ({})").format(
        ...     sql.SQL(', ').join(map(sql.Identifier, names)),
        ...     sql.SQL(', ').join(map(sql.Placeholder, names)))
        >>> print(q2.as_string(conn))
        INSERT INTO my_table ("foo", "bar", "baz") VALUES (%(foo)s, %(bar)s, %(baz)s)

     ra   rd   c                    sv   t  | t|tstd|d|v rtd|t|tu r't|}t|ts6tdt|j|| _	d S )Nzexpected string as name, got r#   zinvalid name: z!expected PyFormat as format, got )
rH   r    r,   rA   rS   r[   r;   r   r%   _format)r   ra   rd   rI   r   r   r      s   


zPlaceholder.__init__r   c                 C   sT   g }| j r|t| j  | jtjur|d| jj  | jj dd	| dS )Nzformat=r"   rn   r#   )
r   r\   rp   r|   r   AUTOra   r$   r%   rM   )r   partsr   r   r   r'     s   zPlaceholder.__repr__r   c                 C   s*   | j j}| jrd| j d| S d| S )Nz%(r#   %)r|   valuer   )r   r   coder   r   r   r     s   "zPlaceholder.as_stringc                 C   s&   |r|j nd }t|}| ||S r   )r+   r   r   rV   )r   r   r1   r2   r   r   r   r*     s   zPlaceholder.as_bytes)r%   r>   r?   r@   r   r}   rA   r
   r    r'   r   r   r   r-   r*   rU   r   r   rI   r   rz     s    &	rz   NULLDEFAULTr   )"r@   r/   ri   abcr   r   typingr   r   r   r   r   r	   r
   pqr   r   adaptr   r   _compatr   
_encodingsr   rA   r   r   r5   rQ   rk   r   rz   r   r   r   r   r   r   <module>   s(    $GA <A