/opt/cloudlinux/venv/lib/python3.11/site-packages/alembic/ddl/__pycache__
Edit: /opt/cloudlinux/venv/lib/python3.11/site-packages/alembic/ddl/__pycache__/impl.cpython-311.pyc (30922B)
f
1g'U ^ U d dl mZ d dlmZ d dlZd dlmZ d dlmZ d dlmZ d dlm Z d dlm
Z
d d lm Z d d
lm Z d d lm
Z
d d lmZ d d
lmZ d dlmZ d dlmZ d dlmZ d dlmZ ddlmZ ddlmZ ddlmZ er~d dlmZ d dlmZ d dlm Z d dlm Z d dl 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, d d&l-m.Z. d d'l/m0Z0 dd(lm1Z1 dd)l2m3Z3 dd*l4m5Z5 dd+l4m6Z6 G d, d-e7 Z8i Z9d.e:d/< ed0g d1 Z; G d2 d3e84 Z
r= r/ r/ 3 s( r> r/ z Dict[str, Type[DefaultImpl]]r: Params)token0tokensargskwargsc e Zd ZU dZdZdZdZddhfZded< d Z d
ed < d Z
d
ed< dd Z e dd Z
dd"Zdd%Zdd*Zedd+ Zd,d ej fdd5Z ddd7Z dddMZ dddQZ dddRZddTZddVZ dddZZ dd[Z dd\Z dd_Z dd`Z ddaZ!ddcZ"dddZ# dddjZ$ddmZ%ddpZ&ddsZ'ddvZ(dw Z)dd~Z*d Z+ dddZ,ddZ-ddZ.d Z/ddZ0ddZ1ddZ2ddZ3d Z4ddZ5d Z6d,S ) DefaultImpla Provide the entrypoint for major migration operations,
including database-specific behavioral variances.
While individual SQL/DDL constructs already provide
for database-specific implementations, variances here
allow for entirely different sequences of operations
to take place for a particular migration, such as
SQL Server's special 'IDENTITY INSERT' step for
bulk inserts.
defaultF;NUMERICDECIMALzTuple[Set[str], ...]
type_synonymsrB z
Sequence[str]type_arg_extract)on_nullzTuple[str, ...]identity_attrs_ignoredialectr
connectionOptional[Connection]as_sqlbooltransactional_ddlOptional[bool]
output_bufferOptional[TextIO] context_optsr5 returnNonec || _ || _ || _ | dd | _ || _ i | _ || _ ||| _ | j r| j st j
d d S d S )N
literal_bindsFz3Can't use literal_binds setting without as_sql mode) rR rS rU getr_ rY memor[ rW r CommandError)selfrR rS rU rW rY r[ s r= r9 zDefaultImpl.__init__\ s $ ) - -ou E E * ( (%6D " ;
'I
r> Type[DefaultImpl]c & t |j S N)r: name)r; rR s r= get_by_dialectzDefaultImpl.get_by_dialectv s gl##r> r r1 c | j J | j |dz | j d S )Nz
)rY writeflush)rc r s r=
static_outputzDefaultImpl.static_outputz sG !--- /// """""r> batch_opr- c dS )zReturn True if the given :class:`.BatchOperationsImpl`
would need the table to be recreated and copied in order to
proceed.
Normally, only returns True on SQLite when operations other
than add_column are present.
FrB )rc rm s r= requires_recreate_in_batchz&DefaultImpl.requires_recreate_in_batch s ur>
batch_implr, tabler& c dS )zperform any operations needed on a table before a new
one is created to replace it in batch mode.
the PG dialect uses this to drop constraints on the table
before the new one uses those same names.
NrB )rc rp rq s r= prep_table_for_batchz DefaultImpl.prep_table_for_batch r> c | j S rf )rS rc s r= bindzDefaultImpl.bind s
r> N constructUnion[ClauseElement, str]execution_optionsOptional[dict[str, Any]] multiparamsSequence[dict]paramsOptional[CursorResult]c T t |t rt | }| j r|s|rt d | j r-t |t j st ddi }ni } |j dd| j
i|}| t | dd
| j z d S | j }|J |r
|j di |}|r t |t" sJ ||fz
}| || S ) Nz+Execution arguments not allowed with as_sqlr_ T)compile_kwargsrR z rB )
isinstancer1 r rU Exceptionr_ r
DDLElementdictcompilerR rl replacestripcommand_terminatorrS rz tupleexecute)rc rx rz r| r~
compile_kwcompiledconns r= _execzDefaultImpl._exec s i % % ( YI ;
Of
O MNNN!
*6,+ +
"/41H I I I
(y( (2 H
H
%%dF3399;;)*
4?D###
C-t-BB0ABB
)!+u55555y( <<;
r> sqlc 2 | || d S rf )r )rc r rz s r= r zDefaultImpl.execute s
3)*****r>
table_name column_namenullableserver_default%Union[_ServerDefault, Literal[False]]rg
Optional[str]type_Optional[TypeEngine]r
autoincrementcomment$Optional[Union[str, Literal[False]]]existing_comment
existing_typeexisting_server_defaultOptional[_ServerDefault]existing_nullableexisting_autoincrementkwr c ||t j dd |/| t j ||||| | |
|
|dur{i }t j || r
t j }n3t j || rt j }| |d< n t j
}| ||||f|| | |
|
d| |/| t j ||||| | |
|
| dur/| t j ||| || | |
|
|0| t j
||||| | |
d S d S )NzBautoincrement and existing_autoincrement only make sense for MySQL )
stacklevel)r r r r r Fimpl)r r r r )r warnr r ColumnNullabler _server_default_is_computedComputedColumnDefault_server_default_is_identityIdentityColumnDefault
ColumnDefault
ColumnType
ColumnComment
ColumnName)rc r r r r rg r r r r r r r r r r cls_s r= alter_columnzDefaultImpl.alter_column s5 $ $(>(J I,
JJ# !"/,C&7%5
& &B 6 7
* 1 8 7
* 1 !6
) JJ "
""/,C&7%5
JJ !"/,C&7%5
% JJ" !"/,C&7%5
JJ !"/,C&7
r> column Column[Any]!Optional[Union[str, quoted_name]]c Z | t j ||| d S Nr )r r AddColumn)rc r r r s r=
add_columnzDefaultImpl.add_column< s-
4>*fVDDDEEEEEr> c Z | t j ||| d S r )r r
DropColumn)rc r r r r s r= drop_columnzDefaultImpl.drop_columnD s-
4?:vfEEEFFFFFr> constc |j | | r)| t j | d S d S rf ) _create_ruler r
AddConstraintrc r s r= add_constraintzDefaultImpl.add_constraintM sI %););D)A)A % JJv+E22 3 3 3 3 3 & %r> r# c T | t j | d S rf )r r DropConstraintr s r= drop_constraintzDefaultImpl.drop_constraintQ s%
6(//00000r> old_table_namenew_table_nameUnion[str, quoted_name]c Z | t j ||| d S r )r r RenameTable)rc r r r s r= rename_tablezDefaultImpl.rename_tableT s9
^^F K K K
r> c |j || j d| | t j | |j || j d| |j D ])}| t j | *| j j
o | j j }|j }|r|r|
| |j D ]"}|j }|r|r| | #d S NF)
checkfirst _ddl_runner)dispatch
before_createrS r r CreateTable after_createindexes CreateIndexrR supports_commentsinline_commentsr create_table_commentcolumnscreate_column_comment)rc rq index with_commentr r s r= create_tablezDefaultImpl.create_table^ s6
$$ 4?u$ %
6%e,,---
## 4?u$ $
] 2 2E JJv)%00 1 1 1 1
L * O4<3O/O - -| - % %e , , ,m 3 3F nG
3<
3**6222 3 3r> c |j || j d| | t j | |j || j d| d S r )r before_droprS r r DropTable
after_droprc rq s r=
drop_tablezDefaultImpl.drop_tableu s
"" 4?u$ #
6#E**+++
!! 4?u$ "
r> r r% c T | t j | d S rf )r r r rc r s r= create_indexzDefaultImpl.create_index~ s%
6%e,,-----r> c T | t j | d S rf )r r SetTableCommentr s r= r z DefaultImpl.create_table_comment s%
6)%0011111r> c T | t j | d S rf )r r DropTableCommentr s r= drop_table_commentz DefaultImpl.drop_table_comment s%
6*51122222r> ColumnElement[Any]c T | t j | d S rf )r r SetColumnComment)rc r s r= r z!DefaultImpl.create_column_comment s%
6*62233333r> c T | t j | d S rf )r r DropIndexr s r=
drop_indexzDefaultImpl.drop_index s%
6#E**+++++r> TUnion[TableClause, Table]rows
List[dict] multiinsertc
4 t |t st d |r*t |d t st d | j rW|D ]R}| t
j j di fd| D Sd S |rd|r+| t
j | d S |D ]6}| t
j j di | 5d S d S )Nz
List expectedr z List of dictionaries expectedc i | ]I\ }}|t |t j s't j ||j | j n|JS ))r )r r _literal_bindparamcr8 ).0kvrq s r=
z+DefaultImpl.bulk_insert.. sx !%1 $. !;#A$ $ #{ = !1EGAJO "# r> )r| rB )
r list TypeErrorr rU r r _insert_inlinevaluesitems)rc rq r r rows ` r= bulk_insertzDefaultImpl.bulk_insert s $%% =O,, ,
=*T!Wd33 = ;<< < ;
r" rC c j | j j |j }t j d| }g }d }|D ]/}t j d| r|}| | 0t |d |dd g i }|rt j d| D ]y}d|v rG|
d \ } }
|
|j | < M|j
| z|S )Nz[\w\-_]+|\(.+?\)z^\(.*\)$r r z[^(),]+=)rR
type_compilerprocessr8 lowerrefindallmatchappendrC splitr rG rF ) rc r
definitionrE term_tokens
paren_termtokenr~ termkeyvals r= _tokenize_column_typez!DefaultImpl._tokenize_column_type s* \/77 DDJJLL
/<<
* *Ex U++
* "
""5)))) A ABBR@@ 5
9j99
5
5$;; #zz#HC14FM#))++..K&&tzz||4444
r> inspector_paramsmetadata_paramsc X |j |j k rdS d | j D }d |j g|j z }d |j g|j z }|D ]=}||h | s!|j |j h | r dS >dS )NTc & g | ]}d |D S )c 6 h | ]}| S rB )r )r ts r= z=DefaultImpl._column_types_match... s ...1QWWYY...r> rB )r batchs r=
z3DefaultImpl._column_types_match.. s' OOO5.....OOOr> F)rD rN joinrE issubset)rc r r synonymsinspector_all_termsmetadata_all_termsr s r= _column_types_matchz DefaultImpl._column_types_match s "o&< < <4OOD inspected_params meta_paramsc t t |j t |j k r|j |j k rdS t |j t |j k r|j |j k rdS d |j }d |j }| j D ]_}t
j || }t
j || }|r1|r/| d | d k r dS `dS )a We want to compare column parameters. However, we only want
to compare parameters that are set. If they both have `collation`,
we want to make sure they are the same. However, if only one
specifies it, dont flag it for being less specific
Fr" r T) lenrE rF r# r rO r searchgroup)rc r) r* inspmetaregmimms r= _column_args_matchz DefaultImpl._column_args_match s'
" # #s+;+B'C'C C C"&6&===5
! !S)9)>%?%? ? ? $4$9995xx(/006688xx *++1133( C3%%B3%%B
b
RXXa[[BHHQKK 7 7 uutr> inspector_columnmetadata_columnc | | }| | }| || sdS | || sdS dS )zReturns True if there ARE differences between the types of the two
columns. Takes impl.type_synonyms into account between retrospected
and metadata types
TF)r r( r4 )rc r5 r6 r r s r= compare_typezDefaultImpl.compare_type sm 556FGG 44_EE''(8/JJ 4&&'7 II 4ur> c ||k S rf rB )rc r5 r6 rendered_metadata_defaultrendered_inspector_defaults r= compare_server_defaultz"DefaultImpl.compare_server_default s *-FFFr> conn_uniquesSet[UniqueConstraint] conn_indexes
Set[Index]metadata_unique_constraintsmetadata_indexesc d S rf rB )rc r= r? rA rB s r= correct_for_autogen_constraintsz+DefaultImpl.correct_for_autogen_constraints) s
r> c b |j j |j urt |d | |d< d S d S )Nexpr)r8 _type_affinityr )rc existingexisting_transfernew_types r= cast_for_batch_migratez"DefaultImpl.cast_for_batch_migrate2 sC = 'x/F F F(,!&)8) ) f % % % G Fr> rF r is_server_defaultc R ddddi}t |j dd| j i| S )zRender a SQL expression that is typically a server default,
index expression, etc.
.. versionadded:: 1.0.11
r TF)r_
include_tablerR rB )r1 r rR )rc rF rL r r s r= render_ddl_sql_exprz DefaultImpl.render_ddl_sql_expr8 sT
u M M
DL
(2
r> inspectorr r c | j S rf )autogen_column_reflect)rc rP s r= _compat_autogen_column_reflectz*DefaultImpl._compat_autogen_column_reflectK s **r> conn_fksSet[ForeignKeyConstraint] metadata_fksc d S rf rB )rc rT rV s r= correct_for_autogen_foreignkeysz+DefaultImpl.correct_for_autogen_foreignkeysN s
r> c dS )zA hook that is attached to the 'column_reflect' event for when
a Table is reflected from the database during the autogenerate
process.
Dialects can elect to modify the information gathered here.
NrB )rc rP rq column_infos r= rR z"DefaultImpl.autogen_column_reflectU rt r> c dS )zA hook called when :meth:`.EnvironmentContext.run_migrations`
is called.
Implementations can set up per-migration-run state here.
NrB rv s r= start_migrationsz DefaultImpl.start_migrations^ rt r> c @ | d| j z dS )zEmit the string ``BEGIN``, or the backend-specific
equivalent, on the current connection context.
This is used in offline mode and typically
via :meth:`.EnvironmentContext.begin_transaction`.
BEGINNrl r rv s r=
emit_beginzDefaultImpl.emit_beginf s&
7T%<<=====r> c @ | d| j z dS )zEmit the string ``COMMIT``, or the backend-specific
equivalent, on the current connection context.
This is used in offline mode and typically
via :meth:`.EnvironmentContext.begin_transaction`.
COMMITNr_ rv s r= emit_commitzDefaultImpl.emit_commitp s&
8d&==>>>>>r> type_objr) autogen_contextr+ Union[str, Literal[False]]c dS )NFrB )rc rd re s r= render_typezDefaultImpl.render_typez s ur> c t t j ||t j \ }}t |dd }t |dd }t | t | k r| d | | j ||t | p t | t | k fS )Nalways) _compare_identity_optionsr _identity_attrsIdentitygetattrrV adddifference_updaterQ )rc metadata_identityinspector_identitydiffignored meta_alwaysinspector_alwayss r= _compare_identity_defaultz%DefaultImpl._compare_identity_default s 2 ' " "
g /4@@ "#5xFF %5 6 6 6 6 HHX t 9:::
JJ M$ 011T:L5M5MM
r> Tuple[Any, ...]c > t d |j D S )Nc 3 $ K | ] }|j V d S rf rg )r cols r= z/DefaultImpl.create_index_sig.. s$ 77#SX777777r> )r r r s r= create_index_sigz DefaultImpl.create_index_sig s! 77 777777r> c
d |D }t | D ]i}|j |v r t j | }|rGt j d|j d| j dt j d | | jd S )Nc i | ]
}|j | S rB r{ )r r s r= r z8DefaultImpl._skip_functional_indexes.. s @ @ @a @ @ @r> z@autogenerate skipping metadata-specified expression-based index z
; dialect z under SQLAlchemy z6 can't reflect these indexes so they can't be compared) r rg r is_expression_indexr r r7 sqlalchemy_versiondiscard)rc rB r? conn_indexes_by_nameidxiexs r= _skip_functional_indexesz$DefaultImpl._skip_functional_indexes s @ @< @ @ @ ()) . .Cx/// 1#66C
. FxF F-1-=F F #."@F F F !((--- . .r> )rR r rS rT rU rV rW rX rY rZ r[ r5 r\ r] )rR r r\ rd )r r1 r\ r] )rm r- r\ rV )rp r, rq r& r\ r] )r\ rT )
rx ry rz r{ r| r} r~ r5 r\ r rf )r ry rz r{ r\ r] ) NFNNNNFNNNNN) r r1 r r1 r rX r r rg r r r r r r rX r r r r r r r r r rX r rX r r r\ r] )r r1 r r r r r\ r] )r r1 r r r r r\ r] )r r r\ r] )r r# r\ r] )r r1 r r r r r\ r] )rq r& r\ r] )r r% r\ r] )r r r\ r] )T)rq r r r r rV r\ r] )r r" r\ rC )r rC r rC r\ rV )r) rC r* rC r\ rV )r5 r r6 r" r\ rV )
r= r> r? r@ rA r> rB r@ r\ r] )F)rF r rL rV r r r\ r1 )rP r r\ r )rT rU rV rU r\ r] )r\ r] )rd r) re r+ r\ rf )r r% r\ rx )7r? r@ rA __doc__r7 rW r rN __annotations__rO rQ r9 classmethodrh rl ro rs propertyrw r
immutabledictr r r r r r r r r r r r r r r r r r( r4 r8 r< rD rK rO rS rX rR r\ r` rc rh rw r~ r rB r> r= rI rI E s)
K ,5y+A*CMCCCC&(((((-99999 4 $ $ $ [$# # # #
X 7;&(!3!3!5!5 ( ( ( ( (Z 7;+ + + + + $(@E "&* $(,8=*..2<@,015 n n n n nh 59 F F F F F !% G G G G G4 4 4 41 1 1 1 59
3 3 3 3.
. . . .2 2 2 23 3 3 34 4 4 4, , , , ! $ $ $ $ $L$ $ $ $L , B G G G
>C
&+ + + +
> > > >? ? ? ?
:8 8 8 8. . . . .r> rI ) metaclassc t }t }| D ]l}t ||d }t ||d }t ||d } | |k r1||k r| | W| | m||fS rf )setrn ro )
attributes metadata_io inspector_io
default_iors ignored_attrattr
meta_value
default_value
conn_values
r= rk rk s 55D55L [$55
D$77
\466
# #]** &&&& r> )>
__future__r collectionsr r typingr r r r r r
r r r
r r
sqlalchemyr r r r r r r r sqlalchemy.enginer r sqlalchemy.engine.cursorr sqlalchemy.engine.reflectionr sqlalchemy.sql.elementsr r r! sqlalchemy.sql.schemar" r# r$ r% r& r' sqlalchemy.sql.selectabler( sqlalchemy.sql.type_apir) r* autogenerate.apir+ operations.batchr, r- r8 r/ r: r rC rI rk rB r> r= r s " " " " " " " " " " " " " 7 ,,,,,,))))))555555666666555555555555333333,,,,,,000000::::::++++++++++++666666555555222222$$$$$$111111111111666666
t
(* ) ) ) ) H D D D E Ej . j . j . j . j .H j . j . j . j .Z r>