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: threadlocal.cpython-310.pyc
o [�h� � @ sL d Z ddlZddlmZ ddlmZ G dd� dej�ZG d d � d ej�ZdS ) a8 Provides a thread-local transactional wrapper around the root Engine class. The ``threadlocal`` module is invoked when using the ``strategy="threadlocal"`` flag with :func:`~sqlalchemy.engine.create_engine`. This module is semi-private and is invoked automatically when the threadlocal engine strategy is used. � N� )�base� )�utilc s4 e Zd Z� fdd�Zdd� Zdd� Zdd� Z� ZS ) � TLConnectionc s t t| �j|i |�� d| _d S �Nr )�superr �__init__�_TLConnection__opencount)�self�arg�kw�� __class__� �H/usr/local/lib/python3.10/dist-packages/sqlalchemy/engine/threadlocal.pyr s zTLConnection.__init__c C s | j d7 _ | S �Nr )r �r r r r �_increment_connect s z TLConnection._increment_connectc C s( | j dkr tj�| � | j d8 _ d S r �r r � Connection�closer r r r r s zTLConnection.closec C s d| _ tj�| � d S r r r r r r � _force_close$ s zTLConnection._force_close)�__name__� __module__� __qualname__r r r r � __classcell__r r r r r s r c s� e Zd ZdZeZe�dd�� fdd��Zdd� Z dd � Z d#d d �Z d d� Z dd� Z dd� Zdd� Zdd� Zdd� Zdd� Z� fdd �Zed d � �Zd d � Zd!d"� Z� ZS )$�TLEnginezPAn Engine that includes support for thread-local managed transactions. z1.3a The 'threadlocal' engine strategy is deprecated, and will be removed in a future release. The strategy is no longer relevant to modern usage patterns (including that of the ORM :class:`.Session` object) which make use of a :class:`.Connection` object in order to invoke statements.c s& t t| �j|i |�� tj�� | _d S �N)r r r r � threading�local� _connections)r �args�kwargsr r r r 1 s zTLEngine.__init__c K s | j di |��S )Nr )�_contextual_connect)r r r r r �contextual_connect= s zTLEngine.contextual_connectc K s` t | jd�s d }n| j�� }|d u s|jr,| j| | �| jj|�fi |��}t� |�| j_|� � S �N�conn) �hasattrr! r' �closed�_tl_connection_cls�_wrap_pool_connect�pool�connect�weakref�refr )r r � connectionr r r r$ @ s ��z TLEngine._contextual_connectNc C s2 t | jd�s g | j_| jj�| �� j|d�� | S )N�trans)�xid)r( r! r1 �appendr$ �begin_twophase)r r2 r r r r4 R s �zTLEngine.begin_twophasec C �. t | jd�s g | j_| jj�| �� �� � | S �Nr1 )r( r! r1 r3 r$ � begin_nestedr r r r r7 Z s �zTLEngine.begin_nestedc C r5 r6 )r( r! r1 r3 r$ �beginr r r r r8 b s zTLEngine.beginc C s | S r r r r r r � __enter__h s zTLEngine.__enter__c C s |d u r | � � d S | �� d S r )�commit�rollback)r �type_�value� tracebackr r r �__exit__k s zTLEngine.__exit__c C s, t | jd�r | jjs d S | jjd �� d S �Nr1 ���)r( r! r1 �preparer r r r rB q s ��zTLEngine.preparec C �2 t | jd�r | jjs d S | jj�d�}|�� d S r@ )r( r! r1 �popr: �r r1 r r r r: y � �� zTLEngine.commitc C rC r@ )r( r! r1 rD r; rE r r r r; � rF zTLEngine.rollbackc s t j�� | _tt| ��� d S r )r r r r! r r �disposer r r r rG � s zTLEngine.disposec C s( t | jd� p| j�� d u p| j�� jS r& )r( r! r' r) r r r r r) � s � �zTLEngine.closedc C s: | j s| �� �� | j�� }|�� | j`g | j_d S d S r )r) r$ r r! r' r r1 )r r0 r r r r � s �zTLEngine.closec C s d| j S )Nz TLEngine(%r))�urlr r r r �__repr__� s zTLEngine.__repr__r )r r r �__doc__r r* r � deprecatedr r% r$ r4 r7 r8 r9 r? rB r: r; rG �propertyr) r rI r r r r r r ) s. � r ) rJ r. � r r r r �Enginer r r r r �<module> s
Save
Cancel