Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/sqlalchemy/dialects/postgresql/__pycache__/pg8000.cpython-39.pyc
Ðазад
a _�h�% � @ sn d Z ddlZddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lm Z dd lm Z dd lm Z dd l m Z d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ zdd lm Z W n ey� dZY n0 G dd� dej�ZG dd� de�ZG dd� de �Z G dd� de �Z G dd � 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+pg8000 :name: pg8000 :dbapi: pg8000 :connectstring: postgresql+pg8000://user:password@host:port/dbname[?key=value&key=value...] :url: https://pythonhosted.org/pg8000/ .. note:: The pg8000 dialect is **not tested as part of SQLAlchemy's continuous integration** and may have unresolved issues. The recommended PostgreSQL dialect is psycopg2. .. _pg8000_unicode: Unicode ------- pg8000 will encode / decode string values between it and the server using the PostgreSQL ``client_encoding`` parameter; by default this is the value in the ``postgresql.conf`` file, which often defaults to ``SQL_ASCII``. Typically, this can be changed to ``utf-8``, as a more useful default:: #client_encoding = sql_ascii # actually, defaults to database # encoding client_encoding = utf8 The ``client_encoding`` can be overridden for a session by executing the SQL: SET CLIENT_ENCODING TO 'utf8'; SQLAlchemy will execute this SQL on all new connections based on the value passed to :func:`_sa.create_engine` using the ``client_encoding`` parameter:: engine = create_engine( "postgresql+pg8000://user:pass@host/dbname", client_encoding='utf8') .. _pg8000_isolation_level: pg8000 Transaction Isolation Level ------------------------------------- The pg8000 dialect offers the same isolation level settings as that of the :ref:`psycopg2 <psycopg2_isolation_level>` dialect: * ``READ COMMITTED`` * ``READ UNCOMMITTED`` * ``REPEATABLE READ`` * ``SERIALIZABLE`` * ``AUTOCOMMIT`` .. versionadded:: 0.9.5 support for AUTOCOMMIT isolation level when using pg8000. .. seealso:: :ref:`postgresql_isolation_level` :ref:`psycopg2_isolation_level` � N� )�_DECIMAL_TYPES)� _FLOAT_TYPES)� _INT_TYPES)� PGCompiler)� PGDialect)�PGExecutionContext)�PGIdentifierPreparer)�UUID)�JSON� )�exc)� processors)�types)�util)� quoted_namec @ s e Zd Zdd� ZdS )� _PGNumericc C sv | j rB|tv r t�tj| j�S |tv s.|tv r2d S t � d| ��n0|tv rNd S |tv s^|tv rdtj S t � d| ��d S )NzUnknown PG numeric type: %d) Z asdecimalr r Z to_decimal_processor_factory�decimal�DecimalZ _effective_decimal_return_scaler r r ZInvalidRequestErrorZto_float��self�dialect�coltype� 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/pg8000.py�result_processor` s" ���z_PGNumeric.result_processorN)�__name__� __module__� __qualname__r r r r r r _ s r c @ s e Zd Zdd� ZdS )�_PGNumericNoBindc C s d S �Nr )r r r r r �bind_processorz s z _PGNumericNoBind.bind_processorN)r r r r! r r r r r y s r c s e Zd Z� fdd�Z� ZS )�_PGJSONc s$ |j dkrd S tt| ��||�S d S )N)r � r )�_dbapi_version�superr" r r �� __class__r r r s z_PGJSON.result_processor)r r r r � __classcell__r r r& r r" ~ s r" c @ s e Zd Zdd� Zdd� ZdS )�_PGUUIDc C s | j sdd� }|S d S )Nc S s | d urt | �} | S r )� _python_UUID��valuer r r �process� s z'_PGUUID.bind_processor.<locals>.process�Zas_uuid)r r r- r r r r! � s z_PGUUID.bind_processorc C s | j sdd� }|S d S )Nc S s | d urt | �} | S r ��strr+ r r r r- � s z)_PGUUID.result_processor.<locals>.processr. )r r r r- r r r r � s z_PGUUID.result_processorN)r r r r! r r r r r r) � s r) c @ s e Zd ZdS )�PGExecutionContext_pg8000N)r r r r r r r r1 � s r1 c @ s e Zd Zdd� Zdd� ZdS )�PGCompiler_pg8000c K s, | j |jfi |��d | j |jfi |�� S )Nz %% )r- �left�right)r �binary�operator�kwr r r �visit_mod_binary� s ���z"PGCompiler_pg8000.visit_mod_binaryc C s d|v rt �d� |�dd�S )N�%%z^The SQLAlchemy postgresql dialect now automatically escapes '%' in text() expressions to '%%'.�%)r �warn�replace)r �textr r r �post_process_text� s �z#PGCompiler_pg8000.post_process_textN)r r r r8 r> r r r r r2 � s r2 c @ s e Zd Zdd� ZdS )�PGIdentifierPreparer_pg8000c C s |� | j| j�}|� dd�S )Nr: r9 )r< Z escape_quoteZescape_to_quote)r r, r r r �_escape_identifier� s z.PGIdentifierPreparer_pg8000._escape_identifierN)r r r r@ r r r r r? � s r? c s� e Zd ZdZdZdZdZdZeZ e Z e Z dZe�ejejeejeeeejeeei�Zd#dd�Z � fdd �Z ej d d � �Z e d d � �Z!dd� Z"dd� Z#dd� Z$dd� Z%dd� Z&dd� Z'd$dd �Z(d%d d �Z)d d � Z*d!d"� Z+� Z,S )&�PGDialect_pg8000�pg8000T�formatZ use_encodingNc K s t j| fi |�� || _d S r )r �__init__�client_encoding)r rE �kwargsr r r rD � s zPGDialect_pg8000.__init__c s | j dk| _tt| ��|� d S )N)r � � )r$ � supports_sane_multi_rowcountr% rA � initialize�r � connectionr& r r rJ � s zPGDialect_pg8000.initializec C s8 | j r0t| j d�r0tdd� t�d| j j�D ��S dS d S )N� __version__c S s g | ] }t |��qS r )�int)�.0�xr r r � <listcomp>� s �z3PGDialect_pg8000._dbapi_version.<locals>.<listcomp>z(\d+)(?:[-\.]?|$))�c rR rR )�dbapi�hasattr�tuple�re�findallrM �r r r r r$ � s ��� z PGDialect_pg8000._dbapi_versionc C s t d�S )NrB )� __import__)�clsr r r rS � s zPGDialect_pg8000.dbapic C s8 |j dd�}d|v r$t|d �|d< |�|j� g |fS )N�user)�username�port)Ztranslate_connect_argsrN �update�query)r �url�optsr r r �create_connect_args� s z$PGDialect_pg8000.create_connect_argsc C s dt |�v S )Nzconnection is closedr/ )r �erL �cursorr r r � is_disconnect� s z PGDialect_pg8000.is_disconnectc C s� |� dd�}t|d�r |j}|dkr,d|_nX|| jv rfd|_|�� }|�d| � |�d� |�� n t� d || j d � | j�f ��d S ) N�_� rL Z AUTOCOMMITTFz=SET SESSION CHARACTERISTICS AS TRANSACTION ISOLATION LEVEL %s�COMMITzZInvalid value '%s' for isolation_level. Valid isolation levels for %s are %s or AUTOCOMMITz, ) r< rT rL Z autocommitZ_isolation_lookuprd �execute�closer � ArgumentError�name�join)r rL �levelrd r r r �set_isolation_level� s( �� ��z$PGDialect_pg8000.set_isolation_levelc C s@ t |d�r|j}|�� }|�d| d � |�d� |�� d S )NrL zSET CLIENT_ENCODING TO '�'rh )rT rL rd ri rj )r rL rE rd r r r �set_client_encoding s z$PGDialect_pg8000.set_client_encodingc C s |j �d|df� d S �Nr � )rL Z tpc_begin�r rL �xidr r r �do_begin_twophase s z"PGDialect_pg8000.do_begin_twophasec C s |j �� d S r )rL Z tpc_preparert r r r �do_prepare_twophase s z$PGDialect_pg8000.do_prepare_twophaseFc C s |j �d|df� d S rr )rL Z tpc_rollback�r rL ru Z is_preparedZrecoverr r r �do_rollback_twophase s z%PGDialect_pg8000.do_rollback_twophasec C s |j �d|df� d S rr )rL Z tpc_commitrx r r r �do_commit_twophase# s z#PGDialect_pg8000.do_commit_twophasec C s dd� |j �� D �S )Nc S s g | ] }|d �qS )r r )rO �rowr r r rQ ) � z8PGDialect_pg8000.do_recover_twophase.<locals>.<listcomp>)rL Z tpc_recoverrK r r r �do_recover_twophase( s z$PGDialect_pg8000.do_recover_twophasec sz g � dd� }� � |� �jd ur6�fdd�}� � |� �jd urV�fdd�}� � |� t� �dkrr� fdd�}|S d S d S )Nc S s | j tj | j t< d S r )Zpy_typesr � text_typer ��connr r r � on_connect. s z/PGDialect_pg8000.on_connect.<locals>.on_connectc s � � | � j� d S r )rq rE r rX r r r� 5 s c s � � | � j� d S r )ro �isolation_levelr rX r r r� < s r c s � D ] }|| � qd S r r )r� �fn)�fnsr r r� C s )�appendrE r� �len)r r� r )r� r r r� + s zPGDialect_pg8000.on_connect)N)TF)TF)-r r r ZdriverZsupports_unicode_statementsZsupports_unicode_bindsZdefault_paramstylerI r1 Zexecution_ctx_clsr2 Zstatement_compilerr? �preparerZdescription_encodingr Z update_copyr Zcolspecs�sqltypes�Numericr �Floatr r r" r r) rD rJ Zmemoized_propertyr$ � classmethodrS rb re ro rq rv rw ry rz r} r� r( r r r& r rA � sH �� � � rA )#�__doc__r rV �baser r r r r r r r �jsonr rs r r r r� r Z sql.elementsr �uuidr* � ImportErrorr� r r r" r) r1 r2 r? rA r r r r r �<module> s< ?
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка