Pi>UdZddlmZddlZddlmZddlmZmZm Z m Z m Z m Z m Z mZmZmZddlmZmZer(ddlmZmZmZmZmZmZddlmZmZdd lmZdd l m!Z!m"Z"m#Z#d Z$dZ%d Z&dZ'd e(d<ej)Z)ej*Z*ej+Z+gdZ,GddeZ-GddeZ.GddeZ/GddZ0GddZ1dS)a## Types of store `Context-aware`: An RDF store capable of storing statements within contexts is considered context-aware. Essentially, such a store is able to partition the RDF model it represents into individual, named, and addressable sub-graphs. Relevant Notation3 reference regarding formulae, quoted statements, and such: http://www.w3.org/DesignIssues/Notation3.html `Formula-aware`: An RDF store capable of distinguishing between statements that are asserted and statements that are quoted is considered formula-aware. `Transaction-capable`: capable of providing transactional integrity to the RDF operations performed on it. `Graph-aware`: capable of keeping track of empty graphs. ) annotationsN)BytesIO) TYPE_CHECKINGAnyDict GeneratorIterableIteratorMappingOptionalTupleUnion) DispatcherEvent)Graph _ContextType _QuadType_TripleChoiceType_TriplePatternType _TripleType)QueryUpdate)Result) IdentifierNodeURIRefNoneUNKNOWN)StoreCreatedEventTripleAddedEventTripleRemovedEvent NodePicklerStoreceZdZdZdS)r!z{This event is fired when the Store is created. Attributes: configuration: String used to create the store N__name__ __module__ __qualname____doc__`/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/rdflib/store.pyr!r!Isr-r!ceZdZdZdS)r"zThis event is fired when a triple is added. Attributes: triple: The triple added to the graph. context: The context of the triple, if any. graph: The graph to which the triple was added. Nr'r,r-r.r"r"Qr-r"ceZdZdZdS)r#zThis event is fired when a triple is removed. Attributes: triple: The triple removed from the graph. context: The context of the triple, if any. graph: The graph from which the triple was removed. Nr'r,r-r.r#r#[r0r-r#cJeZdZddZddZdd ZddZ dddZd dZd!dZ dS)"r$returnrcDi|_i|_|jj|_dSN)_objects_ids __getitem__ _get_objectselfs r.__init__zNodePickler.__init__fs#(* $& =4r-keyr Optional[str]cZ |j|S#t$rYdSwxYwr5)r7get TypeError)r;r=s r._get_idszNodePickler._get_idsks= 9==%% %   44 s  **objectidstrc.||j|<||j|<dSr5)r6r7)r;rCrDs r.registerzNodePickler.registerqs " b &r-sbytesrctt|}|j|_ |S#t $r}t d|zd}~wwxYw)Nz Could not find Node class for %s) Unpicklerrr9persistent_loadloadKeyErrorUnpicklingError)r;rHupes r.loadszNodePickler.loadsusm wqzz " ""- J7799  J J J!"Dq"HII I Js> AAANobjprotocol Optional[Any]binct}t|}|j|_|||Sr5)rPicklerrB persistent_iddumpgetvalue)r;rSrTrVsrcps r.dumpszNodePickler.dumpss@ii CLL- s ||~~r-Mapping[str, Any]c|j}|d=|t|jt|jd|S)Nr9)r7r6)__dict__copyupdatetupler7itemsr6r;states r. __getstate__zNodePickler.__getstate__so ""$$ -  49??,,--5ATATAVAV;W;W X X    r-rgc|j|t|j|_t|j|_|jj|_dSr5)rarcdictr7r6r8r9rfs r. __setstate__zNodePickler.__setstate__sK U###OO T]++ =4r-r3r)r=rr3r>)rCrrDrEr3r)rHrIr3rNN)rSrrTrUrVrU)r3r_)rgr_r3r) r(r)r*r<rBrGrRr^rhrkr,r-r.r$r$es5555  JJJJOS     555555r-r$c<eZdZUdZded<dZded<dZded<dZded< dQdRd Ze dSdZ dTdZ dUdVdZ dUdWdZ dTdZdXdZ dUdYd ZdZd#Z d[d\d&Z d[d]d)Z d[d^d,Zd[d_d.Z d[d`d1Zdad<Zdbd?ZdcdddEZdedFZdfdHZdgdJZdXdKZdXdLZdhdOZdhdPZ dS)ir%Fbool context_aware formula_awaretransaction_aware graph_awareN configurationr> identifierOptional[Identifier]cld|_t|_|r||dSdS)zInitialize the Store. Args: identifier: URIRef of the Store. Defaults to CWD configuration: String containing information open can use to connect to datastore. N)_Store__node_picklerr dispatcheropen)r;rtrus r.r<zStore.__init__sA6:$,,  % IIm $ $ $ $ $ % %r-r3r$c|jddlm}m}ddlm}m}m}m}tx|_}| |d| |d| |d| |d| |d| |d | |d |jS) Nr)r QuotedGraph)BNodeLiteralrVariableSUBLGQV) rx rdflib.graphrr| rdflib.termr}r~rrr$rG)r;rr|r}r~rrnps r. node_picklerzStore.node_picklers   & 7 7 7 7 7 7 7 7 D D D D D D D D D D D D'2}} 4D " KKc " " " KK $ $ $ KKs # # # KK % % % KKs # # # KK S ) ) ) KK# & & &""r-rErcV|jt|dS)N)rt)rydispatchr!r;rts r.createz Store.creates*   !2!O!O!OPPPPPr-Union[str, tuple[str, str]]r Optional[int]ctS)aOpens the store specified by the configuration string. Args: configuration: Store configuration string create: If True, a store will be created if it doesn't exist. If False and the store doesn't exist, an exception is raised. Returns: One of: VALID_STORE, CORRUPTED_STORE, or NO_STORE Raises: Exception: If there are insufficient permissions to open the store. )r )r;rtrs r.rzz Store.opens r-commit_pending_transactioncdS)zCloses the database connection. Args: commit_pending_transaction: Whether to commit all pending transactions before closing (if the store is transactional). Nr,)r;rs r.closez Store.closer-cdS)zDestroys the instance of the store. Args: configuration: The configuration string identifying the store instance. Nr,rs r.destroyz Store.destroyrr-cdS)z:Allows the store to perform any needed garbage collection.Nr,r:s r.gczStore.gcs r-triplercontextrquotedcX|jt||dS)aAdds the given statement to a specific context or to the model. Args: triple: The triple to add context: The context to add the triple to quoted: If True, indicates this statement is quoted/hypothetical (for formula-aware stores) Note: It should be an error to not specify a context and have the quoted argument be True. It should also be an error for the quoted argument to be True when the store is not formula-aware. rrN)ryrr")r;rrrs r.addz Store.adds.&   !1!Q!Q!QRRRRRr-quadsIterable[_QuadType]c x|D]6\}}}}|Jd|d|d|d||||f|7dS)aQAdds each item in the list of statements to a specific context. The quoted argument is interpreted by formula-aware stores to indicate this statement is quoted/hypothetical. Note: The default implementation is a redirect to add. Args: quads: An iterable of quads to add NzContext associated with  z is None!)r)r;rrHr]ocs r.addNz Store.addNsm  # #JAq!Q===#=== HHaAY " " " "  # #r-rOptional[_ContextType]cX|jt||dS)z=Remove the set of triples matching the pattern from the storerN)ryrr#)r;rrs r.removez Store.removes.   !367!S!S!STTTTTr-rKGenerator[Tuple[_TripleType, Iterator[Optional[_ContextType]]], None, None]c#K|\}}}t|trt|tr Jdt|tr Jd|r3|D].}||||f|D]\\}}} } ||| f| fV/dS|||df|D]\\}}} } ||| f| fVdSt|trt|tr Jd|r3|D].} || ||f|D]\\}}} } ||| f| fV/dS|d||f|D]\\}}} } ||| f| fVdSt|trt|tr Jd|r3|D].} ||| |f|D]\\}}} } ||| f| fV/dS||d|f|D]\\}}} } ||| f| fVdSdS)a- A variant of triples that can take a list of terms instead of a single term in any slot. Stores can implement this to optimize the response time from the default 'fallback' implementation, which will iterate over each term in the list and dispatch to triples z object_ / subject are both listsz"object_ / predicate are both listsNz"subject / predicate are both listsz"predicate / subject are both lists) isinstancelisttriples) r;rrsubject predicateobject_rSs1p1o1cgsubjpreds r.triples_choiceszStore.triples_choicessC$'-#G gt $ $' +!'400 T T2T T T0!)T22 X X4X X X2 +"//C,0LL )S17--//( Rb "2rlB...../// )- i.))++$LRR"r2,*****++  & & +!)T22 X X4X X X2 +#//D,0LLy'2G--//( Rb "2rlB...../// )- 9g.))++$LRR"r2,*****++  4 ( ( +!'400 V V2V V V0 +%//D,0LL $0'--//( Rb "2rlB...../// )- gtW5Mw(W(W++$LRR"r2,***** + +++r-triple_pattern>Iterator[Tuple[_TripleType, Iterator[Optional[_ContextType]]]]c|\}}}dS)a A generator over all the triples matching the pattern. Pattern can include any objects for used for comparing against nodes in the store, for example, REGEXTerm, URIRef, Literal, BNode, Variable, Graph, QuotedGraph, Date? DateRange? Args: context: A conjunctive query can be indicated by either providing a value of None, or a specific context can be queries by passing a Graph instance (if store is context aware). Nr,)r;rrrrrCs r.rz Store.triplesZs &4"FFFr-intcdS)aG Number of statements in the store. This should only account for non- quoted (asserted) statements if the context is not specified, otherwise it should return the number of statements in the formula or context given. Args: context: a graph instance to query or None Nr,)r;rs r.__len__z Store.__len__orr-Optional[_TripleType]#Generator[_ContextType, None, None]cdS)z Generator over all contexts in the graph. If triple is specified, a generator over all contexts the triple is in. if store is graph_aware, may also return empty contexts :returns: a generator over Nodes Nr,)r;rs r.contextszStore.contexts{rr-queryUnion[Query, str]initNsr_ initBindingsMapping[str, Identifier] queryGraphkwargsrrc t)aIf stores provide their own SPARQL implementation, override this. queryGraph is None, a URIRef or `__UNION__` If None the graph is specified in the query-string/object If URIRef it specifies the graph to query, If `__UNION__` the union of all named graphs should be queried (This is used by ConjunctiveGraphs Values other than None obviously only makes sense for context-aware stores.) NotImplementedError)r;rrrrrs r.rz Store.query &"!r-rcUnion[Update, str]c t)aIf stores provide their own (SPARQL) Update implementation, override this. queryGraph is None, a URIRef or `__UNION__` If None the graph is specified in the query-string/object If URIRef it specifies the graph to query, If `__UNION__` the union of all named graphs should be queried (This is used by ConjunctiveGraphs Values other than None obviously only makes sense for context-aware stores.) r)r;rcrrrrs r.rcz Store.updaterr-Tprefix namespaceroverridecdS)aBind a namespace to a prefix. Args: prefix: The prefix to bind the namespace to. namespace: The URIRef of the namespace to bind. override: If True, rebind even if the given namespace is already bound to another prefix Nr,)r;rrrs r.bindz Store.bindrr-cdS)Nr,)r;rs r.rz Store.prefixrr-Optional[URIRef]cdSrNr,)r;rs r.rzStore.namespacerr-Iterator[Tuple[str, URIRef]]c# KdS)rFNr,r:s r. namespaceszStore.namespacess   r-cdSrr,r:s r.commitz Store.commitrr-cdSrr,r:s r.rollbackzStore.rollbackrr-graphrc td)zAdd a graph to the store, no effect if the graph already exists. Args: graph: a Graph instance ,Graph method called on non-graph_aware store Exceptionr;rs r. add_graphzStore.add_graphFGGGr-c td)zRemove a graph from the store, this should also remove all triples in the graph Args: graphid: a Graph instance rrrs r. remove_graphzStore.remove_graphrr-rm)rtr>rurv)r3r$)rtrEr3r)F)rtrrror3r)rror3rrl)rrrrrror3r)rrr3rr5)rrrrr3r)rrrrr3r)rrrrr3r)rrr3r)rrr3r) rrrr_rrrrErrr3r) rcrrr_rrrrErrr3r)T)rrErrrror3r)rrr3r>)rrEr3r)r3r)rrr3r)!r(r)r*rp__annotations__rqrrrsr<propertyrrrzrrrrrrrrrrrrcrrrrrrrrr,r-r.r%r%sMM#####K(,+/%%%%%" # # #X #"QQQQJO$              SSSSS*####.+/UUUUU+/:+:+:+:+:+@+/44444*      /3      """"*"""".      HHHHHHHHHHr-r%)2r+ __future__rpickleiortypingrrrrr r r r r r rdflib.eventsrrrrrrrrrrdflib.plugins.sparql.sparqlrr rdflib.queryrrrrr VALID_STORECORRUPTED_STORENO_STOREr rrXrKrO__all__r!r"r#r$r%r,r-r.rs&#"""""                         ,+++++++ 5;:::::::######4444444444   .   (   u1515151515151515hMHMHMHMHMHMHMHMHMHMHr-