iuUddlmZddlmZmZmZmZmZmZm Z m Z m Z m Z m Z mZddlmZddlmZer(ddlmZmZmZmZmZmZmZddlmZmZddlmZddl m!Z!m"Z"d d gZ#d Z$d e%d <Gdd eZ&Gdd eZ'y )) annotations) TYPE_CHECKINGAny CollectionDict GeneratorIteratorMappingOptionalSetTupleUnionoverload)Store) _coalesce)Graph _ContextType _ObjectType_PredicateType _SubjectType_TriplePatternType _TripleType)QueryUpdate)Result) IdentifierURIRef SimpleMemoryMemoryNNoneANYceZdZdZ d dfd Z d ddZ d ddZ d ddZdddZdddZ ddZ dd Z dd Z dd Z dfd Z dfd ZxZS)ra) A fast naive in memory implementation of a triple store. This triple store uses nested dictionaries to store triples. Each triple is stored in two such indices as follows spo[s][p][o] = 1 and pos[p][o][s] = 1. Authors: Michel Pelletier, Daniel Krech, Stefan Niederhauser ctt| |||_i|_i|_i|_i|_i|_yN) superr__init__ identifier_SimpleMemory__spo_SimpleMemory__pos_SimpleMemory__osp_SimpleMemory__namespace_SimpleMemory__prefixself configurationr' __class__s KC:\Projects\mas-dev\.venv\Lib\site-packages\rdflib/plugins/stores/memory.pyr&zSimpleMemory.__init__5sP lD*=9$    /1+- cf|\}}}|j} ||} ||} d| |<|j} | |} | |} d| |<|j} | |} ||}d||<y#ix}||<YQxYw#ix} ||<YYxYw#ix} | |<YPxYw#ix} | |<YXxYw#ix}| |<YOxYw#ix}||<YWxYw)6 Add a triple to the store of triples. N)r(r)r*)r.triplecontextquotedsubject predicateobjectspopooposossospspps r1addzSimpleMemory.addOs&,"Fjj #WB #9 A& jj %YB 6 A' jj "VB !7 A) 9 # " "BW # " "A9  %"$ $BY  A6  "! !BV ! A7 sDAA-A;B BB% A*- A8; B B B"% B0ct|j|D]B\\}}}}|j|||=|j|||=|j|||=Dyr$)listtriplesr(r)r*)r.triple_patternr7r9r:r;cs r1removezSimpleMemory.remove}sk 04DLL4P/Q + (Wi! 7#I.v6 9%f-g6 6"7+I60Rr2c#K|\}}}|tk7r|j}||vr||}|tk7r^||vrY|tk7r |||vr|||f|jfyy||jD]}|||f|jfyy|jD]Z} |tk7r ||| vr|| |f|jf+,|| jD]}|| |f|jf\yy|tk7r|j} || vr| |} |tk7r5|| vr0| |jD]} | ||f|jfyy| jD]1}| |jD]} | ||f|jf3yy|tk7r[|j } || vrJ| |}|jD]1} || jD]} | | |f|jf3yy|j}|jD]K} || }|jD]1} || jD]}| | |f|jf3Mywz)A generator over all the triples matchingN)r!r(_SimpleMemory__contextskeysr)r*)r.rIr7r9r:r;r<subjectDictionaryr>rDr?predicateDictionaryrArBobjectDictionarys r1rHzSimpleMemory.tripless &4"F c>**C#~$'L!# $55!S=%):9)EE'. 6&BDOODU&U U $%6y%A%F%F%H'. 1&=t?P&P P&I.335!S=%):1)=='.6&:DOO%>%@'.1ot7H&H H&A6 # **CC&))n#S=!44!4V!A#$i"3T__5F"FF"?8 s]**C}#&v; )..0A-a0557 !Vndoo.???81 **CXXZ$'F!*//1A.q1668 !Qi):::92 sI,I.c@d}|jdD]}|dz } |S)NrNNNr5)rH)r.r7ir6s r1__len__zSimpleMemory.__len__s) ll#56F FA7r2c|jj|}t|jj||jj|}|r=| |j|=| |j|=||j|<||j|<yt|||jt||<t|||jt||<yN)default)r+getrr,r.prefix namespaceoverridebound_namespace bound_prefixs r1bindzSimpleMemory.binds**..v6 MM  i ( MM  o . '$$\2*MM/2'-DMM) $'0D  V $DMfDDMM)OY? @AJAD  Y|V< =r2c:|jj|dSr$)r+rZr.r\s r1r]zSimpleMemory.namespace##FD11r2c:|jj|dSr$)r,rZr.r]s r1r\zSimpleMemory.prefix}}  D11r2c#\K|jjD] \}}||f ywr$)r+itemsr.r\r]s r1 namespaceszSimpleMemory.namespaces/!%!1!1!7!7!9 FI)# #":*,cddDS)Nc3 K|]}|ywr$).0rJs r1 z*SimpleMemory.__contexts..s2a2 rprp)r.s r1 __contextszSimpleMemory.__contextss2r2c 4tt| ||||fi|yr$)r%rqueryr.rvinitNs initBindings queryGraphkwargsr0s r1rvzSimpleMemory.querys% lD' 6< 7= r2c 4tt| ||||fi|yr$)r%rupdater.r}rxryrzr{r0s r1r}zSimpleMemory.updates% lD( FL* 8> r2NNr/ Optional[str]r'zOptional[Identifier]Fr6rr7rr8boolreturnr r$rIrr7Optional[_ContextType]rr )rIrr7rrz>Iterator[Tuple[_TripleType, Iterator[Optional[_ContextType]]]]r7rrintTr\strr]rr^rrr r\rrzOptional[URIRef]r]rrrrzIterator[Tuple[str, URIRef]])r#Generator[_ContextType, None, None]) rvUnion[Query, str]rxMapping[str, Any]ryMapping[str, Identifier]rzrr{rrr) r}zUnion[Update, str]rxrryrrzrr{rrr )__name__ __module__ __qualname____doc__r&rErKrHrVrar]r\rkrNrvr} __classcell__r0s@r1rr*sG(,+/.$.).< ,,, ,  ,b+/7*7(7  7+/>;*>;(>; H >;@222$     "  /           "  "  /          r2ceZdZdZdZdZdZ d dfd Z d ddZ d ddZ d ddZ d d!dZ d"dZ d#d Z d$d Z d d%d Zdd&d Zd'd Zd'dZ d(dZ d d)dZd*dZd+dZed,dZed-dZd.dZd/dZ d0fd Z d1fd ZxZS)2rz An in memory implementation of a triple store. Same as SimpleMemory above, but is Context-aware, Graph-aware, and Formula-aware Authors: Ashley Sommer Tctt| |||_i|_i|_i|_i|_i|_i|_ i|_ dti|_ t|_ d|_yr$)r%rr&r' _Memory__spo _Memory__pos _Memory__osp_Memory__namespace_Memory__prefix_Memory__context_obj_map_Memory__tripleContextsset_Memory__contextTriples_Memory__all_contexts_Memory__defaultContextsr-s r1r&zMemory.__init__s fd$]3$    /1+- 35NPHLce}*-%FJr2ctj||||||jj||\}}}|j} ||} ||} | |} d} |j || ||| ry|j} | |} | |}d||<|j} ||} ||}d||<y#t$r ix}||<YrwxYw#t$r ix} ||<YwxYw#t $r d| |<d} YwxYw#t$r ix} | |<Y}wxYw#t$r ix}| |<YwxYw#t$r ix}||<YwxYw#t$r ix}||<YwxYw)r4)r8NTr5F) rrErr LookupErrorKeyError_Memory__add_triple_contextrr)r.r6r7r8r9r:object_r<r=r>_ triple_existsr?r@rArBrCrDs r1rEz Memory.add=s  $7      # #G ,&,#Gjj #WB #9 A "' A M !!&-&I  jj %YB !7 A' jj #WB !7 A) Q # " "BW # # " "A9  # "AgJ!M " %"$ $BY % ! A7  ! # " "BW # ! A7  !s~ B/CCC1DD$D3/CCCCC.-C.1DDDDD0/D03EEc|j|}|j||D]\}}|\}}}|j|D]} ||| k7r |j|| |j|d} d| vr"|t | dk(r|j|dt |j|dk(s|j |||=|j |||=|j|||=|j|=|6||jvr(t |j|dk(r |j|=|dk(r8||jvr)|js|jj|yyyy)N)r7T skipQuotedr5rrT) _Memory__ctx_to_strrH_Memory__get_context_for_triple_Memory__remove_triple_contextlenrrrrrr graph_awarerK) r.rIr7req_ctxr6rJr9r:rctxctxss r1rKz Memory.remove{s ##G,ngFIFA*0 'GY44V<&7c>,,VS9=00D0IDt|CIN,,VT:40089Q>JJw' 27;JJy)'27;JJw'0;))&1G  4000D))'23q8%%g. 0 04...$$    & &w /%/ 1r2c#K|j|}|\}}}|K|I|G||jvry|j|jD]}||j|fy|E|C|A|} |j|||}|j ||r||j|fyy|K|j} || vr8| |} ||| vr|6|| |vr.|||f}|j ||r ||j|fyyt| |jD]/} ||| f}|j ||s||j|f1yyt| jD]} |6|| | vr.|| |f}|j ||s$||j|f:;t| | jD]/} || | f}|j ||s||j|f1yyy||j} || vr| |}|T||vrOt||jD]/}|||f}|j ||s||j|f1yyt|jD]P} t|| jD]/}||| f}|j ||s||j|f1Ryy||j}||vrr||}t|jD]P}t||jD]/} || |f}|j ||s||j|f1Ryy|j} t| jD]s}| |} t| jD]P} t| | jD]/} || | f}|j ||s||j|f1Ruy#t $rYywxYwwrM) rrcopy_Memory__contextsr_Memory__triple_has_contextrrGrOrr)r.rIr7rr9r:rr6rr<rPr>rDr?rQrArBrRs r1rHzMemory.tripless##G,&4#G ?y0W_d333//8==?doof555@ Y%:w?R$F JJw' 27;,,VW= $//&"999>  **C#~$'L!( $55".&*;I*FF*19g)F#'#<#>*11g)>#'#<#*C*C*E%F*11a#'#<#  **C#~#&w< .3356A!"21"5":":"<="#Q44VWE"($//&*A"AA>7**C#((*%$'F!/4467A!"3A"6";";"=>"#Q44VWE"($//&*A"AA?8&K  s[A-P0.5s?+>G+>rsc3 K|]}|ywr$rp)rqrs r1rrz"Memory.contexts..<s?r!Arrsrp)rrrr)r.r6subjpredobjrs r1contextszMemory.contexts1sr >V'99?4+>+>? ? dC # 4 &s+A??6* * #"r? " #s%AAAcr|j|}||jvryt|j|S)Nr)rrr)r.r7rs r1rVzMemory.__len__>s9( d++ +4((-..r2c|jstj||y|jj |yr$)rr add_graphrrEr.graphs r1rzMemory.add_graphDs- OOD% (    # #E *r2c|jstj||y|jd| |jj|y#t $rYywxYw)NrT)rr remove_graphrKrrrs r1rzMemory.remove_graphJsU   tU + KK*E 2 ##**51  sA AAch|j|}t|}|r |j|}|||<|s1||d<n+|r||ix}|j|<n||d|ix}|j|<|s|j dj|||j vrt|j |<|j |j||j||_||jk(r|j|=yy#t$r-|jj x}|j|<YwxYw)z;add the given context to the set of contexts for the tripleN) rrrrrrrrEr)r.r6rr7r8rtriple_contexts r1__add_triple_contextzMemory.__add_triple_contextUs\(f  !%!6!6v!>#)N3 '-t$BEvN!6!6v!>&B!6!6v!>   ! !$ ' + +F 3 d++ +),D ! !# & c"&&v.  ! ! )%3D " T33 3%%f- 4I  **//1!6!6v!>  sC;;2D10D1c|jj||j}|s|jS|j Dcgc] \}}|r | c}}Scc}}w)zdreturn a list of contexts (str) for the triple, skipping quoted contexts if skipQuoted==True)rrZrrOri)r.r6rrrr8s r1__get_context_for_triplezMemory.__get_context_for_triplesW $$((1G1GH99; (,zz|B| V6|BBBs AAcR||jj||jvS)z5return True if the triple exists in the given context)rrZr)r.r6rs r1__triple_has_contextzMemory.__triple_has_contexts(d++//8N8NOOOr2c|jj||jj}||=||jk(r|j|=n||j|<|j|j |y)z"remove the context from the tripleN)rrZrrrrK)r.r6rrs r1__remove_triple_contextzMemory.__remove_triple_contextsw$$((1G1GHMMO I 4)) )%%f-,0D ! !& ) c"))&1r2cyr$rpr.rs r1 __ctx_to_strzMemory.__ctx_to_strs69r2cyr$rprs r1rzMemory.__ctx_to_strs/2r2c|y dj|jjj|j}||j|<|S#t $rgt |trKdj|jj|}||jvr|cYS||j|<|cYStdwxYw)Nz{}:{}z1Cannot use that type of object as a Graph context) formatr'r0rrAttributeError isinstancer RuntimeError)r.rctx_strs r1rzMemory.__ctx_to_strs ; TnnS^^%=%=%F%FWG.1D " "7 +N T#s#!..)?)?Ed444"N25&&w/RS S TsA AAC!C4 Cc<fdj|dDS)zgreturn a generator for all the non-quoted contexts (dereferenced) the encoded triple appears inc3ZK|]"}|jj||$ywr$)rrZ)rqrr.s r1rrz$Memory.__contexts..s2 Q"  " " & &w 8Qs(+Tr)r)r.r6s` r1rtzMemory.__contextss% 88D8Q  r2c 4tt| ||||fi|yr$)r%rrvrws r1rvz Memory.querys fd!%zTVTr2c 4tt| ||||fi|yr$)r%rr}r~s r1r}z Memory.updates fd"66<VvVr2rrrrr$r)rIrr7rrzXGenerator[Tuple[_TripleType, Generator[Optional[_ContextType], None, None]], None, None]rrrrr)r6zOptional[_TripleType]rrr)rrrr ) r6rrrr7rr8rrr )r6rrrrzCollection[Optional[str]])r6rrrrr)r6r)rrrr)rr rr )rrrr)r6rrr) rvrrxrryrrzrrr) r}zUnion[Update, Any]rxrryrrzrrr )rrrr context_aware formula_awarerr&rErKrHrar]r\rkrrVrrrrrrrrrrvr}rrs@r1rrs MMK(,+/K$K)KJ <<< <  <B+/$0*$0($0  $0R+/jB*jB(jB  jBX422$ /3 #+ # , #/ + 3.3.3.( 3.  3.  3.l7< C! C/3 C " CP 299 22T* U U"U/ U  U UW"W"W/ W  W WWr2)( __future__rtypingrrrrrr r r r r rr rdflib.storer rdflib.utilr rdflib.graphrrrrrrrrdflib.plugins.sparql.sparqlrr rdflib.queryr rdflib.termrr__all__r!__annotations__rrrpr2r1rsv#    !;#. 8 $ Tc 5c LQWUQWr2