Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/sqlalchemy/dialects/postgresql/__pycache__/pygresql.cpython-39.pyc
Ðазад
a _�h� � @ s\ d Z ddlZddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lm Z dd lm Z dd l m Z dd l mZ dd l mZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ ddlmZ G dd� de�ZG dd� de �ZG dd� de�ZG dd� de�Z G d d � d e �Z G d d � d e�Z G d d!� d!e �Z G d"d#� d#e�Z e Z!dS )$a� .. dialect:: postgresql+pygresql :name: pygresql :dbapi: pgdb :connectstring: postgresql+pygresql://user:password@host:port/dbname[?key=value&key=value...] :url: http://www.pygresql.org/ .. note:: The pygresql dialect is **not tested as part of SQLAlchemy's continuous integration** and may have unresolved issues. The recommended PostgreSQL dialect is psycopg2. � N� )�_DECIMAL_TYPES)� _FLOAT_TYPES)� _INT_TYPES)� PGCompiler)� PGDialect)�PGIdentifierPreparer)�UUID)�HSTORE)�JSON)�JSONB� )�exc)� processors)�util)�Null)�Numericc @ s e Zd Zdd� Zdd� ZdS )� _PGNumericc C s d S �N� )�self�dialectr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/sqlalchemy/dialects/postgresql/pygresql.py�bind_processor, s z_PGNumeric.bind_processorc C s� t |t�s|j}| jrR|tv r.t�tj| j �S |t v s>|t v rBd S t � d| ��n0|tv r^d S |t v sn|t v rttjS t � d| ��d S )NzUnknown PG numeric type: %d)� isinstance�int�oidZ asdecimalr r Z to_decimal_processor_factory�decimal�DecimalZ _effective_decimal_return_scaler r r ZInvalidRequestErrorZto_float�r r �coltyper r r �result_processor/ s& ���z_PGNumeric.result_processorN)�__name__� __module__� __qualname__r r! r r r r r + s r c s( e Zd Z� fdd�Z� fdd�Z� ZS )� _PGHStorec s. |j stt| ��|�S |jj� � fdd�}|S )Nc s t | t�r� | �S | S r )r �dict��value��hstorer r �processP s z)_PGHStore.bind_processor.<locals>.process)�has_native_hstore�superr% r �dbapiZHstore�r r r+ �� __class__r) r r K s z_PGHStore.bind_processorc s |j stt| ��||�S d S r )r, r- r% r! r r0 r r r! W s z_PGHStore.result_processor�r" r# r$ r r! � __classcell__r r r0 r r% J s r% c s( e Zd Z� fdd�Z� fdd�Z� ZS )�_PGJSONc s0 |j stt���|�S |jj� � �fdd�}|S )Nc sN | �j u rd } n t| t�s(| d u r,�jr,d S | d u sBt| ttf�rJ� | �S | S r �ZNULLr r Z none_as_nullr& �listr' ��jsonr r r r+ b s ��z'_PGJSON.bind_processor.<locals>.process)�has_native_jsonr- r4 r r. �Jsonr/ r0 r7 r r ] s z_PGJSON.bind_processorc s |j stt| ��||�S d S r )r9 r- r4 r! r r0 r r r! o s z_PGJSON.result_processorr2 r r r0 r r4 \ s r4 c s( e Zd Z� fdd�Z� fdd�Z� ZS )�_PGJSONBc s0 |j stt���|�S |jj� � �fdd�}|S )Nc sN | �j u rd } n t| t�s(| d u r,�jr,d S | d u sBt| ttf�rJ� | �S | S r r5 r' r7 r r r+ z s ��z(_PGJSONB.bind_processor.<locals>.process)r9 r- r; r r. r: r/ r0 r7 r r u s z_PGJSONB.bind_processorc s |j stt| ��||�S d S r )r9 r- r; r! r r0 r r r! � s z_PGJSONB.result_processorr2 r r r0 r r; t s r; c s( e Zd Z� fdd�Z� fdd�Z� ZS )�_PGUUIDc s. |j stt| ��|�S |jj� � fdd�}|S )Nc sP | d u r d S t | ttf�r8t| �dkr0� | d�S � | �S t | t�rL� | d�S | S )N� )�bytes)r )r �strr> �lenr r' ��uuidr r r+ � s z'_PGUUID.bind_processor.<locals>.process)�has_native_uuidr- r< r r. ZUuidr/ r0 rA r r � s z_PGUUID.bind_processorc s. |j stt| ��||�S | js*dd� }|S d S )Nc S s | d urt | �S d S r )r? r' r r r r+ � s z)_PGUUID.result_processor.<locals>.process)rC r- r< r! Zas_uuid)r r r r+ r0 r r r! � s z_PGUUID.result_processorr2 r r r0 r r< � s r< c @ s e Zd Zdd� Zdd� ZdS )� _PGCompilerc K s, | j |jfi |��d | j |jfi |�� S )Nz %% )r+ �left�right)r �binary�operator�kwr r r �visit_mod_binary� s ���z _PGCompiler.visit_mod_binaryc C s |� dd�S �N�%z%%)�replace)r �textr r r �post_process_text� s z _PGCompiler.post_process_textN)r" r# r$ rJ rO r r r r rD � s rD c @ s e Zd Zdd� ZdS )�_PGIdentifierPreparerc C s |� | j| j�}|� dd�S rK )rM Z escape_quoteZescape_to_quote)r r( r r r �_escape_identifier� s z(_PGIdentifierPreparer._escape_identifierN)r" r# r$ rQ r r r r rP � s rP c sj e Zd ZdZeZeZedd� �Z e � e j eeeeeeeeeeeei�Z � fdd�Zdd� Zdd � Z� Z S ) �PGDialect_pygresqlZpygresqlc C s dd l }|S )Nr )�pgdb)�clsrS r r r r. � s zPGDialect_pygresql.dbapic s� t t| �jf i |�� z4| jj}t�d|�}t|�d��t|�d��f}W n t t t fyf d}Y n0 || _ |dk r�d } }}|dkr�t �d� nd| _d| _d } }}|| _|| _|| _d S ) Nz (\d+)\.(\d+)r � )r r )� r FzAPyGreSQL is only fully supported by SQLAlchemy since version 5.0.T)r- rR �__init__r. �version�re�matchr �group�AttributeError� ValueError� TypeErrorZ dbapi_versionr �warnZsupports_unicode_statementsZsupports_unicode_bindsr, r9 rC )r �kwargsrX �mr, r9 rC r0 r r rW � s( � zPGDialect_pygresql.__init__c C sR |j dd�}d|v r>d|�dd��dd�d |�d�f |d< |�|j� g |fS ) N�user)�username�portz%s:%s�host� �:r r )Ztranslate_connect_args�get�rsplit�pop�update�query)r �url�optsr r r �create_connect_args� s � z&PGDialect_pygresql.create_connect_argsc C sf t || jj�rb|sdS z |j}W n ty2 Y n 0 |s<dS z|jW S ty` |jd u Y S 0 dS )NF)r r. �Error� connectionr\ �closedZ_cnx)r �erq �cursorr r r � is_disconnect� s z PGDialect_pygresql.is_disconnect) r" r# r$ ZdriverrD Zstatement_compilerrP �preparer� classmethodr. r Z update_copyr Zcolspecsr r r r% r: r4 r r r; r r< rW ro ru r3 r r r0 r rR � s$ �� rR )"�__doc__r rY �baser r r r r r r r* r r8 r r rf r r r Z sql.elementsr �typesr: r r r% r4 r; r< rD rP rR r r r r r �<module> s6 M
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0.01 |
proxy
|
phpinfo
|
ÐаÑтройка