+hdZddlZddlmZddlmZddlmZddlmZdd lmZdd lm Z dd lm Z dd l m Z dd l m Z ddlmZddl mZe j"dZej&GddeZy)aProvides an abstraction for obtaining database schema information. Usage Notes: Here are some general conventions when accessing the low level inspector methods such as get_table_names, get_columns, etc. 1. Inspector methods return lists of dicts in most cases for the following reasons: * They're both standard types that can be serialized. * Using a dict instead of a tuple allows easy expansion of attributes. * Using a list for the outer structure maintains order and is easy to work with (e.g. list comprehension [d['name'] for d in cols]). 2. Records that contain a name, such as the column name in a column record use the key 'name'. So for most return values, each record will have a 'name' attribute.. N) Connectable) Connection)Engine)exc) inspection)sql)util) operators)schema) TypeEngine) topologicalc |jdd}| |||g|i|S|jtd|Dtd|jDf}|j|}||||g|i|}|||<|S)N info_cachec3VK|]!}t|tjs|#ywN) isinstancer string_types).0as O/var/www/html/venv/lib/python3.12/site-packages/sqlalchemy/engine/reflection.py zcache..2s BAAt/@/@!Aa Bs))c36K|]\}}|dk7s ||fyw)rN)rkvs rrzcache..3s AAqL/@q!f As  )get__name__tupleitems)fnselfconargskwrkeyrets rcacher)+s d+J$)d)b))  B BB A AA C .. C {s(T(R( 3 JceZdZdZej dddZedZdZ dZ dZ eej dd d Z e jed Ze jed Ze jed Zej,dZej,dZedZdZd4dZd4dZd4dZd4dZdZ dZ!d4dZ"d4dZ#d4dZ$d4dZ%d4dZ&d4dZ'd4dZ(d4d Z)d4d!Z*d4d"Z+d4d#Z,ejZd$d%d&Z. d5d'Z/d(Z0d)Z1d*Z2d+Z3d,e4jjfd-e4jlfd.e4jnfd/e4jpfgZ9d0Z:d1Z;d2Z 4<< -,,((C{{3 T4 r*cbt|dr|j|y|j|y)Nexec_driver_sql)r4_init_connection _init_enginer/s rr.zInspector._init_legacyxs) 4* +  ! !$ '   d #r*c|x|_|_|jjd|_|jj |_i|_y)NT)r0engineconnectclose_op_context_requires_connectr5r)r#r?s rr=zInspector._init_engine~sC"(( DK ,0){{** r*c||_|j|_d|_|jj|_i|_y)NF)r0r?rBr5r)r# connections rr<zInspector._init_connections6  '' ,1){{** r*aThe from_engine() method on :class:`_reflection.Inspector` is deprecated and will be removed in a future release. Please use the :func:`.sqlalchemy.inspect` function on an :class:`_engine.Engine` or :class:`_engine.Connection` in order to acquire an :class:`_reflection.Inspector`.c:|j|j|S)aConstruct a new dialect-specific Inspector object from the given engine or connection. :param bind: a :class:`~sqlalchemy.engine.Connectable`, which is typically an instance of :class:`~sqlalchemy.engine.Engine` or :class:`~sqlalchemy.engine.Connection`. This method differs from direct a direct constructor call of :class:`_reflection.Inspector` in that the :class:`~sqlalchemy.engine.interfaces.Dialect` is given a chance to provide a dialect-specific :class:`_reflection.Inspector` instance, which may provide additional methods. See the example at :class:`_reflection.Inspector`. )r9r.)r7r0s r from_enginezInspector.from_engines>~~c..55r*cJtjtj|Sr)r,r9r.r0s r_connectable_inspzInspector._connectable_insps ##I$:$:DAAr*cJtjtj|Sr)r,r9r=rHs r _engine_inspzInspector._engine_insps##I$:$:DAAr*cJtjtj|Sr)r,r9r<rHs r_connection_inspzInspector._connection_insps##I$>$>EEr*c#K|jr|jj}n |j} ||jr|jyy#|jr|jwwxYww)aReturn a context that optimizes for multiple operations on a single transaction. This essentially allows connect()/close() to be called if we detected that we're against an :class:`_engine.Engine` and not a :class:`_engine.Connection`. N)rBr0r@rAr#conns r_operation_contextzInspector._operation_contextsd  , ,99$$&D99D J00 1t00 1s4A;AA;A88A;c#K|j5}|j|jj|}|j|_|dddy#1swYyxYww)zReturn an :class:`_reflection.Inspector` from this one that will run all operations on a single connection. N)rQr9 __class__r<r)r#rPsub_insps r_inspection_contextzInspector._inspection_contextsU $ $ & $t~~'F'FMH"&//H N   sA$.Ws&'*T!WcN&sr)rQr5r\rsetget_foreign_keysaddlistrsortrCircularDependencyErroredgesremoveupdate difference)r#r rPtnamestuplesremaining_fkcsfknames_for_tabletnamefkeysfkfkeycandidate_sorterrrks @rget_sorted_table_and_fkc_namesz(Inspector.get_sorted_table_and_fkc_names*s2 $ $ & $\\11f2F   @E))%8E'*+G2BvJ+G'H e $ @D!122JJ%5 6>? @ @ D!+"2"266"BCN( %e,77G H D( ) *+ +3  ,H ** D   d#%%&.?Q.H&  "+"2"266"BCN D s0)D 9 D 8DF DF.A!FFc|j5}|jj||jcdddS#1swYyxYw)zReturn a list of temporary table names for the current bind. This method is unsupported by most dialects; currently only SQLite implements it. .. versionadded:: 1.0.0 rZN)rQr5get_temp_table_namesrrOs rrzInspector.get_temp_table_namesasG $ $ & $<<445    'AA c|j5}|jj||jcdddS#1swYyxYw)zReturn a list of temporary view names for the current bind. This method is unsupported by most dialects; currently only SQLite implements it. .. versionadded:: 1.0.0 rZN)rQr5get_temp_view_namesrrOs rrzInspector.get_temp_view_namespsG $ $ & $<<334   rc t|jdrE|j5}|jj|||fd|ji|cdddSiS#1swYiSxYw)aReturn a dictionary of options specified when the table of the given name was created. This currently includes some options that apply to MySQL tables. :param table_name: string name of the table. For special quoting, use :class:`.quoted_name`. :param schema: string schema name; if omitted, uses the default schema of the database connection. For special quoting, use :class:`.quoted_name`. get_table_optionsrN)r4r5rQrrr#rar r&rPs rrzInspector.get_table_options~ss 4< $ $ & $04<<00j&59__HJ   rc |j5}|jj|||fd|ji|cdddS#1swYyxYw)aReturn information about indexes in `table_name`. Given a string `table_name` and an optional string `schema`, return index information as a list of dicts with these keys: * ``name`` - the index's name * ``column_names`` - list of column names in order * ``unique`` - boolean * ``column_sorting`` - optional dict mapping column names to tuple of sort keywords, which may include ``asc``, ``desc``, ``nulls_first``, ``nulls_last``. .. versionadded:: 1.3.5 * ``dialect_options`` - dict of dialect-specific index options. May not be present for all dialects. .. versionadded:: 1.0.0 :param table_name: string name of the table. For special quoting, use :class:`.quoted_name`. :param schema: string schema name; if omitted, uses the default schema of the database connection. For special quoting, use :class:`.quoted_name`. rN)rQr5 get_indexesrrs rrzInspector.get_indexes8sWH $ $ & $+4<<++j&59__HJ   rc |j5}|jj|||fd|ji|cdddS#1swYyxYw)aReturn information about unique constraints in `table_name`. Given a string `table_name` and an optional string `schema`, return unique constraint information as a list of dicts with these keys: * ``name`` - the unique constraint's name * ``column_names`` - list of column names in order :param table_name: string name of the table. For special quoting, use :class:`.quoted_name`. :param schema: string schema name; if omitted, uses the default schema of the database connection. For special quoting, use :class:`.quoted_name`. rN)rQr5get_unique_constraintsrrs rrz Inspector.get_unique_constraintsasV* $ $ & $64<<66j&59__HJ   rc |j5}|jj|||fd|ji|cdddS#1swYyxYw)aReturn information about the table comment for ``table_name``. Given a string ``table_name`` and an optional string ``schema``, return table comment information as a dictionary with these keys: * ``text`` - text of the comment. Raises ``NotImplementedError`` for a dialect that does not support comments. .. versionadded:: 1.2 rN)rQr5get_table_commentrrs rrzInspector.get_table_comment{sV  $ $ & $14<<11j&59__HJ   rc |j5}|jj|||fd|ji|cdddS#1swYyxYw)acReturn information about check constraints in `table_name`. Given a string `table_name` and an optional string `schema`, return check constraint information as a list of dicts with these keys: * ``name`` - the check constraint's name * ``sqltext`` - the check constraint's SQL expression * ``dialect_options`` - may or may not be present; a dictionary with additional dialect-specific options for this CHECK constraint .. versionadded:: 1.3.8 :param table_name: string name of the table. For special quoting, use :class:`.quoted_name`. :param schema: string schema name; if omitted, uses the default schema of the database connection. For special quoting, use :class:`.quoted_name`. .. versionadded:: 1.1.0 rN)rQr5get_check_constraintsrrs rrzInspector.get_check_constraintssV: $ $ & $54<<55j&59__HJ   rz*:meth:`_reflection.Inspector.reflecttable`zThe :meth:`_reflection.Inspector.reflecttable` method was renamed to :meth:`_reflection.Inspector.reflect_table`. This deprecated alias will be removed in a future release.c&|j|i|S)z1See reflect_table. This method name is deprecated) reflect_table)r#r%kwargss r reflecttablezInspector.reflecttables"t!!42622r*c .||vry|j|jj}|j5}|j }dddj } t fd|jD} |j| fij} | rj| tjrVt|tr|j|j }t| tr| j|j } d} i} |j"| |fijD]}d} |j%|||| | s'|j'| |st)j*| |j-| || ||j/| || ||||| |j1| || ||| |j3| || ||| |j5| || ||| |j7| || y#1swYxYw)aZGiven a :class:`_schema.Table` object, load its internal constructs based on introspection. This is the underlying method used by most dialects to produce table reflection. Direct usage is like:: from sqlalchemy import create_engine, MetaData, Table from sqlalchemy import inspect engine = create_engine('...') meta = MetaData() user_table = Table('user', meta) insp = inspect(engine) insp.reflect_table(user_table, None) .. versionchanged:: 1.4 Renamed from ``reflecttable`` to ``reflect_table`` :param table: a :class:`~sqlalchemy.schema.Table` instance. :param include_columns: a list of string column names to include in the reflection process. If ``None``, all columns are reflected. Nc3tK|]/}|jvr|jj|f1ywr)dialect_kwargsr)rrtables rrz*Inspector.reflect_table..s=" E((($$((+ ," s58FT)rnr0r5rQschema_for_objectrgdictreflection_optionsrr_validate_dialect_kwargsr py2krstrdecodeencodingr_reflect_columnr`rNoSuchTableError _reflect_pk _reflect_fk_reflect_indexes_reflect_unique_constraints_reflect_check_constraints_reflect_table_comment)r#rinclude_columnsexclude_columns resolve_fks _extend_onr5rPr rartbl_opts found_tablecols_by_orig_namecol_ds ` rrzInspector.reflect_tablesa@  ! "u%))##  $ $ & 3$++E2F 3ZZ "" //"  *4))  "'"6"6    * *8 4 99&#&w'7'78*c*'..w/?/?@  %T%%  "'"6"6 EK  !   4>>*f#E&&z2 2  '8/                      ((         ''         ## '9 A 3 3s H  Hcd}|jjj|||jj||d}|r||vs|r||vryd}tfddD} dvr| j dg} j dd} t | tjjrtj| d} nGt | tjs-tjtjdd} | j| d vr)tjd id } | j| d vr)tj d id } | j| d vr|j#| tj$||g| i| x||<} | j&|j(vrd| _|j+| d y)Nrgrc34K|]}|vr ||fywrr)rrrs rrz,Inspector._reflect_column..\s*  EzaM  s)nullable autoincrementquoteinfor'commentdialect_optionsdefaultT) _reflectedcomputedidentitysequence)replace_existingr)metadatadispatchcolumn_reflectrrtrrr elements TextClause sa_schema DefaultClause FetchedValuetextappendComputedIdentity_reflect_col_sequenceColumnr' primary_key append_column)r#rrrrr orig_namergrcol_kwcolargsrrcols ` rrzInspector._reflect_columnIs&M  ..tUEB %%dE59V} O ;  7 -       % MM% 12 3 99Y  +I&G'3<<#:#:;#11'dK)?)?@#11HHU9-.4 NN7 #   ))>E*,=>H NN8 $   ))>E*,=>H NN8 $    & &ug 6-6-=-= '. #. '-.  )$s 77e'' '"CO C$7r*cd|vrM|d}tj|ddd}d|vr |d|_d|vr |d|_|j |yy)Nrrgrstart increment)rSequencerrr)r#rrseqrs rrzInspector._reflect_col_sequencesd   #C ))#f+q! FVnG  56#-.1B,B!!$((I# #  +,99/J#/0;;OL$%67O#$45N%&89 G*OO& /&*ii#-  - /FNN/>6!JK OO&'+ii(55#-  - /GFNN388^V,D#EFGF" +  # #..'"&    m> #sFascdesc nulls_first nulls_lastc $|j||}|D]K} | d} | d} | jdi} | d} | jdd}| jdi}| jd}|rFt| j|s,t j d |d d j | d |rg}| D]_} ||vr||n|j|}| j|d}|jD]\}}||vs ||}|j|atj| g|d|itt|jd| fgzNy#t$r!t j |d |d|dYwxYw)Nrg column_namescolumn_sortinguniquerindexrduplicates_constraintz Omitting z key for (, z), key covers omitted columns.z key '(' was not located in columns for table ''r_table)rrrlissubsetr warnrrKeyError_index_sort_exprsrrIndexrror!)r#rar rrrrrindexesindex_drgcolumnsrrflavorr duplicatesidx_colsridx_col c_sortingrops rrzInspector._reflect_indexess"":v6, G6?Dn-G$[[)92>NX&F[[1F%kk*;R@O %<=Js7|'<'<_'M tyy13H )  11*!,"WWQZ+..q"5 !33.EArI~"$W+.(# )& OO   tO113468J7KKL  O, 6 II4:AzK sE%%'FFc  |j||}|D]} | d} | d} | jd} |rBt| j |s(t j ddj| zb| reg} | D],} ||vr||n|j|}| j|.|jtj| d| iy#t$rYywxYw#t$rt j d|d|dYwxYw) Nrgrduplicates_indexzDOmitting unique constraint key for (%s), key covers omitted columns.r zunique constraint key 'r r )rNotImplementedErrorrrlrr rrrrrrrUniqueConstraint)r#rar rrrrr constraintsconst_drrrconstrained_colsrconstrained_cols rrz%Inspector._reflect_unique_constraints:s> 55j&IK # GfoGn-G %78Js7|'<'<_'M 248IIg4FG "  = = 11*!,"WWQZ$%++O< =  # #**,<K7K ;  #   4 II45zCs#CC$ C! C!$%D  D c |j||}|D]&} |jtjdi| (y#t$rYywxYw)Nr)rrrrCheckConstraint) r#rar rrrrrr!r"s rrz$Inspector._reflect_check_constraintsms\ 44ZHK # JG  # #I$=$=$H$H I J #   sA A  A cv |j||}|jdd|_y#t$rYywxYw)Nr)rrrr)r#rar rr comment_dicts rrz Inspector._reflect_table_commentsC ;11*fEL),,VT:EM#   s , 88r)rTN)>r __module__ __qualname____doc__r deprecatedr1 classmethodr9r.r=r<rFr _inspectsrrIrrKrrM contextlibcontextmanagerrQrUpropertyrWrYr\r`rdrrrrrrrrrrmrrrr deprecated_20rrrrrrr asc_opdesc_opnulls_first_op nulls_last_oprrrrrrr*rr,r,<s>.T__  5  '  '$ T__  5 6 6*Z+&B'B Z&!B"BZ*%F&F&  008 D J5+n  *   ?B2"H'R4* DT4 /33 J X@8D %/(M`    ! ""#  001 y../ 8t1fJ&;r*r,)r+r/baserrrrr r r r r r sql.type_apirr decoratorr)_self_inspectsobjectr,rr*rr=sl(%%    K;K;K;r*