kÿa))rddlZddlZddlZddlZddlZddlZddlmZmZm Z m Z m Z m Z ddl mZddlmZgdZer ddlmZddlmZGdd eZGd d eZGd d eZGddeZGddeZGddeZGddeZGddeZ dS)N)IO TYPE_CHECKINGListOptionalUnioncast)BytesIO)urlparse) ProcessorResult ResultParserResultSerializerResultException)Graph)Variablec&eZdZdZdZiidfdZdS)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. cdSNselfgraphs ./usr/lib/python3/dist-packages/rdflib/query.py__init__zProcessor.__init__ FcdSrr)r strOrQuery initBindingsinitNsDEBUGs rqueryzProcessor.query!rrN)__name__ __module__ __qualname____doc__rr"rrrr r sJ   .0%      rr c$eZdZdZdZiifdZdS)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 cdSrrrs rrzUpdateProcessor.__init__2rrcdSrr)rrrr s rupdatezUpdateProcessor.update5rrN)r#r$r%r&rr+rrrr(r(%sH     /1      rr(ceZdZdS)rN)r#r$r%rrrrr9sDrrc$eZdZdZdZdZdZdS)EncodeOnlyUnicodezR This is a crappy work-around for http://bugs.python.org/issue11649 c||_dSr)_EncodeOnlyUnicode__stream)rstreams rrzEncodeOnlyUnicode.__init__Es  rct|tr/|j|ddS|j|dS)Nutf-8) isinstancestrr0writeencode)rargs rr6zEncodeOnlyUnicode.writeHsX c3   % M   7 3 3 4 4 4 4 4 M   $ $ $ $ $rc,t|j|Sr)getattrr0rnames r __getattr__zEncodeOnlyUnicode.__getattr__Nst}d+++rN)r#r$r%r&rr6r=rrrr.r.=sK%%% ,,,,,rr.c<eZdZdZfdZdZdZddZdZxZ 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 ctt||fd|D}tdt |D|_|S)Nc3BK|]}|VdSr)get).0vvaluess r z$ResultRow.__new__..xs-6U6Uvzz!}}6U6U6U6U6U6Urc3PK|]!}t|d|dfV"dS)rN)r5)rCxs rrFz$ResultRow.__new__..ys5LLQAaD 1Q40LLLLLLr)superr?__new__dict enumeratelabels)clsrErNinstance __class__s ` rrKzResultRow.__new__vscC((006U6U6U6Uf6U6U6UVVLL)F:K:KLLLLLrc~||jvrt|t||j|Sr)rNAttributeErrortuple __getitem__r;s rr=zResultRow.__getattr__|s: t{ " " && &  t{4'8999rcl t||S#t$r||jvr(t||j|cYSt ||jvr5t||jt |cYSt |wxYwr)rTrU TypeErrorrNr5KeyErrorr;s rrUzResultRow.__getitem__s !$$T400 0 ! ! !t{""((t{4/@AAAAA4yyDK''((t{3t99/EFFFFF4..  !s9B3A B3#B3Nc8 ||S#t$r|cYSwxYwr)rX)rr<defaults rrBz ResultRow.gets5 :    NNN s  cDtfdjDS)Nc3<K|]}| ||fVdSrr)rCrDrs rrFz#ResultRow.asdict..s4MMQa9LQQL9L9L9L9LMMr)rLrNrs`rasdictzResultRow.asdicts(MMMM$+MMMMMMrr) r#r$r%r&rKr=rUrBr^ __classcell__)rQs@rr?r?Rs!!F ::: !!! NNNNNNNrr?c eZdZdZdefdZdZdZeeedZ e dd e ed e efd Z dde e eefded ede efdZdZdZdZdZdZdS)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. type_c|dvrtd|z||_d|_d|_d|_d|_d|_dS)N) CONSTRUCTDESCRIBESELECTASKzUnknown Result type: %s)rtypevars _bindings _genbindings askAnswerr)rras rrzResult.__init__sQ B B B!";e"CDD D 04  #" rcp|jr)|xjt|jz c_d|_|jSr)rjrilistr]s r _get_bindingszResult._get_bindingss8   % NNd4#455 5NN $D ~rct|tjtjfr||_g|_dS||_dSr)r4types GeneratorType itertoolsislicerjri)rbs r _set_bindingszResult._set_bindingss= a%-y/?@ A A  !D DNNNDNNNrz$a list of variable bindings as dicts)docNformat content_typec ddlm}|r|}n!|r|ddd}nd}||t}|j|fd|i|S)Nrplugin;rHxmlrx)rdflibr{splitrBr parse)sourcerwrxkwargsr{ plugin_keyparsers rrz Result.parses "!!!!!  JJ  %++C33A6JJJ5J 5577v|FHHHHHHrr3r} destinationencodingreturnc l|jdvr|jj|f||d|S ddlm}||t |}|At}t|}|j|fd|i|| St|dr1ttt|} |j| fd|i|ntt|} t| \} } } }}}| dkrt!d dSt#j\}}t'j|d } |j| fd|i|| tt,d rt-j|| n)t-j|| t'j|dS) a Serialize the query result. The :code:`format` argument determines the Serializer class to use. - csv: :class:`~rdflib.plugins.sparql.results.csvresults.CSVResultSerializer` - json: :class:`~rdflib.plugins.sparql.results.jsonresults.JSONResultSerializer` - txt: :class:`~rdflib.plugins.sparql.results.txtresults.TXTResultSerializer` - xml: :class:`~rdflib.plugins.sparql.results.xmlresults.XMLResultSerializer` :param destination: Path of file output or BufferedIOBase object to write the output to. :param encoding: Encoding of output. :param format: One of ['csv', 'json', 'txt', xml'] :param args: :return: bytes rcrd)rrwrrzNrr6z !t99q= rc#bK|jdvr|jD]}|VdS|jdkr |jVdS|jdkrp|jrF|jD]5}|r1|j|t ||jV6d|_dS|jD]}|rt ||jVdSdS)Nrrfre)rgrrkrjriappendr?rh)rtrts r__iter__zResult.__iter__#s 91 1 1Z     Y%  . Y( " " 6*66A6--a000'4955555$(!!!66A6'4955555# "66rcjdvr"jj|Sjdkr5|dkr/tjdt dfdjDStdd |d) NrreresultzPaccessing the 'result' attribute is deprecated. Iterate over the object instead.) stacklevelcRg|]"tfdjD#S)c3(K|] }|V dSrr)rCrDrts rrFz0Result.__getattr__...Bs'33A1Q4333333r)rTrh)rCrtrs @r z&Result.__getattr__..Bs9LLLU333333333LLLr'z' object has no attribute ')rgrr=warningswarnDeprecationWarningrrSr;s` rr=zResult.__getattr__7s 91 1 1dj6L:))$55 5 Y( " "tx'7'7 M4"     MLLLdmLLL L .ddd!STT Trc |j|jkrdS|jdkr|j|jkS|jdkr |j|jko|j|jkS|j|jkS#YdSxYw)NFrfre)rgrkrhrr)rothers r__eq__z Result.__eq__Fs yEJ&&uyE!!~88h&&yEJ.R4=EN3RRzU[00 55sA*A**A*A**A/)NNN)Nr3r})r#r$r%r&r5rrnrupropertyr staticmethodrrrrrrrrrr=rrrrr r sp$ #c # # # #x}*PH $&*II IsmIII\I*15 99eCGn-99 9 % 9999v###!!! 666( U U U     rr ceZdZdZdZdS)r cdSrrr]s rrzResultParser.__init__Urrc dS)zreturn a Result objectNr)rrrs rrzResultParser.parseX rN)r#r$r%rrrrrr r Ts2        rr c,eZdZdefdZddedefdZdS) rrc||_dSr)r)rrs rrzResultSerializer.__init__^s  rr3r1rc dS)z#return a string properly serializedNr)rr1rrs rrzResultSerializer.serializearrN)r3)r#r$r%r rrr5rrrrrr]sVv   c      rr)!rrrrrrrptypingrrrrrrior urllib.parser __all__ rdflib.graphr rdflib.termrobjectr r( Exceptionrr.rTr?r r rrrrrs=   AAAAAAAAAAAAAAAA!!!!!! X X X%""""""$$$$$$        "     f   (     i   ,,,,,,,,*@N@N@N@N@N@N@N@NF|||||V|||~     6        v     r