U
S��W�4 � @ s� d Z ddlZddlT ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ dd
lm Z dd lm
Z
dd lm Z dd
lm Z zddl
mZ e�� W n ek
r� Y nX ddlmZ ddlmZ ddlmZ ddlmZ zddlmZ W n dZY nX ejdd�dd� �ZG dd� de�ZG dd� de�ZG d d � d e�Z G d d � d e�Z G d d!� d!e�Z G d"d#� d#e �Z d$d%� Z!ee e!� G d&d'� d'e �Z"G d(d)� d)e"e#�Z$G d*d+� d+e%�Z&G d,d-� d-e"e#�Z'G d.d/� d/e#�Z(G d0d1� d1e"e(�Z)G d2d3� d3e"e*�Z+d4d5� Z,ej-d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdE� G dFdG� dGe
�Z.G dHdI� dIe/�Z0G dJdK� dKe �Z1e0�2dLdMdNdOdPdQ�� e0�3ej4dRej5dSej6dTej7dUej8dVej9dWej:dRej;dXej<dYej=dRej>dZej?dUej@dSejAdTejBdDi� d[d\� ZCdad_d`�ZDdS )bzr
Collection of postgres-specific extensions, currently including:
* Support for hstore, a key/value type storage
� N)�*)�
Expression)�logger)�Node)�OP)�Param)� Passthrough)�
returns_clone)�
QueryCompiler)� SelectQuery)� UUIDField)�compat)�adapt)�AsIs)�register_adapter)�register_hstore)�JsonF)�clonec C s t | tjt|��S �N)r r �CAST�SQL��selfZas_type� r �/postgres_ext.py�cast# s r c s, e Zd Z� fdd�Zdd� Zdd� Z� ZS )� _LookupNodec s || _ || _tt| ��� d S r )�node�parts�superr �__init__)r r r �� __class__r r r ( s z_LookupNode.__init__c C s t | �| jt| j��S r )�typer �listr �r r r r �
clone_base- s z_LookupNode.clone_basec C s t t| dd�tjt|��S )NT)Zparens)r �Clauser r r r r r r r 0 s z_LookupNode.cast)�__name__�
__module__� __qualname__r r& r �
__classcell__r r r! r r ' s r c sL e Zd Zd� fdd� Zdd� Zeddd��Zd d
� Zd d � Zd
d� Z � Z
S )�_JsonLookupBaseFc s t t| ��||� || _d S r )r r, r �_as_json)r r r �as_jsonr! r r r 4 s z_JsonLookupBase.__init__c C s t | �| jt| j�| j�S r )r# r r$ r r- r% r r r r& 8 s z_JsonLookupBase.clone_baseTc C s
|| _ d S r )r- )r r. r r r r. ; s z_JsonLookupBase.as_jsonc C s8 | � d�}t|ttf�r*t|tjt|��S t|tj|�S �NT) r. �
isinstancer$ �dictr r �JSONB_CONTAINSr � JSONB_EXISTS)r �otherr r r r �contains? s
z_JsonLookupBase.containsc G s t | �d�tjtt|���S r/ )r r. r �JSONB_CONTAINS_ANY_KEYr r$ �r �keysr r r � contains_anyE s
�z _JsonLookupBase.contains_anyc G s t | �d�tjtt|���S r/ )r r. r �JSONB_CONTAINS_ALL_KEYSr r$ r7 r r r � contains_allK s
�z _JsonLookupBase.contains_all)F)T) r( r) r* r r& r r. r5 r9 r; r+ r r r! r r, 3 s r, c @ s e Zd ZdZdd� ZdS )�
JsonLookup� json_lookupc C s t | j| j|g | j�S r )r< r r r- �r �valuer r r � __getitem__T s zJsonLookup.__getitem__N)r( r) r* �
_node_typer@ r r r r r< Q s r< c @ s e Zd ZdZdS )�JsonPath� json_pathN)r( r) r* rA r r r r rB W s rB c @ s$ e Zd ZdZedd� �Zdd� ZdS )� ObjectSlice� object_slicec C sL t |t�r |jpd|jpdg}n"t |t�r2|g}ntt|�d��}| ||�S )Nr �:)r0 �slice�start�stop�int�map�split)�clsr r? r r r r �create] s
zObjectSlice.createc C s t �| |�S r �rD rN r> r r r r@ g s zObjectSlice.__getitem__N)r( r) r* rA � classmethodrN r@ r r r r rD Z s
rD c @ s e Zd Zdd� ZdS )�_Arrayc C s || _ || _d S r )�field�items)r rR rS r r r r k s z_Array.__init__N)r( r) r* r r r r r rQ j s rQ c C sD | j jjj�� }t| j�}|�|� td|| j � � d| j j
f �S )Nz%s::%s%s�[]) rR � model_classZ_meta�database�get_connr rS Zpreparer Zget_column_type�
dimensions)Zarr�connrS r r r � adapt_arrayo s
�rZ c s" e Zd ZdZd� fdd� Z� ZS )�IndexedFieldMixinZGiSTNc s< |� dd� tt| �j||� | jr2|p,| j| _nd | _d S )N�indexT)�
setdefaultr r[ r r\ �default_index_type�
index_type)r r_ �args�kwargsr! r r r } s
zIndexedFieldMixin.__init__)N)r( r) r* r^ r r+ r r r! r r[ z s r[ c sN e Zd ZdZedf� fdd� Zdd� Zdd� Zd d
� Zd d � Z d
d� Z
� Z S )�
ArrayField�GIN� c s4 |||�| _ || _| j �� | _tt| �j||� d S r )�_ArrayField__fieldrX Z get_db_field�db_fieldr rb r )r Z field_classrX r` ra r! r r r � s zArrayField.__init__c C s$ | j �|�}| jd| j 7 _|S )NrT )re �__ddl_column__r? rX )r Z column_type�sqlr r r rg � s zArrayField.__ddl_column__c C s, |d kr d S t |ttf�s"t|�}t| |�S r )r0 r$ rQ r> r r r �db_value� s
zArrayField.db_valuec C s t �| |�S r rO r> r r r r@ � s zArrayField.__getitem__c G s t | tjt|��S r )r r � ACONTAINSr �r rS r r r r5 � s zArrayField.containsc G s t | tjt|��S r )r r �
ACONTAINS_ANYr rk r r r r9 � s zArrayField.contains_any) r( r) r* r^ Z IntegerFieldr rg ri r@ r5 r9 r+ r r r! r rb � s rb c @ s e Zd ZdZdS )�DateTimeTZField� datetime_tzN)r( r) r* rf r r r r rm � s rm c @ sh e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� ZdS )� HStoreField�hashc C s t | tjt|��S r )r r �HKEYr �r �keyr r r r@ � s zHStoreField.__getitem__c C s
t �| �S r )�fnZakeysr% r r r r8 � s zHStoreField.keysc C s
t �| �S r )rt Zavalsr% r r r �values� s zHStoreField.valuesc C s
t �| �S r )rt Zhstore_to_matrixr% r r r rS � s zHStoreField.itemsc G s t �| tt|���S r )rt rG r r$ )r r` r r r rG � s zHStoreField.slicec C s t �| |�S r )rt Zexistrr r r r �exists� s zHStoreField.existsc C s t �| |�S r )rt �definedrr r r r rw � s zHStoreField.definedc K s t | tj|�S r )r r �HUPDATE)r �datar r r �update� s zHStoreField.updatec G s t �| tt|���S r )rt �deleter r$ r7 r r r r{ � s zHStoreField.deletec C sJ t |t�r t| tjt|��S t |ttf�r<t| tjt|��S t| tj |�S r )
r0 r1 r r �HCONTAINS_DICTr r$ �tuple�HCONTAINS_KEYS�
HCONTAINS_KEYr> r r r r5 � s
zHStoreField.containsc G s t | tjtt|���S r )r r �HCONTAINS_ANY_KEYr r$ r7 r r r r9 � s zHStoreField.contains_anyN)r( r) r* rf r@ r8 ru rS rG rv rw rz r{ r5 r9 r r r r ro � s ro c s: e Zd ZdZd � fdd� Zdd� Zdd� Zd d
� Z� ZS ) � JSONField�jsonNc s, t d krtd��|| _tt| �j||� d S )Nz/Your version of psycopg2 does not support JSON.)r � Exception�dumpsr r� r )r r� r` ra r! r r r � s zJSONField.__init__c C s( |d kr |S t |t�s$t|| jd�S |S )N)r� )r0 r r� r> r r r ri � s
zJSONField.db_valuec C s t | |g�S r )r< r> r r r r@ � s zJSONField.__getitem__c G s
t | |�S r )rB r7 r r r �path� s zJSONField.path)N) r( r) r* rf r ri r@ r� r+ r r r! r r� � s
r� c @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd S ) �BinaryJSONField�jsonbrc c C s2 t |ttf�r t| tjt|��S t| tjt|��S r ) r0 r$ r1 r r r2 r r3 r �r r4 r r r r5 � s zBinaryJSONField.containsc C s t | tjt|��S r )r r �JSONB_CONTAINED_BYr r� r r r � contained_by� s z BinaryJSONField.contained_byc G s t | tjtt|���S r )r r r6 r r$ rk r r r r9 � s
�z BinaryJSONField.contains_anyc G s t | tjtt|���S r )r r r: r r$ rk r r r r; � s
�z BinaryJSONField.contains_allN) r( r) r* rf r^ r5 r� r9 r; r r r r r� � s r� c @ s e Zd ZdZdZdd� ZdS )�
TSVectorField�tsvectorrc c C s t | tjt�|��S r )r r �TS_MATCHrt �
to_tsquery)r �queryr r r �match s zTSVectorField.matchN)r( r) r* rf r^ r� r r r r r� s r� c C s t t�| �tjt�|��S r )r rt Z to_tsvectorr r� r� )rR r� r r r �Match s r� rs zH@>zH?&zH?zH?|zH||zA@>zA||zT@@zJB@>zJB<@zJB?|zJB?&zJB?z::)rq rx r| r~ r r� rj rl r� r2 r� r6 r: r3 r c sB e Zd Zd � fdd� Zdd� Zdd� Zdd � Z� fd
d �Z� ZS )
�PostgresqlExtCompilerFc sP t t| ��|||�}d }|D ]}t|t�r |j}q |rL|j�dtd| �� |S )N���zUSING %s) r r� �
_create_indexr0 r[ r_ Znodes�insertr )r rU Zfields�uniqueZclauser_ rR r! r r r� $ s
�
z#PostgresqlExtCompiler._create_indexc C s> | � |j||�\}}dd� |jD �}d|d�|�f }||fS )Nc S s g | ]}t |d ��qS )rd )�str)�.0�partr r r �
<listcomp>4 s z=PostgresqlExtCompiler._parse_object_slice.<locals>.<listcomp>z%s[%s]rF )�
parse_noder r �join)r r � alias_map�convrh �paramsr r r r �_parse_object_slice1 s z)PostgresqlExtCompiler._parse_object_slicec C s� | � |j||�\}}|g}|jD ]*}| � |||�\}} |�|� |�| � q |jr^d�|�}n*|d d� |d }
} d�d�|
�| f�}||fS )N�->r� z->>)r� r r �append�extendr- r� ) r r r� r� rh r� Zlookupsr� Zpart_sqlZ part_params�head�tailr r r �_parse_json_lookup8 s
�
z(PostgresqlExtCompiler._parse_json_lookupc C sT | � |j||�\}}|jr d}nd}|�dd�tt|j�� � |�|| jf�|fS )Nz#>z#>>z{%s}�,) r� r r- r� r� rK r� r Z
interpolation)r r r� r� rh r� Zoperandr r r �_parse_json_pathJ s z&PostgresqlExtCompiler._parse_json_pathc s( t t| ��� }|j| j| j| jd� |S )N)rE r= rC )r r� �
get_parse_maprz r� r� r� )r Z parse_mapr! r r r� S s �z#PostgresqlExtCompiler.get_parse_map)F) r( r) r* r� r� r� r� r� r+ r r r! r r� # s
r� c s@ e Zd ZeZ� fdd�Zd dd�Zd
dd �Z� fd
d �Z� Z S )�PostgresqlExtDatabasec s2 |� dd�| _|� dd�| _tt| �j||� d S )N�server_side_cursorsFr T)�popr� r r r� r )r r` ra r! r r r _ s z PostgresqlExtDatabase.__init__Nc C s |r| � � j|d�S | � � �� S )N��name)rW �cursor)r r� r r r �
get_cursord s z PostgresqlExtDatabase.get_cursorTFc C s� t �||f� |p$| jo$|�� �d�}| �� �� |rN| jtt� � �d�}d}n| �� }z|�
||pdd� W n: t k
r� } z | � � r�| j
r�| �� � W 5 d }~X Y nX |r�| � � r�| �� W 5 Q R X |S )NZselectr� Fr )r �debugr� �lower�
startswithZexception_wrapperr� r� �uuidZuuid1�executer� Zget_autocommitZ autorollbackZrollbackZcommit)r rh r� �require_commit� named_cursorZuse_named_cursorr� �excr r r � execute_sqli s& �
z!PostgresqlExtDatabase.execute_sqlc s* t t| �j|f|�}| jr&t|dd� |S )NT)Zglobally)r r� �_connectr )r rV ra rY r! r r r� � s z PostgresqlExtDatabase._connect)N)NTF)
r( r) r* r� Zcompiler_classr r� r� r� r+ r r r! r r� \ s
�
r� c @ s e Zd Zedd� �Zdd� ZdS )�ServerSideSelectQueryc C s t |j�}|�|�S r )r� rU Z_clone_attributes)rM r� r r r r �clone_from_query� s
z&ServerSideSelectQuery.clone_from_queryc C s | � � \}}| jj||ddd�S )NFT)r� r� )rh rV r� )r rh r� r r r �_execute� s �z ServerSideSelectQuery._executeN)r( r) r* rP r� r� r r r r r� � s
r� ztimestamp with time zoneZhstorer� r� r� )rn rp r� r� r� z@>z?&�?z?|r� z||z&&z@@z<@c c sF t �| �}|j�� �( |�� }|| _|�� D ]
}|V q,W 5 Q R X d S r )r� r� rV Z transactionr� Z_qr�iterator)Z select_queryr Z query_result�objr r r �
ServerSide� s
r� �LEFTTc C s t | td| �|td|��S )Nz%s JOIN LATERALzON %s)r' r )ZlhsZrhsZ join_typeZ conditionr r r � LateralJoin� s
�r� )r� T)E�__doc__r� Zpeeweer r r r r r r r
r r Z psycopg2cffir
�register� ImportErrorZpsycopg2.extensionsr r r Zpsycopg2.extrasr r r� r r r, r< rB rD �objectrQ rZ r[ ZFieldrb Z
DateTimeFieldrm ro r� r� Z TextFieldr� r� rz r� ZPostgresqlDatabaser� r� Zregister_fieldsZ register_opsr| r~ r r� rq rx rj rl r� r2 r� r6 r: r3 r r� r� r r r r �<module> s�
)�9+ � �