Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
local
/
lib
/
python3.10
/
dist-packages
/
sqlalchemy
/
engine
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: reflection.cpython-310.pyc
o [�h�� � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lm Z dd l m Z dd lm Z dd lmZ ejd d� �ZG dd� de�ZdS )a� Provides 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.. � )� Connectable� )�exc)� inspection)�sql)�util)� operators)�schema)� TypeEngine)� deprecated)� topologicalc O s� |� dd �}|d u r| ||g|�R i |��S | jtdd� |D ��tdd� |�� D ��f}|� |�}|d u rE| ||g|�R i |��}|||< |S )N� info_cachec s s � | ] }t |tj�r|V qd S �N)� isinstancer � string_types)�.0�a� r �G/usr/local/lib/python3.10/dist-packages/sqlalchemy/engine/reflection.py� <genexpr>/ s � zcache.<locals>.<genexpr>c s s$ � | ] \}}|d kr||fV qdS )r Nr )r �k�vr r r r 0 s �" )�get�__name__�tuple�items)�fn�self�con�args�kwr �key�retr r r �cache( s � r# c @ sf e Zd ZdZdd� Zedd� �Ze�e �dd� �Z e dd � �Z d d � Z ejd d �dGdd��ZdHdd�Zdd� Zdd� ZdHdd�ZdHdd�ZdHdd �ZdHd d �Zed d �dHd!d"��ZdHd#d$�ZdHd%d&�ZdHd'd(�Z dHd)d*�Z dHd+d,�Z dHd-d.�Z / 0 dId1d2�Z d3d4� Z!d5d6� Z"d7d8� Z#d9d:� Z$d;e%j&fd<e%j'fd=e%j(fd>e%j)fgZ*d?d@� Z+dAdB� Z,dCdD� Z-dEdF� Z.dS )J� Inspectoram Performs database schema inspection. The Inspector acts as a proxy to the reflection methods of the :class:`~sqlalchemy.engine.interfaces.Dialect`, providing a consistent interface as well as caching support for previously fetched metadata. A :class:`.Inspector` object is usually created via the :func:`.inspect` function:: from sqlalchemy import inspect, create_engine engine = create_engine('...') insp = inspect(engine) The inspection method above is equivalent to using the :meth:`.Inspector.from_engine` method, i.e.:: engine = create_engine('...') insp = Inspector.from_engine(engine) Where above, the :class:`~sqlalchemy.engine.interfaces.Dialect` may opt to return an :class:`.Inspector` subclass that provides additional methods specific to the dialect's target database. c C sJ || _ t|d�r |j| _n|| _| j|u r|�� �� | jj| _i | _dS )aj Initialize a new :class:`.Inspector`. :param bind: a :class:`~sqlalchemy.engine.Connectable`, which is typically an instance of :class:`~sqlalchemy.engine.Engine` or :class:`~sqlalchemy.engine.Connection`. For a dialect-specific instance of :class:`.Inspector`, see :meth:`.Inspector.from_engine` �engineN)�bind�hasattrr% �connect�close�dialectr )r r& r r r �__init__T s zInspector.__init__c C s t |jd�r |j�|�S t|�S )a� Construct 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:`.Inspector` in that the :class:`~sqlalchemy.engine.interfaces.Dialect` is given a chance to provide a dialect-specific :class:`.Inspector` instance, which may provide additional methods. See the example at :class:`.Inspector`. � inspector)r' r* r, r$ )�clsr& r r r � from_enginep s zInspector.from_enginec C s t �| �S r )r$ r. )r& r r r �_insp� s zInspector._inspc C s | j jS )z�Return the default schema name presented by the dialect for the current engine's database user. E.g. this is typically ``public`` for PostgreSQL and ``dbo`` for SQL Server. )r* �default_schema_name�r r r r r0 � s z Inspector.default_schema_namec C s$ t | jd�r| jj| j| jd�S g S )z!Return all schema names. �get_schema_names�r )r' r* r2 r& r r1 r r r r2 � s �zInspector.get_schema_names)z1.0z�The :paramref:`get_table_names.order_by` parameter is deprecated and will be removed in a future release. Please refer to :meth:`.Inspector.get_sorted_table_and_fkc_names` for a more comprehensive solution to resolving foreign key cycles between tables.)�order_byNc C s� t | jd�r| jj| j|| jd�}n| j�|�}|dkrCg }|D ]}| �||�D ]}||d kr9|�|d |f� q(q t t � ||��}|S )a� Return all table names in referred to within a particular schema. The names are expected to be real tables only, not views. Views are instead returned using the :meth:`.Inspector.get_view_names` method. :param schema: Schema name. If ``schema`` is left at ``None``, the database's default schema is used, else the named schema is searched. If the database does not support named schemas, behavior is undefined if ``schema`` is not passed as ``None``. For special quoting, use :class:`.quoted_name`. :param order_by: Optional, may be the string "foreign_key" to sort the result on foreign key dependencies. Does not automatically resolve cycles, and will raise :class:`.CircularDependencyError` if cycles exist. .. seealso:: :meth:`.Inspector.get_sorted_table_and_fkc_names` :attr:`.MetaData.sorted_tables` �get_table_namesr3 � foreign_key�referred_table) r' r* r5 r& r r% � table_names�get_foreign_keys�append�listr �sort)r r r4 �tnames�tuples�tname�fkeyr r r r5 � s % � ��zInspector.get_table_namesc s8 t | jd�r| jj| j|| jd�}n| j�|�}t� }t� �i �|D ]'}| �||�}tdd� |D ���|< |D ]}||d krH|� |d |f� q7q"z t t � ||��}W n6 t jy� } z)|jD ]� |�� � ��� fdd��� d D �� q`t t � ||��}W Y d }~nd }~ww ��fd d�|D �d t ��fg S ) ax Return dependency-sorted table and foreign key constraint names in referred to within a particular schema. This will yield 2-tuples of ``(tablename, [(tname, fkname), (tname, fkname), ...])`` consisting of table names in CREATE order grouped with the foreign key constraint names that are not detected as belonging to a cycle. The final element will be ``(None, [(tname, fkname), (tname, fkname), ..])`` which will consist of remaining foreign key constraint names that would require a separate CREATE step after-the-fact, based on dependencies between tables. .. versionadded:: 1.0.- .. seealso:: :meth:`.Inspector.get_table_names` :func:`.sort_tables_and_constraints` - similar method which works with an already-given :class:`.MetaData`. r5 r3 c S s g | ]}|d �qS )�namer )r �fkr r r � <listcomp>� s z<Inspector.get_sorted_table_and_fkc_names.<locals>.<listcomp>r7 c 3 s � | ] }� d |fV qdS )r Nr )r �fkc)�edger r r s � �z;Inspector.get_sorted_table_and_fkc_names.<locals>.<genexpr>r Nc s g | ] }|� | � ��f�qS r )� difference)r r? )�fknames_for_table�remaining_fkcsr r rC s ��)r' r* r5 r& r r% r8 �setr9 �addr; r r< r �CircularDependencyError�edges�remove�update) r r r= r> r? �fkeysr@ �candidate_sort�errr )rE rG rH r � get_sorted_table_and_fkc_names� s@ � �� � �� � �z(Inspector.get_sorted_table_and_fkc_namesc C � | j j| j| jd�S )z�return 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 r3 )r* �get_temp_table_namesr& r r1 r r r rT � �z Inspector.get_temp_table_namesc C rS )z�return 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 r3 )r* �get_temp_view_namesr& r r1 r r r rV rU z Inspector.get_temp_view_namesc K s0 t | jd�r| jj| j||fd| ji|��S i S )a� Return 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_optionsr )r' r* rW r& r �r � table_namer r r r r rW & s ���zInspector.get_table_optionsc C s | j j| j|| jd�S )z�Return all view names in `schema`. :param schema: Optional, retrieve names from a non-default schema. For special quoting, use :class:`.quoted_name`. r3 )r* �get_view_namesr& r )r r r r r rZ : s �zInspector.get_view_namesc C s | j j| j||| jd�S )z�Return definition for `view_name`. :param schema: Optional, retrieve names from a non-default schema. For special quoting, use :class:`.quoted_name`. r3 )r* �get_view_definitionr& r )r � view_namer r r r r[ F s �z Inspector.get_view_definitionc K sJ | j j| j||fd| ji|��}|D ]}|d }t|t�s"|� |d< q|S )a� Return information about columns in `table_name`. Given a string `table_name` and an optional string `schema`, return column information as a list of dicts with these keys: * ``name`` - the column's name * ``type`` - the type of this column; an instance of :class:`~sqlalchemy.types.TypeEngine` * ``nullable`` - boolean flag if the column is NULL or NOT NULL * ``default`` - the column's server default value - this is returned as a string SQL expression. * ``attrs`` - dict containing optional column attributes :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`. :return: list of dictionaries, each representing the definition of a database column. r �type)r* � get_columnsr& r r r )r rY r r �col_defs�col_def�coltyper r r r^ R s ��� �zInspector.get_columnsz0.7z�The :meth:`.Inspector.get_primary_keys` method is deprecated and will be removed in a future release. Please refer to the :meth:`.Inspector.get_pk_constraint` method.c K s$ | j j| j||fd| ji|��d S )z�Return information about primary keys in `table_name`. Given a string `table_name`, and an optional string `schema`, return primary key information as a list of column names. r �constrained_columns�r* �get_pk_constraintr& r rX r r r �get_primary_keysz s ����zInspector.get_primary_keysc K � | j j| j||fd| ji|��S )a� Return information about primary key constraint on `table_name`. Given a string `table_name`, and an optional string `schema`, return primary key information as a dictionary with these keys: constrained_columns a list of column names that make up the primary key name optional name of the primary key constraint. :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`. r rc rX r r r rd � s ���zInspector.get_pk_constraintc K rf )a� Return information about foreign_keys in `table_name`. Given a string `table_name`, and an optional string `schema`, return foreign key information as a list of dicts with these keys: constrained_columns a list of column names that make up the foreign key referred_schema the name of the referred schema referred_table the name of the referred table referred_columns a list of column names in the referred table that correspond to constrained_columns name optional name of the foreign key constraint. :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`. r )r* r9 r& r rX r r r r9 � s ���zInspector.get_foreign_keysc K rf )a� Return 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``, ``nullsfirst``, ``nullslast``. .. 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`. r )r* � get_indexesr& r rX r r r rg � s $���zInspector.get_indexesc K rf )ao Return 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`. r )r* �get_unique_constraintsr& r rX r r r rh � s ���z Inspector.get_unique_constraintsc K rf )a� Return 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 r )r* �get_table_commentr& r rX r r r ri s ���zInspector.get_table_commentc K rf )aK Return 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 r )r* �get_check_constraintsr& r rX r r r rj s ���z Inspector.get_check_constraintsr Tc sp |dur� |v r dS |� � � | jj}| j�� �}� j}t� fdd�|jD ��} | j||fi � j��} | r:� � | � t j rSt |t �rH|�|j�}t |t �rS|�|j�}d} i } | j||fi � j��D ] } d} | �� | ||| � qb| sxt�� j��| �||� | |� | �||� | |||| � | �||� | ||| � | �||� | ||| � | �||� | ||| � | �||� | � dS )a Given a 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.engine.reflection import Inspector engine = create_engine('...') meta = MetaData() user_table = Table('user', meta) insp = Inspector.from_engine(engine) insp.reflecttable(user_table, None) :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. Nc 3 s* � | ]}|� j v r|� j �|�fV qd S r )�dialect_kwargsr �r r ��tabler r r i s � ��z)Inspector.reflecttable.<locals>.<genexpr>FT)rJ r& r* �schema_for_objectrA �dict�reflection_optionsrW rk �_validate_dialect_kwargsr �py2kr �str�decode�encodingr^ �_reflect_columnr �NoSuchTableError� _reflect_pk� _reflect_fk�_reflect_indexes�_reflect_unique_constraints�_reflect_check_constraints�_reflect_table_comment)r rn �include_columns�exclude_columns� resolve_fks� _extend_onr* r rY rq �tbl_opts� found_table�cols_by_orig_name�col_dr rm r � reflecttable< s� ��� � �� �� � � � �zInspector.reflecttablec s, � d }|j �| |� � � d }|r||vs |r ||v r d S � d }t� fdd�dD ��} d� v r8| �� d � g } � �d�d urk� d } t| tjj�rTt j | dd �} nt| t j �sft j t� � d �dd �} | � | � d � v ru| �� | � t j||g| �R i | �� ||< } | j|jv r�d| _|�| � d S ) NrA r] c 3 s$ � | ] }|� v r|� | fV qd S r r rl �r� r r r � s � � �z,Inspector._reflect_column.<locals>.<genexpr>)�nullable� autoincrement�quote�infor! �comment�dialect_options�defaultT)� _reflected�sequence)�dispatch�column_reflectrp rN r r r �elements� TextClause� sa_schema� DefaultClause� FetchedValue�textr: �_reflect_col_sequence�Columnr! � primary_key� append_column) r rn r� r r� r� � orig_namerA ra �col_kw�colargsr� �colr r� r rw � sH � � � ��� zInspector._reflect_columnc C sX d|v r*|d }t �|d dd�}d|v r|d |_d|v r#|d |_|�|� d S d S )Nr� rA r �start� increment)r� �Sequencer� r� r: )r r� r� �seqr� r r r r� � s �z Inspector._reflect_col_sequencec sT | j ||fi |j��}|r(� �fdd�|d D �}|�d�|j_|j�|� d S d S )Nc s$ g | ]}|� v r|�vr� | �qS r r )r �pk�r� r� r r rC s �z)Inspector._reflect_pk.<locals>.<listcomp>rb rA )rd rk r r� rA �_reload)r rY r rn r� r� �pk_cons�pk_colsr r� r ry s �� ��zInspector._reflect_pkc s> | j ||fi |j��} | D ]�} | d } � fdd�| d D �} |r(t| ��|�r(q | d } | d }| d }g }| d ur^|rMtj||jfd| | j|d �|�� |D ] }|�d � | ||g�� qOn#|rrtj||jfd| jtj |d �|�� |D ] }|�d � ||g�� qtd | v r�| d }ni }|� tj | || fd di|��� q d S )NrA c s" g | ] }|� v r � | j n|�qS r )r! )r �c�r� r r rC , s ��z)Inspector._reflect_fk.<locals>.<listcomp>rb �referred_schemar7 �referred_columnsT)�autoloadr � autoload_withr� �.)r� r� r r� �options� link_to_name) r9 rk rI � intersectionr� �Table�metadatar& r: �join� BLANK_SCHEMA�append_constraint�ForeignKeyConstraint)r rY r rn r� r� r� r� rq rO �fkey_d�connamerb r� r7 r� �refspec�columnr� r r� r rz s� �� � ���� ����� �����zInspector._reflect_fk�asc�desc� nullsfirst� nullslastc C sN | � ||�}|D ]�} | d } | d } | �di �} | d } | �dd�}| �di �}| �d�}|rCt| ��|�sCt�d |d �| �f � q|rFqg }| D ]@}z||v rU|| n|j| }W n tyn t�d |||f � Y qJw | �|d �}| j D ] \}}||v r�||�}qx|� |� qJt j | g|�R d |it t|�� �d| fg ��� qd S )NrA � column_names�column_sorting�uniquer] �indexr� �duplicates_constraintz5Omitting %s key for (%s), key covers omitted columns.�, z5%s key '%s' was not located in columns for table '%s'r �_table)rg r rI �issubsetr �warnr� r� �KeyError�_index_sort_exprsr: r� �Indexrp r; r )r rY r rn r� r r� rq �indexes�index_drA �columnsr� r� �flavorr� � duplicates�idx_colsr� �idx_col� c_sortingr �opr r r r{ i sb ���� ��� � �����zInspector._reflect_indexesc C s� z| � ||�}W n ty Y d S w |D ]_} | d } | d } | �d�} |r8t| ��|�s8t�dd�| � � q| r;qg } | D ])}z||v rJ|| n|j| }W n t yb t�d||f � Y q?w | � |� q?|� t j | d| i�� qd S )NrA r� �duplicates_indexzDOmitting unique constraint key for (%s), key covers omitted columns.r� zDunique constraint key '%s' was not located in columns for table '%s')rh �NotImplementedErrorr rI r� r r� r� r� r� r: r� r� �UniqueConstraint)r rY r rn r� r r� rq � constraints�const_dr� r� r� �constrained_colsr� �constrained_colr r r r| � sJ � ���� ��� ��z%Inspector._reflect_unique_constraintsc C sJ z| � ||�}W n ty Y d S w |D ] } |�tjdi | ��� qd S )Nr )rj r� r� r� �CheckConstraint) r rY r rn r� r r� rq r� r� r r r r} � s ��z$Inspector._reflect_check_constraintsc C s8 z| � ||�}W n ty Y d S w |�dd �|_d S )Nr� )ri r� r r� )r rY r rn rq � comment_dictr r r r~ � s �z Inspector._reflect_table_comment)NNr )r TN)/r � __module__� __qualname__�__doc__r+ � classmethodr. r � _inspectsr r/ �propertyr0 r2 r �deprecated_paramsr5 rR rT rV rW rZ r[ r^ r re rd r9 rg rh ri rj r� rw r� ry rz r �asc_op�desc_op� nullsfirst_op� nullslast_opr� r{ r| r} r~ r r r r r$ 9 sd � *8 (� # ( % � 9 I�:3 r$ N)r� �baser � r r r r r r r� � sql.type_apir r r � decoratorr# �objectr$ r r r r �<module> s
Save
Cancel