| Server IP : 192.158.238.246 / Your IP : 3.16.149.93 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python37/lib/python3.7/site-packages/beaker/ext/__pycache__/ |
Upload File : |
B
��[q � @ s� d dl mZ d dlZd dlZd dlmZ d dlmZmZ d dlmZm Z d dl
m Z m Z d dl
mZmZ e�e�ZdaG dd � d e�ZG d
d � d e�Zdd
d�ZdS )� )�pickleN)�datetime)� OpenResourceNamespaceManager� Container)�InvalidCacheBackendError�MissingCacheParameter)�file_synchronizer�null_synchronizer)�verify_directory�SyncDictc @ s~ e Zd Ze� Ze� Zedd� �Zddd�Zdd� Z dd � Z
d
d � Z d d
� Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd� ZdS )�SqlaNamespaceManagerc C s: t d k r d S y dd la W n tk
r4 td��Y nX d S )Nr z?SQLAlchemy, which is required by this backend, is not installed)�sa�
sqlalchemy� ImportErrorr )�cls� r �@/opt/alt/python37/lib/python3.7/site-packages/beaker/ext/sqla.py�_init_dependencies s z'SqlaNamespaceManager._init_dependenciesNc s� t �| |� |r|| _n|r&|d | _| jr6t| j� | jj�t� j�� fdd��| _ | jj
�d� j�j f �fdd��| _ i | _
d| _d| _dS )aQ Create a namespace manager for use with a database table via
SQLAlchemy.
``bind``
SQLAlchemy ``Engine`` or ``Connection`` object
``table``
SQLAlchemy ``Table`` object in which to store namespace data.
This should usually be something created by ``make_cache_table``.
z/container_db_lockc s � S )Nr r )�bindr r �<lambda>6 � z/SqlaNamespaceManager.__init__.<locals>.<lambda>z%s:%sc s � S )Nr r )�tabler r r 8 r FN)r �__init__�lock_dirr
� __class__�binds�get�str�urlr �tables�namer �hash�_is_new�loaded)�self� namespacer r Zdata_dirr �kwargsr )r r r r ! s
z SqlaNamespaceManager.__init__c C s t � S )N)r )r$ r r r �get_access_lock= s z$SqlaNamespaceManager.get_access_lockc C s t d| j | jd�S )Nz databasecontainer/funclock/%s)�
identifierr )r r% r )r$ �keyr r r �get_creation_lock@ s z&SqlaNamespaceManager.get_creation_lockc C s� | j r|| _d S t�| jjjg| jjj| jk�}| j� |��
� }|sRd| _ i | _ nNd| _ y|d | _ W n8 t
tttjtjfk
r� t�d� i | _ d| _ Y nX || _d| _ d S )NTF�dataz.Couln't load pickle data, creating new storage)r# �flagsr
�selectr �cr+ r% r �execute�fetchoner" r! �IOError�OSError�EOFErrorr Z PickleError�log�debug)r$ r, �replacer- �resultr r r �do_openE s&
z SqlaNamespaceManager.do_openc C s� | j d k r�| j dks | j dkr�| jrX| j�� }| jj|| j| jt� � t� � d� d| _n0| j�
| jj j| jk�}| jj|| jt� � d� d | _ d S )Nr. �w)r% r+ �accessed�createdF)r+ r: ) r, r" r �insertr r/ r% r! r �now�updater. )r$ r< r> r r r �do_close[ s
z SqlaNamespaceManager.do_closec C s4 | j �| j jj| jk�}| j�|� i | _d| _d S )NT)r �deleter. r% r r/ r! r" )r$ r@ r r r � do_removeg s z SqlaNamespaceManager.do_removec C s
| j | S )N)r! )r$ r) r r r � __getitem__m s z SqlaNamespaceManager.__getitem__c C s
|| j kS )N)r! )r$ r) r r r � __contains__p s z!SqlaNamespaceManager.__contains__c C s || j |< d S )N)r! )r$ r) �valuer r r � __setitem__s s z SqlaNamespaceManager.__setitem__c C s | j |= d S )N)r! )r$ r) r r r � __delitem__v s z SqlaNamespaceManager.__delitem__c C s
| j �� S )N)r! �keys)r$ r r r rG y s zSqlaNamespaceManager.keys)NN)�__name__�
__module__� __qualname__r r r � classmethodr r r' r* r8 r? rA rB rC rE rF rG r r r r r s
r c @ s e Zd ZeZdS )�
SqlaContainerN)rH rI rJ r Znamespace_managerr r r r rL } s rL � beaker_cachec C s^ t j|| t jdt �d�dd�t jdt jdd�t jdt jdd�t jd t jdd�|rT|n| jd
�S ) zuReturn a ``Table`` object suitable for storing cached values for the
namespace manager. Do not create the table.r% � T)Z primary_keyr: F)Znullabler; r+ )�schema)r
ZTableZColumn�StringZDateTimeZ
PickleTyperO )�metadataZ
table_nameZ schema_namer r r �make_cache_table� s rR )rM N)Zbeaker._compatr Zloggingr Zbeaker.containerr r Zbeaker.exceptionsr r Zbeaker.synchronizationr r Z beaker.utilr
r Z getLoggerrH r4 r
r rL rR r r r r �<module> s
k