U
SW4 @ 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 ejdddd ZG dd deZG dd deZG d d d eZ G d d d eZ G d d! d!eZ 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 Z1e02dLdMdNdOdPdQ e03ej4dRej5dSej6dTej7dUej8dVej9dWej: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 CASTSQLselfZas_type r /postgres_ext.pycast# s r c s, e Zd Z fddZdd Zdd Z ZS ) _LookupNodec s || _ || _tt| d S r )nodepartssuperr __init__)r r r __class__r r r ( s z_LookupNode.__init__c C s t | | jt| jS r )typer listr r r r r
clone_base- s z_LookupNode.clone_basec C s t t| ddtjt|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 ZedddZd 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| jS 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|ttfr*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 | dtjtt|S r/ )r r. r JSONB_CONTAINS_ANY_KEYr r$ r keysr r r contains_anyE s
z _JsonLookupBase.contains_anyc G s t | dtjtt|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 | jS 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 |tr |jpd|jpdg}n"t |tr2|g}ntt|d}| ||S )Nr :)r0 slicestartstopintmapsplit)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 )fielditems)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_metadatabaseget_connr rS Zpreparer Zget_column_type
dimensions)ZarrconnrS 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 )NindexT)
setdefaultr r[ r r\ default_index_type
index_type)r r_ argskwargsr! 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 )
ArrayFieldGIN c s4 |||| _ || _| j | _tt| j|| d S r )_ArrayField__fieldrX Z get_db_fielddb_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_typesqlr r r rg s zArrayField.__ddl_column__c C s, |d kr d S t |ttfs"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 ) HStoreFieldhashc 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 |tr t| tjt|S t |ttfr<t| tjt|S t| tj |S r )
r0 r1 r r HCONTAINS_DICTr r$ tupleHCONTAINS_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 ) JSONFieldjsonNc s, t d krtd|| _tt| j|| d S )Nz/Your version of psycopg2 does not support JSON.)r Exceptiondumpsr r r )r r r` ra r! r r r s zJSONField.__init__c C s( |d kr |S t |ts$t|| jdS |S )N)r )r0 r r r> r r r ri s
zJSONField.db_valuec C s t | |gS 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 ) BinaryJSONFieldjsonbrc c C s2 t |ttfr 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 )
TSVectorFieldtsvectorrc 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|tr |j}q |rL|jdtd| |S )NzUSING %s) r r
_create_indexr0 r[ r_ Znodesinsertr )r rU ZfieldsuniqueZclauser_ 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).0partr r r
<listcomp>4 s z=PostgresqlExtCompiler._parse_object_slice.<locals>.<listcomp>z%s[%s]rF )
parse_noder r join)r r alias_mapconvrh 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 }
} dd|
| f}||fS )N->r z->>)r r r appendextendr- r ) r r r r rh r Zlookupsr Zpart_sqlZ part_paramsheadtailr r r _parse_json_lookup8 s
z(PostgresqlExtCompiler._parse_json_lookupc C sT | |j||\}}|jr d}nd}|ddtt|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 fddZd ddZd
dd Z fd
d Z Z S )PostgresqlExtDatabasec s2 | dd| _| dd| _tt| j|| d S )Nserver_side_cursorsFr T)popr r r r r )r r` ra r! r r r _ s z PostgresqlExtDatabase.__init__Nc C s |r| j|dS | S )Nname)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 uuidZuuid1executer 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||dddS )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_qriterator)Z select_queryr Z query_resultobjr 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+