#HJj7 d dl mZ d dlmZ d dlmZmZmZmZm Z m
Z
m Z d dl m
Z
d dlmZ d dlmZ d dlmZmZmZmZmZmZ d dlmZmZ d d l m Z m Z m Z m Z erd d
lm!Z! dd Z"dd Z#dd
Z$ G d de Z%y) ) annotationsdedent)Any GeneratorIterableIteratorMappingOptionalTuple)Graph) has_httpx)RepositoryNotFoundError)DATASET_DEFAULT_GRAPH_IDDataset _ContextType _QuadType_TriplePatternType _TripleType) VALID_STOREStore)BNodeNodeURIRefVariable) RDF4JClientc
t t |j }|s| S dj dj |D cg c] \ }}d|d|d c}} d| g S c c}}w )N
zPREFIX z: <> )setlistitemsjoin)queryextra_bindingsbindingskvs e/Users/ahmed/devFolder/claude-voice/.venv/lib/python3.12/site-packages/rdflib/plugins/stores/rdf4j.py_inject_prefixesr+ se 4,,./0H 99 IIhGhdaAq1hG H
Gs A$c X t | t r t d | j S )NzaSPARQL-based stores do not support BNodesSee http://www.w3.org/TR/sparql11-query/#BGPsparqlBNodes)
isinstancer Exceptionn3)nodes r* _node_to_sparqlr1 % s- $
G
779 c t d| d S )Nzu
PREFIX config:
[] a config:Repository ;
config:rep.id "a " ;
config:rep.impl
[
config:rep.type "openrdf:SailRepository" ;
config:sail.impl
[
config:native.tripleIndexers "spoc,posc" ;
config:sail.defaultQueryEvaluationMode "STANDARD" ;
config:sail.iterationCacheSyncThreshold "10000" ;
config:sail.type "openrdf:NativeStore" ;
] ;
] ;
.
r )
repository_ids r* _default_repo_configr5 . s%
*?
+ r2 c 2 e Zd ZdZdZdZdZdZ d d fd
Ze d Z
e d Z d ddZ dddZ
d dd Zd d
Z d d d Z d d d Z d d d
Zd!d"dZd#dZd$dZd%dZd&dZd&dZd d'dZ xZS )(
RDF4JStorezAn RDF4J store.TFc | t | }t |||fi || _ || _ d | _ | j || t | y N)r5 r _client_repository_id_repoopensuper__init__) selfbase_urlr4
configurationauthtimeoutcreatekwargs __class__s r* r? zRDF4JStore.__init__M sR 0 ?M"8T7EfE +
-(
r2 c | j S r9 )r: r@ s r* clientzRDF4JStore.client_ s ||r2 c | j 4| j j j | j | _ | j S r9 )r< rJ repositoriesgetr; rI s r* repozRDF4JStore.repoc s8 :: 1155d6I6IJDJzzr2 c 6 | j j t S # t $ rm |rQ| j j j | j | | j j Y t S t d| j d w xY w)Nz Repository z not found.) rN healthr rJ rL rE r; r. r )r@ rB rE s r* r= zRDF4JStore.openi s P II ' P ((//0C0C]S " +d.A.A-B+ NOO Ps " AB>Bc 8 | j j y r9 )rJ close)r@ commit_pending_transactions r* rR zRDF4JStore.closex s r2 c |\ }}}||j t k( rdn|j j }|j d|j d|j d| d}| j j | y )Nr z .
identifierr r/ rN upload) r@ triplecontextquotedspo
graph_name statements r* addzRDF4JStore.add{ s 1a '"4"48P"P
##&&(
ttvhaxq* R@ #r2 c 2 d}|D ]u \ }}}}||j t k( rdn|j j }|j d|j d|j d| d}||z
}w | j j | y )Nr rU z .
rV ) r@ quads
statementsr\ r] r^ cr_ r` s r* addNzRDF4JStore.addN s
JAq!Q 9 0H H \\__&
446(!ADDF81QTTVHAj\FI ) #J
$r2 c l |\ }}}| |j nd }| j j |||| y r9 )rW rN delete)r@ rY rZ r\ r] r^ gs r* removezRDF4JStore.remove s9
1a")"5G 4 Aq!$r2 c # K |\ }}}| |j nd }| j j |||| }t |t r+|D ]% \ }}}}|||ft t
| | g f ' y |D ] } | t d g f y w)NrW )rW rN rM r- r iterr
)
r@ triple_patternrZ r\ r] r^ r_ result_graphri rY s
r* tripleszRDF4JStore.triples s
!1a+2+>W''D
yy}}Q1j9 lG , *
1a!QiuTa'@&A!BBB + ' dD6l** 's BB
c # z K |/| j j D ] }t | | y |\ }}}t |r|n
t d t |r|n
t d t |r|n
t d f}d|z }| j j | }|D ] } t | | d y w)Nrl r\ r] r^ z:SELECT DISTINCT ?graph WHERE { GRAPH ?graph { %s %s %s } }graph)rN graph_namesr
r1 r r% )
r@ rY r_ r\ r] r^ paramsr% resultrows
r* contextszRDF4JStore.contexts s > "ii 3 3 5
DZ88 6 GAq! QHSM: QHSM: QHSM:F MvU
YY__U+F DS\:: s B9B;c P | j j j || y r9 )rN
namespacesr! )r@ prefix namespaceoverrides r* bindzRDF4JStore.bind s 3r2 c t | j j j D cg c] }|j |j
f c} }|j
t | S c c}w r9 )dictrN ry r" r{ rz rM str)r@ r{ xnamespace_prefixess r* rz zRDF4JStore.prefix s^ !.2ii.B.B.G.G.I J.Iakk188
$.I J
"%%c)n55
Ks A,c j | j j j | }| t | S d S r9 )rN ry rM r )r@ rz ru s r* r{ zRDF4JStore.namespace s0 %%))&1!'!3vf~==r2 c # K | j j j D ]% }|j t |j
f ' y wr9 )rN ry r" rz r r{ )r@ ru s r* ry zRDF4JStore.namespaces s= ii**//1F--(8(8!99 9 2s AAc |j t k7 r7| j j d|j j y y )NzCREATE SILENT GRAPH )rW r rN updater/ r@ rr s r* add_graphzRDF4JStore.add_graph s@ 7 7 II 3E4D4D4G4G4I3J K L 8r2 c b | j j j |j y r9 )rN graphsclearrW r s r* remove_graphzRDF4JStore.remove_graph s u / /0r2 c \ | j j || S |j S r9 )rN sizerW )r@ rZ s r* __len__zRDF4JStore.__len__ s' yy~~ gQQg>P>PQQr2 )NNg >@F) rA r r4 r rB z
str | NonerC ztuple[str, str] | NonerD floatrE bool)F)rB z str | tuple[str, str] | NonerE r returnz
int | None)rS r r None)NF)rY r rZ _ContextType | Noner[ r r r )rc zIterable[_QuadType]r r r9 )rY r rZ Optional[_ContextType]r r )rn r rZ r r z>Iterator[Tuple[_TripleType, Iterator[Optional[_ContextType]]]])rY zOptional[_TripleType]r z#Generator[_ContextType, None, None])T)rz r r{ r r| r r r )r{ r r z
Optional[str])rz r r zOptional[URIRef])r z Iterator[Tuple[str, URIRef]])rr r
r r )rZ r r int)__name__
__module__ __qualname____doc__
context_aware
formula_awaretransaction_aware graph_awarer? propertyrJ rN r= rR ra rf rj rp rw r} rz r{ ry r r r
__classcell__)rG s @r* r7 r7 E s MM K %)'+ "
%
$ KP
9
CG
(,
$
$ %
$
$
$
% +/%"% (%
% +/+*+ (+
H +$ /3;+; ,;(46 >:M
1R Rr2 r7 N)r% r r& zMapping[str, Any]r r )r0 r r r )r4 r r r )&
__future__r textwrapr typingr r r r r
r r rdflibr
rdflib.contrib.rdf4jr rdflib.contrib.rdf4j.exceptionsr rdflib.graphr r r r r r rdflib.storer r rdflib.termr r r r r r+ r1 r5 r7 r2 r* r sW " O O O * C , 5 5 0
.ZR ZRr2