ó
    Ñ]j^/  ã                  óº  • S SK Jr  S SKJr  S SKJr  S SKJr  S SKJr  S SKJr  SSKJ	r	  S	S
K
Jr  S	SK
Jr  S	SK
Jr  S	SK
Jr  S	SK
Jr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJ r   SSKJ!r!  SSKJ"r"  SSKJ#r#  SSK$J%r%  SSK&J'r'  S r(S+S" jr) " S# S!\5      r " S$ S%\ 5      r* " S& S'\*5      r+ " S( S)\*5      r,g*),é    )Úannotations)ÚAny)ÚList)ÚOptional)ÚTuple)ÚUnioné   )Úexté   )Ú_OnConflictConstraintT)Ú_OnConflictIndexElementsT)Ú_OnConflictIndexWhereT)Ú_OnConflictSetT)Ú_OnConflictWhereTé   )Úutil)Ú	coercions)Úroles)Úschema)Ú_DMLTableArgument)Ú_exclusive_against)Ú_generative)ÚColumnCollection)ÚReadOnlyColumnCollection©ÚInsert)ÚClauseElement)ÚColumnElement)ÚKeyedColumnElement)Ú
TextClause)Úalias)ÚSelf)r   Úinsertr   c                ó   • [        U 5      $ )aG  Construct a PostgreSQL-specific variant :class:`_postgresql.Insert`
construct.

.. container:: inherited_member

    The :func:`sqlalchemy.dialects.postgresql.insert` function creates
    a :class:`sqlalchemy.dialects.postgresql.Insert`.  This class is based
    on the dialect-agnostic :class:`_sql.Insert` construct which may
    be constructed using the :func:`_sql.insert` function in
    SQLAlchemy Core.

The :class:`_postgresql.Insert` construct includes additional methods
:meth:`_postgresql.Insert.on_conflict_do_update`,
:meth:`_postgresql.Insert.on_conflict_do_nothing`.

r   )Útables    Ú_/home/mande/repo/quber/.venv/lib/python3.13/site-packages/sqlalchemy/dialects/postgresql/dml.pyr#   r#   *   s   € ô" �%‹=Ðó    c                  óÖ   • \ rS rSrSrSrSr\R                    SS j5       r	\
" SSS0S9r\\     S           SS
 jj5       5       r\\   S       SS jj5       5       rSrg	)r   é>   zàPostgreSQL-specific implementation of INSERT.

Adds methods for PG-specific syntaxes such as ON CONFLICT.

The :class:`_postgresql.Insert` object is created using the
:func:`sqlalchemy.dialects.postgresql.insert` function.

Ú
postgresqlFc                ó>   • [        U R                  SS9R                  $ )aã  Provide the ``excluded`` namespace for an ON CONFLICT statement

PG's ON CONFLICT clause allows reference to the row that would
be inserted, known as ``excluded``.  This attribute provides
all columns in this row to be referenceable.

.. tip::  The :attr:`_postgresql.Insert.excluded` attribute is an
    instance of :class:`_expression.ColumnCollection`, which provides
    an interface the same as that of the :attr:`_schema.Table.c`
    collection described at :ref:`metadata_tables_and_columns`.
    With this collection, ordinary names are accessible like attributes
    (e.g. ``stmt.excluded.some_column``), but special names and
    dictionary method names should be accessed using indexed access,
    such as ``stmt.excluded["column name"]`` or
    ``stmt.excluded["values"]``.   See the docstring for
    :class:`_expression.ColumnCollection` for further examples.

.. seealso::

    :ref:`postgresql_insert_on_conflict` - example of how
    to use :attr:`_expression.Insert.excluded`

Úexcluded)Úname)r!   r%   Úcolumns)Úselfs    r&   r,   ÚInsert.excludedK   s   € ô6 �T—Z‘Z jÑ1×9Ñ9Ð9r'   Ú_post_values_clausezCThis Insert construct already has an ON CONFLICT clause established)ÚmsgsNc                ó*   • [        XX4U5      U l        U $ )aü  
Specifies a DO UPDATE SET action for ON CONFLICT clause.

Either the ``constraint`` or ``index_elements`` argument is
required, but only one of these can be specified.

:param constraint:
 The name of a unique or exclusion constraint on the table,
 or the constraint object itself if it has a .name attribute.

:param index_elements:
 A sequence consisting of string column names, :class:`_schema.Column`
 objects, or other column expression objects that will be used
 to infer a target index.

:param index_where:
 Additional WHERE criterion that can be used to infer a
 conditional target index.

:param set\_:
 A dictionary or other mapping object
 where the keys are either names of columns in the target table,
 or :class:`_schema.Column` objects or other ORM-mapped columns
 matching that of the target table, and expressions or literals
 as values, specifying the ``SET`` actions to take.

 .. versionadded:: 1.4 The
    :paramref:`_postgresql.Insert.on_conflict_do_update.set_`
    parameter supports :class:`_schema.Column` objects from the target
    :class:`_schema.Table` as keys.

 .. warning:: This dictionary does **not** take into account
    Python-specified default UPDATE values or generation functions,
    e.g. those specified using :paramref:`_schema.Column.onupdate`.
    These values will not be exercised for an ON CONFLICT style of
    UPDATE, unless they are manually specified in the
    :paramref:`.Insert.on_conflict_do_update.set_` dictionary.

:param where:
 Optional argument. An expression object representing a ``WHERE``
 clause that restricts the rows affected by ``DO UPDATE SET``. Rows not
 meeting the ``WHERE`` condition will not be updated (effectively a
 ``DO NOTHING`` for those rows).


.. seealso::

    :ref:`postgresql_insert_on_conflict`

)ÚOnConflictDoUpdater1   )r/   Ú
constraintÚindex_elementsÚindex_whereÚset_Úwheres         r&   Úon_conflict_do_updateÚInsert.on_conflict_do_updatep   s    € ôx $6Ø¨¸5ó$
ˆÔ ð ˆr'   c                ó(   • [        XU5      U l        U $ )a‰  
Specifies a DO NOTHING action for ON CONFLICT clause.

The ``constraint`` and ``index_elements`` arguments
are optional, but only one of these can be specified.

:param constraint:
 The name of a unique or exclusion constraint on the table,
 or the constraint object itself if it has a .name attribute.

:param index_elements:
 A sequence consisting of string column names, :class:`_schema.Column`
 objects, or other column expression objects that will be used
 to infer a target index.

:param index_where:
 Additional WHERE criterion that can be used to infer a
 conditional target index.

.. seealso::

    :ref:`postgresql_insert_on_conflict`

)ÚOnConflictDoNothingr1   )r/   r5   r6   r7   s       r&   Úon_conflict_do_nothingÚInsert.on_conflict_do_nothing±   s   € ô@ $7Ø¨ó$
ˆÔ ð ˆr'   )r1   )Úreturnz6ReadOnlyColumnCollection[str, KeyedColumnElement[Any]]©NNNNN)r5   r   r6   r   r7   r   r8   r   r9   r   r@   r"   ©NNN)r5   r   r6   r   r7   r   r@   r"   )Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__Ústringify_dialectÚinherit_cacher   Úmemoized_propertyr,   r   Ú_on_conflict_exclusiver   r:   r>   Ú__static_attributes__© r'   r&   r   r   >   s  † ñð %ÐØ€Mà	×Ñð:à	?ó:ó ð:ñ8 0Øà!ð $0ð
ñÐð Øð .2Ø48Ø.2Ø $Ø#'ð=à*ð=ð 2ð=ð ,ð	=ð
 ð=ð !ð=ð 
ô=ó ó ð=ð~ Øð .2Ø48Ø.2ð	!à*ð!ð 2ð!ð ,ð	!ð
 
ô!ó ó ó!r'   c                  óV   • \ rS rSr% SrS\S'   S\S'   S\S'      S     SS
 jjrSrg	)ÚOnConflictClauseé×   r*   zOptional[str]Úconstraint_targetz.Optional[List[Union[str, schema.Column[Any]]]]Úinferred_target_elementsz/Optional[Union[ColumnElement[Any], TextClause]]Úinferred_target_whereclauseNc                ó  • UbY  [        U[        5      (       dD  [        U[        R                  [        R
                  45      (       a  [        US5      =(       d    UnUbä  Ub  [        S5      e[        U[        5      (       a  Xl        S U l	        S U l
        O¬[        U[        R                  5      (       a+  UR                  nUR                  S   R                  S5      nOb[        U[        R
                  5      (       a  UR                  nUR                   nO*UR                  nUR                  S   R                  S5      nUb¡  S U l        U Vs/ s H(  n["        R$                  " [&        R(                  U5      PM*     snU l	        UbT  ["        R$                  " [        U[        R
                  5      (       a  [&        R*                  O[&        R,                  U5      OS U l
        g Uc  S =U l        =U l	        U l
        g g s  snf )Nr-   z8'constraint' and 'index_elements' are mutually exclusiver*   r9   )Ú
isinstanceÚstrr   Ú
Constraintr
   ÚExcludeConstraintÚgetattrÚ
ValueErrorrQ   rR   rS   ÚIndexÚexpressionsÚdialect_optionsÚgetr.   r9   r   Úexpectr   ÚDDLConstraintColumnRoleÚStatementOptionRoleÚWhereHavingRole)r/   r5   r6   r7   Úcolumns        r&   Ú__init__ÚOnConflictClause.__init__à   sã  € ð Ñ!Ü˜j¬#×.Ñ.´:ØÜ×"Ñ"¤C×$9Ñ$9Ð:÷4ñ 4ô % Z°Ó8×F¸J�
àÑ!ØÑ)Ü ØNóð ô ˜*¤c×*Ñ*Ø)3Ô&Ø04�Ô-Ø37�Õ0Ü˜J¬¯©×5Ñ5Ø!+×!7Ñ!7�Ø(×8Ñ8¸ÑF×JÑJØó‘ô ˜J¬×(=Ñ(=×>Ñ>Ø!+×!3Ñ!3�Ø(×.Ñ.‘à!+×!3Ñ!3�Ø(×8Ñ8¸ÑF×JÑJØó�ð Ñ%Ø%)ˆDÔ"ñ -ó-â,�Fô × Ò ¤×!>Ñ!>ÀÖGÙ,ñ-ˆDÔ)ð Ñ*ô × Ò ô & j´#×2GÑ2G×HÑHô ×1Ò1ä"×2Ñ2àôð ð Õ,ð Ñð ðˆDÔ"ð  TÔ%BØÕ0ð  ùò%-s   Å/H)rQ   rR   rS   rB   )r5   r   r6   r   r7   r   )rC   rD   rE   rF   rH   Ú__annotations__rd   rL   rM   r'   r&   rO   rO   ×   sO   ‡ Ø$Ðà$Ó$ØLÓLð"ó ð .2Ø48Ø.2ð	<à*ð<ð 2ð<ð ,÷	<ð <r'   rO   c                  ó   • \ rS rSrSrSrg)r=   i  r>   rM   N)rC   rD   rE   rF   Ú__visit_name__rL   rM   r'   r&   r=   r=     s   † Ø-ƒNr'   r=   c                  óf   ^ • \ rS rSr% SrS\S'   S\S'        S	         S
U 4S jjjrSrU =r$ )r4   i#  r:   z0List[Tuple[Union[schema.Column[Any], str], Any]]Úupdate_values_to_setzOptional[ColumnElement[Any]]Úupdate_whereclausec                ó*  >• [         TU ]  UUUS9  U R                  c  U R                  c  [	        S5      e[        U[        5      (       a  U(       d  [	        S5      eO,[        U[        5      (       a  [        U5      nO[	        S5      eUR                  5        VVs/ s H,  u  pg[        R                  " [        R                  U5      U4PM.     snnU l        Ub+  [        R                  " [        R                  U5      U l        g S U l        g s  snnf )N)r5   r6   r7   zVEither constraint or index_elements, but not both, must be specified unless DO NOTHINGz*set parameter dictionary must not be emptyzqset parameter must be a non-empty dictionary or a ColumnCollection such as the `.c.` collection of a Table object)Úsuperrd   rR   rQ   rZ   rU   Údictr   Úitemsr   r_   r   ÚDMLColumnRolerj   rb   rk   )	r/   r5   r6   r7   r8   r9   ÚkeyÚvalueÚ	__class__s	           €r&   rd   ÚOnConflictDoUpdate.__init__)  s  ø€ ô 	‰ÑØ!Ø)Ø#ð 	ñ 	
ð ×)Ñ)Ñ1Ø×&Ñ&Ñ.äðDóð ô
 �dœD×!Ñ!ÞÜ Ð!MÓNÐNð ä˜Ô.×/Ñ/Ü˜“:‰Däð$óð ð #Ÿj™jœlô%
â*‘
�ô ×Òœe×1Ñ1°3Ó7¸Ó?Ù*ò%
ˆÔ!ð Ñ ô ×ÒœU×2Ñ2°EÓ:ð 	Õð ð 	Õùó	%
s   Â3D)rj   rk   rA   )
r5   r   r6   r   r7   r   r8   r   r9   r   )	rC   rD   rE   rF   rh   rf   rd   rL   Ú__classcell__)rs   s   @r&   r4   r4   #  s_   ø‡ Ø,€NàJÓJØ4Ó4ð .2Ø48Ø.2Ø $Ø#'ð*
à*ð*
ð 2ð*
ð ,ð	*
ð
 ð*
ð !÷*
ö *
r'   r4   N)r%   r   r@   r   )-Ú
__future__r   Útypingr   r   r   r   r   Ú r
   Ú_typingr   r   r   r   r   r   Úsqlr   r   r   Úsql._typingr   Úsql.baser   r   r   r   Úsql.dmlr   ÚStandardInsertÚsql.elementsr   r   r   r    Úsql.expressionr!   Úutil.typingr"   Ú__all__r#   rO   r=   r4   rM   r'   r&   Ú<module>rƒ      sŸ   ðõ #å Ý Ý Ý Ý å Ý ,Ý /Ý ,Ý %Ý 'Ý Ý Ý Ý Ý ,Ý *Ý #Ý (Ý 0Ý /Ý )Ý )Ý .Ý &Ý #Ý ð €ôô(Vˆ^ô VôrE�}ô EôP.Ð*ô .ô0
Ð)õ 0
r'   