U
|
¸ý°d;? ã @ sè d Z ddlZddlZddlmZ ddlmZ ddlmZ ddlm Z ddlm
|
Z
|
dd lm Z dd
|
lm Z dd lm Z dd lmZ dd lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z ddl m Z G dd de j Z!G dd d e j"Z#G d d d e#e j$Z%G d d d e#Z&G d!d" d"eZ'G d#d$ d$eZ(G d%d& d&e jj)Z*G d'd( d(e jj+Z,G d)d* d*e jj-Z.G d+d, d,eZ/G d-d. d.e
|
Z0G d/d0 d0e Z1G d1d2 d2e j2Z3G d3d4 d4e j4Z5G d5d6 d6e j6Z7G d7d8 d8e j8Z9G d9d: d:e j:Z;G d;d< d<e j<Z=G d=d> d>e j>Z?G d?d@ d@e j@ZAG dAdB dBeZBG dCdD dDeeZCe D¡ ZEG dEdF dFeZFG dGdH dHZGG dIdJ dJe ZHG dKdL dLeZIG dMdN dNe ZJeJZKdS )Oaó
|
.. dialect:: postgresql+pg8000
|
:name: pg8000
|
:dbapi: pg8000
|
:connectstring: postgresql+pg8000://user:password@host:port/dbname[?key=value&key=value...]
|
:url: https://pypi.org/project/pg8000/
|
|
.. versionchanged:: 1.4 The pg8000 dialect has been updated for version
|
1.16.6 and higher, and is again part of SQLAlchemy's continuous integration
|
with full feature support.
|
|
.. _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_ssl:
|
|
SSL Connections
|
---------------
|
|
pg8000 accepts a Python ``SSLContext`` object which may be specified using the
|
:paramref:`_sa.create_engine.connect_args` dictionary::
|
|
import ssl
|
ssl_context = ssl.create_default_context()
|
engine = sa.create_engine(
|
"postgresql+pg8000://scott:tiger@192.168.0.199/test",
|
connect_args={"ssl_context": ssl_context},
|
)
|
|
If the server uses an automatically-generated certificate that is self-signed
|
or does not match the host name (as seen from the client), it may also be
|
necessary to disable hostname checking::
|
|
import ssl
|
ssl_context = ssl.create_default_context()
|
ssl_context.check_hostname = False
|
ssl_context.verify_mode = ssl.CERT_NONE
|
engine = sa.create_engine(
|
"postgresql+pg8000://scott:tiger@192.168.0.199/test",
|
connect_args={"ssl_context": ssl_context},
|
)
|
|
.. _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``
|
|
.. seealso::
|
|
:ref:`postgresql_isolation_level`
|
|
:ref:`psycopg2_isolation_level`
|
|
|
é Né )ÚARRAY)Ú_DECIMAL_TYPES)Ú _FLOAT_TYPES)Ú
|
_INT_TYPES)ÚENUM©ÚINTERVAL)Ú
|
PGCompiler)Ú PGDialect)ÚPGExecutionContext)ÚPGIdentifierPreparer)ÚJSON)ÚJSONB)Ú JSONPathType)Ú _SpaceVector)Ú OIDVECTORé )Úexc)Úutil)Ú
|
processors)Úsqltypes)Ú quoted_namec @ s e Zd ZdZdS )Ú _PGStringTN©Ú__name__Ú
|
__module__Ú __qualname__Úrender_bind_cast© r r ú\d:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/dialects/postgresql/pg8000.pyr w s r c @ s e Zd ZdZdd ZdS )Ú
|
_PGNumericTc C sv | j rB|tkr t tj| j¡S |tks.|tkr2d S t
|
d| ¡n0|tkrNd S |tks^|tkrdtj 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ÚdialectZcoltyper r r Úresult_processor~ s$ ÿÿÿz_PGNumeric.result_processorN©r r r r r' r r r r r! { s r! c @ s e Zd ZdZdZdS )Ú_PGFloatÚfloatTN©r r r Z__visit_name__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_processor s z _PGNumericNoBind.bind_processorN)r r r r. r r r r r, s r, c @ s e Zd ZdZdd ZdS )Ú_PGJSONTc C s d S r- r r$ r r r r' ¤ s z_PGJSON.result_processorNr( r r r r r/ ¡ s r/ c @ s e Zd ZdZdd ZdS )Ú_PGJSONBTc C s d S r- r r$ r r r r' « s z_PGJSONB.result_processorNr( r r r r r0 ¨ s r0 c @ s e Zd Zdd ZdS )Ú_PGJSONIndexTypec C s t dd S )Nzshould not be here)ÚNotImplementedError©r% Údbapir r r Úget_dbapi_type° s z _PGJSONIndexType.get_dbapi_typeN©r r r r5 r r r r r1 ¯ s r1 c @ s e Zd ZdZdZdS )Ú_PGJSONIntIndexTypeZjson_int_indexTNr+ r r r r r7 ´ s r7 c @ s e Zd ZdZdZdS )Ú_PGJSONStrIndexTypeZjson_str_indexTNr+ r r r r r8 º s r8 c @ s e Zd ZdS )Ú_PGJSONPathTypeN©r r r r r r r r9 À s r9 c @ s e Zd Zdd ZdS )Ú_PGEnumc C s |j S r- )ÚUNKNOWNr3 r r r r5 Ç s z_PGEnum.get_dbapi_typeNr6 r r r r r; Æ s r; c @ s$ e Zd ZdZdd Zedd ZdS )Ú _PGIntervalTc C s |j S r- r r3 r r r r5 Î s z_PGInterval.get_dbapi_typec K s t |jdS )N)Z precision)r= Zsecond_precision)ÚclsÚintervalÚkwr r r Úadapt_emulated_to_nativeÑ s z$_PGInterval.adapt_emulated_to_nativeN)r r r r r5 Ú classmethodrA r r r r r= Ë s r= c @ s e Zd ZdZdS )Ú _PGTimeStampTNr r r r r rC Ö s rC c @ s e Zd ZdZdS )Ú_PGDateTNr r r r r rD Ú s rD c @ s e Zd ZdZdS )Ú_PGTimeTNr r r r r rE Þ s rE c @ s e Zd ZdZdS )Ú
|
_PGIntegerTNr r r r r rF â s rF c @ s e Zd ZdZdS )Ú_PGSmallIntegerTNr r r r r rG æ s rG c @ s e Zd ZdS )Ú _PGNullTypeNr: r r r r rH ê s rH c @ s e Zd ZdZdS )Ú _PGBigIntegerTNr r r r r rI î s rI c @ s e Zd ZdZdS )Ú
|
_PGBooleanTNr r r r r rJ ò s rJ c @ s e Zd ZdZdS )Ú_PGARRAYTNr r r r r rK ö s rK c @ s e Zd ZdS )Ú _PGOIDVECTORNr: r r r r rL ú s rL c @ s e Zd Zdd Zdd ZdS )ÚPGExecutionContext_pg8000c C s: dt t| dd
t t dd
f }t| j ¡ |S )Nzc_%s_%sé )ÚhexÚidÚ_server_side_idÚServerSideCursorZ_dbapi_connectionÚcursor)r% Úidentr r r Úcreate_server_side_cursor s *z3PGExecutionContext_pg8000.create_server_side_cursorc C s | j s
|
d S d S r- )Zcompiled©r% r r r Úpre_exec s z"PGExecutionContext_pg8000.pre_execN)r r r rU rW r r r r rM s rM c @ s e Zd ZdZdd Zedd Zedd Zedd Zd d d Z dd Z
|
dd Z d ddZ dd Z dd Zdd Zd ddZd S ) rR Tc C s || _ || _d S r- )rT rS )r% rS rT r r r Ú__init__ s zServerSideCursor.__init__c C s | j jS r- )rS Ú
|
connectionrV r r r rY s zServerSideCursor.connectionc C s | j jS r- )rS ÚrowcountrV r r r rZ s zServerSideCursor.rowcountc C s | j jS r- )rS Ú descriptionrV r r r r[ s z ServerSideCursor.descriptionr Nc C s( d| j d | }| jj|||d | S )NzDECLARE z NO SCROLL CURSOR FOR )Ústream)rT rS Úexecute)r% Ú operationÚargsr\ Úopr r r r] s zServerSideCursor.executec C s | j ||¡ | S r- )rS Ú executemany)r% r^ Z
|
param_setsr r r ra # s z ServerSideCursor.executemanyc C s | j d| j ¡ | j ¡ S )NzFETCH FORWARD 1 FROM )rS r] rT ÚfetchonerV r r r rb ' s zServerSideCursor.fetchonec C s@ |d kr| ¡ S | j dtt| d | j ¡ | j ¡ S d S )NzFETCH FORWARD z FROM )ÚfetchallrS r] ÚstrÚintrT )r% Únumr r r Ú fetchmany+ s ÿzServerSideCursor.fetchmanyc C s | j d| j ¡ | j ¡ S )NzFETCH FORWARD ALL FROM )rS r] rT rc rV r r r rc 4 s zServerSideCursor.fetchallc C s | j d| j ¡ | j ¡ d S )NzCLOSE )rS r] rT ÚcloserV r r r rh 8 s zServerSideCursor.closec G s | j j| d S r- )rS Ú setinputsizes)r% Úsizesr r r ri < s z ServerSideCursor.setinputsizesc C s d S r- r )r% ÚsizeÚcolumnr r r Ú setoutputsize? s z ServerSideCursor.setoutputsize)r N)N)N)r r r Ú server_siderX ÚpropertyrY rZ r[ r] ra rb rg rc rh ri rm r r r r rR s
|
|
|
|
|
rR c @ s e Zd Zdd ZdS )ÚPGCompiler_pg8000c K s$ | j |jf|d | j |jf| S )Nz %% )ÚprocessÚleftÚright)r% ÚbinaryÚoperatorr@ r r r Úvisit_mod_binaryD s ÿþÿz"PGCompiler_pg8000.visit_mod_binaryN)r r r rv r r r r rp C s rp c @ s e Zd Zdd ZdS )ÚPGIdentifierPreparer_pg8000c O s t j| f|| d| _d S )NF)r rX Z_double_percents)r% r_ Úkwargsr r r rX M s z$PGIdentifierPreparer_pg8000.__init__N)r r r rX r r r r rw L s rw c 1 @ s e Zd ZdZdZdZdZdZdZe Z
|
e Z e ZdZdZdZe ejejeejeeje ej e ej e ej!e"e#e$ej j%e&ej j'e(ej j)e*ej j+e,ej-e.e/e.ej0e1ej0e1ej2e3ej4e5ej6e7ej8e9ej:e;ej<e=ej>e?e@eAi¡Zd,ddZBejCdd ZDeEd d
|
ZFd d ZGd d ZHdd ZIdd ZJdd ZKdd ZLdd ZMdd ZNdd ZOd d ZPd d ZQd-d"d#ZRd.d$d%ZSd&d' ZTd(d) ZUejCd*d+ ZVdS )/ÚPGDialect_pg8000Úpg8000TÚformatNc K s* t j| f| || _| jdk r&tdd S )N)r é é z$pg8000 1.16.6 or greater is required)r rX Úclient_encodingÚ_dbapi_versionr2 )r% r~ rx r r r rX
s
|
zPGDialect_pg8000.__init__c C s8 | j r0t| j dr0tdd t d| j j¡D S dS d S )NÚ __version__c S s g | ] }t |qS r )re )Ú.0Úxr r r Ú
|
<listcomp> s ÿz3PGDialect_pg8000._dbapi_version.<locals>.<listcomp>z(\d+)(?:[-\.]?|$))éc r r )r4 ÚhasattrÚtupleÚreÚfindallr rV r r r r s ÿþÿ z PGDialect_pg8000._dbapi_versionc C s t dS )Nrz )Ú
|
__import__)r> r r r Ú import_dbapi s z PGDialect_pg8000.import_dbapic C s8 |j dd}d|kr$t|d |d< | |j¡ g |fS )NÚuser)ÚusernameÚport)Ztranslate_connect_argsre ÚupdateÚquery)r% ÚurlÚoptsr r r Úcreate_connect_args s
|
z$PGDialect_pg8000.create_connect_argsc C s* t || jjr dt|kr dS dt|kS )Nz network errorTzconnection is closed)Ú
|
isinstancer4 ZInterfaceErrorrd )r% ÚerY rS r r r Ú is_disconnect¥ s
|
ÿz PGDialect_pg8000.is_disconnectc C s dS )N)Ú
|
AUTOCOMMITzREAD COMMITTEDzREAD UNCOMMITTEDzREPEATABLE READZ SERIALIZABLEr )r% Údbapi_connectionr r r Úget_isolation_level_values¯ s z+PGDialect_pg8000.get_isolation_level_valuesc C sP | dd¡}|dkr d|_n0d|_| ¡ }| d| ¡ | d¡ | ¡ d S )NÚ_ú r TFz;SET SESSION CHARACTERISTICS AS TRANSACTION ISOLATION LEVEL ÚCOMMIT)ÚreplaceZ
|
autocommitrS r] rh )r% r ÚlevelrS r r r Úset_isolation_level¸ s ÿ
|
z$PGDialect_pg8000.set_isolation_levelc C s< | ¡ }z$| d|rdnd ¡ | d¡ W 5 | ¡ X d S )Nú-SET SESSION CHARACTERISTICS AS TRANSACTION %sz READ ONLYz
|
READ WRITEr ©rS rh r] ©r% rY ÚvaluerS r r r Ú set_readonlyÇ s
|
ÿÿz PGDialect_pg8000.set_readonlyc C s6 | ¡ }z| d¡ | ¡ d }W 5 | ¡ X |dkS )Nzshow transaction_read_onlyr Úon©rS rh r] rb ©r% rY rS Úvalr r r Ú get_readonlyÒ s
|
|
z PGDialect_pg8000.get_readonlyc C s< | ¡ }z$| d|rdnd ¡ | d¡ W 5 | ¡ X d S )Nr Z
|
DEFERRABLEzNOT DEFERRABLEr r r¡ r r r Úset_deferrableÜ s
|
ÿÿz PGDialect_pg8000.set_deferrablec C s6 | ¡ }z| d¡ | ¡ d }W 5 | ¡ X |dkS )Nzshow transaction_deferrabler r¤ r¥ r¦ r r r Úget_deferrableç s
|
|
z PGDialect_pg8000.get_deferrablec C s8 | ¡ }| d| dd¡ d¡ | d¡ | ¡ d S )NzSET CLIENT_ENCODING TO 'ú'z''r )rS r] r rh )r% r r~ rS r r r Ú_set_client_encodingñ s
|
ÿÿ
|
z%PGDialect_pg8000._set_client_encodingc C s |j d|df¡ d S ©Nr Ú )rY Z tpc_begin©r% rY Úxidr r r Údo_begin_twophaseû s z"PGDialect_pg8000.do_begin_twophasec C s |j ¡ d S r- )rY Z tpc_preparer¯ r r r Údo_prepare_twophaseþ s z$PGDialect_pg8000.do_prepare_twophaseFc C s |j d|df¡ d S r )rY Z tpc_rollback©r% rY r° Z is_preparedZrecoverr r r Údo_rollback_twophase s z%PGDialect_pg8000.do_rollback_twophasec C s |j d|df¡ d S r )rY Z
|
tpc_commitr³ 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 )r Úrowr r r r s z8PGDialect_pg8000.do_recover_twophase.<locals>.<listcomp>)rY Z tpc_recover)r% rY r r r Údo_recover_twophase s z$PGDialect_pg8000.do_recover_twophasec sv g dd } |¡ jd k r6fdd} |¡ jrRfdd} |¡ t dkrn fdd}|S d S d S )Nc S s | j t | j t< d S r- )Zpy_typesrd r ©Úconnr r r Ú
|
on_connect s z/PGDialect_pg8000.on_connect.<locals>.on_connectc s | j¡ d S r- )r¬ r~ r¸ rV r r rº s c s | d j¡ | d j¡ d S )Nér iÚ )Zregister_in_adapterÚ_json_deserializerr¸ rV r r rº s r c s D ] }|| qd S r- r )r¹ Úfn)Úfnsr r rº * s )Úappendr~ r¼ Úlen)r% rº r )r¾ r% r rº s
|
|
|
|
zPGDialect_pg8000.on_connectc C s dS )Nú;r rV r r r Ú _dialect_specific_select_one2 s z-PGDialect_pg8000._dialect_specific_select_one)N)TF)TF)Wr r r ZdriverZsupports_statement_cacheZsupports_unicode_statementsZsupports_unicode_bindsZdefault_paramstyleZ supports_sane_multi_rowcountrM Zexecution_ctx_clsrp Zstatement_compilerrw ÚpreparerZ supports_server_side_cursorsr Zdescription_encodingr Z update_copyr Zcolspecsr ÚStringr ÚNumericr, ÚFloatr) r r/ ÚBooleanrJ ÚNullTyperH r r0 r r9 Ú JSONIndexTyper1 ÚJSONIntIndexTyper7 ÚJSONStrIndexTyper8 ZIntervalr= r ÚDateTimerC ÚDaterD ÚTimerE ÚIntegerrF Ú SmallIntegerrG Ú
|
BigIntegerrI ÚEnumr; r rK r rL rX Zmemoized_propertyr rB r r r r r r£ r¨ r© rª r¬ r± r² r´ rµ r· rº r r r r r ry R s° éþ
|
|
|
|
|
|
|
ÿ
|
ÿ
|
$ry )LÚ__doc__r" r Úarrayr ZPGARRAYÚbaser r r r r r
|
r r r Újsonr r r Z
|
pg_catalogr r r® r r Zenginer Zsqlr Z sql.elementsr rÄ r rÅ r! rÆ r) r, r/ r0 rÉ r1 rÊ r7 rË r8 r9 r; r= rÌ rC rÍ rD rÎ rE rÏ rF rÐ rG rÈ rH rÑ rI rÇ rJ rK rL ÚcounterrQ rM rR rp rw ry r& r r r r Ú<module> sh U
|
8 f
|
