U
|
¸ý°d6Y ã @ s d Z ddlmZ ddlZddlZddlmZ ddlmZ ddlm Z ddl
|
m Z dd l
|
m Z dd
|
l mZ dd l mZ dd l mZ dd l mZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z ddl m Z er
|
ddlm Z e d¡Z!G dd dej"Z#G d d d eZ$G d d d eZ%G d d! d!eZ&G d"d# d#ejj'Z(G d$d% d%ejj)Z*G d&d' d'eZ+G d(d) d)eZ,G d*d+ d+ej-Z.G d,d- d-ej/Z0G d.d/ d/ej1Z2G d0d1 d1ej3Z4G d2d3 d3ej5Z6G d4d5 d5ej7Z8G d6d7 d7ej9Z:G d8d9 d9ej;Z<G d:d; d;e j=Z>G d<d= d=e j?Z@G d>d? d?e ZAG d@dA dAeZBG dBdC dCeZCdDdE ZDG dFdG dGe ZEG dHdI dIZFG dJdK dKeFZGG dLdM dMeZHG dNdO dOeHZIG dPdQ dQZJG dRdS dSeEZKeEZLeKZMdS )Tad
|
.. dialect:: postgresql+psycopg
|
:name: psycopg (a.k.a. psycopg 3)
|
:dbapi: psycopg
|
:connectstring: postgresql+psycopg://user:password@host:port/dbname[?key=value&key=value...]
|
:url: https://pypi.org/project/psycopg/
|
|
``psycopg`` is the package and module name for version 3 of the ``psycopg``
|
database driver, formerly known as ``psycopg2``. This driver is different
|
enough from its ``psycopg2`` predecessor that SQLAlchemy supports it
|
via a totally separate dialect; support for ``psycopg2`` is expected to remain
|
for as long as that package continues to function for modern Python versions,
|
and also remains the default dialect for the ``postgresql://`` dialect
|
series.
|
|
The SQLAlchemy ``psycopg`` dialect provides both a sync and an async
|
implementation under the same dialect name. The proper version is
|
selected depending on how the engine is created:
|
|
* calling :func:`_sa.create_engine` with ``postgresql+psycopg://...`` will
|
automatically select the sync version, e.g.::
|
|
from sqlalchemy import create_engine
|
sync_engine = create_engine("postgresql+psycopg://scott:tiger@localhost/test")
|
|
* calling :func:`_asyncio.create_async_engine` with
|
``postgresql+psycopg://...`` will automatically select the async version,
|
e.g.::
|
|
from sqlalchemy.ext.asyncio import create_async_engine
|
asyncio_engine = create_async_engine("postgresql+psycopg://scott:tiger@localhost/test")
|
|
The asyncio version of the dialect may also be specified explicitly using the
|
``psycopg_async`` suffix, as::
|
|
from sqlalchemy.ext.asyncio import create_async_engine
|
asyncio_engine = create_async_engine("postgresql+psycopg_async://scott:tiger@localhost/test")
|
|
The ``psycopg`` dialect has the same API features as that of ``psycopg2``,
|
with the exception of the "fast executemany" helpers. The "fast executemany"
|
helpers are expected to be generalized and ported to ``psycopg`` before the final
|
release of SQLAlchemy 2.0, however.
|
|
|
.. seealso::
|
|
:ref:`postgresql_psycopg2` - The SQLAlchemy ``psycopg``
|
dialect shares most of its behavior with the ``psycopg2`` dialect.
|
Further documentation is available there.
|
|
é )Ú annotationsN)Úcast)Ú TYPE_CHECKINGé )Úranges)Ú_PGDialect_common_psycopg)Ú"_PGExecutionContext_common_psycopg)ÚINTERVAL)Ú
|
PGCompiler)ÚPGIdentifierPreparer)Ú REGCONFIG)ÚJSON)ÚJSONB)Ú JSONPathTypeé )Úpool)Úutil)ÚAdaptedConnection)Úsqltypes)Úawait_fallback)Ú
|
await_only)ÚIterablez sqlalchemy.dialects.postgresqlc @ 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/psycopg.pyr Z s r c @ s e Zd ZdZdS )Ú _PGREGCONFIGTNr r r r r r ^ s r c @ s e Zd ZdZdd Zdd ZdS )Ú_PGJSONTc C s | d |j¡S ©N)Ú_make_bind_processorÚ _psycopg_Json©ÚselfÚdialectr r r Úbind_processore s z_PGJSON.bind_processorc C s d S r" r ©r& r' Úcoltyper r r Úresult_processorh s z_PGJSON.result_processorN©r r r r r( r+ r r r r r! b s r! c @ s e Zd ZdZdd Zdd ZdS )Ú_PGJSONBTc C s | d |j¡S r" )r# Ú_psycopg_Jsonbr% r r r r( o s z_PGJSONB.bind_processorc C s d S r" r r) r r r r+ r s z_PGJSONB.result_processorNr, r r r r r- l s r- c @ s e Zd ZdZdZdS )Ú_PGJSONIntIndexTypeZjson_int_indexTN©r r r Z__visit_name__r r r r r r/ v s r/ c @ s e Zd ZdZdZdS )Ú_PGJSONStrIndexTypeZjson_str_indexTNr0 r r r r r1 | s r1 c @ s e Zd ZdS )Ú_PGJSONPathTypeN©r r r r r r r r2 s r2 c @ s e Zd ZdZdS )Ú _PGIntervalTNr r r r r r4 s r4 c @ s e Zd ZdZdS )Ú _PGTimeStampTNr r r r r r5 s r5 c @ s e Zd ZdZdS )Ú_PGDateTNr r r r r r6 s r6 c @ s e Zd ZdZdS )Ú_PGTimeTNr r r r r r7 s r7 c @ s e Zd ZdZdS )Ú
|
_PGIntegerTNr r r r r r8 s r8 c @ s e Zd ZdZdS )Ú_PGSmallIntegerTNr r r r r r9 s r9 c @ s e Zd ZdZdS )Ú _PGNullTypeTNr r r r r r: s r: c @ s e Zd ZdZdS )Ú _PGBigIntegerTNr r r r r r; ¢ s r; c @ s e Zd ZdZdS )Ú
|
_PGBooleanTNr r r r r r< ¦ s r< c @ s e Zd Zdd Zdd ZdS )Ú _PsycopgRangec s t t|j fdd}|S )Nc s& t | tjr" | j| j| j| j} | S r" )Ú
|
isinstancer ÚRangeÚlowerÚupperÚboundsÚempty©Úvalue©Ú psycopg_Ranger r Úto_range® s ÿz._PsycopgRange.bind_processor.<locals>.to_range)r ÚPGDialect_psycopgÚ_psycopg_Range©r& r' rH r rF r r( « s z _PsycopgRange.bind_processorc C s dd }|S )Nc S s2 | d k r.t j| j| j| jr | jnd| j d} | S )Nú[)©rB rC ©r r? Z_lowerZ_upperZ_boundsrD r r r rH ¸ s üz0_PsycopgRange.result_processor.<locals>.to_ranger ©r& r' r* rH r r r r+ · s
|
z _PsycopgRange.result_processorN©r r r r( r+ r r r r r= ª s r= c @ s e Zd Zdd Zdd ZdS )Ú_PsycopgMultiRangec s4 t t|jt t|jtd fdd}|S )Nc s0 t | t fr| S fddtd| D S )Nc s" g | ]} |j |j|j|jqS r )r@ rA rB rC )Ú.0ÚelementrF r r Ú
|
<listcomp>Ó s úüzG_PsycopgMultiRange.bind_processor.<locals>.to_range.<locals>.<listcomp>zIterable[ranges.Range])r> Ústrr rD ©ZNoneTypeZpsycopg_MultirangerG r r rH Î s
|
ùÿz3_PsycopgMultiRange.bind_processor.<locals>.to_range)r rI rJ Ú_psycopg_MultirangeÚtyperK r rV r r( Æ s ÿz!_PsycopgMultiRange.bind_processorc C s dd }|S )Nc S s | d k rdd | D } | S )Nc S s2 g | ]*}t j|j|j|jr |jnd |j dqS )rL rM rN )rR Úelemr r r rT ã s úüzI_PsycopgMultiRange.result_processor.<locals>.to_range.<locals>.<listcomp>r rD r r r rH á s
|
ù
|
z5_PsycopgMultiRange.result_processor.<locals>.to_ranger rO r r r r+ à s z#_PsycopgMultiRange.result_processorNrP r r r r rQ Å s rQ c @ s e Zd ZdS )ÚPGExecutionContext_psycopgNr3 r r r r rZ ò s rZ c @ s e Zd ZdS )ÚPGCompiler_psycopgNr3 r r r r r[ ö s r[ c @ s e Zd ZdS )Ú PGIdentifierPreparer_psycopgNr3 r r r r r\ ú s r\ c C s t d| j| j¡ d S )Nz%s: %s)ÚloggerÚinfoZseverityZmessage_primary)Z
|
diagnosticr r r Ú _log_noticesþ s r_ c ' s´ e Zd ZdZdZdZdZdZeZ e
|
Z e Z dZdZdZe ejejeeeeeejee e ejj e ejj e!ejj"e#ej$e%e&e%ej'e(ej)e*ej+e,ej-e.ej/e0ej1e2e3j4e5e3j6e7i¡Z fddZ8 fdd Z9d
|
d Z: fd d Z;e<dd Z=e<dd Z>ej?dd Z@ej?dd ZAej?dd ZBej?dd ZCej?dd ZDej?d d ZEd d ZF fd d!ZGd"d# ZHd$d% ZId&d' ZJd(d) ZKd*d+ ZLd5d-d.ZMd6d/d0ZNd7d1d2ZOej?d3d4 ZP ZQS )8rI ÚpsycopgTZpyformat)r r Nc s¶ t jf | | jr²t d| jj¡}|rFtdd | ddd¡D | _| jdk rXt dd d
|
l
|
m } || jj | _ }| jrd d lm} || j| | jr²d d lm} || j| d S ) Nz(\d+)\.(\d+)(?:\.(\d+))?c s s | ]}|d k rt |V qd S r" )Úint)rR Úxr r r Ú <genexpr>0 s z-PGDialect_psycopg.__init__.<locals>.<genexpr>r é r )r r rd z,psycopg version 3.0.2 or higher is required.r )Ú AdaptersMap)Úset_json_loads)Úset_json_dumps)ÚsuperÚ__init__ÚdbapiÚreÚmatchÚ __version__ÚtupleÚgroupÚpsycopg_versionÚ ImportErrorZ psycopg.adaptre ÚadaptersÚ_psycopg_adapters_mapZ_json_deserializerZpsycopg.types.jsonrf Z_json_serializerrg )r& ÚkwargsÚmre Z adapters_maprf rg ©Ú __class__r r ri * s* ÿ
|
|
ÿ ÿ
|
zPGDialect_psycopg.__init__c s< t |¡\}}| jr | j|d< | jd k r4| j|d< ||fS )NÚcontextÚclient_encoding)rh Úcreate_connect_argsrs ry )r& ÚurlZcargsZcparamsrv r r rz I s
|
|
|
z%PGDialect_psycopg.create_connect_argsc C s ddl m} | |jj|¡S ©Nr )ÚTypeInfo)Ú psycopg.typesr} ÚfetchÚ
|
connectionÚdriver_connection)r& r Únamer} r r r Ú_type_info_fetchS s z"PGDialect_psycopg._type_info_fetchc sb t |¡ | jsd| _| jr^| |d¡}|d k | _| jr^ddlm} ||| j |||j
|
d S )NFZhstorer )Úregister_hstore) rh Ú
|
initializeZinsert_returningZ insert_executemany_returningZuse_native_hstorer Ú_has_native_hstoreZpsycopg.types.hstorer rs r )r& r r^ r rv r r r
X s
|
z PGDialect_psycopg.initializec C s dd l }|S ©Nr )r` )Úclsr` r r r Ú import_dbapip s z PGDialect_psycopg.import_dbapic C s t S r" )ÚPGDialectAsync_psycopg)r r{ r r r Úget_async_dialect_clsv s z'PGDialect_psycopg.get_async_dialect_clsc C s& | j jj| j jj| j jj| j jjdS )N)zREAD COMMITTEDzREAD UNCOMMITTEDzREPEATABLE READÚ SERIALIZABLE)rj ZIsolationLevelZREAD_COMMITTEDZREAD_UNCOMMITTEDZREPEATABLE_READr ©r& r r r Ú_isolation_lookupz s
|
üz#PGDialect_psycopg._isolation_lookupc C s ddl m} |jS ©Nr )Újson)r~ r ZJson©r& r r r r r$ s z PGDialect_psycopg._psycopg_Jsonc C s ddl m} |jS r )r~ r ZJsonbr r r r r. s z PGDialect_psycopg._psycopg_Jsonbc C s ddl m} |S )Nr )ÚTransactionStatus)Ú
|
psycopg.pqr )r& r r r r Ú_psycopg_TransactionStatus s z,PGDialect_psycopg._psycopg_TransactionStatusc C s ddl m} |S )Nr )r? )Zpsycopg.types.ranger? )r& r? r r r rJ s z PGDialect_psycopg._psycopg_Rangec C s ddl m} |S )Nr )Ú
|
Multirange)Zpsycopg.types.multiranger )r& r r r r rW s z%PGDialect_psycopg._psycopg_Multirangec C s ||_ ||_d S r" ©Ú
|
autocommitÚisolation_level©r& r r r r r r Ú_do_isolation_level¡ s z%PGDialect_psycopg._do_isolation_levelc s, |j j}t |¡}|| jjkr(| ¡ |S r" )r^ Útransaction_statusrh Úget_isolation_levelr ÚIDLEÚrollback)r& Údbapi_connectionZ status_beforerE rv r r r ¥ s
|
z%PGDialect_psycopg.get_isolation_levelc C s4 |dkr| j |dd d n| j |d| j| d d S )NZ
|
AUTOCOMMITTr F)r r )r& r Úlevelr r r Úset_isolation_level¯ s ÿýz%PGDialect_psycopg.set_isolation_levelc C s
|
||_ d S r" ©Z read_only©r& r rE r r r Ú set_readonly» s z PGDialect_psycopg.set_readonlyc C s |j S r" r¢ ©r& r r r r Ú get_readonly¾ s z PGDialect_psycopg.get_readonlyc s> dd }|g j d k r.fdd} |¡ fdd}|S )Nc S s | t¡ d S r" )Zadd_notice_handlerr_ ©Úconnr r r Únotices s z-PGDialect_psycopg.on_connect.<locals>.noticesc s | j¡ d S r" )r¡ r r§ r r r Ú
|
on_connectÉ s z0PGDialect_psycopg.on_connect.<locals>.on_connectc s D ] }|| qd S r" r )r¨ Úfn)Úfnsr r rª Ï s )r Úappend)r& r© rª r )r¬ r& r rª Á s
|
|
z PGDialect_psycopg.on_connectc C s* t || jjr&|d k r&|js"|jr&dS dS )NTF)r> rj ÚErrorÚclosedÚbroken)r& Úer Úcursorr r r Ú is_disconnectÕ s z PGDialect_psycopg.is_disconnectFc
|
C s` |j j}|s |jj| jjkr$| ¡ |j}z |s<| |d¡ | |¡ W 5 |sZ| ||¡ X d S )NT)
|
r r r^ r r r r r Ú_do_autocommitÚexecute)r& r ÚcommandÚrecoverZ
|
dbapi_connZbefore_autocommitr r r Ú_do_prepared_twophaseÛ s ÿÿü z'PGDialect_psycopg._do_prepared_twophasec C s. |r | j |d| d|d n | |j¡ d S )NzROLLBACK PREPARED 'ú'©r· )r¸ Z do_rollbackr ©r& r ÚxidZ is_preparedr· r r r Údo_rollback_twophaseî s
|
ÿz&PGDialect_psycopg.do_rollback_twophasec C s. |r | j |d| d|d n | |j¡ d S )NzCOMMIT PREPARED 'r¹ rº )r¸ Z do_commitr r» r r r Údo_commit_twophaseø s
|
ÿz$PGDialect_psycopg.do_commit_twophasec C s dS )Nú;r r r r r Ú _dialect_specific_select_one s z.PGDialect_psycopg._dialect_specific_select_one)F)TF)TF)Rr r r ZdriverÚsupports_statement_cacheZ supports_server_side_cursorsZdefault_paramstyleZ supports_sane_multi_rowcountrZ Zexecution_ctx_clsr[ Zstatement_compilerr\ Úpreparerrp r rs r Z update_copyr Zcolspecsr ÚStringr r r r r! r r- r r2 ÚJSONIntIndexTyper/ ÚJSONStrIndexTyper1 ZIntervalr4 r ÚDater6 ÚDateTimer5 ÚTimer7 ÚIntegerr8 Ú SmallIntegerr9 Ú
|
BigIntegerr; r Z AbstractRanger= ZAbstractMultiRangerQ ri rz r r
Ú classmethodr r Zmemoized_propertyr r$ r. r rJ rW r r r¡ r¤ r¦ rª r³ r¸ r½ r¾ rÀ Ú __classcell__r r rv r rI s® îþ
|
|
|
|
|
|
|
|
|
|
|
ÿ
|
ÿ
|
|
rI c @ s e Zd ZdZdZddddZdd Zed d
|
Zej d d
|
Zd d Z
|
dddZ dd Z dd Z dd ZdddZdd ZdS ) ÚAsyncAdapt_psycopg_cursor©Ú_cursorÚawait_Ú_rowsNÚNone©Úreturnc C s || _ || _g | _d S r" rÏ )r& r² rÑ r r r ri s z"AsyncAdapt_psycopg_cursor.__init__c C s t | j|S r" )ÚgetattrrÐ ©r& r r r r Ú __getattr__ s z%AsyncAdapt_psycopg_cursor.__getattr__c C s | j jS r" ©rÐ Ú arraysizer r r r rÚ s z#AsyncAdapt_psycopg_cursor.arraysizec C s || j _d S r" rÙ ©r& rE r r r rÚ s c C s | j ¡ | j ¡ d S r" )rÒ ÚclearrÐ Ú_closer r r r Úclose s
|
z AsyncAdapt_psycopg_cursor.closec K sb | | jj||f|¡}| jj}|r^|j| jjkr^| | j ¡ ¡}t|t sXt || _
|
n|| _
|
|S r" ) rÑ rÐ rµ ZpgresultÚstatusÚ_psycopg_ExecStatusZ TUPLES_OKÚfetchallr> ÚlistrÒ )r& ÚqueryÚparamsÚkwÚresultÚresÚrowsr r r rµ ! s
|
z!AsyncAdapt_psycopg_cursor.executec C s | | j ||¡¡S r" )rÑ rÐ Ú executemany)r& rã Z
|
params_seqr r r ré 0 s z%AsyncAdapt_psycopg_cursor.executemanyc c s | j r| j d¡V q d S r ©rÒ Úpopr r r r Ú__iter__3 s z"AsyncAdapt_psycopg_cursor.__iter__c C s | j r| j d¡S d S d S r rê r r r r Úfetchone8 s z"AsyncAdapt_psycopg_cursor.fetchonec C s2 |d kr| j j}| jd|
}| j|d
| _|S r )rÐ rÚ rÒ )r& ÚsizeÚretvalr r r Ú fetchmany? s
|
z#AsyncAdapt_psycopg_cursor.fetchmanyc C s | j }g | _ |S r" )rÒ )r& rï r r r rá G s z"AsyncAdapt_psycopg_cursor.fetchall)N)N)r r r Ú __slots__rà ri rØ ÚpropertyrÚ ÚsetterrÞ rµ ré rì rí rð rá r r r r rÎ s
|
|
|
|
rÎ c @ s@ e Zd ZdddZdd Zdd Zdd d
|
Zd d Zd d ZdS )Ú AsyncAdapt_psycopg_ss_cursorNc K s | | jj||f|¡ | S r" )rÑ rÐ rµ )r& rã rä rå r r r rµ N s z$AsyncAdapt_psycopg_ss_cursor.executec C s | | j ¡ ¡ d S r" )rÑ rÐ rÞ r r r r rÞ R s z"AsyncAdapt_psycopg_ss_cursor.closec C s | | j ¡ ¡S r" )rÑ rÐ rí r r r r rí U s z%AsyncAdapt_psycopg_ss_cursor.fetchoner c C s | | j |¡¡S r" )rÑ rÐ rð )r& rî r r r rð X s z&AsyncAdapt_psycopg_ss_cursor.fetchmanyc C s | | j ¡ ¡S r" )rÑ rÐ rá r r r r rá [ s z%AsyncAdapt_psycopg_ss_cursor.fetchallc c s> | j ¡ }z| | ¡ ¡V W q
|
tk
|
r6 Y q:Y q
|
X q
|
d S r" )rÐ Ú __aiter__rÑ Ú __anext__ÚStopAsyncIteration)r& Úiteratorr r r rì ^ s
|
|
z%AsyncAdapt_psycopg_ss_cursor.__iter__)N)r ) r r r rµ rÞ rí rð rá rì r r r r rô M s
|
|
rô c @ s e Zd ZdZeeZddddZdd Zd d d
|
Z d d Z
|
d d Z dd Z dd Z edd Zejdd Zdd Zdd Zdd Zd d ZdS ) Ú AsyncAdapt_psycopg_connectionr rÓ rÔ c C s
|
|| _ d S r" ©Ú _connectionr¥ r r r ri k s z&AsyncAdapt_psycopg_connection.__init__c C s t | j|S r" )rÖ rû r× r r r rØ n s z)AsyncAdapt_psycopg_connection.__getattr__Nc K s$ | | jj||f|¡}t|| j S r" )rÑ rû rµ rÎ )r& rã rä rå r² r r r rµ q s z%AsyncAdapt_psycopg_connection.executec O s4 | j j||}t|dr$t|| jS t|| jS d S )Nr )rû r² Úhasattrrô rÑ rÎ )r& Úargsrå r² r r r r² u s
|
z$AsyncAdapt_psycopg_connection.cursorc C s | | j ¡ ¡ d S r" )rÑ rû Úcommitr r r r rþ | s z$AsyncAdapt_psycopg_connection.commitc C s | | j ¡ ¡ d S r" )rÑ rû r r r r r r s z&AsyncAdapt_psycopg_connection.rollbackc C s | | j ¡ ¡ d S r" )rÑ rû rÞ r r r r rÞ s z#AsyncAdapt_psycopg_connection.closec C s | j jS r" )rû r r r r r r
s z(AsyncAdapt_psycopg_connection.autocommitc C s | |¡ d S r" ©Úset_autocommitrÛ r r r r s c C s | | j |¡¡ d S r" )rÑ rû r rÛ r r r r s z,AsyncAdapt_psycopg_connection.set_autocommitc C s | | j |¡¡ d S r" )rÑ rû r¡ rÛ r r r r¡ s z1AsyncAdapt_psycopg_connection.set_isolation_levelc C s | | j |¡¡ d S r" )rÑ rû Ú set_read_onlyrÛ r r r r s z+AsyncAdapt_psycopg_connection.set_read_onlyc C s | | j |¡¡ d S r" )rÑ rû Úset_deferrablerÛ r r r r s z,AsyncAdapt_psycopg_connection.set_deferrable)N)r r r rñ Ú staticmethodr rÑ ri rØ rµ r² rþ r rÞ rò r ró r r¡ r r r r r r rù g s"
|
|
|
rù c @ s e Zd ZdZeeZdS )Ú%AsyncAdaptFallback_psycopg_connectionr N)r r r rñ r r rÑ r r r r r s r c @ s" e Zd ZddddZdd ZdS )ÚPsycopgAdaptDBAPIrÓ rÔ c C s2 || _ | j j ¡ D ]\}}|dkr|| j|< qd S )NÚconnect)r` Ú__dict__Úitems)r& r` ÚkÚvr r r ri s zPsycopgAdaptDBAPI.__init__c O sJ | dd¡}t |¡r.tt| jjj||S tt | jjj||S d S ©NÚasync_fallbackF)
|
rë r Úasboolr r r` ZAsyncConnectionr rù r )r& Úargrå r r r r r § s
|
ÿÿÿzPsycopgAdaptDBAPI.connectN)r r r ri r r r r r r s r c @ s\ e Zd ZdZdZedd Zedd Zdd Zdd Z d
|
d Z
|
d d Z dd Z dd Z dS )r Tc C s" dd l }ddlm} |t_t|S )Nr )Ú
|
ExecStatus)r` r r rÎ rà r )r r` r r r r r ¹ s z#PGDialectAsync_psycopg.import_dbapic C s( |j dd¡}t |¡r tjS tjS d S r )rã Úgetr r r Z FallbackAsyncAdaptedQueuePoolZAsyncAdaptedQueuePool)r r{ r r r r Úget_pool_class s
|
z%PGDialectAsync_psycopg.get_pool_classc C s& ddl m} |j}| | |j|¡¡S r| )r~ r} r rÑ r r )r& r r r} Zadaptedr r r r Ì s z'PGDialectAsync_psycopg._type_info_fetchc C s | |¡ | |¡ d S r" )r r¡ r r r r r Ò s
|
z*PGDialectAsync_psycopg._do_isolation_levelc C s | |¡ d S r" rÿ r£ r r r r´ Ö s z%PGDialectAsync_psycopg._do_autocommitc C s | |¡ d S r" )r r£ r r r r¤ Ù s z#PGDialectAsync_psycopg.set_readonlyc C s | |¡ d S r" )r r£ r r r r Ü s z%PGDialectAsync_psycopg.set_deferrablec C s |j S r" rú r¥ r r r Úget_driver_connectionß s z,PGDialectAsync_psycopg.get_driver_connectionN)r r r Zis_asyncrÁ rÌ r r r r r´ r¤ r r r r r r r µ s
|
|
r )NÚ__doc__Ú
|
__future__r Úloggingrk Útypingr r Ú r Z_psycopg_commonr r Úbaser r
|
r r r r r r r r Zenginer Zsqlr Zutil.concurrencyr r r Ú getLoggerr] rà r r r! r- rÄ r/ rÅ r1 r2 r4 rÇ r5 rÆ r6 rÈ r7 rÉ r8 rÊ r9 ZNullTyper: rË r; ÚBooleanr< ZAbstractRangeImplr= ZAbstractMultiRangeImplrQ rZ r[ r\ r_ rI rÎ rô rù r r r r' Z dialect_asyncr r r r Ú<module> sr 3
|
|
|
- F3.
|
