kÿaydZddlmZmZddlmZddlmZmZddl m Z m Z dZ dZ dZd Zd Zd Zd Zd ZdZdZdZdZdZifdZdS)z+ Code for carrying out Update Operations )GraphVariable) QueryContext) _fillTemplate_join)evalBGPevalPartcP|dkr|jS|j|S)NDEFAULT)graphdataset get_contextctxgs >/usr/lib/python3/dist-packages/rdflib/plugins/sparql/update.py_graphOrDefaultr s)I~~y{&&q)))c|dkrjgS|dkr%fdjDS|dkr&tjSj|gS)z! return a list of graphs r NAMEDc>g|]}|jjjk|S) identifierr ).0crs r z_graphAll..s1   AU1U1UA1U1U1UrALL)r r contextslistrrs` r _graphAllr s I~~ { g    {++--     eCK((**+++ ''**++rc|jr$||jd|jdS||jddS)z4 http://www.w3.org/TR/sparql11-update/#load F)defaultpublicIDTr"N)graphiriloadiri)rus revalLoadr)$sN  z&  ;;;;; %%%%%rc|j|j}t|dkrt d|jzt d)z6 http://www.w3.org/TR/sparql11-update/#create rzGraph %s already exists.zCreate not implemented!)r rr%len Exceptionrrr(rs r evalCreater./sO  ++A 1vvzz2Q\ABBB - . ..rc`t||jD]}|ddS)z5 http://www.w3.org/TR/sparql11-update/#clear NNNN)r r%remover-s r evalClearr29s? sAJ ' '%% #$$$$%%rc|jjjr9t||jD]!}|jj|"dSt ||dS)z4 http://www.w3.org/TR/sparql11-update/#drop N)r store graph_awarer r% remove_graphr2r-s revalDropr7Bsm {$3 ++ . .A K  * *1 - - - - . . #qrc|j}||jz }|jD],}|j|}||j|z }-dS)z: http://www.w3.org/TR/sparql11-update/#insertData Nr triplesquadsr rrr(rcgs revalInsertDatar>MZ ANAW [ $ $Q ' ' agajrc|j}||jz}|jD],}|j|}||j|z}-dS)z: http://www.w3.org/TR/sparql11-update/#deleteData Nr9r<s revalDeleteDatarA\r?rc t||j}|jD]g}|j|}||}t |tt||j|}h|D]v}|j}|t|j|z}|jD]M}|j| |}|t|j||z}NwdS)z; http://www.w3.org/TR/sparql11-update/#deleteWhere N) rr:r;r r pushGraphrrr rget)rr(resrr=rs revalDeleteWhererFks #qy ! !C W77 [ $ $Q ' ' MM"  Cga445566 // I ]19a ( (( / /A((q22B - A.. .BB / //rc|}|jr|d}|jD]r}|jrD|s%t}||}d}||jdM|jr|j}||ds|js;|jr4|j|j}||}t||j }|jr?|r|}|jr4|j|j}||}|D]}|j }|j r|t|j j|z}|j jD]E\}} |j||} | t| |z} F|jr|t|jj|z }|jjD]E\}} |j||} | t| |z } FdS)NFTr$)usingr"rrCr&named withClauser rr wherer deleterr:r;itemsrDinsert) rr( originalctx otherDefaultddgrrErqr=s r evalModifyrTsKK w+  + +Ay +#(B--++C#'LD1111 +GE*** 7q| K # #AL 1 1mmA 3 Cw#  C < # '' 55A--""C ** Y 8 * - 0!44 4B,,.. * *1[,,QUU1XX66mAq))) 8 * - 0!44 4B,,.. * *1[,,QUU1XX66mAq)))**rc|j\}}t||}t||}|j|jkrdS||z }dS)zY add all triples from src to dst http://www.w3.org/TR/sparql11-update/#add N)r rrrr(srcdstsrcgdstgs revalAddr[sNwHC 3 $ $D 3 $ $D $/))DLDDDrc@|j\}}t||}t||}|j|jkrdS|d||z }|jjjr!|jj|dS|ddS)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 Nr0)r rrr1r r4r5r6rVs revalMover]swHC 3 $ $D 3 $ $D $/))KK"###DLD {$( &&t,,,,, &'''''rc|j\}}t||}t||}|j|jkrdS|d||z }dS)zz remove all triples from dst add all triples from src to dst http://www.w3.org/TR/sparql11-update/#copy Nr0)r rrr1rVs revalCopyr_sawHC 3 $ $D 3 $ $D $/))KK"###DLDDDrcV|D]}td|D}t||}|j|_ |jdkrt ||n+|jdkrt ||n|jdkrt||n|jdkrt||n|jdkrt||n|jdkrt||n|jd krt||n|jd krt||nf|jd krt||nJ|jd krt||n.|jd krt||nt!d|#|jsYxYwdS)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 c3>K|]\}}t||fVdS)N)r)rkvs r zevalUpdate..s1NNAXa[[!,NNNNNNr) initBindingsLoadClearDropCreateAddMoveCopy InsertData DeleteData DeleteWhereModifyzUnknown update operation: N)dictrMrprologuenamer)r2r7r.r[r]r_r>rArFrTr,silent)r updaterer(rs r evalUpdatervs(""NN9K9K9M9MNNNNN 5|<<<z  va    7""#q!!!!6!!a    8##3""""5Q6!!a    6!!a    <''sA&&&&<''sA&&&&=((Q''''8##3""""i!! EFFF 8   C""s EF F&N)__doc__rdflibrrrdflib.plugins.sparql.sparqlrrdflib.plugins.sparql.evalutilsrrrdflib.plugins.sparql.evaluaterr rr r)r.r2r7r>rArFrTr[r]r_rvrrrr|sR #"""""""555555@@@@@@@@<<<<<<<<*** , , , &&&///%%%      ///(:*:*:*z$(((8,,.666666r