i,dZddlmZddlmZmZmZmZmZddl m Z ddl m Z m Z ddlmZmZddlmZddlmZmZmZdd lmZmZmZdd Zdd Zdd Zdd ZddZddZ ddZ!ddZ"ddZ#ddZ$ddZ%ddZ&ddZ' d ddZ(y)z+ Code for carrying out Update Operations ) annotations) TYPE_CHECKINGIteratorMappingOptionalSequence)Graph)evalBGPevalPart) _fillTemplate_join) CompValue) FrozenDict QueryContextUpdate) IdentifierURIRefVariablecZ|dk(r |jS|jj|S)NDEFAULT)graphdataset get_context)ctxgs KC:\Projects\mas-dev\.venv\Lib\site-packages\rdflib/plugins/sparql/update.py_graphOrDefaultrs(I~yy{{&&q))cX|dk(r |jgS|dk(rK|jjDcgc]'}|j|jjk7r|)c}S|dk(r#t |jjS|jj |gScc}w)z! return a list of graphs rNAMEDALL)rrcontexts identifierlistr)rrcs r _graphAllr&s I~ { g[[))+ ,||syy333 +  eCKK((*++ ''*++ s,B'ctrt|jtsJ|jr)|j |jd|jy|j |jdy)z4 http://www.w3.org/TR/sparql11-update/#load F)defaultintoTr(N)r isinstanceirirgraphiriload)rus revalLoadr0.sP !%%(((zz AJJ7 %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!)rrr-len Exceptionr#rr/rs r evalCreater5<sH  +A 1vz2Q\\ABB - ..rc\t||jD]}|jdy)z5 http://www.w3.org/TR/sparql11-update/#clear NNNN)r&r-remover4s r evalClearr9Fs&sAJJ ' #$(rc|jjjrAt||jD]'}|jjj |)yt ||y)z4 http://www.w3.org/TR/sparql11-update/#drop N)rstore graph_awarer&r- remove_graphr9r4s revalDropr>NsP {{$$3 +A KK   * *1 -, #qrc|j}||jz }|jD]/}|jj |}||j|z }1y)z: http://www.w3.org/TR/sparql11-update/#insertData Nrtriplesquadsrrrr/rcgs revalInsertDatarEYsP ANAWW [[ $ $Q ' aggajrc|j}||jz}|jD]/}|jj |}||j|z}1y)z: http://www.w3.org/TR/sparql11-update/#deleteData Nr@rCs revalDeleteDatarGhsP ANAWW [[ $ $Q ' aggajrc 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) r rArBrr pushGraphr r$rr get)rr/resrrDr%s revalDeleteWhererLxs !(QYY 7C WW [[ $ $Q ' MM" Cga456  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*)usingr(r rIr.named withClauserrr whererdeleter rArBitemsrJinsert) rr/ originalctx otherDefaultddgrrKr%qrDs r evalModifyrZsK ww Ayy#B--+C#'LD1GGE*. 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)rrr#rr/srcdstsrcgdstgs revalAddrasIwwHC 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 Nr7)rrr#r8rr;r<r=r\s revalMovercswwHC 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 Nr7)rrr#r8r\s revalCopyresXwwHC 3 $D 3 $D $//) KK"# DLDrNcb|jD]}td|xsijD}t||}|j|_ |j dk(rt ||n'|j dk(rt||n |j dk(r t||n|j dk(r t||n|j dk(r t||n|j dk(r t||n|j d k(r t||n~|j d k(r t||nb|j d k(r t||nF|j d k(r t||n*|j d k(r t!||nt#d|y#|j$sYxYw)af 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 .. caution:: This method can access indirectly requested network endpoints, for example, query processing will attempt to access network endpoints specified in ``SERVICE`` directives. When processing untrusted or potentially malicious queries, measures should be taken to restrict network and file access. For information on available security measures, see the RDFLib :doc:`Security Considerations ` documentation. c3<K|]\}}t||fywN)r).0kvs r zevalUpdate..As V9UAXa[!,9Us) initBindingsLoadClearDropCreateAddMoveCopy InsertData DeleteData DeleteWhereModifyzUnknown update operation: N)algebradictrSrprologuenamer0r9r>r5rarcrerErGrLrZr3silent)rupdatermr/rs r evalUpdatersbJ^^V,:L"9S9S9UVV 5|<zz  vva 7"#q!6!a 8#3"5Q6!a 6!a <'sA&<'sA&=(Q'8#3"! EFF=> 88s EFF.)rrrstrreturnzOptional[Graph])rrrrrzSequence[Graph])rrr/rrNonerh)rr r~rrmz"Optional[Mapping[str, Identifier]]rr))__doc__ __future__rtypingrrrrr rdflib.graphr rdflib.plugins.sparql.evaluater r rdflib.plugins.sparql.evalutilsr r !rdflib.plugins.sparql.parserutilsrrdflib.plugins.sparql.sparqlrrr rdflib.termrrrrr&r0r5r9r>rErGrLrZrarcrerrrrs #GG<@7II44*,( &/%   /*=*@((B88<F F F5F Fr