o mi=@sddlmZddlZddlZddlZddlZddlmZm Z ddlm Z m Z m Z m Z mZmZmZmZmZmZmZddlZddlmZmZmZddlmZddlmZddlm Z m!Z!m"Z"m#Z#m$Z$m%Z%e rjdd l&m'Z'ed Z(Gd d d e)Z*Gd dde*Z+Gddde*Z,Gddde*Z-Gddde Z.GdddeZ/Gddde/Z0GdddZ1GdddZ2GdddZ3Gdd d Z4dS)!) annotationsN)MappingMutableMapping) TYPE_CHECKINGAny ContainerDict GeneratorIterableListOptionalTupleTypeVarUnion)ConjunctiveGraphDatasetGraph)NamespaceManager) CompValue)BNode IdentifierLiteralNodeURIRefVariable)Path_AnyTc@eZdZddddZdS) SPARQLErrorNmsg Optional[str]cCt||dSN) Exception__init__selfrr'V/home/kim/smarthome/.venv/lib/python3.10/site-packages/rdflib/plugins/sparql/sparql.pyr$$zSPARQLError.__init__r"rr __name__ __module__ __qualname__r$r'r'r'r(r#rc@r) NotBoundErrorNrr cCr!r"rr$r%r'r'r(r$)r)zNotBoundError.__init__r"r*r+r'r'r'r(r0(r/r0c@seZdZdZddZdS) AlreadyBoundzr'r'r( __getitem__Gs   zBindings.__getitem__rboolcCs$z||WdStyYdSw)NTFrArBr'r'r( __contains__Os  zBindings.__contains__valueNonecCs||j|<dSr"r<r&r>rGr'r'r( __setitem__Vr4zBindings.__setitem__cCstd)NzDelItem is not implemented!)r#rBr'r'r( __delitem__YzBindings.__delitem__intcCs0d}|}|dur|t|j7}|j}|dus|SNr)lenr<r9)r&ir=r'r'r(__len__\szBindings.__len__Generator[str, None, None]ccs0|}|dur|jEdH|j}|dusdSdSr")r<r9)r&r=r'r'r(__iter__ds  zBindings.__iter__cs ddfddDdS)Nz Bindings({z, c3s|] }||fVqdSr"r').0kr3r'r( lsz#Bindings.__str__..z}))joinr3r'r3r(__str__js zBindings.__str__cCst|Sr")r?r3r'r'r(__repr__nrMzBindings.__repr__)r9r:)r>r?r@r?)r>rr@rD)r>r?rGrr@rH)r>r?r@rHr@rN)r@rSr@r?) r,r-r.r6r$rCrFrKrLrRrTrYrZr'r'r'r(r89s       r8c@s|eZdZdZd&ddZddZd'd d Zd(ddZd'ddZd)ddZ d*ddZ d*ddZ d+ddZ d,d!d"Z d,d#d$Zd%S)- FrozenDictz^ An immutable hashable dict Taken from http://stackoverflow.com/a/2704866/81121 argsrkwargscOst|i||_d|_dSr")r;r<_hash)r&r^r_r'r'r(r$zs zFrozenDict.__init__cC t|jSr")iterr<r3r'r'r(rT~ zFrozenDict.__iter__r@rNcCrar")rPr<r3r'r'r(rRrczFrozenDict.__len__r>rcCs |j|Sr"rIrBr'r'r(rCrczFrozenDict.__getitem__cCsL|jdur#d|_|D]\}}|jt|N_|jt|N_q |jSrO)r`itemshashrJr'r'r(__hash__s zFrozenDict.__hash__varsContainer[Variable]cstfdd|DS)Nc3 |] }|dvr|VqdSrNr'rUxrgr'r(rWz%FrozenDict.project..)r]rdr&rgr'rmr(projectszFrozenDict.projectother!t.Mapping[Identifier, Identifier]rDcCstt|| Sr")rDset intersection)r&rqr'r'r(disjointDomainszFrozenDict.disjointDomainc Cs<|D]}z||||krWdSWqtyYqwdS)NFTrE)r&rqrVr'r'r( compatibles zFrozenDict.compatiblecCstt||}|Sr")r] itertoolschainrdr&rqresr'r'r(mergeszFrozenDict.merger?cCrar")r?r<r3r'r'r(rYrczFrozenDict.__str__cCrar")reprr<r3r'r'r(rZrczFrozenDict.__repr__N)r^rr_rr[)r>rr@r)rgrhr@r])rqrrr@rD)rqrrr@r]r\)r,r-r.r6r$rTrRrCrfrprurvr{rYrZr'r'r'r(r]rs       r]c@sveZdZd$ddZd%d d Zd&d dZd'ddZed(ddZed)ddZ ed*ddZ d+d,d d!Z d-d"d#Z dS).FrozenBindingsctx QueryContextcOs"tj|g|Ri|||_dSr")r]r$r~)r&r~r^r_r'r'r(r$s zFrozenBindings.__init__r>Union[Identifier, str]r@rcCsDt|ts t|}t|ttfs|S||jvr|jj|S|j|Sr") isinstancerrrr<r~ initBindingsrBr'r'r(rCs    zFrozenBindings.__getitem__rgrhct|jfdd|DS)Nc3rirjr'rkrmr'r(rWrnz)FrozenBindings.project..r}r~rdror'rmr(rpszFrozenBindings.projectrqrrcCs t|jt||}|Sr")r}r~rwrxrdryr'r'r(r{szFrozenBindings.mergedatetime.datetimecC|jjSr")r~nowr3r'r'r(rzFrozenBindings.nowt.Mapping[Identifier, BNode]cCrr")r~bnodesr3r'r'r(rrzFrozenBindings.bnodesOptional[Prologue]cCrr")r~prologuer3r'r'r(rrzFrozenBindings.prologueNbefore_exceptOptional[Container[Variable]]cs*sgtjfddDS)zY return a frozen dict only of bindings made in self since before c3s@|]}|dvs|djjvs|ddur|VqdSrj)r~rrkrrr&r'r(rWs z(FrozenBindings.forget..r)r&rrr'rr(forgetszFrozenBindings.forgetcr)z@ return a frozen dict only of bindings in these c3rirjr'rktheser'r(rWrnz*FrozenBindings.remember..r)r&rr'rr(rememberszFrozenBindings.remember)r~r)r>rr@r)rgrhr@r})rqrrr@r}r@r)r@r)r@rr")rrrrr@r})r@r}) r,r-r.r$rCrpr{propertyrrrrrr'r'r'r(r}s        r}c@seZdZdZ    d;dd?ddZed@ddZ  dAdBdd Z dCd$d%Z d>dDd(d)Z d>dEd-d.Z dFd0d1Z dGd2d3ZdHd4d5ZdHd6d7ZdId9d:ZdS)Jrz@ Query context - passed along when evaluating the query NgraphOptional[Graph]bindings4Optional[Union[Bindings, FrozenBindings, List[Any]]]r"Optional[Mapping[str, Identifier]]c Cs ||_t|pgd|_|r|j|||t|ttfr||rit|_t|_ |D]=}|j rG| |j }|j |7_ |sF|j |j ddq*|j rgt|jj|j d}| |j }||7}|sg|j |j ddq*n||_tjjjrv|j|_ n |jj|_ nd|_||_ d|_d|_tt|_dS)N)r=T)default)store identifierF)rr8rupdaterrr_datasetrrr get_contextloadnameddatasetrrdflibpluginssparqlZSPARQL_DEFAULT_GRAPH_UNIONZdefault_contextr_now collections defaultdictrr) r&rrrZ datasetClauser=Z from_graphZ namedGraphsZfrom_named_graphsr'r'r(r$sL        zQueryContext.__init__r@rcCs"|jdurtjtjj|_|jSr")rdatetimertimezoneutcr3r'r'r(r,s zQueryContext.now4Optional[Union[FrozenBindings, Bindings, List[Any]]]cCsDt|jdur |jn|j|p|j|jd}|j|_|j|_|j|_|S)N)r)rrrrrrr)r&rrr'r'r(clone2szQueryContext.clonercCs|jdur td|jS)z "current datasetNzwYou performed a query operation requiring a dataset (i.e. ConjunctiveGraph), but operating currently on a single graph.)rr#r3r'r'r(r?s zQueryContext.datasetFsourcerrrDintoOptional[Identifier]r_rrHc snfdd}tjjjs|r|j|j|7_dSdS|r&||j|dS|dur,|}||j||dS)aP Load data from the source into the query context's. Args: source: The source to load from. default: If `True`, triples from the source will be added to the default graph, otherwise it will be loaded into a graph with `source` URI as its name. into: The name of the graph to load the data into. If `None`, the source URI will be used as as the name of the graph. **kwargs: Keyword arguments to pass to [`parse`][rdflib.graph.Graph.parse]. csz |j|fddiWStyYnwz |j|fddiWSty+Ynwz |j|fddiWStyAYnwz |j|fddiWSty[td|w)NformatturtlexmlZn3ntz3Could not load %s as either RDF/XML, N3 or NTriples)parser#)rrr_r'r(_load`s,    z QueryContext.load.._loadN)rrrZSPARQL_LOAD_GRAPHSrrr)r&rrrr_rr'rr(rJs  zQueryContext.loadr>Union[str, Path]Optional[Union[str, Path]]cCs4t|ttfs |Sz|j|WStyYdSwr")rrrrrArBr'r'r(rCs  zQueryContext.__getitem__r? Optional[Any]cCs"z||WSty|YSwr"rE)r&r>rr'r'r(gets   zQueryContext.getrgOptional[Iterable[Variable]]r}cs2rt|fdd|jDSt||jS)zO Return a static copy of the current variable bindings as dict c3s$|] \}}|vr||fVqdSr"r')rUrVvrmr'r(rWs"z(QueryContext.solution..)r}rrdror'rmr(solutions zQueryContext.solutionrGcCs,||jvr|j||krt||j|<dSr")rr2rJr'r'r(rKszQueryContext.__setitem__cCs|}||_|Sr")rr)r&rrr'r'r( pushGraphszQueryContext.pushGraphcCs|t|j}|Sr")rr8r)r&rr'r'r(pushszQueryContext.pushcCs |gSr"rr3r'r'r(cleanrczQueryContext.cleanfrozenbindingscCs||}|S)zO Create a new read/write query context from the given solution r)r&rcr'r'r(thaws zQueryContext.thaw)NNNN)rrrrrrrr")rrr@r)r@r)FN) rrrrDrrr_rr@rH)r>rr@r)r>r?rrr@r)rgrr@r})r>r?rGr?r@rH)rrr@r)r@r)rr}r@r)r,r-r.r6r$rrrrrrCrrrKrrrrr'r'r'r(rs0 1     8    rc@s8eZdZdZdddZdd d ZdddZdddZdS)ProloguezI A class for holding prefixing bindings and base URI information r@rHcCsd|_tt|_dSr")baserrnamespace_managerr3r'r'r(r$szPrologue.__init__prefixr localnamercCs6|jj|pd}|durtd|t||pdS)NzUnknown namespace prefix : %s)rr namespacer#r)r&rrnsr'r'r( resolvePNames zPrologue.resolvePNameurircCs|jj||dddS)NT)replace)rbind)r&rrr'r'r(rsz Prologue.bindiriOptional[Union[CompValue, str]]cCspt|tr&|jdkr||j|jS|jdkr$t|j|j| |j dS|St|t r6d|vr6t ||j dS|S)z Apply BASE / PREFIXes to URIs (and to datatypes in Literals) TODO: Move resolving URIs to pre-processing Zpnameliteral)langdatatype:)r) rrnamerrrrstringr absolutizerrr)r&rr'r'r(rs  zPrologue.absolutizeN)r@rH)rr rr r@r)rr rrr@rH)rrr@r)r,r-r.r6r$rrrr'r'r'r(rs    rc@eZdZdZd ddZdS) Queryz' A parsed and translated query rralgebrarcC||_||_|dSr"rrr&rrr'r'r(r$zQuery.__init__N)rrrrr5r'r'r'r(rrc@r) Updatez( A parsed and translated update rrrList[CompValue]cCrr"rrr'r'r(r$rzUpdate.__init__N)rrrrr5r'r'r'r(rrr)5 __future__rrrrwtypingtcollections.abcrrrrrrr r r r r rrZrdflib.plugins.sparqlrZ rdflib.graphrrrZrdflib.namespacerZ!rdflib.plugins.sparql.parserutilsrZ rdflib.termrrrrrrZ rdflib.pathsrrr#rr0r2r7r8r]r}rrrrr'r'r'r(s6 4    9>FB*