?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/sqlalchemy/testing/fixtures/__pycache__/base.cpython-39.pyc
???????
a ��Jh�/ � @ s� d dl mZ d dlZddlmZ ddlmZ ddlmZ ddlm Z dd lm Z dd lm Z dd lm Z dd lm Z dd lmZ ddlmZ ddlmZ ddlmZ e�� G dd� d��ZdaG dd� d�ZdS )� )� annotationsN� )� assertions)�config)�eq_)� drop_all_tables_from_metadata� )�Column)�func)�Integer)�select)�Table)�DeclarativeBase)�MappedAsDataclass)�registryc @ s e Zd ZdZdZdZdZdZd$dd�Ze � � dd� �Z e � � dd � �Z e � � d d � �Z e � � d d � �Ze � � dd� �Ze j dd� �Ze j dd� �Ze � � dd� �Ze � � dd� �Ze � � dd� �Ze � � dd� �Ze � � d d � �Ze j d d � d D �d!�d"d#� �ZdS )%�TestBase� NFc C s |s J |��d S �Nr )�self�val�msgr r �U/home/agenciai/.local/lib/python3.9/site-packages/sqlalchemy/testing/fixtures/base.py�assert_0 s zTestBase.assert_c c s" t jj}d t j_d V |t j_d S r )r �dbZ_compiled_cache)r �_cacher r r �nocache3 s zTestBase.nocachec c sD t | dd �ptj}|�� �}|V W d � n1 s60 Y d S �N�bind)�getattrr r �connect)r �eng�connr r r �connection_no_trans: s z TestBase.connection_no_transc c sJ t | dd �ptj}|�� }|�� }|a|V d a|jr>|�� |�� d S r ) r r r r �begin� _connection_fixture_connection� is_active�rollback�close)r r r! �transr r r � connectionA s zTestBase.connectionc # sj g � g �d� �fdd� }|V �D ] }z |� � W q" Y q"0 q"� D ] }z |�� W qF Y qF0 qFd S )NFc s � � | � |r�� | � d S r )�append)�resultZconsume��to_closeZ to_consumer r �go[ s z/TestBase.close_result_when_finished.<locals>.go)F)�allr' )r r. �rr r, r �close_result_when_finishedV s z#TestBase.close_result_when_finishedc c s8 t |tt�� �t�d�ddd�id�}|V |�� d S )N�2 �mysql�mariadb�oracle)�metadata�type_annotation_map)r �str�sa�String� with_variant�dispose)r r6 �regr r r r l s ���zTestBase.registryc # s, |� G � fdd�dt �}|V |j�� d S )Nc s. e Zd Z� Zee�� �e�d�ddd�iZdS )z TestBase.decl_base.<locals>.Baser2 r3 r4 r5 N� �__name__� __module__� __qualname__r6 r8 r9 r: r; r7 r �Z_mdr r �Base} s ��rC )r r r< �r r6 rC r rB r � decl_basey s zTestBase.decl_basec # s. |� G � fdd�dt t�}|V |j�� d S )Nc s, e Zd Z� Zee�� �e�d�dd�iZdS )z#TestBase.dc_decl_base.<locals>.Baser2 r3 r4 Nr> r rB r r rC � s ��rC )r r r r< rD r rB r � dc_decl_base� s zTestBase.dc_decl_basec c s |V d S r r )r � future_enginer) r r r �future_connection� s zTestBase.future_connectionc c s d V d S r r )r r r r rG � s zTestBase.future_enginec # s0 ddl m� d� fdd� }|V � j�d� d S )Nr ��enginesFc s( |d u r i }d|d< � j | ||||d�S )N�fixtureZscope)�url�options�asyncio�transfer_staticpool� share_pool��testing_engine)rL rM �futurerN rO rP rI r r �gen_testing_engine� s �z3TestBase.testing_engine.<locals>.gen_testing_enginerK )NNNFFF)� rJ Ztesting_reaperZ_drop_testing_engines)r rT r rI r rR � s �zTestBase.testing_enginec s � fdd�}|S )Nc s d| d< � f i | ��S )NTrN r )�kwrQ r r r. � s z)TestBase.async_testing_engine.<locals>.gor )r rR r. r rQ r �async_testing_engine� s z TestBase.async_testing_enginec c s� ddl m} |�� }||j_|V |j`trxt�� rxt�� }|�� t� � � t |t� W d � q�1 sl0 Y n t |t j � dS )z>Provide bound MetaData for a single test, dropping afterwards.r )�schemaN) ZsqlrX ZMetaData�instancer6 r$ Zin_transactionZget_transactionr& r# r r r )r �requestrX r6 r( r r r r6 � s �� �$zTestBase.metadatac C s* g | ]"}d D ]}dD ]}|||f�qq qS ))�none�executer# �TFr )�.0r& �second_operation� begin_nestedr r r � <listcomp>� s �zTestBase.<listcomp>r] )�paramsc sP |j \��� td|tdt���t| dd �p.tj}��|� � ���fdd�}|S )N�test�datar c sJ | � � ���}� �rltjjjs&t�d� |r4| �� }n|�� }|�� |r\| ���� ddi� n|���� ddi� �r~|� � n|� � �dk�rt � t jjd��f �dkr�|r�| ���� ddi� q�|���� ddi� n �dkr�|r�| �� n|�� W d � n1 �s0 Y W d � n1 �s.0 Y |�rT| ���� dd i� n|���� dd i� �n,|�r�| ���� ddi� n|���� ddi� |�r���r�| � � n| � � n��r�|� � n|� � �dk�r�t � t jjd��� �dk�r,|�r| ���� ddi� n|���� ddi� nL�dk�rVt|d��rL|� � n| � � n"�d k�rx|�rp| �� n|�� W d � n1 �s�0 Y W d � n1 �s�0 Y d }� �r�|d 7 }��s�|d 7 }|�r�t| �tt�� �����|� nH| �� �.}t|�tt�� �����|� W d � n1 �s<0 Y d S ) Nzsavepoints not enabledrd � r[ z�Can't operate on closed transaction inside context manager. Please complete the context manager before emitting further commands.r\ � r# � r` r � )r# r � requirementsZ savepoints�enabledZ skip_testr` r\ �insertr& �commitr Zexpect_raises_messager9 �excZInvalidRequestError�hasattrr Zscalarr r �count� select_fromr )�subjectZtrans_on_subjectZexecute_on_subjectr( Z nested_transZexpected_committedr! �r` r& r_ �tr r �run_test� s� � � H � H� �z4TestBase.trans_ctx_manager_fixture.<locals>.run_test)�paramr r r r r r �create)r rZ r6 r rt r rr r �trans_ctx_manager_fixture� s wz"TestBase.trans_ctx_manager_fixture)N)r? r@ rA � __requires__Z__unsupported_on__Z __only_on__Z __skip_if__Z"__leave_connections_for_teardown__r r rK r r" r) r1 r rE rF rH rG rR rW r6 rw r r r r r sH �� r c @ s e Zd ZdZdS )�FutureEngineMixinz alembic's suite still using thisN)r? r@ rA �__doc__r r r r ry m s ry )� __future__r Z sqlalchemyr9 rU r r r �utilr r r r r r Zormr r r Zmark_base_test_classr r$ ry r r r r �<module> s& P
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????