o
    Šåg 6  ã                   @  sô   d dl mZ 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dlm	Z	 dd	lm
Z
 d
dlmZ d
dlmZ d
dlmZ d
dlmZ d
dlmZ eded�Zejfdd„Zejfdd„ZG dd„ deje ƒZG dd„ dejƒZdd„ ZdS )é    )ÚannotationsN)ÚAny)ÚOptional)ÚTypeVaré   )ÚCONTAINED_BY)ÚCONTAINS)ÚOVERLAPé   )Útypes)Úutil)Ú
expression)Ú	operators)Ú_TypeEngineArgumentÚ_T)Úboundc                 C  ó   |  | |¡S )zjA synonym for the ARRAY-level :meth:`.ARRAY.Comparator.any` method.
    See that method for details.

    )Úany©ÚotherÚarrexprÚoperator© r   ú`/var/www/html/flaskapp/venv/lib/python3.10/site-packages/sqlalchemy/dialects/postgresql/array.pyr      ó   r   c                 C  r   )zjA synonym for the ARRAY-level :meth:`.ARRAY.Comparator.all` method.
    See that method for details.

    )Úallr   r   r   r   ÚAll'   r   r   c                      sL   e Zd ZdZd ZdZdZ‡ fdd„Zedd„ ƒZ	dd
d„Z
ddd„Z‡  ZS )Úarraya0  A PostgreSQL ARRAY literal.

    This is used to produce ARRAY literals in SQL expressions, e.g.::

        from sqlalchemy.dialects.postgresql import array
        from sqlalchemy.dialects import postgresql
        from sqlalchemy import select, func

        stmt = select(array([1, 2]) + array([3, 4, 5]))

        print(stmt.compile(dialect=postgresql.dialect()))

    Produces the SQL:

    .. sourcecode:: sql

        SELECT ARRAY[%(param_1)s, %(param_2)s] ||
            ARRAY[%(param_3)s, %(param_4)s, %(param_5)s]) AS anon_1

    An instance of :class:`.array` will always have the datatype
    :class:`_types.ARRAY`.  The "inner" type of the array is inferred from
    the values present, unless the ``type_`` keyword argument is passed::

        array(["foo", "bar"], type_=CHAR)

    Multidimensional arrays are produced by nesting :class:`.array` constructs.
    The dimensionality of the final :class:`_types.ARRAY`
    type is calculated by
    recursively adding the dimensions of the inner :class:`_types.ARRAY`
    type::

        stmt = select(
            array(
                [array([1, 2]), array([3, 4]), array([column("q"), column("x")])]
            )
        )
        print(stmt.compile(dialect=postgresql.dialect()))

    Produces:

    .. sourcecode:: sql

        SELECT ARRAY[
            ARRAY[%(param_1)s, %(param_2)s],
            ARRAY[%(param_3)s, %(param_4)s],
            ARRAY[q, x]
        ] AS anon_1

    .. versionadded:: 1.3.6 added support for multidimensional array literals

    .. seealso::

        :class:`_postgresql.ARRAY`

    Ú
postgresqlTc                   sœ   |  dd ¡}tƒ jtjg|¢R i |¤Ž dd„ | jD ƒ| _|d ur#|n
| jr+| jd ntj}t	|t
ƒrGt
|j|jd ur@|jd ndd�| _d S t
|ƒ| _d S )NÚtype_c                 S  s   g | ]}|j ‘qS r   )Útype)Ú.0Úargr   r   r   Ú
<listcomp>r   s    z"array.__init__.<locals>.<listcomp>r   r   é   )Ú
dimensions)ÚpopÚsuperÚ__init__r   Úcomma_opÚclausesÚ_type_tupleÚsqltypesÚNULLTYPEÚ
isinstanceÚARRAYÚ	item_typer%   r    )Úselfr*   ÚkwÚtype_argÚ	main_type©Ú	__class__r   r   r(   n   s   ÿý


ÿû	zarray.__init__c                 C  s   | fS ©Nr   ©r1   r   r   r   Ú_select_iterable†   ó   zarray._select_iterableFNc                   s@   |sˆ t ju rtjd |ˆ ˆˆjdd�S t‡ ‡‡fdd„|D ƒƒS )NT)Ú_compared_to_operatorr   Ú_compared_to_typeÚuniquec                   s   g | ]}ˆj ˆ |d ˆd�‘qS )T)Ú_assume_scalarr   )Ú_bind_param)r!   Úo©r   r1   r   r   r   r#   —   s    ýÿÿz%array._bind_param.<locals>.<listcomp>)r   Úgetitemr   ÚBindParameterr    r   )r1   r   Úobjr>   r   r   rA   r   r?   Š   s   ú
üÿzarray._bind_paramc                 C  s"   |t jt jt jfv rt | ¡S | S r7   )r   Úany_opÚall_oprB   r   ÚGrouping)r1   Úagainstr   r   r   Ú
self_groupŸ   s   
zarray.self_group)FNr7   )Ú__name__Ú
__module__Ú__qualname__Ú__doc__Ú__visit_name__Ústringify_dialectÚinherit_cacher(   Úpropertyr9   r?   rI   Ú__classcell__r   r   r5   r   r   0   s    8

r   c                   @  s€   e Zd ZdZ			dddd„ZG dd„ dejjƒZeZe	dd„ ƒZ
e	dd„ ƒZdd„ Zejdd„ ƒZdd„ Zdd„ Zdd„ ZdS )r/   an
  PostgreSQL ARRAY type.

    The :class:`_postgresql.ARRAY` type is constructed in the same way
    as the core :class:`_types.ARRAY` type; a member type is required, and a
    number of dimensions is recommended if the type is to be used for more
    than one dimension::

        from sqlalchemy.dialects import postgresql

        mytable = Table(
            "mytable",
            metadata,
            Column("data", postgresql.ARRAY(Integer, dimensions=2)),
        )

    The :class:`_postgresql.ARRAY` type provides all operations defined on the
    core :class:`_types.ARRAY` type, including support for "dimensions",
    indexed access, and simple matching such as
    :meth:`.types.ARRAY.Comparator.any` and
    :meth:`.types.ARRAY.Comparator.all`.  :class:`_postgresql.ARRAY`
    class also
    provides PostgreSQL-specific methods for containment operations, including
    :meth:`.postgresql.ARRAY.Comparator.contains`
    :meth:`.postgresql.ARRAY.Comparator.contained_by`, and
    :meth:`.postgresql.ARRAY.Comparator.overlap`, e.g.::

        mytable.c.data.contains([1, 2])

    Indexed access is one-based by default, to match that of PostgreSQL;
    for zero-based indexed access, set
    :paramref:`_postgresql.ARRAY.zero_indexes`.

    Additionally, the :class:`_postgresql.ARRAY`
    type does not work directly in
    conjunction with the :class:`.ENUM` type.  For a workaround, see the
    special type at :ref:`postgresql_array_of_enum`.

    .. container:: topic

        **Detecting Changes in ARRAY columns when using the ORM**

        The :class:`_postgresql.ARRAY` type, when used with the SQLAlchemy ORM,
        does not detect in-place mutations to the array. In order to detect
        these, the :mod:`sqlalchemy.ext.mutable` extension must be used, using
        the :class:`.MutableList` class::

            from sqlalchemy.dialects.postgresql import ARRAY
            from sqlalchemy.ext.mutable import MutableList


            class SomeOrmClass(Base):
                # ...

                data = Column(MutableList.as_mutable(ARRAY(Integer)))

        This extension will allow "in-place" changes such to the array
        such as ``.append()`` to produce events which will be detected by the
        unit of work.  Note that changes to elements **inside** the array,
        including subarrays that are mutated in place, are **not** detected.

        Alternatively, assigning a new array value to an ORM element that
        replaces the old one will always trigger a change event.

    .. seealso::

        :class:`_types.ARRAY` - base array type

        :class:`_postgresql.array` - produces a literal array value.

    FNr0   ú_TypeEngineArgument[Any]Úas_tupleÚboolr%   úOptional[int]Úzero_indexesc                 C  s>   t |tƒr	tdƒ‚t |tƒr|ƒ }|| _|| _|| _|| _dS )a-  Construct an ARRAY.

        E.g.::

          Column("myarray", ARRAY(Integer))

        Arguments are:

        :param item_type: The data type of items of this array. Note that
          dimensionality is irrelevant here, so multi-dimensional arrays like
          ``INTEGER[][]``, are constructed as ``ARRAY(Integer)``, not as
          ``ARRAY(ARRAY(Integer))`` or such.

        :param as_tuple=False: Specify whether return results
          should be converted to tuples from lists. DBAPIs such
          as psycopg2 return lists by default. When tuples are
          returned, the results are hashable.

        :param dimensions: if non-None, the ARRAY will assume a fixed
         number of dimensions.  This will cause the DDL emitted for this
         ARRAY to include the exact number of bracket clauses ``[]``,
         and will also optimize the performance of the type overall.
         Note that PG arrays are always implicitly "non-dimensioned",
         meaning they can store any number of dimensions no matter how
         they were declared.

        :param zero_indexes=False: when True, index values will be converted
         between Python zero-based and PostgreSQL one-based indexes, e.g.
         a value of one will be added to all index values before passing
         to the database.

        zUDo not nest ARRAY types; ARRAY(basetype) handles multi-dimensional arrays of basetypeN)r.   r/   Ú
ValueErrorr    r0   rT   r%   rW   )r1   r0   rT   r%   rW   r   r   r   r(   î   s   
'ÿ

zARRAY.__init__c                   @  s(   e Zd ZdZdd„ Zdd„ Zdd„ ZdS )	zARRAY.Comparatora*  Define comparison operations for :class:`_types.ARRAY`.

        Note that these operations are in addition to those provided
        by the base :class:`.types.ARRAY.Comparator` class, including
        :meth:`.types.ARRAY.Comparator.any` and
        :meth:`.types.ARRAY.Comparator.all`.

        c                 K  ó   | j t|tjd�S )zåBoolean expression.  Test if elements are a superset of the
            elements of the argument array expression.

            kwargs may be ignored by this operator but are required for API
            conformance.
            ©Úresult_type)Úoperater   r,   ÚBoolean)r1   r   Úkwargsr   r   r   Úcontains+  s   zARRAY.Comparator.containsc                 C  rY   )z„Boolean expression.  Test if elements are a proper subset of the
            elements of the argument array expression.
            rZ   )r\   r   r,   r]   ©r1   r   r   r   r   Úcontained_by4  s   ÿzARRAY.Comparator.contained_byc                 C  rY   )zuBoolean expression.  Test if array has elements in common with
            an argument array expression.
            rZ   )r\   r	   r,   r]   r`   r   r   r   Úoverlap<  s   zARRAY.Comparator.overlapN)rJ   rK   rL   rM   r_   ra   rb   r   r   r   r   Ú
Comparator!  s
    		rc   c                 C  s   | j S r7   )rT   r8   r   r   r   ÚhashableD  r:   zARRAY.hashablec                 C  s   t S r7   )Úlistr8   r   r   r   Úpython_typeH  s   zARRAY.python_typec                 C  s   ||kS r7   r   )r1   ÚxÚyr   r   r   Úcompare_valuesL  s   zARRAY.compare_valuesc                 C  s   t | jtjƒo
| jjS r7   )r.   r0   r,   ÚEnumÚnative_enumr8   r   r   r   Ú_against_native_enumO  s   þzARRAY._against_native_enumc                   s:   ˆj  |¡ |¡‰ ˆ d u rd S dd„ ‰‡ ‡‡fdd„}|S )Nc                 S  s   dd  | ¡› d�S )NzARRAY[z, ú])Újoin)Úelementsr   r   r   Úto_str]  s   z'ARRAY.literal_processor.<locals>.to_strc                   s   ˆ  | ˆ ˆjˆ¡}|S r7   )Ú_apply_item_processorr%   ©ÚvalueÚinner©Ú	item_procr1   rp   r   r   Úprocess`  s   
ÿz(ARRAY.literal_processor.<locals>.process)r0   Údialect_implÚliteral_processor©r1   Údialectrw   r   ru   r   ry   V  s   ÿzARRAY.literal_processorc                   s$   ˆj  |¡ |¡‰ ‡ ‡fdd„}|S )Nc                   s   | d u r| S ˆ  | ˆ ˆjt¡S r7   )rq   r%   re   ©rs   ©rv   r1   r   r   rw   m  s
   
ÿz%ARRAY.bind_processor.<locals>.process)r0   rx   Úbind_processorrz   r   r}   r   r~   h  s
   ÿzARRAY.bind_processorc                   sT   ˆj  |¡ ||¡‰‡‡fdd„}ˆjr(|‰t d¡‰‡fdd„‰ ‡ ‡fdd„}|S )Nc                   s*   | d u r| S ˆ  | ˆ ˆjˆjrt¡S t¡S r7   )rq   r%   rT   Útuplere   r|   r}   r   r   rw   |  s   üüz'ARRAY.result_processor.<locals>.processz^{(.*)}$c                   s   ˆ   | ¡ d¡}t|ƒS )Nr   )ÚmatchÚgroupÚ_split_enum_valuesrr   )Úpatternr   r   Úhandle_raw_string‹  s   z1ARRAY.result_processor.<locals>.handle_raw_stringc                   s(   | d u r| S ˆt | tƒrˆ | ƒƒS | ƒS r7   )r.   Ústrr|   )r„   Úsuper_rpr   r   rw   �  s   ÿÿý)r0   rx   Úresult_processorrl   ÚreÚcompile)r1   r{   Úcoltyperw   r   )r„   rv   rƒ   r1   r†   r   r‡   w  s   ÿ
zARRAY.result_processor)FNF)r0   rS   rT   rU   r%   rV   rW   rU   )rJ   rK   rL   rM   r(   r,   r/   rc   Úcomparator_factoryrQ   rd   rf   ri   r   Úmemoized_propertyrl   ry   r~   r‡   r   r   r   r   r/   ¦   s$    Jû3!


r/   c                 C  sŽ   d| vr| r|   d¡S g S |  dd¡}| dd¡}g }t  d|¡}d}|D ]}|dkr/| }q%|r;| | dd¡¡ q%| t d	|¡¡ q%|S )
Nú"ú,z\"z_$ESC_QUOTE$_z\\ú\z(")Fz([^\s,]+),?)ÚsplitÚreplacerˆ   ÚappendÚextendÚfindall)Úarray_stringÚtextÚresultÚ	on_quotesÚ	in_quotesÚtokr   r   r   r‚   ž  s   r‚   )Ú
__future__r   rˆ   Útypingr   r   r   r   r   r   r	   Ú r   r,   r   Úsqlr   Úsql._typingr   r   Úeqr   ÚExpressionClauseListr   r/   r‚   r   r   r   r   Ú<module>   s(   			v y