File: //opt/alt/python37/lib64/python3.7/site-packages/psycopg2/__pycache__/extensions.cpython-37.pyc
B
*��]� � @ s� d Z ddlZddlmZmZmZmZmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m Z m Z m Z m Z m!Z! yDddlm"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ W n e0k
r� Y nX ddlm1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z> ddlm?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZW dZXdZYdZZd Z[d
Z\dZ]dZ^dZ_d Z`d
ZadZbd Zce`ZddZedZfd Zgd
ZhdZidZjd Zkd
ZldZmd d
� ZnG dd� deo�ZpG dd� deo�Zqd dd�Zre�sd�e�sd�fdd�ZtddlumvZvmwZw yev� \ZxZyew� \ZzZ{W n e0k
�rt Y nX [v[wddl|m}Z} [}x:e~eA�� �D ]*\Z�Z�e���dd���d d���� Z�e�eAe�< �q�W [�[�dS ) a� psycopg extensions to the DBAPI-2.0
This module holds all the extensions to the DBAPI-2.0 provided by psycopg.
- `connection` -- the new-type inheritable connection class
- `cursor` -- the new-type inheritable cursor class
- `lobject` -- the new-type inheritable large object class
- `adapt()` -- exposes the PEP-246_ compatible adapting mechanism used
by psycopg to adapt Python types to PostgreSQL ones
.. _PEP-246: https://www.python.org/dev/peps/pep-0246/
� N) � BINARYARRAY�BOOLEAN� BOOLEANARRAY�BYTES�
BYTESARRAY�DATE� DATEARRAY�
DATETIMEARRAY�DECIMAL� DECIMALARRAY�FLOAT�
FLOATARRAY�INTEGER� INTEGERARRAY�INTERVAL�
INTERVALARRAY� LONGINTEGER�LONGINTEGERARRAY�
ROWIDARRAY� STRINGARRAY�TIME� TIMEARRAY�UNICODE� UNICODEARRAY�AsIs�Binary�Boolean�Float�Int� QuotedString)�MXDATE�
MXDATETIME� MXDATETIMETZ�
MXINTERVAL�MXTIME� MXDATEARRAY�MXDATETIMEARRAY�MXDATETIMETZARRAY�MXINTERVALARRAY� MXTIMEARRAY�
DateFromMx�
TimeFromMx�TimestampFromMx�IntervalFromMx)�PYDATE�
PYDATETIME� PYDATETIMETZ�
PYINTERVAL�PYTIME� PYDATEARRAY�PYDATETIMEARRAY�PYDATETIMETZARRAY�PYINTERVALARRAY� PYTIMEARRAY�
DateFromPy�
TimeFromPy�TimestampFromPy�IntervalFromPy)�adapt�adapters� encodings�
connection�cursor�lobject�Xid�
libpq_version� parse_dsn� quote_ident� string_types� binary_types�new_type�new_array_type�
register_type� ISQLQuote�Notify� Diagnostics�Column�ConnectionInfo�QueryCanceledError�TransactionRollbackError�set_wait_callback�get_wait_callback�encrypt_password� � � � � c C s |t | tf< dS )z;Register 'callable' as an ISQLQuote adapter for type 'typ'.N)r= rK )�typ�callable� r\ �F/opt/alt/python37/lib64/python3.7/site-packages/psycopg2/extensions.py�register_adapterf s r^ c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �SQL_INz-Adapt any iterable to an SQL quotable object.c C s || _ d | _d S )N)�_seq�_conn)�self�seqr\ r\ r] �__init__n s zSQL_IN.__init__c C s
|| _ d S )N)ra )rb Zconnr\ r\ r] �preparer s zSQL_IN.preparec C s^ dd� | j D �}| jd k r>x"|D ]}t|d�r |�| j� q W dd� |D �}dd�|� d S )Nc S s g | ] }t |��qS r\ )r< )�.0�or\ r\ r] �
<listcomp>x s z$SQL_IN.getquoted.<locals>.<listcomp>re c S s g | ] }|� � �qS r\ )� getquoted)rf rg r\ r\ r] rh } s � (s , � ))r` ra �hasattrre �join)rb Zpobjs�objZqobjsr\ r\ r] ri u s
zSQL_IN.getquotedc C s t | �� �S )N)�strri )rb r\ r\ r] �__str__� s zSQL_IN.__str__N)�__name__�
__module__� __qualname__�__doc__rd re ri rp r\ r\ r\ r] r_ l s
r_ c @ s" e Zd ZdZdd� Zddd�ZdS ) � NoneAdapterz�Adapt None to NULL.
This adapter is not used normally as a fast path in mogrify uses NULL,
but it makes easier to adapt composite types.
c C s d S )Nr\ )rb rn r\ r\ r] rd � s zNoneAdapter.__init__� NULLc C s |S )Nr\ )rb Z_nullr\ r\ r] ri � s zNoneAdapter.getquotedN)rv )rq rr rs rt rd ri r\ r\ r\ r] ru � s ru c K s� | dkr|sdS |s t | � | S d|krFd|kr8td��|�d�|d< dd� |�� D �}| dk rvt | �}|�|� |}d�d d
� |�� D ��} t | � | S ) z4Convert a set of keywords into a connection strings.N� ZdatabaseZdbnamez8you can't specify both 'database' and 'dbname' argumentsc S s i | ]\}}|d k r||�qS )Nr\ )rf �k�vr\ r\ r] �
<dictcomp>� s z make_dsn.<locals>.<dictcomp>� c S s$ g | ] \}}d |t t|��f �qS )z%s=%s)�
_param_escapero )rf rx ry r\ r\ r] rh � s z make_dsn.<locals>.<listcomp>)rD � TypeError�pop�items�updaterm )Zdsn�kwargs�tmpr\ r\ r] �make_dsn� s&
r� z([\\'])z\sc C s. | sdS |� d| �} |�| �r*d| d } | S )z9
Apply the escaping rule required by PQconnectdb
z''z\\\1�')�sub�search)�sZ re_escapeZre_spacer\ r\ r] r| � s
r| )�register_default_json�register_default_jsonb)�Range�_rw �-)N)�rt �re�_reZpsycopg2._psycopgr r r r r r r r r
r r r
r r r r r r r r r r r r r r r r r r r r! r" r# r$ r% r& r' r( r) r* r+ r, r- � ImportErrorr. r/ r0 r1 r2 r3 r4 r5 r6 r7 r8 r9 r: r; r< r= r> r? r@ rA rB rC rD rE rF rG rH rI rJ rK rL rM rN rO rP rQ rR rS rT ZISOLATION_LEVEL_AUTOCOMMITZ ISOLATION_LEVEL_READ_UNCOMMITTEDZ ISOLATION_LEVEL_READ_COMMITTEDZ ISOLATION_LEVEL_REPEATABLE_READZ ISOLATION_LEVEL_SERIALIZABLEZISOLATION_LEVEL_DEFAULTZ STATUS_SETUPZ STATUS_READYZ STATUS_BEGINZ STATUS_SYNCZ STATUS_ASYNCZSTATUS_PREPAREDZSTATUS_IN_TRANSACTIONZPOLL_OKZ POLL_READZ
POLL_WRITEZ
POLL_ERRORZTRANSACTION_STATUS_IDLEZTRANSACTION_STATUS_ACTIVEZTRANSACTION_STATUS_INTRANSZTRANSACTION_STATUS_INERRORZTRANSACTION_STATUS_UNKNOWNr^ �objectr_ ru r� �compiler| Zpsycopg2._jsonr� r� ZJSONZ JSONARRAYZJSONBZ
JSONBARRAYZpsycopg2._ranger� �listr rx ry �replace�upperr\ r\ r\ r] �<module> sb �D@l
#