3 d*%@sddlmZddlmZddlmZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z ddl m Z ddlmZd d d d d gZGdd d eZGdddeZGdd d eZGdddeZGdddeZGdd d eZGdd d eZGdd d eZdS))absolute_import)division)print_functionN)BytesIO)PY2) text_type)urlparse ProcessorResult ResultParserResultSerializerResultExceptionc@s(eZdZdZddZiidfddZdS)r z Query plugin interface. This module is useful for those wanting to write a query processor that can plugin to rdf. If you are wanting to execute a query you likely want to do so through the Graph class query method. cCsdS)N)selfgraphrr./tmp/pip-build-7vycvbft/rdflib/rdflib/query.py__init__szProcessor.__init__FcCsdS)Nr)r strOrQuery initBindingsinitNsDEBUGrrrquery"szProcessor.queryN)__name__ __module__ __qualname____doc__rrrrrrr sc@s&eZdZdZddZiifddZdS)UpdateProcessora! Update plugin interface. This module is useful for those wanting to write an update processor that can plugin to rdflib. If you are wanting to execute an update statement you likely want to do so through the Graph class update method. .. versionadded:: 4.0 cCsdS)Nr)rrrrrr3szUpdateProcessor.__init__cCsdS)Nr)rrrrrrrupdate6szUpdateProcessor.updateN)rrrrrrrrrrr&s rc@s eZdZdS)r N)rrrrrrrr :sc@s(eZdZdZddZddZddZdS) EncodeOnlyUnicodezR This is a crappy work-around for http://bugs.python.org/issue11649 cCs ||_dS)N)_EncodeOnlyUnicode__stream)rstreamrrrrFszEncodeOnlyUnicode.__init__cCs.t|tr|jj|jdn |jj|dS)Nzutf-8) isinstancerrwriteencode)rargrrrr"Is zEncodeOnlyUnicode.writecCs t|j|S)N)getattrr)rnamerrr __getattr__OszEncodeOnlyUnicode.__getattr__N)rrrrrr"r'rrrrr>srcsBeZdZdZfddZddZddZd d d Zd d ZZ S) ResultRowa a single result row allows accessing bindings as attributes or with [] >>> from rdflib import URIRef, Variable >>> rr=ResultRow({ Variable('a'): URIRef('urn:cake') }, [Variable('a')]) >>> rr[0] rdflib.term.URIRef(u'urn:cake') >>> rr[1] Traceback (most recent call last): ... IndexError: tuple index out of range >>> rr.a rdflib.term.URIRef(u'urn:cake') >>> rr.b Traceback (most recent call last): ... AttributeError: b >>> rr['a'] rdflib.term.URIRef(u'urn:cake') >>> rr['b'] Traceback (most recent call last): ... KeyError: 'b' >>> rr[Variable('a')] rdflib.term.URIRef(u'urn:cake') .. versionadded:: 4.0 cs<tt|j|fdd|D}tddt|D|_|S)Nc3s|]}j|VqdS)N)get).0v)valuesrr zsz$ResultRow.__new__..css"|]}t|d|dfVqdS)rN)r)r*xrrrr-{s)superr(__new__dict enumeratelabels)clsr,r4instance) __class__)r,rr1ws  zResultRow.__new__cCs$||jkrt|tj||j|S)N)r4AttributeErrortuple __getitem__)rr&rrrr's zResultRow.__getattr__c Csny tj||Stk rh||jkr8tj||j|St||jkr\tj||jt|St|YnXdS)N)r9r: TypeErrorr4rKeyError)rr&rrrr:s  zResultRow.__getitem__Nc Cs"y||Stk r|SXdS)N)r<)rr&defaultrrrr)sz ResultRow.getcstfddjDS)Nc3s&|]}|dk r||fVqdS)Nr)r*r+)rrrr-sz#ResultRow.asdict..)r2r4)rr)rrasdictszResultRow.asdict)N) rrrrr1r'r:r)r> __classcell__rr)r7rr(Ss "  r(c@s~eZdZdZddZddZddZeeedd Ze dd d Z dddZ ddZ ddZ erbe ZddZddZddZd S)r a A common class for representing query result. There is a bit of magic here that makes this appear like different Python objects, depending on the type of result. If the type is "SELECT", iterating will yield lists of ResultRow objects If the type is "ASK", iterating will yield a single bool (or bool(result) will return the same bool) If the type is "CONSTRUCT" or "DESCRIBE" iterating will yield the triples. len(result) also works. cCs<|dkrtd|||_d|_d|_d|_d|_d|_dS)N CONSTRUCTDESCRIBESELECTASKzUnknown Result type: %s)r@rArBrC)r typevars _bindings _genbindings askAnswerr)rtype_rrrrs zResult.__init__cCs&|jr |jt|j7_d|_|jS)N)rGrFlist)rrrr _get_bindingsszResult._get_bindingscCs*t|tjtjfr ||_g|_n||_dS)N)r!types GeneratorType itertoolsislicerGrF)rbrrr _set_bindingsszResult._set_bindingsz$a list of variable bindings as dicts)docNcKsTddlm}|r|}n|r,|jddd}nd}|j|t}|j|fd|i|S)Nr)plugin;r.xml content_type)rdflibrSsplitr)r parse)sourceformatrVkwargsrSZ plugin_keyparserrrrrYs z Result.parseutf-8rUcKs0|jd kr$|jj|f||d|Sddlm}|j|t|}|dkrtt}t|}|j|fd|i||j St |dr|}|j|fd|i|n|} t | \} } } } }}| dkrt ddSt j\}}tj|d }|j|fd|i||jt td rtj|| ntj|| tj|dS)Nr@rA)encodingr[r)rSr_r"zWARNING: not saving as locationzis not a local file referencewbmove)r@rAz..)r9rE)r*)r)rPr (sz&Result.__getattr__..z!'%s' object has no attribute '%s')r@rA)rDrr'warningswarnDeprecationWarningryr8)rr&r)rrr's zResult.__getattr__c CshyX|j|jkrdS|jdkr(|j|jkS|jdkrJ|j|jkoH|j|jkS|j|jkSWn dSdS)NFrCrB)rDrHrEryr)rotherrrr__eq__-s      z Result.__eq__)NNN)Nr^rU)rrrrrrKrQpropertyry staticmethodrYrcrzr{r __nonzero__r~r'rrrrrr s     "c@seZdZddZddZdS)r cCsdS)Nr)rrrrr?szResultParser.__init__cKsdS)zreturn a Result objectNr)rrZr\rrrrYBszResultParser.parseN)rrrrrYrrrrr =sc@seZdZddZdddZdS)r cCs ||_dS)N)r)rrrrrrIszResultSerializer.__init__utf-8cKsdS)z#return a string properly serializedNr)rr r_r\rrrrcLszResultSerializer.serializeN)r)rrrrrcrrrrr Gs) __future__rrrrirNrlrgrrLsixrrrZsix.moves.urllib.parser__all__objectr r Exceptionr rr9r(r r r rrrrs.       E&