NgQ).ddlmZddlmZmZmZmZerddlZdddddZed d zZ ed d zZ ed d zZ ed d zZ eded zdzZ ed edzdzZed edzdzZGddZdS)) annotations) TYPE_CHECKINGDictListOptionalNz-PREFIX owl: z:PREFIX rdf: z5PREFIX rdfs: z0PREFIX xsd: )owlrdfrdfsxsdr zeSELECT DISTINCT ?cls ?com WHERE { ?instance a ?cls . OPTIONAL { ?cls rdfs:comment ?com } }zvSELECT DISTINCT ?cls ?com WHERE { ?instance a/rdfs:subClassOf* ?cls . OPTIONAL { ?cls rdfs:comment ?com } }zSELECT DISTINCT ?cls ?com WHERE { ?instance a/rdfs:subClassOf* ?cls . FILTER (isIRI(?cls)) . OPTIONAL { ?cls rdfs:comment ?com } }zdSELECT DISTINCT ?rel ?com WHERE { ?subj ?rel ?obj . OPTIONAL { ?rel rdfs:comment ?com } }r z|SELECT DISTINCT ?rel ?com WHERE { ?rel a/rdfs:subPropertyOf* rdf:Property . OPTIONAL { ?rel rdfs:comment ?com } }rzSELECT DISTINCT ?op ?com WHERE { ?op a/rdfs:subPropertyOf* owl:ObjectProperty . OPTIONAL { ?op rdfs:comment ?com } }zSELECT DISTINCT ?dp ?com WHERE { ?dp a/rdfs:subPropertyOf* owl:DatatypeProperty . OPTIONAL { ?dp rdfs:comment ?com } }c|eZdZdZ dd dZed!dZd"dZd#dZe d$dZ d%dZ d&dZ dS)'RdfGraphaRDFlib wrapper for graph operations. Modes: * local: Local file - can be queried and changed * online: Online file - can only be queried, changes can be stored locally * store: Triple store - can be queried and changed if update_endpoint available Together with a source file, the serialization should be specified. *Security note*: Make sure that the database connection uses credentials that are narrowly-scoped to only include necessary permissions. Failure to do so may result in data corruption or loss, since the calling code may attempt commands that would result in deletion, mutation of data if appropriately prompted or reading sensitive data if such data is present in the database. The best way to guard against such negative outcomes is to (as appropriate) limit the permissions granted to the credentials used with this tool. See https://python.langchain.com/docs/security for more information. Nttlr source_file Optional[str] serializationquery_endpointupdate_endpointstandard local_copy graph_kwargsOptional[Dict] store_kwargsreturnNonec ~||_||_||_||_||_||_ ddl} ddlm} n#t$rtdwxYw|jdx} vrtd| d|s|r|r|s|rtd|rl| d rd |_ nd |_ |j |j|_| j |_|j||j |r|pi}d |_ |s-| jdi||_|j|n.| jdi||_|j||f|pi}| j |jfi||_t)|jst+dd|_|dS)a Set up the RDFlib graph :param source_file: either a path for a local file or a URL :param serialization: serialization of the input :param query_endpoint: SPARQL endpoint for queries, read access :param update_endpoint: SPARQL endpoint for UPDATE queries, write access :param standard: RDF, RDFS, or OWL :param local_copy: new local copy for storing changes :param graph_kwargs: Additional rdflib.Graph specific kwargs that will be used to initialize it, if query_endpoint is provided. :param store_kwargs: Additional sparqlstore.SPARQLStore specific kwargs that will be used to initialize it, if query_endpoint is provided. rN) sparqlstorezTCould not import rdflib python package. Please install it with `pip install rdflib`.)r r rz+Invalid standard. Supported standards are: .zCould not unambiguously initialize the graph wrapper. Specify either a file (local or online) via the source_file or a triple store via the endpoints.httponlinelocal)formatstorezThe graph is empty.)rrrrrrrdflibrdflib.plugins.storesr ImportError ValueError startswithmodeGraphgraphparse SPARQLStore_storeopenSPARQLUpdateStorelenAssertionErrorschema load_schema) selfrrrrrrrrr%rsupported_standardss `/var/www/html/ai-engine/env/lib/python3.11/site-packages/langchain_community/graphs/rdf_graph.py__init__zRdfGraph.__init__osk6'*,.  $  MMM 9 9 9 9 9 9 9   ?   =8N!N!4 O OT>QTTT   "   $3  7   E%%f-- 7$ # ?*&*&6DO%DJ J  [1C  D D D  C'-2LDI" D5k5EE EE    0000;k;KKlKK    ./!BCCC'-2L%dkBB\BBDJ4: 8 !677 7  s 7Astrc|jS)z; Returns the schema of the graph database. )r4)r6s r8 get_schemazRdfGraph.get_schemas {queryList[rdflib.query.ResultRow]cddlm}ddlm |j|}n#|$r}t d|d}~wwxYwfd|DS)z" Query the graph. r ParserError) ResultRow&Generated SPARQL statement is invalid Nc4g|]}t||Sr$) isinstance).0rrCs r8 z"RdfGraph.query..s(;;;a*Q ":":;;;;r=)rdflib.exceptionsrB rdflib.queryrCr,r>r()r6r>rBreserCs @r8r>zRdfGraph.querys 211111****** O*""5))CC O O OM!MMNN N O;;;;3;;;;s*AAAc2ddlm} |j|n#|$r}t d|d}~wwxYw|jrA|j|j|jdddSt d) z# Update the graph. rrArDNr) destinationr!z5No target file specified for saving the updated file.)rJrBr,updater(r serializesplit)r6r>rBrMs r8rQzRdfGraph.updates 211111 O J  e $ $ $ $ O O OM!MMNN N O ? V J  ODO4I4I#4N4Nr4R !     TUU Us#?:?iricd|vr|dd}n3d|vr|dd}ntd|d|S)N#rO/zUnexpected IRI 'z ', contains neither '#' nor '/'.)rSr()rT local_names r8_get_local_namezRdfGraph._get_local_names` #::3+JJ CZZ3+JJUUUUVV Vr=rLrdflib.query.ResultRowvarcdt||zdz|||zdzt|dzdzS)N (, com))r:rY)r6rLr[s r8 _res_to_strzRdfGraph._res_to_strsh #c(mm  ""3s8,, -   #e*oo      r=c dfd }jdkrGt}t}|||_dSjdkrGt }t }|||_dSjd krt}t}t}d d fd |Dd d fd|Ddd fd|Dd_dStdjd)z4 Load the graph schema information. classesr? relationshipsrr:cddfd|Dddfd|DdS)NzIn the following, each IRI is followed by the local name and optionally its description in parentheses. The RDF graph supports the following node types: r^c<g|]}|dSclsrarGrHr6s r8rIz?RdfGraph.load_schema.._rdf_s_schema..s)JJJQd..q%88JJJr=z5 The RDF graph supports the following relationships: c<g|]}|dS)relrirjs r8rIz?RdfGraph.load_schema.._rdf_s_schema..s)PPPQd..q%88PPPr= )join)rcrdr6s r8 _rdf_s_schemaz+RdfGraph.load_schema.._rdf_s_schema sx V99JJJJ'JJJKKVV 99PPPP-PPPQQ VVV r=r r rzIn the following, each IRI is followed by the local name and optionally its description in parentheses. The OWL graph supports the following node types: r^c<g|]}|dSrgrirjs r8rIz(RdfGraph.load_schema..*s)GGGQd..q%88GGGr=z^ The OWL graph supports the following object properties, i.e., relationships between objects: c<g|]}|dS)oprirjs r8rIz(RdfGraph.load_schema..-)EEEAd..q$77EEEr=zi The OWL graph supports the following data properties, i.e., relationships between objects and literals: c<g|]}|dS)dprirjs r8rIz(RdfGraph.load_schema..0rsr=rmzMode 'z' is currently not supported.N)rcr?rdr?rr:) rr> cls_query_rdf rel_query_rdfr4cls_query_rdfsrel_query_rdfs cls_query_owl op_query_owl dp_query_owlrnr()r6roclssrelsopsdpss` r8r5zRdfGraph.load_schemas       =E ! !::m,,D::m,,D'-d33DKKK ]f $ $::n--D::n--D'-d33DKKK ]e # #::m,,D**\**C**\**C K99GGGG$GGGHH K K 99EEEEEEEFF K K99EEEEEEEFF K K K KKKRdmRRRSS Sr=)NrNNr NNN)rrrrrrrrrrrrrrrrrr)rr:)r>r:rr?)r>r:rr)rTr:rr:)rLrZr[r:rr:)rr) __name__ __module__ __qualname____doc__r9propertyr<r>rQ staticmethodrYrar5r$r=r8r r Zs,&*',(,)-"'$('+'+WWWWWrX <<<< VVVV(\     +T+T+T+T+T+Tr=r ) __future__rtypingrrrrr%prefixesrvrxrzrwryr{r|r r$r=r8rs""""""MMM @ L H B      &!        UOv  Vuo   Vuo  YTYTYTYTYTYTYTYTYTYTr=