Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/sqlalchemy/testing/__pycache__/assertsql.cpython-39.pyc
Ðазад
a _�h5 � @ sN d dl Z d dlZd dlZddlmZ ddlmZ ddlmZ ddlm Z ddl m Z ddl m Z G d d � d e�ZG d d � d e�ZG d d� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd � d e�ZG d d � d e�ZG d d � d e �d g d!���ZG d"d#� d#e�Z ej d$d%� �Z dS )&� N� )�event)�util)�url)�DefaultDialect)�_distill_params)� _DDLCompilesc @ s( e Zd ZdZdZdZdd� Zdd� ZdS )� AssertRuleFNTc C s d S �N� ��self�execute_observedr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/sqlalchemy/testing/assertsql.py�process_statement s z AssertRule.process_statementc C s ds J d��d S )NFz?All statements are complete, but pending assertion rules remainr �r r r r �no_more_statements s �z AssertRule.no_more_statements)�__name__� __module__� __qualname__� is_consumed� errormessage�consume_statementr r r r r r r s r c @ s e Zd ZdS )� SQLMatchRuleN�r r r r r r r r $ s r c @ s" e Zd ZdZddd�Zdd� ZdS )� CursorSQLFNc C s || _ || _d S r )� statement�params)r r r r r r �__init__+ s zCursorSQL.__init__c C sj |j d }| j|jks,| jd urH| j|jkrHd| j| j|j|jf | _n |j �d� d| _|j sfd| _d S )Nr z5Testing for exact SQL %s parameters %s received %s %sT)� statementsr r � parametersr �popr r )r r �stmtr r r r / s$ � ���� zCursorSQL.process_statement)N)r r r r r r r r r r r ( s r c @ sF e Zd Zddd�Zdd� Zdd� Zd d � Zd d � Zd d� Zdd� Z dS )� CompiledSQLN�defaultc C s || _ || _|| _d S r )r r �dialect)r r r r% r r r r E s zCompiledSQL.__init__c C s t �dd| j�}||kS �N�[\n\t]� )�re�subr )r r �received_statementr" r r r � _compare_sqlJ s zCompiledSQL._compare_sqlc C sF | j dkrt� S | j dkr$ddi}ni }t�| j ��� f i |��S d S )Nr$ � postgresqlZimplicit_returningT)r% r r �URL� get_dialect)r r r r r r �_compile_dialectN s z CompiledSQL._compile_dialectc s� |j }| �|�}t|jjt�r:|jjj||j�d�d�� n&|jjj||jj |jj |j�d�d�� t � ddt �� ��}|j}|s�� �� g}n� fdd�|D �}||fS )zxreconstruct the statement and params in terms of a target dialect, which for CompiledSQL is just DefaultDialect.�schema_translate_map)r% r1 )r% � column_keys�inliner1 r' r( c s g | ]}� � |��qS r )�construct_params)�.0�m��compiledr r � <listcomp>u s z3CompiledSQL._received_statement.<locals>.<listcomp>)�contextr0 � isinstancer8 r r �compileZexecution_options�getr2 r3 r) r* r � text_typer r4 )r r r: Zcompare_dialect�_received_statementr �_received_parametersr r7 r r? Y s2 ���� �z CompiledSQL._received_statementc C s� |j }| �|�\}}| �|�}| �||�}|r�|d ur�t|�}t|�}|r�|r�t|�d��} tt|��D ]8\} } | D ] } | | vs�| | | | krt qhqt|| = qFqhd}q�qF|s�|r�d}|r�d| _d | _ n| � |�||d� | _ d S )Nr FT)r+ Zreceived_parameters) r: r? � _all_paramsr, �list�dictr! � enumerater r �_failure_message) r r r: r? r@ r Z equivalent� all_paramsZ all_received�param�idx�receivedZ param_keyr r r r { s@ � ���z CompiledSQL.process_statementc C s@ | j r8t�| j �r | � |�}n| j }t|t�s4|g}|S d S d S r )r r �callabler; rB )r r: r r r r rA � s zCompiledSQL._all_paramsc C s" d| j �dd�t|��dd�f S )NzzTesting for compiled statement %r partial params %s, received %%(received_statement)r with params %%(received_parameters)r�%�%%)r �replace�repr�r Zexpected_paramsr r r rE � s ���z CompiledSQL._failure_message)Nr$ ) r r r r r, r0 r? r rA rE r r r r r# D s "1 r# c @ s& e Zd Zd dd�Zdd� Zdd� ZdS ) �RegexSQLNr$ c C s, t �| � t�|�| _|| _|| _|| _d S r )r r r) r< �regex� orig_regexr r% )r rQ r r% r r r r � s zRegexSQL.__init__c C s" d| j �dd�t|��dd�f S )Nz{Testing for compiled statement ~%r partial params %s, received %%(received_statement)r with params %%(received_parameters)rrK rL )rR rM rN rO r r r rE � s ���zRegexSQL._failure_messagec C s t | j�|��S r )�boolrQ �match)r r r+ r r r r, � s zRegexSQL._compare_sql)Nr$ )r r r r rE r, r r r r rP � s rP c s4 e Zd Zdd� Zdd� Z� fdd�Zdd� Z� ZS ) � DialectSQLc C s |j jS r )r: r% r r r r r0 � s zDialectSQL._compile_dialectc C s t �dd|�}||kS r& )r) r* )r � real_stmt� received_stmtr" r r r �_compare_no_space� s z DialectSQL._compare_no_spacec sJ t t| ��|�\}}|jD ]}| �|j|�r q>qtd| ��||jjfS )NzICan't locate compiled statement %r in list of statements actually invoked) �superrU r? r rX r �AssertionErrorr: Zcompiled_parameters)r r rW Zreceived_paramsrV �� __class__r r r? � s �� ��z DialectSQL._received_statementc C st t �dd| j�}|jjj}|dkr2t �dd|�}n:d }|dkrDd}n|dkrRd }n |d kr^d }t �d||�}||kS ) Nr' r( Zpyformatz :([\w_]+)z%(\1)sZqmark�?�formatz%s�numeric)r) r* r r: r% � paramstyle)r r r+ r" r` �replr r r r, � s zDialectSQL._compare_sql)r r r r0 rX r? r, � __classcell__r r r[ r rU � s rU c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�CountStatementsc C s || _ d| _d S �Nr ��count�_statement_count)r rf r r r r s zCountStatements.__init__c C s | j d7 _ d S )N� )rg r r r r r s z!CountStatements.process_statementc C s( | j | jkr$ds$J d| j | jf ��d S )NFz,desired statement count %d does not match %dre r r r r r s �z"CountStatements.no_more_statementsN)r r r r r r r r r r rc s rc c @ s e Zd Zdd� Zdd� ZdS )�AllOfc G s t |�| _d S r )�set�rules�r rk r r r r s zAllOf.__init__c C sj t | j�D ]H}d |_|�|� |jrB| j�|� | js<d| _ qfq |js d | _ qfq t | j�d j| _d S �NTr )rB rk r r r �discard�r r �ruler r r r s zAllOf.process_statementN)r r r r r r r r r ri s ri c s, e Zd Zdd� Zdd� Z� fdd�Z� ZS )�EachOfc G s t |�| _d S r )rB rk rl r r r r / s zEachOf.__init__c C sV | j rF| j d }|�|� |jr.| j �d� n|jr<|j| _|jr qFq | j sRd| _d S )Nr T)rk r r r! r r ro r r r r 2 s zEachOf.process_statementc s: | j r"| j d js"| j d �� n| j r6tt| ��� d S rd )rk r r rY rq r r[ r r r @ s zEachOf.no_more_statements)r r r r r r rb r r r[ r rq . s rq c @ s e Zd Zdd� ZdS )�Orc C s< | j D ] }|�|� |jrd| _ q8qt| j �d j| _d S rm )rk r r rB r ro r r r r H s zOr.process_statementN)r r r r r r r r rr G s rr c @ s e Zd Zdd� ZdS )�SQLExecuteObservedc C s" || _ || _t||�| _g | _d S r )r: � clauseelementr r r )r r: rt � multiparamsr r r r r S s zSQLExecuteObserved.__init__N)r r r r r r r r rs R s rs c @ s e Zd ZdS )�SQLCursorExecuteObservedNr r r r r rv Z s rv )r r r: � executemanyc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� SQLAsserterc C s g | _ d S r )� accumulatedr r r r r d s zSQLAsserter.__init__c C s | j | _| ` d S r )ry �_finalr r r r �_closeg s zSQLAsserter._closec G sn t |� }t| j�}|rJ|�d�}|�|� |jr4qJq|jrdsJ |j��q|r\dsjJ d��n|jsj|�� d S )Nr Fz Additional SQL statements remain)rq rB rz r! r r r r )r rk rp Zobservedr r r r �assert_k s zSQLAsserter.assert_N)r r r r r{ r| r r r r rx c s rx c # s� t � � g �t�| d��fdd��}t�| d�� �fdd��}z.� V W t�| d|� t�| d|� � �� n&t�| d|� t�| d|� � �� 0 d S )NZbefore_executec s |||f� d d �< d S r r )�connrt ru r )�origr r �connection_execute� s z)assert_engine.<locals>.connection_executeZafter_cursor_executec sj |sd S � j r*� j d j|u r*� j d }n&t|�d �d �d �}� j �|� |j�t||||�� d S )N���r rh r )ry r: rs �appendr rv )r} �cursorr r r: rw Zobs�Zasserterr~ r r �cursor_execute� s �� ��z%assert_engine.<locals>.cursor_execute)rx r Z listens_for�remover{ )�enginer r� r r� r � assert_engine| s �r� ) � collections� contextlibr) r( r r r� r Zengine.defaultr Z engine.utilr Zschemar �objectr r r r# rP rU rc ri rq rr rs � namedtuplerv rx �contextmanagerr� r r r r �<module> s: . ��
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка