Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/sqlalchemy/engine/__pycache__/default.cpython-39.pyc
Ðазад
a _�hI� � @ sr d Z ddlZddlZddlZddlZddlmZ ddlmZ ddlmZ ddlm Z dd lm Z dd lm Z dd lm Z dd lm Z dd lmZ ddlmZ ddlmZ ddlmZ ddlmZ e�dejejB �Ze�dejejB �ZG dd� dej�Z G dd� de �Z G dd� de ej �Z G dd� de ej!�Z"G d d � d e ej#�Z$G d d � d e �Z%G d d!� d!ej&�Z'e'e _(dS )"a Default implementations of per-dialect sqlalchemy.engine classes. These are semi-private implementation classes which are only of importance to database dialect authors; dialects will usually use the classes here as the base class for their own corresponding classes. � N� )� interfaces)� reflection)�result� )�event)�exc)�pool)� processors)�types)�util)�compiler)� expression)�schema)� quoted_namez-\s*(?:UPDATE|INSERT|CREATE|DELETE|DROP|ALTER)z \s*SELECTc @ s� e Zd ZdZejZejZej Z ej Z dZ dZdZdZeZdZdZdZdZdZdZdZdZdZdZ dZ dZ dZ e �!de �"d�fde j#fde �"d �fd e �"d �fd e j#fd e j#fd e j#fde j$fg�Z%dZ&e j'r�dZ(dZ)dZ*dZ+ndZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1dZ2i Z3dZ4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZ<dZ=dZ>e �!� Z?e j@dd�dedd��ZAe jBdd � �ZCeDd d � �ZEeDd d � �ZFeGd!d"� �ZHeGd#d$� �ZId%d&� ZJd'd(� ZKd)d*� ZLd+d,� ZMdfd-d.�ZNd/d0� ZOd1d2� ZPd3d4� ZQdgd5d6�ZRd7d8� ZSd9d:� ZTd;d<� ZUd=d>� ZVd?d@� ZWdAdB� ZXdCdD� ZYdEdF� ZZdGdH� Z[dIdJ� Z\e jBdKdL� �Z]dMdN� Z^dOdP� Z_dQdR� Z`dSdT� ZadUdV� ZbdhdWdX�ZcdidYdZ�Zddjd[d\�Zed]d^� Zfd_d`� Zgdadb� Zhdcdd� ZidS )k�DefaultDialectz!Default implementation of DialectTFr �convert_unicode�force� pool_timeoutZecho�debugZ echo_poolZ pool_recycleZ pool_sizeZ max_overflowZpool_threadlocalN� use_encoding�defaulti' �named� )z1.3z�The :paramref:`_sa.create_engine.convert_unicode` parameter and corresponding dialect-level parameters are deprecated, and will be removed in a future release. Modern DBAPIs support Python Unicode natively and this parameter is unnecessary.)r �utf-8�staticc K sf t | dd�s t�d| j � || _|| _d| _d | _|| _|d urJ|| _ n | jd ur`| jj | _ n| j | _ |d urv|| _ | j dv | _| � | �| _ | �| �| _|d ur�|| _|d ur�|| _|| _| | _| dkr�d| _n$| dv r�d| _| dk| _n t�d ��| | _| j�r | j| _| | _| jd k�r,t� |�| _ n| jd u�rFt� | j�| _ t � | j�| _ t� | j�| _!d S ) NZported_sqla_06Tz2The %s dialect is not yet ported to the 0.6 formatF)Zqmark�format�numericr )Zdynamic� dynamic_warnr z?empty_in_strategy may be 'static', 'dynamic', or 'dynamic_warn'r )"�getattrr �warn�namer �encoding� positionalZ_ischema�dbapi� paramstyle�default_paramstyle�implicit_returning�preparer�identifier_preparer� type_compiler�supports_right_nested_joins�supports_native_boolean�case_sensitive�empty_in_strategyZ_use_static_inZ_warn_on_empty_inr � ArgumentError�#_user_defined_max_identifier_length�max_identifier_length� label_length�description_encodingr Z to_unicode_processor_factory�_description_decoder�codecs� getencoder�_encoder�_decoder) �selfr r" r% r$ r' r+ r- r, r. r1 r2 �kwargsr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/sqlalchemy/engine/default.py�__init__� sh �� �� �� ��zDefaultDialect.__init__c C s t �� S �N)�weakref�WeakKeyDictionary�r9 r r r; � _type_memos s zDefaultDialect._type_memosc C s | j d | j S )N�+)r! Zdriverr@ r r r; �dialect_description s z"DefaultDialect.dialect_descriptionc C s | j S )z�True if this dialect supports sane rowcount even if RETURNING is in use. For dialects that don't support RETURNING, this is synonymous with ``supports_sane_rowcount``. )�supports_sane_rowcountr@ r r r; � supports_sane_rowcount_returning s z/DefaultDialect.supports_sane_rowcount_returningc C s t | dtj�S )NZ poolclass)r r Z QueuePool)�cls�urlr r r; �get_pool_class) s z DefaultDialect.get_pool_classc C sB d� | j�d�dd� �}zt|d � W n ty< Y n0 d S )N�.r ���z .provision)�join� __module__�split� __import__� ImportError)rF �packager r r; �load_provisioning- s z DefaultDialect.load_provisioningc C s� z| � |�| _W n ty( d | _Y n0 z| �|�| _W n tyR d | _Y n0 z| �|j�| _W n ty~ d | _Y n0 | �|�| _ | j d ur�| � |�r�d | _ | _ | j s�| �|�}|r�|| _| jr�| j| jkr�t�d| j| jf ��d S )NzQLabel length of %d is greater than this dialect's maximum identifier length of %d)Z_get_server_version_info�server_version_info�NotImplementedErrorZ_get_default_schema_nameZdefault_schema_name�get_default_isolation_level� connection�default_isolation_level�_check_unicode_returns�returns_unicode_stringsr3 �_check_unicode_descriptionr4 r0 � _check_max_identifier_lengthr1 r2 r r/ )r9 rU Zmax_ident_lengthr r r; � initialize5 sJ � � � �� � � ��zDefaultDialect.initializec C s d S r= r r@ r r r; � on_connecta s zDefaultDialect.on_connectc C s dS )z�Perform a connection / server version specific check to determine the max_identifier_length. If the dialect's class level max_identifier_length should be used, can return None. .. versionadded:: 1.3.9 Nr )r9 rU r r r; rZ e s z+DefaultDialect._check_max_identifier_lengthc C s | � |�S )a� Given a DBAPI connection, return its isolation level, or a default isolation level if one cannot be retrieved. May be overridden by subclasses in order to provide a "fallback" isolation level for databases that cannot reliably retrieve the actual isolation level. By default, calls the :meth:`_engine.Interfaces.get_isolation_level` method, propagating any exceptions raised. .. versionadded:: 1.3.22 )Zget_isolation_level�r9 Z dbapi_connr r r; rT q s z*DefaultDialect.get_default_isolation_levelc s� t jr�jst j� nt j� �jr*��� �ni �� ���fdd��t�t� d�t � d��t�t� d�t � d��g}|r|||7 }�fdd�|D �}|� dd g�r�d S |dhkS d S ) Nc s� � t �| g�j�d��}z,�j�� }��||�� |�� }|�� W n6 tj yz } z t � d| � W Y d }~dS d }~0 0 t |d t j �S d S )N��dialectz2Exception attempting to detect unicode returns: %rFr )r �select�compilerU �cursor�_cursor_execute�fetchone�closer Z DBAPIErrorr r � isinstance� text_type)�test� statementrb �row�de)�cast_torU � parametersr9 r r; � check_unicode� s � ��z<DefaultDialect._check_unicode_returns.<locals>.check_unicodez'test plain returns'�< z'test unicode returns'c s h | ] }� |��qS r r )�.0rh )rn r r; � <setcomp>� � z8DefaultDialect._check_unicode_returns.<locals>.<setcomp>TFZ conditional)r �py2k�supports_unicode_statements� binary_typerg r# �execute_sequence_formatr �cast�literal_column�sqltypesZVARCHARZUnicode� issuperset)r9 rU Zadditional_testsZtests�resultsr )rl rn rU rm r9 r; rW � s, ���z%DefaultDialect._check_unicode_returnsc C s~ t jr| jst j}nt j}|j�� }zJ|�|t� t� d�� d�g�j | d��� t |jd d t j�W |�� S |�� 0 d S )Nz'x'Z some_labelr^ r )r rs rt ru rg rU rb �executer r` rx �labelra rf � descriptionre )r9 rU rl rb r r r; rY � s$ �����z)DefaultDialect._check_unicode_descriptionc C s t �|| j�S )a) Provide a database-specific :class:`.TypeEngine` object, given the generic object which comes from the types module. This method looks for a dictionary called ``colspecs`` as a class or instance-level variable, and passes on to :func:`_types.adapt_type`. )ry Z adapt_type�colspecs)r9 Ztypeobjr r r; �type_descriptor� s z DefaultDialect.type_descriptorc K s$ t j�|�}|j||||fi |��S r= )r Z InspectorZ from_engine� reflecttable)r9 rU �tableZinclude_columnsZexclude_columnsZ resolve_fks�optsZinspr r r; r� � s ��zDefaultDialect.reflecttablec K s d| j ||fd|i|��iS )z�Compatibility method, adapts the result of get_primary_keys() for those dialects which don't implement get_pk_constraint(). Zconstrained_columnsr )Zget_primary_keys)r9 �connZ table_namer �kwr r r; �get_pk_constraint� s ����z DefaultDialect.get_pk_constraintc C s& t |�| jkr"t�d|| jf ��d S )Nz7Identifier '%s' exceeds maximum length of %d characters)�lenr1 r ZIdentifierError)r9 �identr r r; �validate_identifier� s ��z"DefaultDialect.validate_identifierc O s | j j|i |��S r= )r$ �connect)r9 ZcargsZcparamsr r r; r� � s zDefaultDialect.connectc C s |� � }|�|j� g |gS r= )Ztranslate_connect_args�update�query)r9 rG r� r r r; �create_connect_args� s z"DefaultDialect.create_connect_argsc sb d|v r*|d �t �|d���fdd��}d|v r^t�|d �� � |_t �|d�� fdd��}d S )N�isolation_levelZengine_connectc s |s�� | � � d S r= )�_set_connection_isolation�rU �branch)r� r9 r r; � set_isolation s zBDefaultDialect.set_engine_execution_options.<locals>.set_isolation�schema_translate_mapc s � | _ d S r= )�schema_for_objectr� )�getterr r; �set_schema_translate_map s zMDefaultDialect.set_engine_execution_options.<locals>.set_schema_translate_map)r Z listens_forr �_schema_getterr� )r9 �enginer� r� r� r )r� r� r9 r; � set_engine_execution_options s z+DefaultDialect.set_engine_execution_optionsc C s8 d|v r| � ||d � d|v r4t�|d �}||_d S )Nr� r� )r� r r� r� )r9 rU r� r� r r r; � set_connection_execution_options s z/DefaultDialect.set_connection_execution_optionsc C s6 |� � rt�d� | �|j|� |jjj�| j� d S )Nz�Connection is already established with a Transaction; setting isolation_level may implicitly rollback or commit the existing transaction, or have no effect until next transaction) Zin_transactionr r �set_isolation_levelrU Z_connection_recordZfinalize_callback�append�reset_isolation_level)r9 rU �levelr r r; r� s � �z(DefaultDialect._set_connection_isolationc C s d S r= r �r9 �dbapi_connectionr r r; �do_begin* s zDefaultDialect.do_beginc C s |� � d S r= )�rollbackr� r r r; � do_rollback- s zDefaultDialect.do_rollbackc C s |� � d S r= )�commitr� r r r; � do_commit0 s zDefaultDialect.do_commitc C s |� � d S r= )re r� r r r; �do_close3 s zDefaultDialect.do_closec C s t t�dg�j| d��S )Nr r^ )�strr r` ra r@ r r r; � _dialect_specific_select_one6 s z+DefaultDialect._dialect_specific_select_onec C s� d }z0|� � }z|�| j� W |�� n |�� 0 W nF | jjyz } z*| �|||�rdW Y d }~dS � W Y d }~nd }~0 0 dS d S )NFT)rb r| r� re r$ �Error� is_disconnect)r9 r� rb �errr r r; �do_ping: s zDefaultDialect.do_pingc C s dt �ddd � S )z�Create a random two-phase transaction ID. This id will be passed to do_begin_twophase(), do_rollback_twophase(), do_commit_twophase(). Its format is unspecified. z _sa_%032xr r � )�random�randintr@ r r r; � create_xidJ s zDefaultDialect.create_xidc C s |� t�|�� d S r= )r| r ZSavepointClause�r9 rU r! r r r; � do_savepointS s zDefaultDialect.do_savepointc C s |� t�|�� d S r= )r| r ZRollbackToSavepointClauser� r r r; �do_rollback_to_savepointV s z'DefaultDialect.do_rollback_to_savepointc C s |� t�|�� d S r= )r| r ZReleaseSavepointClauser� r r r; �do_release_savepointY s z#DefaultDialect.do_release_savepointc C s |� ||� d S r= )� executemany�r9 rb ri rm �contextr r r; �do_executemany\ s z DefaultDialect.do_executemanyc C s |� ||� d S r= �r| r� r r r; � do_execute_ s zDefaultDialect.do_executec C s |� |� d S r= r� )r9 rb ri r� r r r; �do_execute_no_paramsb s z#DefaultDialect.do_execute_no_paramsc C s dS )NFr )r9 �erU rb r r r; r� e s z DefaultDialect.is_disconnectc C s | � || j� d S r= )r� rV r] r r r; r� h s z$DefaultDialect.reset_isolation_levelc C sx |d u r d S t jr(t|t�r(|�| j�}|�� }|�� }||krD|S ||kr\| j� |�s\|S ||krpt |dd�S |S d S )NT)�quote) r rs rf r� �decoder" �lower�upperr) �_requires_quotesr �r9 r! Z name_lowerZ name_upperr r r; �normalize_namen s$ �� z DefaultDialect.normalize_namec C sf |d u r d S |� � }|�� }||kr(|S ||kr@| j�|�s@|}tjrb| jsZ|�| j�}nt |�}|S r= ) r� r� r) r� r rs �supports_unicode_binds�encoder" �unicoder� r r r; �denormalize_name� s" ��z DefaultDialect.denormalize_name) Fr NNNNTNr NN)N)N)N)N)N)j�__name__rL � __qualname__�__doc__r Z SQLCompiler�statement_compiler� DDLCompiler� ddl_compilerZGenericTypeCompilerr* �IdentifierPreparerr( Zsupports_alterZsupports_commentsZinline_commentsZdefault_sequence_base�tuplerv Zsupports_views�supports_sequences�sequences_optional�"preexecute_autoincrement_sequences�postfetch_lastrowidr' r+ Zcte_follows_insertZsupports_native_enumr, Z#non_native_boolean_check_constraint� supports_simple_order_by_label�tuple_in_valuesr � immutabledictZ bool_or_strZasintZasboolZengine_config_typesZsupports_native_decimalZpy3krt r� rX r3 r! r1 r0 Zmax_index_name_lengthZmax_constraint_name_lengthrD � supports_sane_multi_rowcountr r& Zsupports_default_valuesZsupports_empty_insertZsupports_multivalues_insertZsupports_is_distinct_from� supports_server_side_cursorsZsupports_for_update_ofrR Zconstruct_argumentsZrequires_name_normalizeZreflection_optionsZ dbapi_exception_translation_mapZdeprecated_paramsr< �memoized_propertyrA �propertyrC rE � classmethodrH rQ r[ r\ rZ rT rW rY r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r; r , s� ��* � � J , 7 r c @ s e Zd Zdd� ZdS )�_RendersLiteralc C s dd� }|S )Nc S s d| S )Nz'%s'r )�valuer r r; �process� s z2_RendersLiteral.literal_processor.<locals>.processr )r9 r_ r� r r r; �literal_processor� s z!_RendersLiteral.literal_processorN)r� rL r� r� r r r r; r� � s r� c @ s e Zd ZdS )� _StrDateTimeN�r� rL r� r r r r; r� � s r� c @ s e Zd ZdS )�_StrDateNr� r r r r; r� � s r� c @ s e Zd ZdS )�_StrTimeNr� r r r r; r� � s r� c @ sR e Zd ZejZejZejZ ej Z dZ dZ dZdZdZdZejeejeejeiZdS )�StrCompileDialectTFN)r� rL r� r ZStrSQLCompilerr� r� r� ZStrSQLTypeCompilerr* r� r( r� r� r� r' r, r� ry �DateTimer� �Dater� �Timer� r r r r r; r� � s �r� c @ s� e Zd ZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZdZdZe�� Zedd� �Zedd� �Zdd� Zed d � �Zed d � �Zejd d� �Zejdd� �Z ejdd� �Z ejdd� �Z ejdd� �Z ejdd� �Z ejdd� �Z!dd � Z"e#d d � �Z$d d � Z%d!d"� Z&d#d$� Z'd%d&� Z(d'd(� Z)d)d*� Z*d+d,� Z+d-d.� Z,d/d0� Z-d1d2� Z.e#d3d4� �Z/d5d6� Z0d7d8� Z1d9d:� Z2d;d<� Z3d=d>� Z4d?d@� Z5dAdB� Z6dRdCdD�Z7dEdF� Z8dZ9dSdHdI�Z:dJdK� Z;dLdM� Z<dNdO� Z=dPdQ� Z>dS )T�DefaultExecutionContextFNc C s� | � | �}||_||_|j|_| |_}d|_|j|_|jrVt|j�|_|j� |j� |j s|t � |�|_ |�|j �d |_nt � |� |_|_ |�� |_g |_|jr�|�� g|_ni g|_|S )z8Initialize execution context for a DDLElement construct.Tr )�__new__�root_connection�_dbapi_connectionr_ �compiled�isddl�execution_options�_execution_options�dictr� rt r rg �unicode_statementr7 ri � create_cursorrb �compiled_parametersr# rv rm )rF r_ rU r� Z compiled_ddlr9 r� r r r; � _init_ddl� s( z!DefaultExecutionContext._init_ddlc sX | � | �}||_||_|j|_� |_� js.J �� j�|j�|_� j � j � j f|_ t �� �|_�jsv|j�|jj�|_n|j|_� j|_� j|_� j|_� j|_|s�� �� g|_n&� fdd�t|�D �|_t |�dk|_ |� � |_ |js�|js�|j�r d|_ t!� jj"�|_#t!� j$�o� jj" �|_%|jj&�s4|jj'�rN|j �rF|�(� n|�)� � j*�� j+�rrt,���|�-� ��}n� j.�r�|jj/}g }� j.�r�|jD ]V�g }|D ]6} | �v �r�|�0�| �| �� n|�0�| � �q�|�0��1|�� �q�nZ�j } |jD ]J�| �r"t,���fdd��D ��}nt,��fdd��D ��}|�0|� �q���1|�|_2|S )z6Initialize execution context for a Compiled construct.c s g | ]\}}� j ||d ��qS ))Z _group_number)�construct_params)rp �grp�m)r� r r; � <listcomp>. s �z:DefaultExecutionContext._init_compiled.<locals>.<listcomp>r Tc 3 s< | ]4}�� |�d |�v r*�| � | �n� | fV qdS )r N�r7 �rp �key)�compiled_paramsr_ r r r; � <genexpr>_ s � ��z9DefaultExecutionContext._init_compiled.<locals>.<genexpr>c 3 s2 | ]*}||�v r �| � | �n� | fV qd S r= r r� )r� r r r; r� i s ���)3r� r� r� r_ r� Z can_executer� �unionr� Z_result_columnsZ_ordered_columnsZ_textual_ordered_columns�result_column_structr rg r� rt r� r" ri �isinsert�isupdate�isdeleteZ isplaintext�is_textr� r� � enumerater� r� r� rb �is_crud�boolZ _returning�_is_explicit_returning� returning�_is_implicit_returning�insert_prefetch�update_prefetch� _process_executemany_defaults� _process_executesingle_defaultsZ_bind_processorsZ contains_expanding_parametersr� �_expand_in_parametersr# � positiontupr� rv rm ) rF r_ rU r� r� rm r9 r �paramr� r� r )r� r� r_ r r; �_init_compiled s� �� � � � � � z&DefaultExecutionContext._init_compiledc s� �j rt�d���jjr(�jjr(td��i �_�jd }|jrDg }nd}i �i }|jr^�jj n�jj D �]r� �jj � }|j �rʈ �v r�|� �n�|� � �}|s�g �|� < �j� |jr�|jn|jg��� < n�t|d ttf��r8� fdd�t|d�D � �|� < �jj�rdnd d ���fd d �t|�D �� �� < n<� fd d�t|d�D � �|� < d ��fdd ��D ���� < |��� ��� �fdd ��D �� |j�r�|�dd � �D �� dd� �D ��j� < qf|jrf|�� � qf�fdd�}t�d|�j ��_ |S )z�handle special 'expanding' parameters, IN tuples that are rendered on a per-parameter basis for an otherwise fixed SQL statement string. z7'expanding' parameters can't be used with executemany()zQ'expanding' bind parameters not supported with 'numeric' paramstyle at this time.r Nc s6 g | ].\}}t |d �D ]\}}d� ||f |f�qqS )r z%s_%s_%s)r )rp �i� tuple_element�jr� �r! r r; r� � s �zADefaultExecutionContext._expand_in_parameters.<locals>.<listcomp>r zVALUES � �, c 3 s8 | ]0\� �d d� � ���fdd�t��D �� V qdS )z(%s)r c 3 s6 | ].\}}�j jd �� t�� | d i V qdS )r! r N)r� � bindtemplater� )rp r r� )r r9 � to_updater r r; r� � s �����zJDefaultExecutionContext._expand_in_parameters.<locals>.<genexpr>.<genexpr>N)rK r �rp )r9 r )r r r; r� � s ���z@DefaultExecutionContext._expand_in_parameters.<locals>.<genexpr>c s g | ]\}}d � |f |f�qS )z%s_%sr )rp r r� r r r; r� � s �c 3 s" | ]\}}� j jd |i V qdS )r! N)r� r �rp r� r� r@ r r; r� � s �c 3 s& | ] \}}� �v r|�� fV qd S r= r r )r! r r r; r� � s �c s s | ]\}}|V qd S r= r )rp r! r� r r r; r� � rr c S s g | ] \}}|�qS r r )rp � expand_keyr� r r r; r� � s c s � | � d� S )Nr )�group)r� )�replacement_expressionsr r; �process_expanding� s zHDefaultExecutionContext._expand_in_parameters.<locals>.process_expandingz\[EXPANDING_(\S+)\]) r� r �InvalidRequestErrorr� r# Z_numeric_bindsrS �_expanded_parametersr� r �bindsZ expanding�popZvisit_empty_set_exprZ_expanding_in_types�typerf r� �listr r_ r� rK r� �extendr� �re�subri ) r9 r� r r� r Zto_update_setsZ parameter�valuesr r )r! r r r9 r r; r y s� �� � � ���� � �� �� �� �z-DefaultExecutionContext._expand_in_parametersc s | � | �}||_||_|j|_d|_|j|_|sP|jjrF� �� g|_ q�i g|_ ndt |d � j�rh||_ nLt |d t �r�� j r�||_ q�� fdd�|D �p�i g|_ n� fdd�|D �|_ t |�dk|_� j s�t |tj�r�||_� �|�d |_n | |_|_|�� |_|S )z8Initialize execution context for a string SQL statement.Tr c s g | ]� � �fd d�� D ��qS )c s i | ]}�� |�d � | �qS )r r� )rp �k)�dr_ r r; � <dictcomp> rr zFDefaultExecutionContext._init_statement.<locals>.<listcomp>.<dictcomp>r r r^ )r+ r; r� s �z;DefaultExecutionContext._init_statement.<locals>.<listcomp>c s g | ]}� � |��qS r )rv )rp �pr^ r r; r� s r )r� r� r� r_ r r� r� r# rv rm rf r� rt r� r� r rg r� r7 ri r� rb )rF r_ rU r� ri rm r9 r r^ r; �_init_statement� s@ �� �� z'DefaultExecutionContext._init_statementc C s4 | � | �}||_||_|j|_|j|_|�� |_|S )z;Initialize execution context for a ColumnDefault construct.)r� r� r� r_ r� r� r� rb )rF r_ rU r� r9 r r r; � _init_default s z%DefaultExecutionContext._init_defaultc C s8 | j r| j jS d| jv r,| jj�| jd �S | jjS d S )Nr� )r� r( r� r_ r) Z_with_schema_translater@ r r r; r) # s �z+DefaultExecutionContext.identifier_preparerc C s | j jS r= )r� r� r@ r r r; r� . s z DefaultExecutionContext.enginec C s | j jS r= )r� � postfetchr@ r r r; �postfetch_cols2 s z&DefaultExecutionContext.postfetch_colsc C s$ | j r| jjS | jr | jjS dS d S )Nr )r r� r r r r@ r r r; � prefetch_cols6 s z%DefaultExecutionContext.prefetch_colsc C s | j j d S r= )r� r r@ r r r; �returning_cols? s z&DefaultExecutionContext.returning_colsc C s | j �dd�S )N� no_parametersF)r� �getr@ r r r; r4 C s z%DefaultExecutionContext.no_parametersc C s@ | j �d| j r | jr tjp d�}|tju r8| �| j�S |S d S )N� autocommitF)r� r5 r� ri r ZPARSE_AUTOCOMMIT�should_autocommit_textr� )r9 r6 r r r; �should_autocommitG s ��� z)DefaultExecutionContext.should_autocommitc C s� | j }t|tj�r*| jjs*| j�|�d }| jjr>| j�� }ni }|j | j ||| d� | j � � d }|dur�|� | j| j j d d �}|r�||�S |S )a Execute a string statement on the current cursor, returning a scalar result. Used to fire off sequences, default phrases, and "select lastrowid" types of statements individually or in the context of a parent INSERT or UPDATE statement. r )r� Nr )r� rf r rg r_ rt r7 r# rv rc rb rd �_cached_result_processorr~ )r9 �stmt�type_r� Zdefault_params�r�procr r r; �_execute_scalarV s$ �� �z'DefaultExecutionContext._execute_scalarc C s | j �� S r= )r� Z_branchr@ r r r; rU w s z"DefaultExecutionContext.connectionc C s t �|�S r= )�AUTOCOMMIT_REGEXP�match)r9 ri r r r; r7 { s z.DefaultExecutionContext.should_autocommit_textc C sv | j js dS | j jrd| j�dd�o`| jr8t| jjtj �p`| j sPt| jjtj �o`| jo`t � | j�}n| j�dd�}|S )NFZstream_resultsT) r_ r� Zserver_side_cursorsr� r5 r� rf ri r Z SelectableZ TextClause�SERVER_SIDE_CURSOR_REr@ )r9 Zuse_server_sider r r; �_use_server_side_cursor~ s0 � �� ��� ��z/DefaultExecutionContext._use_server_side_cursorc C s* | � � rd| _| �� S d| _| j�� S d S )NTF)rB �_is_server_side�create_server_side_cursorr� rb r@ r r r; r� � s z%DefaultExecutionContext.create_cursorc C s t � �d S r= )rS r@ r r r; rD � s z1DefaultExecutionContext.create_server_side_cursorc C s d S r= r r@ r r r; �pre_exec� s z DefaultExecutionContext.pre_execc C s d S r= r r@ r r r; � post_exec� s z!DefaultExecutionContext.post_execc C s |� | j|�S )z�Return a 'result processor' for a given type as present in cursor.description. This has a default implementation that dialects can override for context-sensitive result type handling. )r9 r_ )r9 r; ZcolnameZcoltyper r r; �get_result_processor� s z,DefaultExecutionContext.get_result_processorc C s | j jS )a� return self.cursor.lastrowid, or equivalent, after an INSERT. This may involve calling special cursor functions, issuing a new SELECT on the cursor (or a new one), or returning a stored value that was calculated within post_exec(). This function will only be called for dialects which support "implicit" primary key generation, keep preexecute_autoincrement_sequences set to False, and when no explicit id value was bound to the statement. The function is called once, directly after post_exec() and before the transaction is committed or ResultProxy is generated. If the post_exec() method assigns a value to `self._lastrowid`, the value is used in place of calling get_lastrowid(). Note that this method is *not* equivalent to the ``lastrowid`` method on ``ResultProxy``, which is a direct proxy to the DBAPI ``lastrowid`` accessor in all cases. )rb � lastrowidr@ r r r; � get_lastrowid� s z%DefaultExecutionContext.get_lastrowidc C s d S r= r )r9 r� r r r; �handle_dbapi_exception� s z.DefaultExecutionContext.handle_dbapi_exceptionc C s | j rt�| �S t�| �S d S r= )rC r ZBufferedRowResultProxyZ ResultProxyr@ r r r; �get_result_proxy� s z(DefaultExecutionContext.get_result_proxyc C s | j jS r= )rb �rowcountr@ r r r; rL � s z DefaultExecutionContext.rowcountc C s | j jS r= )r_ rD r@ r r r; rD � s z.DefaultExecutionContext.supports_sane_rowcountc C s | j jS r= )r_ r� r@ r r r; r� � s z4DefaultExecutionContext.supports_sane_multi_rowcountc C s� | j r:| js:| js,| jjs,| jjr,| �� n| js:| �� | � � }| j r�| jrv|� � }|| _ | � |� |� � d |_q�| js�|� � d |_nB| jr�| jr�|� � }|| _ |� � d |_n|jd u r�|j |� � |S r= )r r� r r� �inliner_ r� � _setup_ins_pk_from_lastrowid�_setup_ins_pk_from_emptyrK rd �returned_defaults�%_setup_ins_pk_from_implicit_returningZ _soft_close� _metadatar r rL )r9 r rj r r r; �_setup_crud_result_proxy� s< ��� z0DefaultExecutionContext._setup_crud_result_proxyc s� | j jd �| j jj}| jd �| �� ��d ur||j� � d ur^� j�| j d �}|d ur^|���� ���fdd�|j D �| _ n��fdd�|j D �| _ d S )Nr r c s( g | ] }|� u r�n�� �|�d ��qS r= �r5 �rp �c�Z autoinc_colr� � key_getterrH r r; r� s ��zHDefaultExecutionContext._setup_ins_pk_from_lastrowid.<locals>.<listcomp>c s g | ]}� � �|�d ��qS r= rT rU �r� rX r r; r� ' s �) r� � _key_getters_for_crud_columnri r� r� rI Z_autoincrement_columnr$ r9 r_ � primary_key�inserted_primary_key)r9 r� r= r rW r; rN s$ �� �z4DefaultExecutionContext._setup_ins_pk_from_lastrowidc s< | j jd �| j jj}| jd � � �fdd�|jD �| _d S )Nr r c s g | ]}� � �|�d ��qS r= rT rU rY r r; r� 0 s zDDefaultExecutionContext._setup_ins_pk_from_empty.<locals>.<listcomp>)r� rZ ri r� r� r[ r\ )r9 r� r rY r; rO , s �z0DefaultExecutionContext._setup_ins_pk_from_emptyc s\ �d u rd | _ d S | jjd �| jjj}| jd � �fdd�� �fdd�|jD �D �| _ d S )Nr r c s$ g | ] \}}|d u r � | n|�qS r= r )rp �colr� )rj r r; r� < s �zQDefaultExecutionContext._setup_ins_pk_from_implicit_returning.<locals>.<listcomp>c s g | ]}|� � �|�d �f�qS r= rT )rp r] rY r r; r� > s �)r\ r� rZ ri r� r� r[ )r9 rj r� r )r� rX rj r; rQ 4 s ��z=DefaultExecutionContext._setup_ins_pk_from_implicit_returningc C s | j s | jot| jj�S r= )r r r r� r0 r@ r r r; �lastrow_has_defaultsD s �z,DefaultExecutionContext.lastrow_has_defaultsc sP t | jd�sdS i }| jjD ]j}|j�| j�}t|�}|�| jj�� � dur~|r`� |vr~||vr~|rt� |v st||v r~� ||< q d||< q | jjr�| jj � || j | j | j | � | jj�rhg }| jjD ]V} | jj| }|�|d�� � dur�| | jv �r|�� gt| j| � � q�|�� � q�z| j j|� W n: t�yd } z | j�| ddd| � W Y d} ~ n d} ~ 0 0 n�i } | jj�� D ]�\}} |�|d�� � du�rx|�r�|�| | �} | jj�s�| j� | �d } | | jv �r�| � � fdd�| j| D �� n� | | < �qxz| j jf i | �� W n: t�yJ } z | j�| ddd| � W Y d} ~ n d} ~ 0 0 dS )a& Given a cursor and ClauseParameters, call the appropriate style of ``setinputsizes()`` on the cursor, using DB-API types from the bind parameter's ``TypeEngine`` objects. This method only called by those dialects which require it, currently cx_oracle. � bind_namesNr c 3 s | ]}|� fV qd S r= r )rp r �Zdbtyper r; r� � s �z:DefaultExecutionContext.set_input_sizes.<locals>.<genexpr>) �hasattrr� r_ r$ Z_unwrapped_dialect_implr_ Zget_dbapi_typer$ Z _has_events�dispatchZdo_setinputsizesrb ri rm r# r r" r5 r! r& r� r� Z setinputsizes� BaseExceptionr� Z_handle_dbapi_exception�itemsr� r7 r� ) r9 � translateZ include_typesZ exclude_typesZ inputsizesZ bindparamZ dialect_implZdialect_impl_clsZpositional_inputsizesr� r� Zkeyword_inputsizesr r` r; �set_input_sizesI s~ ����� � � � � � � �z'DefaultExecutionContext.set_input_sizesc C s� |j r| �||�S |jr(|| _|�| �S |jrv| j}|jsJt� |j|�}n|j}t� |g�j |d�}|� |di �� � S |jS d S )N)�bindr )� is_sequenceZ fire_sequence� is_callable�current_column�argZis_clause_elementrU Z _arg_is_typedr Z type_coercer` ra Z_execute_compiledZscalar)r9 �columnr r; r� Z default_argrV r r r; � _exec_default� s z%DefaultExecutionContext._exec_defaultTc s� z| j �| j}W n ty, t�d��Y n0 |r�| jr�| jjjr�|j rf|j d � |j j �|j i}n|j �|j i}d� | jjj d �� }|�� �fdd�|D �� |S �S dS )ai Return a dictionary of parameters applied to the current row. This method can only be used in the context of a user-defined default generation function, e.g. as described at :ref:`context_default_functions`. When invoked, a dictionary is returned which includes entries for each column/value pair that is part of the INSERT or UPDATE statement. The keys of the dictionary will be the key value of each :class:`_schema.Column`, which is usually synonymous with the name. :param isolate_multiinsert_groups=True: indicates that multi-valued INSERT constructs created using :meth:`_expression.Insert.values` should be handled by returning only the subset of parameters that are local to the current column default invocation. When ``False``, the raw parameters of the statement are returned including the naming convention used in the case of multi-valued INSERT. .. versionadded:: 1.2 added :meth:`.DefaultExecutionContext.get_current_parameters` which provides more functionality over the existing :attr:`.DefaultExecutionContext.current_parameters` attribute. .. seealso:: :attr:`.DefaultExecutionContext.current_parameters` :ref:`context_default_functions` zdget_current_parameters() can only be invoked in the context of a Python side column default functionr r c 3 s" | ]}|�d |� f fV qdS )z%s_m%dNr r� ��indexrm r r; r� s zADefaultExecutionContext.get_current_parameters.<locals>.<genexpr>N)�current_parametersrj �AttributeErrorr r r r� ri Z_has_multi_parametersZ_is_multiparam_columnro �originalr� rm �keysr� )r9 Zisolate_multiinsert_groupsrl r+ rs r rn r; �get_current_parameters� s0 ! � ��� �z.DefaultExecutionContext.get_current_parametersc C s$ |j d u rd S | �||j |j�S d S r= )r rm r$ �r9 rl r r r; �get_insert_default s z*DefaultExecutionContext.get_insert_defaultc C s$ |j d u rd S | �||j |j�S d S r= )�onupdaterm r$ ru r r r; �get_update_default s z*DefaultExecutionContext.get_update_defaultc C s� | j jd }i }| j j}| j j}|D ] }|jr$|jjr$|jj||< q$|D ] }|jrH|jjrH|jj||< qH| jD ]~}|| _ |D ]4}||v r�|| }n | � |�}|d ur|||||�< q||D ]4}||v r�|| }n | � |�}|d ur�||||�< q�qn| ` d S )Nr ) r� rZ r r r � is_scalarrk rw r� rp rv rx )r9 rX Zscalar_defaultsr r rV r �valr r r; r s2 z5DefaultExecutionContext._process_executemany_defaultsc C s� | j jd }| jd | _}| j jD ]B}|jrH|jjsH|jjrH|jj}n | � |�}|d ur$||||�< q$| j j D ]"}| � |�}|d urp||||�< qp| `d S )Nr r ) r� rZ r� rp r r rh ry rk rv r rx )r9 rX r� rV rz r r r; r : s � z7DefaultExecutionContext._process_executesingle_defaults)NNN)T)?r� rL r� r r r r r r� r� r� ri r� rP r r Z_translate_colnamer r� r! r� r� r r r. r/ r� r) r� r1 r2 r3 r4 r8 r> r� rU r7 rB r� rD rE rF rG rI rJ rK rL rD r� rS rN rO rQ r^ rf rm rp rt rv rx r r r r r r; r� � s� un / ! ' � X <%r� ))r� r5 r� r' r> r r r r r r r r r ry r �sqlr r r Z sql.elementsr ra �I�UNICODEr? rA �Dialectr �objectr� r� r� r� r� r� r� r� ZExecutionContextr� Zexecution_ctx_clsr r r r; �<module> sP � z
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка