o mi@sdZddlmZddlmZddlmZmZmZddl m Z ddl m Z mZmZddlmZddlmZmZmZdd lmZd gZeeefZGd d d eZd S) a This is a rdflib plugin for parsing NQuad files into Conjunctive graphs that can be used and queried. The store that backs the graph *must* be able to handle contexts. ```python >>> from rdflib import ConjunctiveGraph, URIRef, Namespace >>> g = ConjunctiveGraph() >>> data = open("test/data/nquads.rdflib/example.nquads", "rb") >>> g.parse(data, format="nquads") # doctest:+ELLIPSIS )> >>> assert len(g.store) == 449 >>> # There should be 16 separate contexts >>> assert len([x for x in g.store.contexts()]) == 16 >>> # is the name of entity E10009 "Arco Publications"? >>> # (in graph http://bibliographica.org/entity/E10009) >>> # Looking for: >>> # >>> # >>> # "Arco Publications" >>> # >>> s = URIRef("http://bibliographica.org/entity/E10009") >>> FOAF = Namespace("http://xmlns.com/foaf/0.1/") >>> assert(g.value(s, FOAF.name).eq("Arco Publications")) ``` ) annotations) getreader)AnyMutableMappingOptional) ParserError)ConjunctiveGraphDatasetGraph) InputSource)W3CNTriplesParserr_tailr_wspace)BNode NQuadsParserc@s(eZdZ  ddd dZddddZdS)rNF inputsourcer sinkr bnode_contextOptional[_BNodeContextType] skolemizeboolkwargsrc Ks$|jjsJdt|jdd}|j}d}t|ttfr|j}n|jdur3|j|jkr-|}n||j}|dur?||_||||_ ||_ | } | sU| } t d| } t| ds^td| |_d|_ ||_} |jduru |j Sz||Wnty} ztd | | fd} ~ wwqe) aParse inputsource as an N-Quads file. Args: inputsource: The source of N-Quads-formatted data. sink: The graph where parsed quads will be stored. bnode_context: Optional dictionary mapping blank node identifiers to [`BNode`][rdflib.term.BNode] instances. See `.W3CNTriplesParser.parse` for more details. skolemize: Whether to skolemize blank nodes. Returns: The Dataset containing the parsed quads. Raises: AssertionError: If the sink store is not context-aware. ParseError: If the input is not a file-like object or contains invalid lines. z1NQuadsParser must be given a context-aware store.T)storeZ default_unionNzutf-8readz)Item to parse must be a file-like object.zInvalid line (%s): %r)rZ context_awarer default_context isinstancer identifier get_contextZ remove_graphrrZgetCharacterStreamZ getByteStreamrhasattr ParseErrorfilebufferreadlineline parseline) selfrrrrrZdsZ ds_defaultZnew_default_contextsourceZ_NQuadsParser__linemsgr)W/home/kim/smarthome/.venv/lib/python3.10/site-packages/rdflib/plugins/parsers/nquads.pyparse2sL       zNQuadsParser.parsereturnNonecCs|t|jr|jdrdS||}|t|}|t||}|t|p5||}|t |jrBt d|rR|j | |||fdS|j j |||fdS)N#zTrailing garbage)Zeatrr$ startswithsubject predicateobjectZurirefZnodeidr r rraddr)r&rr0r1objcontextr)r)r*r%vs       zNQuadsParser.parseline)NF) rr rr rrrrrr)N)rrr,r-)__name__ __module__ __qualname__r+r%r)r)r)r*r/s  DN)__doc__ __future__rcodecsrtypingrrrZrdflib.exceptionsrr Z rdflib.graphrr r Z rdflib.parserr Zrdflib.plugins.parsers.ntriplesr r rZ rdflib.termr__all__strZ_BNodeContextTyperr)r)r)r*s