3 d@sdZddlmZmZddlmZddlmZddlm Z m Z ddl m Z m Z ddZd d Zd d Zd dZddZddZddZddZddZddZddZddZdd Zifd!d"Zd#S)$z+ Code for carrying out Update Operations )GraphVariable) iteritems) QueryContext) _fillTemplate_join)evalBGPevalPartcCs|dkr|jS|jj|SdS)NDEFAULT)graphdataset get_context)ctxgr>/tmp/pip-build-7vycvbft/rdflib/rdflib/plugins/sparql/update.py_graphOrDefaultsrcsX|dkrjgS|dkr0fddjjDS|dkrFtjjSjj|gSdS)z! return a list of graphs r ZNAMEDcsg|]}|jjjkr|qSr) identifierr ).0c)rrr sz_graphAll..ALLN)r r Zcontextslistr )rrr)rr _graphAllsrcCs0|jr|j|jd|jdn|j|jdddS)z4 http://www.w3.org/TR/sparql11-update/#load F)defaultZpublicIDT)rN)graphiriloadZiri)rurrrevalLoad&srcCs4|jj|j}t|dkr(td|jtddS)z6 http://www.w3.org/TR/sparql11-update/#create rzGraph %s already exists.zCreate not implemented!N)r r rlen Exceptionr)rrrrrr evalCreate1s r!cCs$xt||jD]}|jdqWdS)z5 http://www.w3.org/TR/sparql11-update/#clear N)NNN)rrremove)rrrrrr evalClear;sr#cCs>|jjjr0x.t||jD]}|jjj|qWn t||dS)z4 http://www.w3.org/TR/sparql11-update/#drop N)r store graph_awarerr remove_graphr#)rrrrrrevalDropDs r'cCs>|j}||j7}x(|jD]}|jj|}||j|7}qWdS)z: http://www.w3.org/TR/sparql11-update/#insertData N)r triplesquadsr r )rrrcgrrrevalInsertDataOs    r+cCs>|j}||j8}x(|jD]}|jj|}||j|8}qWdS)z: http://www.w3.org/TR/sparql11-update/#deleteData N)r r(r)r r )rrrr*rrrevalDeleteData^s    r,cCst||j}x>|jD]4}|jj|}|j|}t|tt||j|}qWxX|D]P}|j}|t |j|8}x4|jD]*}|jj|j |}|t |j||8}qtWqRWdS)z; http://www.w3.org/TR/sparql11-update/#deleteWhere N) rr(r)r r pushGraphrrr rget)rrresrr*rrrrevalDeleteWherems      r0c Cs|}|jrhd}xX|jD]N}|jrJ|s8t}|j|}d}|j|jddq|jr|j}|j|ddqW|j r|jr|jj|j}|j|}t ||j }|jr|r|}|jr|jj|j}|j|}x|D]}|j }|j r,|t |j j|8}x:t|j jD]*\}} |jj|j|} | t | |8} qW|jr|t |jj|7}x:t|jjD]*\}} |jj|j|} | t | |7} qRWqWdS)NFT)r)Zusingrrr-rnamedZ withClauser r r wherer deleterr(rr)r.insert) rrZ originalctxZ otherDefaultdZdgrr/rqr*rrr evalModifysF       r7cCs:|j\}}t||}t||}|j|jkr.dS||7}dS)zY add all triples from src to dst http://www.w3.org/TR/sparql11-update/#add N)r rr)rrsrcdstsrcgdstgrrrevalAdds     r<cCsh|j\}}t||}t||}|j|jkr.dS|jd||7}|jjjrZ|jjj|n |jddS)z remove all triples from dst add all triples from src to dst remove all triples from src http://www.w3.org/TR/sparql11-update/#move N)NNN)NNN)r rrr"r r$r%r&)rrr8r9r:r;rrrevalMoves      r=cCsD|j\}}t||}t||}|j|jkr.dS|jd||7}dS)zz remove all triples from dst add all triples from src to dst http://www.w3.org/TR/sparql11-update/#copy N)NNN)r rrr")rrr8r9r:r;rrrevalCopys     r>c Csdx\|D]R}tddt|D}t||d}|j|_y |jdkrRt||n|jdkrht||n|jdkr~t||n|jdkrt||n|jdkrt ||n|jd krt ||n|jd krt ||nl|jd krt ||nV|jd krt ||n>|jd krt||n&|jdkr4t||ntd|fWq|jsVYqXqWdS)ad http://www.w3.org/TR/sparql11-update/#updateLanguage 'A request is a sequence of operations [...] Implementations MUST ensure that operations of a single request are executed in a fashion that guarantees the same effects as executing them in lexical order. Operations all result either in success or failure. If multiple operations are present in a single request, then a result of failure from any operation MUST abort the sequence of operations, causing the subsequent operations to be ignored.' This will return None on success and raise Exceptions on error css|]\}}t||fVqdS)N)r)rkvrrr szevalUpdate..) initBindingsLoadZClearZDropZCreateAddZMoveZCopyZ InsertDataZ DeleteDataZ DeleteWhereZModifyzUnknown update operation: %sN)dictrrZprologuenamerr#r'r!r<r=r>r+r,r0r7r Zsilent)r updaterBrrrrr evalUpdates>                       rHN)__doc__ZrdflibrrsixrZrdflib.plugins.sparql.sparqlrZrdflib.plugins.sparql.evalutilsrrZrdflib.plugins.sparql.evaluaterr rrrr!r#r'r+r,r0r7r<r=r>rHrrrrs&      =