4YshydZddlmZmZddlmZddlmZmZddl m Z m Z dZ dZ dZd Zd Zd Zd Zd ZdZdZdZdZdZifdZy)z+ Code for carrying out Update Operations )GraphVariable) QueryContext) _fillTemplate_join)evalBGPevalPartcZ|dk(r |jS|jj|S)NDEFAULT)graphdataset get_context)ctxgs |/var/www/sten-cake5-migrate2.hellocrow.space/lexinfo-master/env/lib/python3.12/site-packages/rdflib/plugins/sparql/update.py_graphOrDefaultr s(I~yy{{&&q))cZ|dk(r |jgS|dk(rL|jjDcgc](}|j|jjk7s'|*c}S|dk(r#t |jjS|jj |gScc}w)z! return a list of graphs r NAMEDALL)r r contexts identifierlistr)rrcs r _graphAllrs I~ { g{{++- AUAU1UA   eCKK((*++ ''*++  s (B(B(c|jr)|j|jd|jy|j|jdy)z4 http://www.w3.org/TR/sparql11-update/#load F)defaultpublicIDTrN)graphiriloadiri)rus revalLoadr$$s9  zz  ; %rc|jj|j}t|dkDrt d|j zt d)z6 http://www.w3.org/TR/sparql11-update/#create rzGraph %s already exists.zCreate not implemented!)r rr len Exceptionrrr#rs r evalCreater)/sH  +A 1vz2Q\\ABB - ..rc\t||jD]}|jdy)z5 http://www.w3.org/TR/sparql11-update/#clear NNNN)rr remover(s r evalClearr-9s+ sAJJ '% #$%rc|jjjrAt||jD]'}|jjj |)yt ||y)z4 http://www.w3.org/TR/sparql11-update/#drop N)r store graph_awarerr remove_graphr-r(s revalDropr2BsU {{$$3 + .A KK   * *1 - . #qrc|j}||jz }|jD]/}|jj |}||j|z }1y)z: http://www.w3.org/TR/sparql11-update/#insertData Nr triplesquadsr rrr#rcgs revalInsertDatar9MU ANAWW [[ $ $Q ' aggajrc|j}||jz}|jD]/}|jj |}||j|z}1y)z: http://www.w3.org/TR/sparql11-update/#deleteData Nr4r7s revalDeleteDatar<\r:rc t||j}|jD]Z}|jj |}|j |}t |tt||j|}\|D]~}|j}|t|j|z}|jD]H}|jj |j|}|t|j||z}Jy)z; http://www.w3.org/TR/sparql11-update/#deleteWhere N) rr5r6r r pushGraphrrr rget)rr#resrr8rs revalDeleteWhererAks #qyy !C WW7 [[ $ $Q ' MM" Cga4567 / II ]199a (( /A((q2B - A. .B / /rc|}|jrd}|jD]w}|jr=|st}|j|}d}|j |jdL|j sY|j }|j |dy|jsB|j r6|jj|j }|j|}t||j}|jrFr|}|j r6|jj|j }|j|}|D]8}|j}|jr|t|jj|z}|jjj!D]>\}} |jj|j#|} | t| |z} @|j$s|t|j$j|z }|j$jj!D]>\}} |jj|j#|} | t| |z } @;y)NFTr)usingrrr>r!named withClauser rr wherer deleterr5r6itemsr?insert) rr# originalctx otherDefaultddgrr@rqr8s r evalModifyrOsK ww  +Ayy#B--+C#'LD1GGE* +0 77q|| KK # #ALL 1mmA 3 Cww C << '' 5A--"C * YY 88 - 0 0!4 4B,,. *1[[,,QUU1X6mAq)) * 88 - 0 0!4 4B,,. *1[[,,QUU1X6mAq)) **rc|j\}}t||}t||}|j|jk(ry||z }y)zY add all triples from src to dst http://www.w3.org/TR/sparql11-update/#add N)r rrrr#srcdstsrcgdstgs revalAddrVsEwwHC 3 $D 3 $D $//)DLDrc`|j\}}t||}t||}|j|jk(ry|jd||z }|jj j r&|jj j|y|jdy)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 Nr+)r rrr,r r/r0r1rQs revalMoverXswwHC 3 $D 3 $D $//)KK"#DLD {{$$ &&t, &'rc|j\}}t||}t||}|j|jk(ry|jd||z }y)zz remove all triples from dst add all triples from src to dst http://www.w3.org/TR/sparql11-update/#copy Nr+)r rrr,rQs revalCopyrZsRwwHC 3 $D 3 $D $//)KK"#DLDrcF|D]}td|jD}t||}|j|_ |jdk(rt ||n'|jdk(rt ||n |jdk(r t||n|jdk(r t||n|jdk(r t||n|jdk(r t||n|jd k(r t||n~|jd k(r t||nb|jd k(r t||nF|jd k(r t||n*|jd k(r t||nt!d|y#|j"sYxYw)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||fyw)N)r).0kvs r zevalUpdate..sNAXa[!,Ns) initBindingsLoadClearDropCreateAddMoveCopy InsertData DeleteData DeleteWhereModifyzUnknown update operation: N)dictrHrprologuenamer$r-r2r)rVrXrZr9r<rArOr'silent)r updaterar#rs r evalUpdaterrs^("N9K9K9MNN 5|<zz  vva 7"#q!6!a 8#3"5Q6!a 6!a <'sA&<'sA&=(Q'8#3"! EFF?"@ 88s EFF N)__doc__rdflibrrrdflib.plugins.sparql.sparqlrrdflib.plugins.sparql.evalutilsrrrdflib.plugins.sparql.evaluaterr rrr$r)r-r2r9r<rArOrVrXrZrrrrrysd #5@<* , &/%  /(:*z$(8,,.6r