Pi=ddlmZddlZddlZddlZddlZddlmZm Z ddlm Z m Z m Z m Z mZmZmZmZmZmZmZddlZddlmZmZmZddlmZddlmZddlm Z m!Z!m"Z"m#Z#m$Z$m%Z%e rdd l&m'Z'ed Z(Gd d e)Z*Gd de*Z+Gdde*Z,Gdde*Z-Gdde Z.GddeZ/Gdde/Z0GddZ1GddZ2GddZ3Gdd Z4dS)!) annotationsN)MappingMutableMapping) TYPE_CHECKINGAny ContainerDict GeneratorIterableListOptionalTupleTypeVarUnion)ConjunctiveGraphDatasetGraph)NamespaceManager) CompValue)BNode IdentifierLiteralNodeURIRefVariable)Path_AnyTceZdZdddZdS) SPARQLErrorNmsg Optional[str]c<t||dSN) Exception__init__selfr s p/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/rdflib/plugins/sparql/sparql.pyr%zSPARQLError.__init__$s4%%%%%r#r r!__name__ __module__ __qualname__r%r)r(rr#s-&&&&&&&r)rceZdZdddZdS) NotBoundErrorNr r!c<t||dSr#rr%r&s r(r%zNotBoundError.__init__)T3'''''r)r#r*r+r/r)r(r1r1(s-(((((((r)r1ceZdZdZdZdS) AlreadyBoundz>73< z ** z#r)rboolc: ||dS#t$rYdSwxYw)NTFrJrKs r( __contains__zBindings.__contains__Os7  II4   55 s  valueNonec||j|<dSr#rDr'rFrQs r( __setitem__zBindings.__setitem__Vs r)c td)NzDelItem is not implemented!)r$rKs r( __delitem__zBindings.__delitem__Ys5666r)intcRd}|}| |t|jz }|j}| |SNr)lenrDr@)r'irEs r(__len__zBindings.__len__\s7  $m QTNAAmr)Generator[str, None, None]c#BK|}||jEd{V|j}|dSdSr#)rDr@)r'rEs r(__iter__zBindings.__iter__ds9 $mtOOOOOOOAmmmmmr)cRddfdDzdzS)Nz Bindings({z, c3,K|]}||fVdSr#r/).0kr's r( z#Bindings.__str__..ls+'C'CDG 'C'C'C'C'C'Cr)z}))joinr8s`r(__str__zBindings.__str__js4dii'C'C'C'Cd'C'C'CCCCdJJr)c t|Sr#)rGr8s r(__repr__zBindings.__repr__ns4yyr))r@rA)rFrGrHrG)rFrrHrM)rFrGrQrrHrR)rFrGrHrRrHrY)rHr_rHrG) r,r-r.r:r%rLrPrVrXr^rarhrjr/r)r(r?r?9s4827777 KKKKr)r?cheZdZdZddZdZdd Zdd Zdd ZddZ ddZ ddZ d dZ d!dZ d!dZdS)" FrozenDictz^ An immutable hashable dict Taken from http://stackoverflow.com/a/2704866/81121 argsrkwargsc6t|i||_d|_dSr#)rCrD_hash)r'rorps r(r%zFrozenDict.__init__zs!04d0Ef0E0E$( r)c*t|jSr#)iterrDr8s r(razFrozenDict.__iter__~DG}}r)rHrYc*t|jSr#)r\rDr8s r(r^zFrozenDict.__len__47||r)rFrc|j|Sr#rTrKs r(rLzFrozenDict.__getitem__sws|r)c|j[d|_|D]?\}}|xjt|zc_|xjt|zc_@|jSr[)rritemshashrUs r(__hash__zFrozenDict.__hash__sd : DJ"jjll * * U d3ii'  d5kk) zr)varsContainer[Variable]c^tfd|DS)Nc30K|]}|dv |VdSrNr/rdxr}s r(rfz%FrozenDict.project..s+BBQqTT\\!\\\\BBr))rnrzr'r}s `r(projectzFrozenDict.projects.BBBBTZZ\\BBBBBBr)other!t.Mapping[Identifier, Identifier]rMcbtt|| Sr#)rMset intersection)r'rs r(disjointDomainzFrozenDict.disjointDomains'D ..u556666r)c\|D](} ||||krdS#t$rY%wxYwdS)NFTrO)r'rres r( compatiblezFrozenDict.compatibles\  A 7eAh&& 55'    ts  ))cttj||}|Sr#)rn itertoolschainrzr'rress r(mergezFrozenDict.merges0u{{}}EEFF r)rGc*t|jSr#)rGrDr8s r(rhzFrozenDict.__str__rwr)c*t|jSr#)reprrDr8s r(rjzFrozenDict.__repr__rur)N)rorrprrk)rFrrHr)r}r~rHrn)rrrHrM)rrrHrnrl)r,r-r.r:r%rar^rLr|rrrrrhrjr/r)r(rnrnrs))))    CCCC7777 r)rnceZdZddZddZdd ZddZeddZed dZ ed!dZ d"d#dZ d$dZ dS)%FrozenBindingsctx QueryContextc>tj|g|Ri|||_dSr#)rnr%r)r'rrorps r(r%zFrozenBindings.__init__s.D242226222r)rFUnion[Identifier, str]rHrct|tst|}t|ttfs|S||jvr|jj|S|j|Sr#) isinstancerrrrDr initBindingsrKs r(rLzFrozenBindings.__getitem__sf#t$$ 3--C#x011 J dg  8(- -73< r)r}r~cjt|jfd|DS)Nc30K|]}|dv |VdSrr/rs r(rfz)FrozenBindings.project..s+(Q(QqAaDDLLLLLL(Q(Qr)rrrzrs `r(rzFrozenBindings.projects2dh(Q(Q(Q(QDJJLL(Q(Q(QRRRr)rrct|jtj||}|Sr#)rrrrrzrs r(rzFrozenBindings.merges4TXytzz||U[[]]'S'STT r)datetime.datetimec|jjSr#)rnowr8s r(rzFrozenBindings.nows x|r)t.Mapping[Identifier, BNode]c|jjSr#)rbnodesr8s r(rzFrozenBindings.bnodess xr)Optional[Prologue]c|jjSr#)rprologuer8s r(rzFrozenBindings.prologues x  r)Nbefore_exceptOptional[Container[Variable]]czsgtjfdDS)zY return a frozen dict only of bindings made in self since before c3tK|]2}|dvs"|djjvs|d.|V3dSr)rr)rdrrrr's r(rfz(FrozenBindings.forget..s`  aDGOOttx444ad|+  ,+++  r)r)r'rrs```r(forgetzFrozenBindings.forgetse G H            r)cjt|jfd|DS)z@ return a frozen dict only of bindings in these c30K|]}|dv |VdSrr/)rdrtheses r(rfz*FrozenBindings.remember..s+(R(RqAaDEMMMMMM(R(Rr)r)r'rs `r(rememberzFrozenBindings.remembers4dh(R(R(R(RDJJLL(R(R(RSSSr))rr)rFrrHr)r}r~rHr)rrrHrrHr)rHr)rHrr#)rrrrrHr)rHr) r,r-r.r%rLrrpropertyrrrrrr/r)r(rrs     SSSSXX!!!X!NR     2TTTTTTr)rceZdZdZ d.d/d Zed0d Z d1d2dZed3dZ d4d5dZ d6dZ d1d7d"Z d1d8d&Z d9d(Z d:d)Zd;d*Zd;d+Zdr222  / M  . . . # A eg'78 9 9  > '  "WW & > >Ay >%*%6%6qy%A%A  j0 )? IIaiI>>>>&+"&,"4''' -2,=,=ag,F,F)#'88 0> IIaguI=== >!& >(C>!%DJJ!%!=DJJ DMDJ,0 15 ;F;R < <  r)rHrc|j3tjtjj|_|jSr#)rdatetimertimezoneutcr8s r(rzQueryContext.now,s0 9  )--h.?.CDDDIyr)4Optional[Union[FrozenBindings, Bindings, List[Any]]]ct|j|jn|j|p|j|j}|j|_|j|_|j|_|S)N)r)rrrrrrr)r'rrs r(clonezQueryContext.clone2s\ !]6DMMDJ  % *    ] *;r)rc<|jtd|jS)z "current datasetNzwYou performed a query operation requiring a dataset (i.e. ConjunctiveGraph), but operating currently on a single graph.)rr$r8s r(rzQueryContext.dataset?s- = ;  }r)FsourcerrrMintoOptional[Identifier]rprrRc fd}tjjjs.|r*|xj|j|z c_dSdS|r||j|dS||}||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]. c, |j|fddiS#t$rYnwxYw |j|fddiS#t$rYnwxYw |j|fddiS#t$rYnwxYw |j|fddiS#t$rtd|zwxYw)Nformatturtlexmln3ntz3Could not load %s as either RDF/XML, N3 or NTriples)parser$)rrrps r(_loadz QueryContext.load.._load`s( "u{6EE(EfEEE     "u{6BB%B6BBB     "u{6AA$A&AAA     "u{6AA$A&AAA   IFR s9  4 AAA A"!A"&A66BN)rrrSPARQL_LOAD_GRAPHSrrr)r'rrrrprs ` r(rzQueryContext.loadJs,     (~$7 > ? dl66v>>>  ? ? >dj&)))))<!Ddl..t44f=====r)rFUnion[str, Path]Optional[Union[str, Path]]c|t|ttfs|S |j|S#t$rYdSwxYwr#)rrrrrJrKs r(rLzQueryContext.__getitem__sR#x011 J =% %   44 s - ;;rG Optional[Any]c8 ||S#t$r|cYSwxYwr#rO)r'rFrs r(getzQueryContext.gets5 9    NNN s  r}Optional[Iterable[Variable]]rcr3t|fd|jDSt||jS)zO Return a static copy of the current variable bindings as dict c3.K|]\}}|v ||fVdSr#r/)rdrevr}s r(rfz(QueryContext.solution..s/MM$!Q1991v9999MMr))rrrzrs `r(solutionzQueryContext.solutionsg  ?!MMMM$-*=*=*?*?MMM "$ (;(;(=(=>> >r)rQcj||jvr|j||krt||j|<dSr#)rr6rUs r(rVzQueryContext.__setitem__s< $-  DM#$6%$?$?.. " cr)c<|}||_|Sr#)rr)r'rrs r( pushGraphzQueryContext.pushGraphs JJLLr)cT|t|j}|Sr#)rr?r)r'rs r(pushzQueryContext.pushs" JJx .. / /r)c,|gSr#rr8s r(cleanzQueryContext.cleanszz"~~r)frozenbindingsc0||}|S)zO Create a new read/write query context from the given solution r)r'rcs r(thawzQueryContext.thaws JJ~ & &r))NNNN)rrrrrrrr#)rrrHr)rHr)FN) rrrrMrrrprrHrR)rFrrHr)rFrGrrrHr)r}rrHr)rFrGrQrGrHrR)rrrHr)rHr)rrrHr)r,r-r.r:r%rrrrrrLrrrVrrrrr/r)r(rrsr "&IM;? / / / / / bX PT     X%) 6>6>6>6>6>p ? ? ? ? ?####  r)rc2eZdZdZddZdd Zdd ZddZdS)ProloguezI A class for holding prefixing bindings and base URI information rHrRcTd|_tt|_dSr#)baserrnamespace_managerr8s r(r%zPrologue.__init__s##' !1%''!:!:r)prefixr! localnamerc|jj|pd}|td|zt ||pdzS)NzUnknown namespace prefix : %s)rr namespacer$r)r'rrnss r( resolvePNamezPrologue.resolvePNamesO  # ) 3 3FLb A A :;fDEE EbIO,---r)urirc@|j||ddS)NT)replace)rbind)r'rrs r(rz Prologue.binds& ##FC#>>>>>r)iriOptional[Union[CompValue, str]]cdt|trk|jdkr ||j|jS|jdkr4t |j|j| |j Sn/t|trd|vrt||j S|S)z Apply BASE / PREFIXes to URIs (and to datatypes in Literals) TODO: Move resolving URIs to pre-processing pnameliteral)langdatatype:)r) rrnamer rrrstringr absolutizerrr)r'rs r(rzPrologue.absolutizes c9 % % /x7""((S]CCCx9$$JSX 8U8U% V $ $ /SCZZ#DI... . r)N)rHrR)rr!rr!rHr)rr!rrrHrR)rrrHr)r,r-r.r:r%r rrr/r)r(rrsn;;;;.... ????r)rceZdZdZddZdS) Queryz' A parsed and translated query rralgebrarc&||_||_|dSr#rrr'rrs r(r%zQuery.__init__    IIIr)N)rrrrr9r/r)r(rr8JJJJJJr)rceZdZdZddZdS) Updatez( A parsed and translated update rrrList[CompValue]c&||_||_|dSr#r!r"s r(r%zUpdate.__init__r#r)N)rrrr'r9r/r)r(r&r&r$r)r&)5 __future__rrrrtypingtcollections.abcrrrrrr r r r r rrrrdflib.plugins.sparqlr rdflib.graphrrrrdflib.namespacer!rdflib.plugins.sparql.parserutilsr rdflib.termrrrrrr rdflib.pathsrrr$rr1r6r<r?rnrrrrr&r/r)r(r3s""""""33333333                          9999999999------777777JJJJJJJJJJJJJJJJ"!!!!!! &&&&&)&&& (((((K((( #####;###(((((k((( 66666~666r;;;;;;;;|CTCTCTCTCTZCTCTCTL~~~~~~~~B''''''''TJJJJJJJJJJJJJJJJJJr)