|
Server : Apache System : Linux cvar2.toservers.com 3.10.0-962.3.2.lve1.5.73.el7.x86_64 #1 SMP Wed Aug 24 21:31:23 UTC 2022 x86_64 User : njnconst ( 1116) PHP Version : 8.4.18 Disable Function : NONE Directory : /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/ |
Upload File : |
�
���\c @ s� d Z d d l Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d
l m
Z
d d l m Z d d l m
Z
d
d l m Z d
d l m Z d
d l m Z d
d l m Z d
d l m Z y d d l m Z Wn e k
r+d Z n Xd e j f d � � YZ d e f d � � YZ d e
f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e
f d � � YZ! d! e f d" � � YZ" e" Z# d S(# s
.. dialect:: postgresql+pg8000
:name: pg8000
:dbapi: pg8000
:connectstring: postgresql+pg8000://user:password@host:port/dbname[?key=value&key=value...]
:url: https://pythonhosted.org/pg8000/
.. _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:`.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`
i����Ni ( t _DECIMAL_TYPES( t _FLOAT_TYPES( t
_INT_TYPES( t
PGCompiler( t PGDialect( t PGExecutionContext( t PGIdentifierPreparer( t UUID( t JSONi ( t exc( t
processors( t types( t util( t quoted_namet
_PGNumericc B s e Z d � Z RS( c C s� | j r] | t k r+ t j t j | j � S| t k sC | t k rG d St
j d | � � nB | t k rm d S| t k s� | t k r� t j St
j d | � � d S( Ns Unknown PG numeric type: %d(
t asdecimalR R
t to_decimal_processor_factoryt decimalt Decimalt _effective_decimal_return_scaleR R t NoneR t InvalidRequestErrort to_float( t selft dialectt coltype( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt result_processor[ s ( t __name__t
__module__R ( ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR Z s t _PGNumericNoBindc B s e Z d � Z RS( c C s d S( N( R ( R R ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt bind_processoru s ( R R R ( ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR t s t _PGJSONc B s e Z d � Z RS( c C s0 | j d k r d St t | � j | | � Sd S( Ni i
( i i
i ( t _dbapi_versionR t superR R ( R R R ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR z s ( R R R ( ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR y s t _PGUUIDc B s e Z d � Z d � Z RS( c C s | j s d � } | Sd S( Nc S s | d k r t | � } n | S( N( R t _python_UUID( t value( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt process� s ( t as_uuid( R R R% ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR � s c C s | j s d � } | Sd S( Nc S s | d k r t | � } n | S( N( R t str( R$ ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR% � s ( R& ( R R R R% ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR � s ( R R R R ( ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR" � s
t PGExecutionContext_pg8000c B s e Z RS( ( R R ( ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR( � s t PGCompiler_pg8000c B s e Z d � Z d � Z RS( c K s* | j | j | � d | j | j | � S( Ns %% ( R% t leftt right( R t binaryt operatort kw( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt visit_mod_binary� s c C s, d | k r t j d � n | j d d � S( Ns %%s^ The SQLAlchemy postgresql dialect now automatically escapes '%' in text() expressions to '%%'.t %( R t warnt replace( R t text( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt post_process_text� s
( R R R/ R4 ( ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR) � s t PGIdentifierPreparer_pg8000c B s e Z d � Z RS( c C s( | j | j | j � } | j d d � S( NR0 s %%( R2 t escape_quotet escape_to_quote( R R$ ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt _escape_identifier� s ( R R R8 ( ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR5 � s t PGDialect_pg8000c B s e Z d Z e Z e Z d Z e Z e Z e
Z e Z
d Z e j e j i e e j 6e e j 6e e 6e e j 6e e 6� Z d d � Z d � Z e j d � � Z e! d � � Z" d � Z# d � Z$ d � Z% d
� Z& d � Z' d � Z( e e) d
� Z* e e) d � Z+ d � Z, d � Z- RS( t pg8000t formatt use_encodingc K s t j | | � | | _ d S( N( R t __init__t client_encoding( R R> t kwargs( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR= � s c C s, | j d k | _ t t | � j | � d S( Ni i i ( i i i ( R t supports_sane_multi_rowcountR! R9 t
initialize( R t
connection( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyRA � s c C sX | j rP t | j d � rP t g t j d | j j � D] } t | � ^ q7 � Sd Sd S( Nt __version__s (\d+)(?:[-\.]?|$)ic ( ic ic ic ( t dbapit hasattrt tuplet ret findallRC t int( R t x( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR � s )c C s
t d � S( NR: ( t
__import__( t cls( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyRD � s c C sO | j d d � } d | k r5 t | d � | d <n | j | j � g | f S( Nt usernamet usert port( t translate_connect_argsRI t updatet query( R t urlt opts( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt create_connect_args� s
c C s d t | � k S( Ns connection is closed( R' ( R t eRB t cursor( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt
is_disconnect� s c C s� | j d d � } t | d � r- | j } n | d k rE t | _ nz | | j k r� t | _ | j � } | j d | � | j d � | j � n+ t
j d | | j d j
| j � f � � d S( Nt _t RB t
AUTOCOMMITs= SET SESSION CHARACTERISTICS AS TRANSACTION ISOLATION LEVEL %st COMMITsZ Invalid value '%s' for isolation_level. Valid isolation levels for %s are %s or AUTOCOMMITs , ( R2 RE RB t Truet
autocommitt _isolation_lookupt FalseRW t executet closeR t
ArgumentErrort namet join( R RB t levelRW ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt set_isolation_level� s
c C sW t | d � r | j } n | j � } | j d | d � | j d � | j � d S( NRB s SET CLIENT_ENCODING TO 't 'R\ ( RE RB RW Ra Rb ( R RB R> RW ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt set_client_encoding s
c C s | j j d | d f � d S( Ni t ( RB t tpc_begin( R RB t xid( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt do_begin_twophase s c C s | j j � d S( N( RB t tpc_prepare( R RB Rl ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt do_prepare_twophase s c C s | j j d | d f � d S( Ni Rj ( RB t tpc_rollback( R RB Rl t is_preparedt recover( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt do_rollback_twophase s c C s | j j d | d f � d S( Ni Rj ( RB t
tpc_commit( R RB Rl Rq Rr ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt do_commit_twophase s c C s$ g | j j � D] } | d ^ q S( Ni ( RB t tpc_recover( R RB t row( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt do_recover_twophase# s c s� g � d � } � j | � � j d k rJ � f d � } � j | � n � j d k rx � f d � } � j | � n t � � d k r� � f d � } | Sd Sd S( Nc S s | j t j | j t <d S( N( t py_typesR t text_typeR
( t conn( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt
on_connect) s c s � j | � j � d S( N( Ri R> ( R{ ( R ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR| 0 s c s � j | � j � d S( N( Rg t isolation_level( R{ ( R ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR| 7 s i c s x � D] } | | � q Wd S( N( ( R{ t fn( t fns( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR| > s
( t appendR> R R} t len( R R| ( ( R R sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR| & s
N(. R R t driverR] t supports_unicode_statementst supports_unicode_bindst default_paramstyleR@ R( t execution_ctx_clsR) t statement_compilerR5 t preparert description_encodingR t update_copyR t colspecsR t sqltypest NumericR t FloatR R R" R R R= RA t memoized_propertyR t classmethodRD RU RX Rg Ri Rm Ro R` Rs Ru Rx R| ( ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR9 � s>
($ t __doc__R RG t baseR R R R R R R R t jsonR Rj R R
R R� R t sql.elementsR
t uuidR# t ImportErrorR R� R R R R" R( R) R5 R9 R ( ( ( sK /usr/lib64/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt <module>@ s:
�