File: //usr/local/lib/python3.10/dist-packages/sqlalchemy/testing/__pycache__/engines.cpython-310.pyc
o
���gf4 � @ s� d dl mZ d dlZd dlZd dlZd dlmZ d dlmZ d dlmZ d dlZd dl Z ddl
m Z ddl m
Z
dd l mZ d
d l
mZ d
d l
mZ d
d
l mZ d
dlmZ ejrkd
dlmZ d
dlmZ d
dlmZ G dd� d�Ze� Z e
dd� �Z e
dd� �Z e
dd� �Z e
dd� �Z d:d d �Z!G d d � d �Z"d;d d!�Z#ej$ " "d<d=d-d.��Z%ej$ / "d>d?d2d.��Z% " " " "d@d3d.�Z%d:d4d5�Z&G d6d7� d7�Z'G d8d9� d9�Z(dS )A� )� annotationsN)�Any)�Dict)�Optional� )�config)� decorator)�
gc_collect� )�event)�pool)�
await_only)�Literal)�Engine)�URL)� AsyncEnginec @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#S )$�ConnectionKillerc C s" t �� | _t�t�| _t� | _d S �N)�weakref�WeakKeyDictionary�
proxy_refs� collections� defaultdict�set�testing_engines�dbapi_connections��self� r �E/usr/local/lib/python3.10/dist-packages/sqlalchemy/testing/engines.py�__init__% s
zConnectionKiller.__init__c C sD t �|d| j� t �|d| j� t �|d| j� t �|d| j� d S )N�checkout�checkin�close�close_detached)r �listen� _add_conn� _remove_conn)r r r r r �add_pool* s zConnectionKiller.add_poolc C s | j �|� d| j|< d S )NT)r �addr )r � dbapi_con�
con_record� con_proxyr r r r& 2 s zConnectionKiller._add_connc G s | j �|� d S r )r �discard)r �
dbapi_conn�argr r r r' 6 s z ConnectionKiller._remove_connc C s, | � |j� |dv s J �| j| �|� d S )N)�class�global�function�fixture)r( r r r) )r �engine�scoper r r �
add_engine9 s zConnectionKiller.add_enginec
C �B z|� W d S t y } zt�d| � W Y d }~d S d }~ww )Nz5testing_reaper couldn't rollback/close connection: %s�� Exception�warnings�warn�r �fn�er r r �_safe? s ���zConnectionKiller._safec C s. t | j�D ]}|d ur|jr| �|j� qd S r )�listr �is_validr? �rollback�r �recr r r � rollback_allG s
��z ConnectionKiller.rollback_allc C s^ t | j�D ]}|d ur|jr| j�|j� | �|j� q| jD ]}| �|j� q | j� � d S r )
r@ r rA r r- �dbapi_connectionr? �_checkinrB �clear)r rD �conr r r � checkin_allL s �
z ConnectionKiller.checkin_allc C s | � � d S r )rJ r r r r � close_all[ � zConnectionKiller.close_allc C s* t jsd S ddlm} |�|jj|� d S �Nr )� provision)r �bootstrapped_as_sqlalchemy� rN �prepare_for_drop_tablesr4 �url)r �
connectionrN r r r rQ ^ s z(ConnectionKiller.prepare_for_drop_tablesc C s� | j | }t|�D ]2}t| j�D ]}|d ur*|jr*|jd ur*|j|ju r*| �|j� qt|d�r7t |�
� � q |�
� q |� � d S )N� sync_engine) r r@ r rA �_poolr r? rG �hasattrr
�disposerH )r r5 �engrD � proxy_refr r r �_drop_testing_enginesg s
�
z&ConnectionKiller._drop_testing_enginesc C � | � d� d S )Nr2 )rZ r r r r �
after_testx � zConnectionKiller.after_testc C sj t jsd S |jjr d S | �� ddlm} t j�� �}|� |j
j |� W d � d S 1 s.w Y d S rM ) r rO � __class__�"__leave_connections_for_teardown__rJ rP rN �db�connectrQ r4 rR )r �testrN �connr r r �after_test_outside_fixtures{ s "�z,ConnectionKiller.after_test_outside_fixturesc C s | � � | �d� | �d� d S )Nr2 r0 )rJ rZ r r r r � stop_test_class_inside_fixtures� s
z0ConnectionKiller.stop_test_class_inside_fixturesc C sD t jjr t� t jjr tt jj�}t jj�� J d| ��d S d S )NFz/%d connection recs not cleared after test suite)r �base� _strong_ref_connection_recordsr �lenrH )r �lnr r r � stop_test_class_outside_fixtures� s ���z1ConnectionKiller.stop_test_class_outside_fixturesc C s" | � � | jD ]}| �|� qd S r )rJ r rZ )r r5 r r r �
final_cleanup� s
�z ConnectionKiller.final_cleanupc C s | j D ]}|jr
J �qd S r )r rA rC r r r �assert_all_closed� s
��z"ConnectionKiller.assert_all_closedN)�__name__�
__module__� __qualname__r r( r& r' r6 r? rE rJ rK rQ rZ r\ rd re rj rk rl r r r r r $ s$
r c O s( z| |i |�� W t �� d S t �� w r )�testing_reaperrl �r= �args�kwr r r �assert_conns_closed� s rt c O �( z| |i |�� W t �� dS t �� w )zBDecorator that rolls back all open connections after fn execution.N)rp rE rq r r r �rollback_open_connections� s rv c O s t �� | |i |�� dS )z:Decorator that closes all connections before fn execution.N�rp rJ rq r r r � close_first� s rx c O ru )z9Decorator that closes all connections after fn execution.Nrw rq r r r �close_open_connections� s ry c c sZ � dd l m} |jD ] }| r|| v rq
t||d �}|s%ttd| �j|�}|�� V q
d S )Nr zsqlalchemy.dialects.%s)�sqlalchemy.dialects�dialects�__all__�getattr�
__import__�dialect)�exclude�d�name�modr r r � all_dialects� s �
� �r� c @ s> e Zd Zdd� Zdd� Zdd� Zdd� Zdd
d �Zd d
� ZdS )�ReconnectFixturec C s || _ g | _d| _d S �NF)�dbapi� connections�
is_stopped)r r� r r r r � �
zReconnectFixture.__init__c C � t | j|�S r )r} r� �r �keyr r r � __getattr__� rL z ReconnectFixture.__getattr__c O sN | j j|i |��}| jr | �|j� |�� }|�d� J d��| j�|� |S )Nzselect 1Fz%simulated connect failure didn't work) r� ra r� r? r# �cursor�executer� �append)r rr �kwargsrc �cursr r r ra � s
zReconnectFixture.connectc
C r7 )Nz.ReconnectFixture couldn't close connection: %sr8 r< r r r r? � s ��zReconnectFixture._safeFc C s, || _ t| j�D ]}| �|j� qg | _d S r )r� r@ r� r? r# )r �stop�cr r r �shutdown� s
zReconnectFixture.shutdownc C s
d| _ d S r� )r� r r r r �restart �
zReconnectFixture.restartN)F) rm rn ro r r� ra r? r� r� r r r r r� � s
r� c sj | pt jj} t jjj}|si }t|�|d< t| |���j� � �fdd�}�jjj�_ �jjj
�_ |�_�S )N�modulec s �j j�� d�j j_� � d S r� )r r� r� r� r ��_disposer4 r r rW s
z$reconnecting_engine.<locals>.dispose) r r` rR r r� r� �testing_enginerW r� �
test_shutdownr� � test_restart)rR �optionsr� rW r r� r �reconnecting_engine
s
r� FrR �
Optional[URL]r� �Optional[Dict[str, Any]]�asyncio�Literal[False]�transfer_staticpool�bool�returnr c C � d S r r �rR r� r� r� r r r r� � r� T�
Literal[True]r c C r� r r r� r r r r� ' r� c C s� |r
|rJ �ddl m} nddlm} ddlm} |s"d}d} d}
n|�dd�}|�d d�} |�d
d�}
| p9tjj } || �} tjd u sK| j
tjj j
krTtj rTtj � � } ni } |d ur_| �
|� || fi | ��} |
r�| jd kr�t�| d �d
d� �}
t�| d�dd� �}|r�ddlm} tjd ur�ttjj|�r�d}| j�tjj� n|r�tjj| _| dkr�|r�d| j_nd| _t| jtj�r�d| vr�d| vr�d| vr�d| j_d| j_|r�t� | | � | S )Nr )�create_async_engine)�
create_engine)�make_urlTr2 F�
use_reaperr5 �sqlite_savepoint�sqlitera c S s
d | _ d S r )�isolation_level)rF �connection_recordr r r �
do_connect\ s
z"testing_engine.<locals>.do_connect�beginc S r[ )N�BEGIN)�exec_driver_sql)rc r r r �do_begin` s z testing_engine.<locals>.do_begin)�
StaticPoolr1 r � pool_timeout� max_overflow) �sqlalchemy.ext.asyncior� �
sqlalchemyr� �sqlalchemy.engine.urlr� �popr r` rR �
drivername�db_opts�copy�updater� r � listens_for�sqlalchemy.poolr� �
isinstancer �_transfer_fromrT � _has_events� QueuePool�_timeout�
_max_overflowrp r6 )rR r� r� r� �
share_pool�_sqlite_savepointr� r� r� r5 r� � use_optionsr4 r� r� r� r r r r� 0 sd �
�
� � c sr ddl m} | s tjj} g � � fdd�}� fdd�}�fdd�}|| d |��t�d
�r.J �� �_|�_|�_�S ) a' Provides a mocking engine based on the current testing.db.
This is normally used to test DDL generation flow as emitted
by an Engine.
It should not be used in other cases, as assert_compile() and
assert_sql_execution() are much better choices with fewer
moving parts.
r )�create_mock_enginec s � � | � d S r )r� )�sql�ars ��bufferr r �executor� r] z mock_engine.<locals>.executorc s" dd� � D �}|| ksJ |��d S )Nc S s g | ] }t �d dt|���qS )z[\n\t]rP )�re�sub�str��.0�sr r r �
<listcomp>� s z3mock_engine.<locals>.assert_sql.<locals>.<listcomp>r )�stmts�recvr� r r �
assert_sql� s z mock_engine.<locals>.assert_sqlc s �j � d�� fdd��jD ��S )N�
c 3 s � | ] }t |j� d ��V qdS ))r N)r� �compiler� �r� r r � <genexpr>� s � z1mock_engine.<locals>.print_sql.<locals>.<genexpr>)r �join�mockr )r4 r� r � print_sql� s z mock_engine.<locals>.print_sqlz://r� ) r� r� r r` r� rV r� r� r� )� dialect_namer� r� r� r� r )r� r4 r � mock_engine� s r� c @ s: e Zd ZdZdd� Zd
dd�Zdd� Zd d
� Zd d � ZdS )�DBAPIProxyCursorzuProxy a DBAPI cursor.
Tests can provide subclasses of this to intercept
DBAPI-level cursor operations.
c O s" || _ || _|j|i |��| _d S r )r4 rS r� )r r4 rc rr r� r r r r � s zDBAPIProxyCursor.__init__Nc K s. |r
| j j||fi |��S | j j|fi |��S r )r� r� )r �stmt�
parametersrs r r r r� � s zDBAPIProxyCursor.executec K s | j j||fi |��S r )r� � executemany)r r� �paramsrs r r r r� � s z DBAPIProxyCursor.executemanyc C s
t | j�S r )�iterr� r r r r �__iter__� r� zDBAPIProxyCursor.__iter__c C r� r )r} r� r� r r r r� � rL z DBAPIProxyCursor.__getattr__r ) rm rn ro �__doc__r r� r� r� r� r r r r r� � s
r� c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �DBAPIProxyConnectionz}Proxy a DBAPI connection.
Tests can provide subclasses of this to intercept
DBAPI-level connection operations.
c C s || _ || _|| _d S r )rc r4 �
cursor_cls)r r4 rc r� r r r r � r� z DBAPIProxyConnection.__init__c O s | j | j| jg|�R i |��S r )r� r4 rc )r rr r� r r r r� � s zDBAPIProxyConnection.cursorc C s | j �� d S r )rc r# r r r r r# � r] zDBAPIProxyConnection.closec C r� r )r} rc r� r r r r� � rL z DBAPIProxyConnection.__getattr__N)rm rn ro r� r r� r# r� r r r r r� � s r� r )NN)NNFF)
rR r� r� r� r� r� r� r� r� r )NNTF)
rR r� r� r� r� r� r� r� r� r )NNFFFF))�
__future__r r r� �typingr r r r: r rP r �utilr r r r r
� util.typingr �
TYPE_CHECKINGr4 r �
engine.urlr � ext.asyncior r rp rt rv rx ry r� r� r� �overloadr� r� r� r� r r r r �<module> sp
+��
�
S&