1Ei ( d Z ddlZddlZddlmZ ddlmZ ddlmZ ej d Z ej d Z
G d
d e Z d Z
ej d
Z G d dej j Z G d dej j Z G d de Z G d de Z G d de Z G d de Z G d de Z G d d ej Z G d d ej e Z G d d!ej Z d#d"Z dS )$z4Foundational utilities common to many sql modules.
N )
ClauseVisitor )exc)utilPARSE_AUTOCOMMITNO_ARGc $ e Zd ZdZd Zd Zd ZdS ) Immutablez@mark a ClauseElement as 'immutable' when expressions are cloned.c t d Nz(Immutable objects do not support copyingNotImplementedErrorself optionaldictkwargss g/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/sql/base.py
unique_paramszImmutable.unique_params !"LMMM c t d r
r r s r paramszImmutable.params r r c | S N r s r _clonezImmutable._clone" s r N)__name__
__module__ __qualname____doc__r r r r r r r r sM JJN N NN N N r r c 2 t j d | D S )Nc g | ] }|j
S r )
_from_objects).0elements r
z!_from_objects..' s K K KwW 2 K K Kr ) itertoolschain)elementss r r% r% & s ? K K( K K K LLr c b |d } | |g|dd R i | |S )z Mark a method as generative.r r N) _generate)fnargskwr s r _generativer1 * sF 7 DBt d122h " Kr c < e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d S )
_DialectArgViewzaA dictionary view of dialect-level arguments in the form
_.
c || _ d S r )obj)r r5 s r __init__z_DialectArgView.__init__9 s
r c | dd \ }}||fS # t $ r.}t j t | | Y d }~d S d }~ww xY w)N_r replace_context)split
ValueErrorr raise_KeyError)r keydialect value_keyerrs r _keyz_DialectArgView._key< sz &!$3!2!2 GY I% % < < < K
s ; ; ; ; ; ; ; ; ; ; )r r? r@ rA optrB s r __getitem__z_DialectArgView.__getitem__D s !YYs^^ "(*73C y> ! $ < < < K
s ; ; ; ; ; ; ; ; ; ; _r9 )rC r5 rE r> r r= r
ArgumentError)r r? valuer@ rA rB s r __setitem__z_DialectArgView.__setitem__N s
A!%3 GY K | ]}t |j V d S r )len
_non_defaults)r& r/ s r z*_DialectArgView.__len__..` sA
" # #
r )sumr5 rE valuesr s r __len__z_DialectArgView.__len___ sA
07799
r c 4 fd j j D S )Nc 3 ~ K | ]7}j j | j D ] }t j |d | V 8dS )r8 N)r5 rE rR r
safe_kwarg)r& dialect_name
value_namer s r rS z+_DialectArgView.__iter__..f ss
"h 6
O|||ZZ @ A A
r )r5 rE r s `r __iter__z_DialectArgView.__iter__e s3
$ 8
r N) r r r! r" r6 rC rH rL rN rV r\ r r r r3 r3 3 s
& & &" " " A A A9 9 9
r r3 c 6 e Zd ZdZd Zd Zd Zd Zd Zd Z dS ) _DialectArgDictzA dictionary view of dialect-level arguments for a specific
dialect.
Maintains a separate collection of user-specified arguments
and dialect-specified default arguments.
c " i | _ i | _ d S r rR _defaultsr s r r6 z_DialectArgDict.__init__x s r c t t t | j | j S r )rQ setrR unionra r s r rV z_DialectArgDict.__len__| s+ 3t)**00 @@AAAr c t t t | j | j S r )iterrc rR rd ra r s r r\ z_DialectArgDict.__iter__ s+ C*++11$.AABBBr c H || j v r
| j | S | j | S r r` r r? s r rH z_DialectArgDict.__getitem__ s+ $$ $ $%c* *>#& &r c || j |< d S r rR )r r? rK s r rL z_DialectArgDict.__setitem__ s "'3 r c | j |= d S r rj rh s r rN z_DialectArgDict.__delitem__ s s # # #r N)
r r r! r" r6 rV r\ rH rL rN r r r r^ r^ o s~ B B BC C C' ' ' ( ( ($ $ $ $ $r r^ c e Zd ZdZed Zej d Ze d Z
ej d d Z ej
e Zd Zej d Zd Zd
S )
DialectKWArgsa9 Establish the ability for a class to have dialect-specific arguments
with defaults and constructor validation.
The :class:`.DialectKWArgs` interacts with the
:attr:`.DefaultDialect.construct_arguments` present on a dialect.
.. seealso::
:attr:`.DefaultDialect.construct_arguments`
c t j | }|t j d|z | |vri || < ||| |< dS )a Add a new kind of dialect-specific keyword argument for this class.
E.g.::
Index.argument_for("mydialect", "length", None)
some_index = Index('a', 'b', mydialect_length=5)
The :meth:`.DialectKWArgs.argument_for` method is a per-argument
way adding extra arguments to the
:attr:`.DefaultDialect.construct_arguments` dictionary. This
dictionary provides a list of argument names accepted by various
schema-level constructs on behalf of a dialect.
New dialects should typically specify this dictionary all at once as a
data member of the dialect class. The use case for ad-hoc addition of
argument names is typically for end-user code that is also using
a custom compilation scheme which consumes the additional arguments.
:param dialect_name: name of a dialect. The dialect must be
locatable, else a :class:`.NoSuchModuleError` is raised. The
dialect must also include an existing
:attr:`.DefaultDialect.construct_arguments` collection, indicating
that it participates in the keyword-argument validation and default
system, else :class:`.ArgumentError` is raised. If the dialect does
not include this collection, then any keyword argument can be
specified on behalf of this dialect already. All dialects packaged
within SQLAlchemy include this collection, however for third party
dialects, support may vary.
:param argument_name: name of the parameter.
:param default: default value of the parameter.
.. versionadded:: 0.9.4
NzRDialect '%s' does have keyword-argument validation and defaults enabled configured)rm _kw_registryr rJ )clsrZ
argument_namedefaultconstruct_arg_dictionarys r argument_forzDialectKWArgs.argument_for sk P $1#=l#K # +#=?KL
. . .,. $S )7> %m444r c t | S )a9 A collection of keyword arguments specified as dialect-specific
options to this construct.
The arguments are present here in their original ``_``
format. Only arguments that were actually passed are included;
unlike the :attr:`.DialectKWArgs.dialect_options` collection, which
contains all options known by this dialect including defaults.
The collection is also writable; keys are accepted of the
form ``_`` where the value will be assembled
into the list of options.
.. versionadded:: 0.9.2
.. versionchanged:: 0.9.4 The :attr:`.DialectKWArgs.dialect_kwargs`
collection is now writable.
.. seealso::
:attr:`.DialectKWArgs.dialect_options` - nested dictionary form
)r3 r s r dialect_kwargsz DialectKWArgs.dialect_kwargs s 0 t$$$r c | j S )z4A synonym for :attr:`.DialectKWArgs.dialect_kwargs`.)rv r s r r zDialectKWArgs.kwargs s
""r zsqlalchemy.dialectsc p | j | }|j d S t |j S r )registryloadconstruct_argumentsdict)dialectsrZ dialect_clss r _kw_reg_for_dialectz!DialectKWArgs._kw_reg_for_dialect s7 ',,\:: * 24K3444r c t j | }t }| |j dd i n@t | j j D ]&}||v r |j || '|S )N*)rm ro r^ ra updatereversed __class____mro__)r rZ rs drp s r _kw_reg_for_dialect_clsz%DialectKWArgs._kw_reg_for_dialect_cls s #0#=l#K # +
K T{ + + + + 677
F
F222K&&'?'DEEEr c X t j t j | j S )a A collection of keyword arguments specified as dialect-specific
options to this construct.
This is a two-level nested registry, keyed to ````
and ````. For example, the ``postgresql_where``
argument would be locatable as::
arg = my_object.dialect_options['postgresql']['where']
.. versionadded:: 0.9.2
.. seealso::
:attr:`.DialectKWArgs.dialect_kwargs` - flat dictionary form
)r PopulateDictportable_instancemethodr r s r rE z DialectKWArgs.dialect_options s* & ()E F F
r c |sd S |D ]}t j d| }|st d|z | dd \ }} | j | }d|vr&||vr"t j d|d|d| j || ||< # t
j $ ra t j
d |d
| t x| j |< }|j
dd i || |j |< Y w xY wd S ) Nz ^(.+?)_(.+)$zGAdditional arguments should be named _, got '%s'r r r z Argument z is not accepted by dialect z on behalf of zCan't validate argument z,; can't locate any SQLAlchemy dialect named )rematch TypeErrorgrouprE r rJ r rF r warnr^ ra r rR )r r kmrZ arg_namers r s r _validate_dialect_kwargsz&DialectKWArgs._validate_dialect_kwargs s F C CA ++A
?ABC &'WWQ]] "L(
C+/+? +M( 777 (@@@ ++ 11lllDNN< :@,X66) (
6
6
6 qq,,(
:I9J9JJ$\2Q ""C;///,21I)))
6 C Cs
BA-C?>C?N)r r r! r" classmethodrt r memoized_propertyrv propertyr dependenciesr r ro r rE r r r r rm rm s
/? /? [/?b
% % %2 # # X# T,--5 5 .-5 %4$%899L
,%C %C %C %C %Cr rm c e Zd ZdZd ZdS )
GenerativezRAllow a ClauseElement to generate itself via the
@_generative decorator.
c | j | j }| j |_ |S r )r __new____dict__copy)r ss r r- zGenerative._generateG s3 N " "4> 2 2]''))
r N)r r r! r" r- r r r r r A s-
r r c v e Zd ZdZdZ ej ZdZe d Z
d Z d Z d Z
ed ZdS )
ExecutablezMark a :class:`_expression.ClauseElement` as supporting execution.
:class:`.Executable` is a superclass for all "statement" types
of objects, including :func:`select`, :func:`delete`, :func:`update`,
:func:`insert`, :func:`text`.
TNc d|v rt j d d|v rt j d | j | | _ dS )a Set non-SQL options for the statement which take effect during
execution.
Execution options can be set on a per-statement or
per :class:`_engine.Connection` basis. Additionally, the
:class:`_engine.Engine` and ORM :class:`~.orm.query.Query`
objects provide
access to execution options which they in turn configure upon
connections.
The :meth:`execution_options` method is generative. A new
instance of this statement is returned that contains the options::
statement = select([table.c.x, table.c.y])
statement = statement.execution_options(autocommit=True)
Note that only a subset of possible execution options can be applied
to a statement - these include "autocommit" and "stream_results",
but not "isolation_level" or "compiled_cache".
See :meth:`_engine.Connection.execution_options` for a full list of
possible options.
.. seealso::
:meth:`_engine.Connection.execution_options`
:meth:`_query.Query.execution_options`
:meth:`.Executable.get_execution_options`
isolation_levelz'isolation_level' execution option may only be specified on Connection.execution_options(), or per-engine using the isolation_level argument to create_engine().compiled_cachezm'compiled_cache' execution option may only be specified on Connection.execution_options(), not per statement.N)r rJ _execution_optionsrd )r r0 s r execution_optionsz Executable.execution_optionsZ ss B " "#/
r ! !#H
#'"9"?"?"C"C r c | j S )zGet the non-SQL options which will take effect during execution.
.. versionadded:: 1.3
.. seealso::
:meth:`.Executable.execution_options`
)r r s r get_execution_optionsz Executable.get_execution_options s
&&r c | j }|4t | d| j j }d|z }t j | | | || S )z.Compile and execute this :class:`.Executable`.N descriptionzThis %s is not directly bound to a Connection or Engine. Use the .execute() method of a Connection or Engine to execute this construct.)bindgetattrr r r UnboundExecutionError_execute_clauseelement)r multiparamsr elabelmsgs r executezExecutable.execute sa I 9D- 1HIIE-/45
+C00 0''k6BBBr c @ | j |i | S )znCompile and execute this :class:`.Executable`, returning the
result's scalar representation.
)r scalar)r r r s r r zExecutable.scalar s'
t|[3F33::<<. s ***SVV***r )reprr s r __str__zColumnCollection.__str__ s **T***+++r c n dj | v r<j j k r,| j }|j |j k r|| j |j = j | j v r| j j | j j < fd| j D | j dd< dS | j dS )a Add the given column to this collection, removing unaliased
versions of this column as well as existing columns with the
same key.
E.g.::
t = Table('sometable', metadata, Column('col1', Integer))
t.columns.replace(Column('col1', Integer, key='columnone'))
will remove the original 'col1' from the collection, and add
the new column under the name 'columnname'.
Used by schema.Column to override columns during table reflection.
Nc g | ]
}|u rn| S r r )r& r column
remove_cols r r( z,ColumnCollection.replace.. s2 $ $ $56!z//q$ $ $r )namer? _datar append)r r otherr s ` @r replacezColumnCollection.replace s
;$ 6:#<#<%EzUY&& "
Juy) : # # FJ/J!'
6: !$ $ $ $ $:>:K$ $ $D aaa
$ $V , , , , ,r c P |j st j d || |j < dS )zAdd a column to this collection.
The key attribute of the column will be used as the hash key
for this dictionary.
z-Can't add unnamed column to column collectionN)r? r rJ r r s r r zColumnCollection.add
s: z #?
"VZr c t r r rh s r rN z ColumnCollection.__delitem__ !###r c t r r )r r? r5 s r r z ColumnCollection.__setattr__ r r c
6 || v rp| | }||u rd S | | s-t j d|dt |dd d|d t j |d | j | || j |< d S )NzColumn z
on table tablez being replaced by zG, which has the same key. Consider use_labels for select() statements. proxy_set) shares_lineager r r r resetr r r )r r? rK existings r rL z ColumnCollection.__setitem__ s $;; CyH5 **511
ssGHgt < < < .A s%
AVOOAOOOr )r r? r r s `r removezColumnCollection.remove? sL Jvz "
(
!!! r c t | }t | j | j fd|D | j d |D d S )Nc 3 * K | ]
\ }}|v |V d S r r )r& r r all_col_sets r rS z*ColumnCollection.update..H s: !
!
%a{&:&:A&:&:&:&:!
!
r c 3 $ K | ] \ }}||fV d S r r )r& r r s r rS z*ColumnCollection.update..K s* ::5!*::::::r listrc r extendr r r iter_colsr s @r r zColumnCollection.updateE s E{{$+,, !
!
!
!
"!
!
!
::T::::::::r c t | }t | j | j fd|D | j d |D d S )Nc 3 $ K | ]
}|v|V d S r r )r& r r s r rS z*ColumnCollection.extend..P s- I IqA[4H4H4H4H4H4H I Ir c 3 ( K | ]
}|j |fV d S r )r? r s r rS z*ColumnCollection.extend..Q s( 3315!*333333r r r s @r r zColumnCollection.extendM su E{{$+,, I I I ID I I IIII
33d33333333r Nsqlalchemy.sql.elementsc g }t |d| D ]:}| j D ]0}| | r| ||k 1; |j | S r )r r r r and_r r+ r lr locals r __eq__zColumnCollection.__eq__U sw 66 ) )A *
)
)##E** )HHQ%Z(((
) x}a r c t |t j st j d t j | | S )Nz'__contains__ requires a string argument)
isinstancer string_typesr rJ OrderedProperties __contains__r r s r r z ColumnCollection.__contains__^ sC %!233 O#$MNN N%224???r c | j | j dS )Nr r r r s r __getstate__z ColumnCollection.__getstate__c s T5FGGGr c t | d|d t | d|d d S )Nr r )r r )r states r __setstate__z ColumnCollection.__setstate__f sA 4%.9994 ~1FGGGGGr c . |t | j v S r )rc r r cols r contains_columnz ColumnCollection.contains_columnj s c$+,,,,r c 6 t | j | j S r )ImmutableColumnCollectionr r r s r as_immutablez ColumnCollection.as_immutablem s (T5FGGGr )r r r! r" __slots__r6 r r r rN r rL r r r r __hash__r r r r r r r r
__classcell__)r s @r r r sj I , , , - - -D " " "$ $ $$ $ $ 8$ $ $
; ; ;4 4 4 HT011! ! 21!@ @ @
H H HH H H- - -H H H H H H Hr r c 0 e Zd Zd Zej j xZZdS )r c ~ t j | | t | d| d S r )r ImmutablePropertiesr6 r r )r data all_columnss r r6 z"ImmutableColumnCollection.__init__r s9 ))$5554 =====r N) r r r! r6 r r
_immutabler r r r r r r q s/ > > > .99FVVVr r c X e Zd Zd Zd Zd Z ej d d Zd Z dS ) ColumnSetc
|| v S r r r s r r zColumnSet.contains_columnz s d{r c : |D ]}| | d S r )r )r r r s r r zColumnSet.extend} s, C HHSMMMM r c @ t | t | z S r )r r
s r __add__zColumnSet.__add__ s DzzDKK''r r c g }|D ]5}| D ]0}| | r| ||k 16 |j | S r )r r r r s r r zColumnSet.__eq__ sh ) )A
)
)##E** )HHQ%Z(((
) x}a r c N t t d | D S )Nc 3 K | ]}|V d S r r )r& xs r rS z%ColumnSet.__hash__.. s" **!******r )hashtupler s r r zColumnSet.__hash__ s' E**T*****+++r N)
r r r! r r r) r r r r r r r r% r% y sz ( ( ( T011! ! 21!, , , , ,r r% c | j }|sV| j j }t | dt | dd }|r|d|}nd|z }|d|z }t j | |S )Nfullnamer z object z %s objectzm%s is not bound to an Engine or Connection. Execution can not proceed without a database to execute against.)r r r r r r )
schemaitemr r r r items r _bind_or_errorr4 s ?D -#,
GJ$E$E
&%)TT551DD %D ; !"
',,, Kr r ) r" r) r visitorsr r r symbolr r r r r% decoratorr1 collections_abcMutableMappingr3 r^ rm r r r r r r r r ordered_column_setr% r4 r r r r< s
# # # # # # 4; 122 X
M M M 9
9
9
9
9
d*9 9
9
9
x $ $ $ $ $d*9 $ $ $@oC oC oC oC oCF oC oC oCd p p p p p p p pf8 8 8 8 8 8 8 8"4 4 4 4 4M 4 4 4 WH WH WH WH WHt- WH WH WHt: : : : : 8:J : : :, , , , ,' , , ,0 r