guUddlmZddlZddlZddlmZddlmZddlmZddlmZddlm Z ddlm Z dd lm Z dd lm Z dd lm Z dd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z ddlm!Z!dd l!m"Z"erxdd!lm#Z#dd"lm$Z$dd#l%m&Z&dd$l%m'Z'dd%l(m)Z)dd&l*m+Z+dd'l,m-Z-dd(l,m.Z.dd)l/m0Z0dd*l/m1Z1dd+l2m3Z3dd,l2m4Z4dd-l2m5Z5dd.l2m6Z6dd/l7m8Z8dd0l9m:Z:dd1lm;Z;dd2lm?Z?dd4l>m@Z@ejeBZCGd5d6eDZEiZFd7eGd8<Gd9d:eE;ZHGd<d=e ZI d?d>ZJy)@) annotationsN)Any)Callable)Dict)Iterable)List)Mapping) NamedTuple)Optional)Sequence)Set)Tuple)Type) TYPE_CHECKING)Union)cast)Column)MetaData)PrimaryKeyConstraintschema)String)Table)text)_autogen)base)_constraint_sig)ComparisonResult)util) sqla_compat)Literal)TextIO) Connection)Dialect) CursorResult) Inspector) ClauseElement) Executable) ColumnElement) quoted_name) Constraint)ForeignKeyConstraint)Index)UniqueConstraint) TableClause) TypeEngine)_ServerDefault)AutogenContext)ApplyBatchImpl)BatchOperationsImplc eZdZ ddZy)ImplMetacVtj||||}d|vr |t|d<|S)N __dialect__)type__init___impls)cls classnamebasesdict_newtypes O/var/www/html/AdoubleTech/venv/lib/python3.12/site-packages/alembic/ddl/impl.pyr<zImplMeta.__init__Cs4 --Yu= E !+.F5' (N)r?strr@zTuple[Type[DefaultImpl]]rADict[str, Any])__name__ __module__ __qualname__r<rDrCr8r8Bs#  (  rDr8zDict[str, Type[DefaultImpl]]r=ceZdZUdZdZdZdZddhfZded<d Z d ed <d Z d ed< d>dZ e d?dZ d@dZ dAdZ dBdZ dCdZedDdZddej*f dEdZ dF dGdZ dH dIdZ dF dJdZ dF dKdZdLdZdMdZ dF dNdZdOdZdOd ZdPd!Z dQd"Z!dQd#Z"dRd$Z#dPd%Z$ dS dTd&Z%dUd'Z& dVd(Z' dWd)Z( dXd*Z)d+Z* dYd,Z+d-Z, dZ d[d.Z-d\d/Z. d]d0Z/d1Z0d^d2Z1d^d3Z2d^d4Z3 d_d5Z4d6Z5 d`d7Z6 dad8Z7 dad9Z8 dbd:Z9 dcd;Z:d<Z; ddd=ZrXs rCget_by_dialectzDefaultImpl.get_by_dialectsgll##rDc|jJ|jj|dz|jjy)Nz )r\writeflush)rars rC static_outputzDefaultImpl.static_outputs>!!---   /   "rDc t|ttdtdd|}|r|j t d|d|S)aGenerate a :class:`.Table` object which will be used as the structure for the Alembic version table. Third party dialects may override this hook to provide an alternate structure for this :class:`.Table`; requirements are only that it be named based on the ``version_table`` parameter and contains at least a single string-holding column named ``version_num``. .. versionadded:: 1.14 version_num F)nullabler_pkc)rd)rrrrappend_constraintr)ra version_tableversion_table_schemaversion_table_pkkwvts rCversion_table_implzDefaultImpl.version_table_implsW&  J =&*u ='     $!=/(>   rDcy)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. FrJ)rabatch_ops rCrequires_recreate_in_batchz&DefaultImpl.requires_recreate_in_batchsrDcy)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. NrJ)ra batch_impltables rCprep_table_for_batchz DefaultImpl.prep_table_for_batchrDc|jSrc)rYras rCbindzDefaultImpl.binds rDNct|tr t|}|jr||r t d|j r)t|t jstddi}ni}trt|tsJ|jd d|ji|}|jt|jddj|j zy|j"}|J|r|j$d i|}|r | t d|r|j'||S|j'||S) Nz&SQL parameters not allowed with as_sqlrWT)compile_kwargsrX z z2Can't send params and multiparams at the same timerJ) isinstancerErrZ TypeErrorrWr DDLElementdictrr)compilerXrireplacestripcommand_terminatorrYexecution_optionsexecute)ra constructr multiparamsparams compile_kwcompiledconns rC_execzDefaultImpl._execsA i %YI ;;&& HII!!*6,,+"/41HI  !)];;;(y((LLLH   H %%dF399;))* ??D# ## -t--B0AB+1H||I{;;||Iv66rDc(|j||yrc)r)rasqlrs rCrzDefaultImpl.executes 3)*rDc ||tjdd|,|jtj||||| | | | |duri}t j || rtj}n(J II,    JJ##!"/,C&7%5    &B66 71188 711!6 )) JJ" ""/,C&7%5      JJ!"/,C&7%5   %  JJ""!"/,C&7%5     JJ!"/,C&7  rDcR|jtj|||yNr)rr AddColumn)rarcolumnrs rC add_columnzDefaultImpl.add_columnps 4>>*fVDErDc R|jtj|||yr)rr DropColumn)rarrrrss rC drop_columnzDefaultImpl.drop_columnxs 4??:vfEFrDc|j|j|r%|jtj|yyrc) _create_rulerr AddConstraintraconsts rCadd_constraintzDefaultImpl.add_constraints8    %););D)A JJv++E2 3*BrDcL|jtj|yrc)rrDropConstraintrs rCdrop_constraintzDefaultImpl.drop_constraints 6((/0rDcR|jtj|||yr)rr RenameTable)raold_table_namenew_table_namers rC rename_tablezDefaultImpl.rename_tables"   ^^F K rDc d|jj||jd||jt j |fi||jj ||jd||jD]&}|jt j|(|jjxr|jj }|j}|r|r|j||jD]%}|j}|s|s|j|'yNF) checkfirst _ddl_runner)dispatch before_createrYrr CreateTable after_createindexes CreateIndexrXsupports_commentsinline_commentsrcreate_table_commentcolumnscreate_column_comment)rar{rsindex with_commentrrs rC create_tablezDefaultImpl.create_tables $$ 4??u$ %  6%%e2r23 ## 4??u$ $ ]] 2E JJv))%0 1 2 LL * * O4<<3O3O/O -- |  % %e ,mm 3FnnG<**62 3rDc |jj||jd||jt j |fi||jj ||jd|yr)r before_droprYrr DropTable after_drop)rar{rss rC drop_tablezDefaultImpl.drop_tablesh "" 4??u$ #  6##E0R01 !! 4??u$ " rDc N|jtj|fi|yrc)rrrrarrss rC create_indexzDefaultImpl.create_indexs 6%%e2r23rDcL|jtj|yrc)rrSetTableCommentrar{s rCrz DefaultImpl.create_table_comments 6))%01rDcL|jtj|yrc)rrDropTableCommentrs rCdrop_table_commentzDefaultImpl.drop_table_comments 6**512rDcL|jtj|yrc)rrSetColumnComment)rars rCrz!DefaultImpl.create_column_comments 6**623rDc N|jtj|fi|yrc)rr DropIndexrs rC drop_indexzDefaultImpl.drop_indexs 6##E0R01rDct|ts td|rt|dts td|jr|D]}|j t j|jdi|jDcic]Q\}}|t|t js/t j|||j|jn|Sc}}y|re|r'|j t j||y|D]6}|j t j|jdi|8yycc}}w)Nz List expectedrzList of dictionaries expected)r)rrJ) rlistrrrZrr"_insert_inlinevaluesitems_literal_bindparamcr;)rar{rows multiinsertrowkvs rC bulk_insertzDefaultImpl.bulk_insertsK $%O, , *T!Wd3;< < ;;   >$%q !" &''   $JJ#2259t $ DK66u=DDKsK  s AEcR|jjj|jj }t j d|}g}d}|D],}t jd|r|}|j|.t|d|ddgi}|rt j d|D]o}d|vr@|jd\} } | j|j| j<G|jj|jq|S)Nz[\w\-_]+|\(.+?\)z^\(.*\)$rrz[^(),]+=)rX type_compilerprocessr;lowerrefindallmatchappendParamssplitrkwargsargs) rar definitiontokens term_tokens paren_termtokenrtermkeyvals rC_tokenize_column_typez!DefaultImpl._tokenize_column_types\\//77 DJJL JJ':JG!#   *Exx U+" ""5)  *  A ABR@  9j9 5$;#zz#HC14FMM#))+.KK&&tzz|4  5 rDc |j|jk(ry|jDcgc] }|Dchc]}|jc}"}}}dj|jg|jz}dj|jg|jz}|D]>}||hj |s(|j|jhj |s>yycc}wcc}}w)NT F)token0rQrjoinrissubset)rainspector_paramsmetadata_paramsbatchtsynonymsinspector_all_termsmetadata_all_termss rC_column_types_matchzDefaultImpl._column_types_matchs  " "o&<&< <<@)>%? ?  $4$9$99xx(//0668xx **+113(( C3%B3%BbRXXa[BHHQK7  rDc|j|}|j|}|j||sy|j||syy)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)rrr()rainspector_columnmetadata_columnrrs rC compare_typezDefaultImpl.compare_typeHsQ 556FG44_E''(8/J&&'7IrDc ||k7SrcrJ)rar*r+rendered_metadata_defaultrendered_inspector_defaults rCcompare_server_defaultz"DefaultImpl.compare_server_defaultXs*-FFFrDcyrcrJ)ra conn_uniques conn_indexesmetadata_unique_constraintsmetadata_indexess rCcorrect_for_autogen_constraintsz+DefaultImpl.correct_for_autogen_constraintsas rDcn|jj|jurt|d||d<yy)Nexpr)r;_type_affinityr)raexistingexisting_transfernew_types rCcast_for_batch_migratez"DefaultImpl.cast_for_batch_migratejs: == ' 'x/F/F F(,!&)8) f % GrDc Xddd}t|j|j|S)zdRender a SQL expression that is typically a server default, index expression, etc. TF)rW include_table)rXr)rErrX)rar8is_server_defaultrsrs rCrender_ddl_sql_exprzDefaultImpl.render_ddl_sql_exprps/(,eD  LLjL I  rDc|jSrc)autogen_column_reflect)ra inspectors rC_compat_autogen_column_reflectz*DefaultImpl._compat_autogen_column_reflect~s***rDcyrcrJ)raconn_fks metadata_fkss rCcorrect_for_autogen_foreignkeysz+DefaultImpl.correct_for_autogen_foreignkeyss rDcy)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. NrJ)rarDr{ column_infos rCrCz"DefaultImpl.autogen_column_reflectr}rDcy)zA hook called when :meth:`.EnvironmentContext.run_migrations` is called. Implementations can set up per-migration-run state here. NrJrs rCstart_migrationszDefaultImpl.start_migrationsr}rDc@|jd|jzy)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`. BEGINNrirrs rC emit_beginzDefaultImpl.emit_begins 7T%<%<<=rDc@|jd|jzy)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`. COMMITNrPrs rC emit_commitzDefaultImpl.emit_commits 8d&=&==>rDcyNFrJ)ratype_objautogen_contexts rC render_typezDefaultImpl.render_typesrDcTt||tjdh\}}t|dd}t|dd}t |t |k7r|j d|j |j||t |xst |t |k7fS)Nalways)skip)_compare_identity_optionsr"Identitygetattrbooladddifference_updaterU)rametadata_identityinspector_identitydiffignored meta_alwaysinspector_alwayss rC_compare_identity_defaultz%DefaultImpl._compare_identity_defaults2    "  g/4@ "#5xF  %5 6 6 HHX  t99:   J M$01T:L5MM   rDcrt|j}t|j}||k7rd|d|Sy)Nzunique=z to unique=)r`unique)rametadata_indexreflected_index conn_unique meta_uniques rC_compare_index_uniquez!DefaultImpl._compare_index_uniquesB?112 >001 + %[MB BrDc 2tjd||fi|S)NTrfrom_constraintra constraintoptss rC_create_metadata_constraint_sigz+DefaultImpl._create_metadata_constraint_sigs..tT:NNNrDc 2tjd||fi|SrVrrrts rC _create_reflected_constraint_sigz,DefaultImpl._create_reflected_constraint_sigs..udJO$OOrDc:g}|j||}|r|j||j|}|j|}t j |sJt j |sJ||fD]/}|j stjd|j1|j|jk7r+|jd|jd|j|rtj|StjS)zCompare two indexes by comparing the signature generated by ``create_index_sig``. This method returns a ``ComparisonResult``. zGenerating approximate signature for index %s. The dialect implementation should either skip expression indexes or provide a custom implementation. expression  to )rprrwryr is_index_sighas_expressionslogwarningr column_namesr DifferentEqual)rarlrmmsg unique_msgm_sigr_sigsigs rCcompare_indexeszDefaultImpl.compare_indexess// O   JJz "44^D55oF$$U+++$$U+++%< C"" :II     !3!3 3 JJe001e6H6H5IJ  #--c2 2#))+ +rDc|j|}|j|}|j}|j}||k7rtjd|d|Stj S)aCompare two unique constraints by comparing the two signatures. The arguments are two tuples that contain the unique constraint and the signatures generated by ``create_unique_constraint_sig``. This method returns a ``ComparisonResult``. r{r|)rwryunnamedrrr)rametadata_constraintreflected_constraint metadata_tup reflected_tupmeta_sigconn_sigs rCcompare_unique_constraintz%DefaultImpl.compare_unique_constraint s;;  ==   '' (( x #--hZtH:6 $))+ +rDc T|Dcic]}|j|}}t|D]{}|j|vrtj|}|s*t j d|jd|j dtjd|j|}ycc}w)Nz@autogenerate skipping metadata-specified expression-based index z ; dialect z under SQLAlchemy z6 can't reflect these indexes so they can't be compared) rdrr"is_expression_indexr!rr:sqlalchemy_versiondiscard)rar5r3rconn_indexes_by_nameidxiexs rC_skip_functional_indexesz$DefaultImpl._skip_functional_indexes)s3?@a @@() .Cxx//11#6C .xxl*T-=-=,@A""-"@"@!ABFF!((- . AsB%c&|jdiS)Ndialect_options)r[)rareflected_objectkinds rC adjust_reflected_dialect_optionsz,DefaultImpl.adjust_reflected_dialect_options:s ##$5r::rD)rXr&rYOptional[Connection]rZr`r_Optional[bool]r\zOptional[TextIO]r^rFreturnNone)rXr&rzType[DefaultImpl])rrErr) rprErq Optional[str]rrr`rsrrr)rwr6rr`)rzr5r{rrr)rr) rUnion[Executable, str]rzOptional[Mapping[str, Any]]rz%Optional[Sequence[Mapping[str, Any]]]rMapping[str, Any]rzOptional[CursorResult]rc)rrrzOptional[dict[str, Any]]rr) NFNNNNFNNNNN) rrErrErmrrz%Union[_ServerDefault, Literal[False]]rdrrOptional[TypeEngine]rrrrrz$Optional[Union[str, Literal[False]]]rrrrrzOptional[_ServerDefault]rrrrrsrrr)rrEr Column[Any]r!Optional[Union[str, quoted_name]]rr)rrErrrrrr)rrrr)rr-rr)rrErzUnion[str, quoted_name]rrrr)r{rrsrrr)rr/rsrrr)r{rrr)rzColumnElement[Any]rr)T)r{zUnion[TableClause, Table]rz List[dict]rr`rr)rrrr)rrrrrr`)r!rr"rrr`)r*rr+rrr`) r2Set[UniqueConstraint]r3 Set[Index]r4rr5rrr)F)r8r)r@r`rsrrrE)rDr(rr)rGSet[ForeignKeyConstraint]rHrrr)rr)rWr2rXr4rzUnion[str, Literal[False]])rlr/rmr/rr)ruz _autogen._Crvrrz_constraint_sig[_autogen._C])rlr/rmr/rr)rr0rr0rr)rrFrrErrF)=rGrHrI__doc__r:r_rrQ__annotations__rRrUr< classmethodrerirurxr|propertyrr! immutabledictrrrrrrrrrrrrrrrrrrr(r,r0r6r=rArErIrCrMrQrTrYrirprwryrrrrrJrDrCrLrLRsT K,5y+A*CM'C&(m( .B?A)  *  ( % 4$$#  ,       D +     (  16     :>=A$6D$6$6$8 +7)+77+7; +7 " +7 +7`7;+ #+4+  +$(@E"&* $(,8=*..2<@,015nnn! n > n  n$nn&n6n(n,n":n*n!/n !n" #nh59 FFF2 F  F!% GGG G  G4159   0 2    3. 42342! &(&& &  &P&P &9? , &5; B +>D  G + ! &;  %    >C  !  6:  JM    + + 0      >?"5C #  8#6; O%O/2O %O P%P/2P %P ),),),  ),V,-,/,  ,8."; .;69; ;rDrL) metaclassc6eZdZUded<ded<ded<ded<y) rrErz List[str]rrzDict[str, str]rN)rGrHrIrrJrDrCrr@s K  O rDrc tj|}tj|}tt dfd }|||tj|t|j|tjr6|t |dit |di|j t |difS)Nct|j D]c}|j|}|j|}||k7s+|j|}||k(r j|Sj|eyrc)set differencer[ra) meta_dict insp_dict default_dictattrsattr meta_value insp_value default_valuere ignored_attrr\s rC check_dictsz._compare_identity_options..check_dictsVsx J))$/ #D"t,J"t,JZ' , 0 0 6 . $$T*HHTN #rDdialect_kwargs)rrrrrrrz Iterable[str])r"_get_identity_options_dictrunionidentity_has_dialect_kwargsr_r) metadata_io inspector_io default_ior\meta_dinsp_drrers ` @@rCr]r]Gs 3 3K @F  3 3L AF 5D5L#$#$#(# # ..z: F &!  ..  K!12 6 L"2B 7  % % L"2B 7    rD)r-Union[schema.Identity, schema.Sequence, None]rrrz'Union[schema.Identity, schema.Sequence]r\zSet[str])K __future__rloggingrtypingrrrrrr r r r r rrrr sqlalchemyrrrrrrrrrrrrr!r"r#r$sqlalchemy.enginer%r&sqlalchemy.engine.cursorr'sqlalchemy.engine.reflectionr(sqlalchemy.sqlr)r*sqlalchemy.sql.elementsr+r,sqlalchemy.sql.schemar-r.r/r0sqlalchemy.sql.selectabler1sqlalchemy.sql.type_apir2r3autogenerate.apir4operations.batchr5r6 getLoggerrGrr;r8r=rrLrr]rJrDrCrs#  +8:,)56,)530:+652$116g! t (*$)k ;Hk ;\Z/>/?/8/  /rD