gFLZddlmZddlZddlZddlmZddlmZddlmZddlmZddlm Z ddlm Z dd lm Z dd lm Z dd lm Z dd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z ddl!m"Z"ddl#m$Z$ddl#m%Z%ddl#m&Z&ddl#m'Z'ddl#m(Z(dd l)m*Z*dd!l+m,Z,erZdd"lm-Z-dd#lm.Z.dd$lm/Z/dd%lm0Z0dd&lm1Z1dd'lm2Z2dd(l3m4Z4dd)l!m5Z5dd*l6m7Z7dd+l8m9Z9dd,l#m:Z:dd-l;mm?Z?dd0l>m@Z@ed1ed23ZAGd4d5e ZBdd6ZCeDejd7eDcgc] }eC| c}ZFeFd8k\ZGeFd9k\ZHeFd:k\ZIeFd;k\ZJeFdd?ZPer dd@ZQnddAlRmQZQ ddBlmSZSdCZTeFdDk\ZU ddHlmVZVeWeVe"ZX d ddIZYdCZZeKrddLl!m[Z[nddMl\m]Z[ede^e[fZ_ee^e[fZ` ddNZa ddOZb ddPZcdQZdej ddRZfddSZg ddTZh ddUZi ddVZjddWZkddXZlddYZm ddZZndd[Zo dd\Zpd]Zqd^Zrdd_Zsdd`ZtddaZudbZvddcZwddZxeyejderdfZ{dgZ|ndhZ{diZ|ddjZ}ddkZ~ddlZdmZ ddnZ ddoZddpZGdqdrejtZeQe ddsZGdtdue$ZeQe ddvZddwZ ddxZ ddyZddzZd{Zdd|ZeHrdd}lmZdd~lmZeZn ddlmZdZddZddZddZycc}w#eO$r dd=l#mNZNYwxYw#eO$res GdEdFePZSdGZTdGZUYwxYw#eO$res GdJdKePZVdGZZYwxYw)) annotationsN)Any)Callable)Dict)Iterable)Iterator)Mapping)Optional)Protocol)Set)Type) TYPE_CHECKING)TypeVar)Union) __version__)inspectschema)sql)types)url)CheckConstraint)Column)ForeignKeyConstraint)visitors) DialectKWArgs) BindParameter) ColumnClause) quoted_name) TextClause)UnaryExpression)traverse) TypeGuard) ClauseElement)Index)Table) Connection)Dialect) Transaction) Inspector)ColumnCollection) SQLCompiler)Insert) ColumnElement) Constraint) SchemaItem)Select) TableClause_CE)zColumnElement[Any]r0)boundceZdZddZy)_CompilerProtocolc yN)selfelementcompilerkws W/var/www/html/AdoubleTech/venv/lib/python3.12/site-packages/alembic/util/sqla_compat.py__call__z_CompilerProtocol.__call__>sN)r;rr<rr=rreturnstr)__name__ __module__ __qualname__r?r9r@r>r6r6=sJr@r6c, t|S#|cYSxYwr8)int)values r> _safe_intrIAs5z s z (\d+|[abc]\d)))rJ)rJrL)rJrL)) _NONE_NAMEceZdZdZy) _Unsupportedz.Placeholder for unsupported SQLAlchemy classesN)rCrDrE__doc__r9r@r>rRrRYs4r@rRcyr8r9)r;dialectss r>compilesrV_s;>r@)rV)ComputedT)rJrKc eZdZy)rWNrCrDrEr9r@r>rWrWk r@rWF)Identityc |iStrA|j}|r-t|tsJ|j |j |Si}t|t r*|j|d<|j|j|d<d}|j |Dcic]}t||d|t||dc}|Scc}w)Nalwayson_null) start incrementminvaluemaxvalue nominvalue nomaxvaluecyclecacheorder) identity_has_dialect_kwargs_as_dict isinstancerupdatedialect_kwargsr\r^r_getattr)identityrmas_dictattrskeys r>_get_identity_options_dictrss  I ('')G!(M:::x66763G(H-$,OO!##/)1)9)9GI& E NN %xd3?355  s"Cc eZdZy)r\NrZr9r@r>r\r\yr[r@r\) _NoneName)symbolcB|tuxst|ttfSr8)rPrkrBrunames r>constraint_name_definedrzs  :  CD3 2B!CCr@c"t|tSr8)rkrBrxs r>constraint_name_stringr|s dC  r@c t|r|SdSr8)r|rxs r>constraint_name_or_noner~s*$/49T9r@autoc#K |j}|dy|s"|J|j5ddddydy#t$rd}YBwxYw#1swYyxYwwr8)in_transactionAttributeErrorbegin connectionrs r>_ensure_scope_for_ddlrsy #22 ) ))!!#          s=A" A"A"AA" AA"AA"AA"cZtr|j|S|j|S)N) hide_password)sqla_14render_as_string __to_string__)rrs r>url_render_as_stringrs+#s##-@@ s  }==r@c@t|}|r|S|jSr8)_get_connection_transactionrr transactions r>"_safe_begin_connection_transactionrs&.j9K!!r@c@t|}|r|jyyr8)rcommitrs r>#_safe_commit_connection_transactionrs".j9Kr@c@t|}|r|jyyr8)rrollbackrs r>%_safe_rollback_connection_transactionrs".j9Kr@cH |j}|S#t$rYywxYw)NF)rrrs r>_get_connection_in_transactionrs1 #22  s  !!c|jSr8) expressions)idxs r>_idx_table_bound_expressionsr s ??r@c bt|dr|jdi|S|jdi|S)N_copyr9)hasattrrcopy) schema_itemr=s r>rrs8{G$ {  &2&&{%"%%r@c^tr|jS|j}|jSr8)rget_transaction_root_Connection__transaction)rrs r>rrs-))++   )))r@cttjdrtjj|i|Stj|i|S)Ncreate)rrURLr)argr=s r> _create_urlr s<sww!ww~~s)b))ww"r""r@c~trt|j||S|jj|||Sr8)rr has_tabledialect) connectable tablename schemanames r>_connectable_has_tabler's?{#--iDD"",, J  r@c tr,|j5}|j||cdddS|jj||S#1swYyxYwr8)r_operation_contextexecutebind) inspector statementparamsconns r>_exec_on_inspectorr2sT  ) ) + 3t<< 62 3 3~~%%i88 3 3s AAcbts |jSddlm}|j|j uS)Nrr)rnullablesqlalchemy.sqlr_user_defined_nullableNULL_UNSPECIFIED)metadata_columnrs r>_nullability_might_be_unsetr:s/ ''')  2 2f6M6M M r@c4tsytd|DS)NFc3<K|]}t|tywr8)rkrW.0sds r> z._server_default_is_computed..IE:b(+E) has_computedanyserver_defaults r>_server_default_is_computedrEs EnEEEr@c4tsytd|DS)NFc3<K|]}t|tywr8)rkr\rs r>rz._server_default_is_identity..Prr)rrrs r>_server_default_is_identityrLs EnEEEr@c^t|tr|j}|J|S|jSr8)rkrparenttable) constraintrs r>_table_for_constraintrSs5*23!!    r@ct|tr$|jDcgc]}|jc}St|trt |j St|jScc}wr8) rkrelementsrr _find_columnssqltextlistcolumns)rfks r>_columns_for_constraintr\sY*23$.$7$78b 88 J 0Z//00J&&'' 9sA/cVtr|j|dS|j|dSr8)r reflect_table reflecttable)rrs r>_reflect_tableres0&&ud33%% 4  r@cpt|r*t|\}}|j|j|S|Sr8)_type_has_variants_get_variant_mappinggetry)type_r base_typemappings r>_resolve_for_variantrns3% 1%8 7{{7<<33 r@_variant_mappingc,t|jSr8)boolrrs r>rrxsE**++r@c||jfSr8)rrs r>rr{se,,,,r@c8t|tjuSr8)typesqltypesVariantrs r>rrsE{h....r@c2|j|jfSr8)implrrs r>rrszz5==((r@c tr8|jJ|jJt|jt sJ|j Dcgc]}|j|j}}|jj}|jj}|jdjjj}|jdjjj}|jDcgc]}|jj}}|j} |j} |j} |j} ||||||| | | | f Scc}wcc}w)Nr)rrrrkrr& column_keysryrcolumnrondeleteonupdate deferrable initially) rrrsource_columns source_table source_schema target_schema target_tabler;target_columnsrrrrs r>_fk_specrs\!!---""...*++U3331;0F0F), 3$$N$$))L%%,,M''*1177>>M&&q)0066;;L9C9L9LMggnn))MNM""H""H&&J$$I  Ns EE#c|jdj}|jd}|jddj |}|j J||j j k(S)Nr.)r _get_colspecsplitpopjoinrrr)rspectokenstablekeys r>_fk_is_self_referentialrsj   q ! . . 0D ZZ_F JJrNxxH    (( ( z((,, ,,r@c|jSr8) _type_bound)rs r>_is_type_boundrs  ! !!r@cLt}t|id|ji|S)z2locate Column objects within the given expression.r)setr"add)clausecolss r>rrs%%(ED VR(DHH-. Kr@c|jJ||j}t|ds t|dr|jj|y|j|y)z(remove a column from a ColumnCollection.N _immutable _readonly)rrr_parentremove) collectionr to_removes r>_remove_column_from_collectionr sY :: !! !6::&Iz<(GJ ,L!!),)$r@cbt|tr-t|tj}|j ||St|t r t||St|trt||jSt|tjr t||Std)zAa workaround for the Index construct's severe lack of flexibilityz#String or text() construct expected)rkrBrrNULLTYPE append_columnr _textual_index_element_textual_index_columntextrr._copy_expression ValueError)rtext_cs r>r%r%s% 5(++ , A E: &%eU33 E1 2$UEJJ77 E3,, -u-->??r@c<fd}tj|i|S)Nct|tri|j]|jurO|jjvrj|jSt |}j ||Syr8)rkrrryr*rr#)colr*rs r>replacez!_copy_expression..replacese sF # % -xx<>>)#~~chh//#J**1-r@)rreplacement_traverse) expressionrr.s ` r>r'r's$   ( (B r@c"eZdZdZdZddZdZy)r$aQWrap around a sqlalchemy text() construct in such a way that we appear like a column-oriented SQL expression to an Index construct. The issue here is that currently the Postgresql dialect, the biggest recipient of functional indexes, keys all the index expressions to the corresponding column expressions when rendering CREATE INDEX, so the Index we create here needs to have a .columns collection that is the same length as the .expressions collection. Ultimately SQLAlchemy should support text() expressions in indexes. See SQLAlchemy issue 3174. _textual_idx_elementc||_||_|j|_tj|jjt j |_|j|jyr8) rr&rrrrrr" fake_columnr#)r:rr&s r>__init__z_textual_index_element.__init__ sP  99!==9J9JK D,,-r@c |jgSr8)r4)r:r=s r> get_childrenz#_textual_index_element.get_childrens  !!r@N)rr&r&r rANone)rCrDrErS__visit_name__r5r7r9r@r>r$r$s ,N."r@r$c <|j|jfi|Sr8)processr&r;r<r=s r>_render_textual_index_columnr=s  8  GLL /B //r@c eZdZy)_literal_bindparamNrZr9r@r>r?r?sr@r?c (|j|fi|Sr8)render_literal_bindparamr<s r>_render_literal_bindparamrB!s -8 , ,W ; ;;r@c*tr |jSiSr8)sqla_13kwargs)r-s r>_column_kwargsrF(szz r@c|jy|Jtr|jj|dSt |jdrt |j}nt }|t|jd}|j|}t|tjr#|j|d}|j|S|jj|S)NF_alembic_quotequote)rJrx)ryridentifier_preparerformat_constraintrrrrB __class__rkrr% ddl_compiler_prepared_index_name)rrquoted_name_clsnew_nameds r>_get_constraint_final_namerS/s    **<< u=  :??G ,%)$9O)O"3z#7uE))x)8 j&,, /$$Wd3A))*5 5..@@L Lr@ctr2|jy|J|jj|d}|duS|jduS)NFrH)rryrKrL)rrrys r>_constraint_is_namedrUTs\ ?? """"**<< u= 4d**r@cltr |jSt|jxr |jSr8)r is_mariadbrserver_version_info _is_mariadb mysql_dialects r>rYrYcs5'''  - - *))  r@c|jSr8) _mariadb_normalized_version_inforZs r>r]r]ms  9 99r@cntr|jjS|jdS)NT)inline)rinsertr_)rs r>_insert_inlineraqs+||~$$&&||4|((r@)create_mock_engine)select create_enginec tdd|S)Nz postgresql://mock)strategyexecutorrd)rrir=s r>rbrbs fx  r@c@tjt|fi|Sr8)rrcr)rr=s r>_selectrkszz$w-.2..r@c@|jD]}t|syyNTF)r is_expression)indexexprs r>is_expression_indexrqs'!!   r@ct|tr|j}t|trt|tr |jryyrm)rkr!r;r is_literal)rps r>rnrns7 T? +|| T? + dL )T__ r@)rHrBrAzUnion[int, str])r;zType[ClauseElement]rUrBrAz0Callable[[_CompilerProtocol], _CompilerProtocol])F)roz&Union[Identity, schema.Sequence, None]rmrrAzDict[str, Any])ry_ConstraintNamerAz!TypeGuard[_ConstraintNameDefined])ryrtrAzTypeGuard[str])ryrtrA Optional[str])rOptional[Connection]rAzIterator[None])T)rr'rAr))rr'rAr8)rrvrAr)rr%rAzIterable[ColumnElement[Any]])rr3rAr3)rr'rAzOptional[Transaction])rAzurl.URL)rr'rrBrzUnion[str, None]rAr)rAr)rr/rAr&)rr*rr&rAr8)rrrAr)rrrAr)rr/rAr)rr+rz%Union[Column[Any], ColumnClause[Any]]rAr8)rr&r)z*Union[str, TextClause, ColumnElement[Any]]rAz&Union[ColumnElement[Any], Column[Any]])r0r3rr&rAr3)r;r$r<r,rArB)r;r?r<r,rArB)r-rrAr )rzUnion[Index, Constraint]rOptional[Dialect]rAru)rzUnion[Constraint, Index]rrwrAr)r[r(rAr)rzUnion[TableClause, Table]rAr-)rAr1)ror%rAr)rprrAr) __future__r contextlibretypingrrrrrr r r r r rrr sqlalchemyrrrrrrsqlalchemy.enginersqlalchemy.schemarrrrrsqlalchemy.sql.basersqlalchemy.sql.elementsrrrr r!sqlalchemy.sql.visitorsr"typing_extensionsr#r$r%r&r'r(r)sqlalchemy.engine.reflectionr*r+sqlalchemy.sql.compilerr,sqlalchemy.sql.dmlr-r.sqlalchemy.sql.schemar/r0sqlalchemy.sql.selectabler1r2r3r6rItuplefindall_versrDr sqla_14_18 sqla_14_26sqla_2sqlalchemy_versionsqlalchemy.sql.namingrP ImportErrorrRrVsqlalchemy.ext.compilerrWrhas_computed_reflectionr\ issubclassrirs has_identityrusqlalchemy.utilrvrBrt_ConstraintNameDefinedrzr|r~AUTOINCREMENT_DEFAULTcontextmanagerrrrrrrrrrrrrrrrrrrrr TypeEnginerrrrrrr r%r'r$r=r?rBrFrSrUrYr]rarbrc _sa_selectrkrerqrn)xs0r>rs#  "(!-$2#-10/.3,'(  ,)-643)50005 e5!CDEKK %2::&6 DEaYq\E  6/ 6/ j j $ A> 55?$?14? 9? 1 2/L#z13/#-X}"E %%8%% %NL -3c9,-sI~.D D&D ! !! : ::  $,>"""   &***#  (+ 9I   9 FF (  8   23,- /)B-"% %*O% %$@ @C@+@$*"S..": !0 #0/:00"0    < <+6<<< "M("M3D"M"MJ +( +3D +  + :) -0G( /SFA@@A&$  | L#$  | L s<M M#.M5<N# M21M25NNN*)N*