dh*LSSKJr SSKJrJrJrJr SSKJrJ r "SS5r g))md5)AnyDictListTuple) GraphDocument Relationshipc \rSrSrSrSS\S\S\SS4Sjjr\ S\4S j5r 04S \S \ S\ \ \\44S jjrSS jrSSjrS\SS4SjrS\SS4SjrSS\ \S\ \\\\4S\SS4SjjrSrg) KuzuGraphuKùzu wrapper for graph operations. *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. dbdatabaseallow_dangerous_requestsreturnNcUSLa [S5eSSKnXlUR UR5UlX lUR5 g![a [S5ef=f)u0Initializes the Kùzu graph database connection.TzThe KuzuGraph class is a powerful tool that can be used to execute arbitrary queries on the database. To enable this functionality, set the `allow_dangerous_requests` parameter to `True` when constructing the KuzuGraph object.rNuSCould not import Kùzu python package.Please install Kùzu with `pip install kuzu`.) ValueErrorkuzu ImportErrorr Connectionconnrrefresh_schema)selfr rrrs ]/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/graphs/kuzu_graph.py__init__KuzuGraph.__init__sv $4 /5    OODGG,    @  s AA)cUR$)u(Returns the schema of the Kùzu database)schemars r get_schemaKuzuGraph.get_schema/s{{queryparamscURRX5nUR5n/nUR5(aJUR 5nUR [ [XF555 UR5(aMJU$)uQuery Kùzu database)rexecuteget_column_nameshas_nextget_nextappenddictzip)rr"r#result column_names return_listrows rr"KuzuGraph.query4sq""51..0  oo//#C   tC $:; <oor!c /nURR5nUHn/US.nURRU5nUHmnXVSnSnXVSS:a<SXV;aXVSH n USU S3- nM O[XVS5Hn US - nM Xx- nUS R UU45 Mo UR U5 M /n URR 5n U H'n U R S U S S U SSU SS35 M) /nU Hn U Sn/US.nURR SUS35nUR5(aGUR5nUSnUSnUS R UU45 UR5(aMGUR U5 M SUSUSU S3Ul g)u,Refreshes the Kùzu graph schema information) propertieslabeltype dimensionrshape[]z[]r2z(:srcz)-[:namez]->(:dst)zCALL table_info('z ') RETURN *;zNode properties: z Relationships properties: z Relationships:  N) r_get_node_table_names_get_node_property_namesranger)_get_rel_table_namesr%r'r(r)rnode_propertiesnode_table_names table_namecurrent_table_schemar2 property_name property_typelist_type_flagsi relationships rel_tablestablerel_properties query_resultr/ prop_name prop_types rrKuzuGraph.refresh_schema>s,99::<*J24z#J ;;JGJ!+ * 9& A !#,[9A=*";;!+!:7!CA*!Ah6N"D"'z'@'M!NA*d2N"O/ $\299%%","  " "#7 8)+, YY335 E  U5\N$uV}oU5<.J  EvJ24z#J 99,,#J<|<L''))"++-F F $\2999i:PQ ''))  ! !"6 7  01))7(89+_B 0 r!c:URRS5 g)Nz CREATE NODE TABLE IF NOT EXISTS Chunk ( id STRING, text STRING, type STRING, PRIMARY KEY(id) ); rr%rs r_create_chunk_node_table"KuzuGraph._create_chunk_node_tabless   r! node_labelcBURRSUS35 g)Nz- CREATE NODE TABLE IF NOT EXISTS zv ( id STRING, type STRING, PRIMARY KEY(id) ); rW)rrZs r_create_entity_node_table#KuzuGraph._create_entity_node_tables( --7L9   r!relc URRSURSURRSURRS35 g)Nz, CREATE REL TABLE IF NOT EXISTS z ( FROM z TO z ); )rr%r4sourcetarget)rr^s r!_create_entity_relationship_table+KuzuGraph._create_entity_relationship_tablesN ,,/HH:6jjoo&d3::??*;<   r!graph_documentsallowed_relationshipsinclude_sourcec <[UVVs1sH oDRHoURiM M" snn5nUGHnU(aUR5 URR R S5(dS[URRRS55R5URR S'URRSURR SURRS.S9 UHnURU5 M URGHnURRSURS3SUR0S9 U(dMAUR5 Sn/n UHnU RS U35 M [[!U 55n US R#U 5- nUS - nU(aURRU5 URU;dMURRS URS 3URR SURS.S9 GM" UR$Hn UR'U 5 U RRn U RRn U R(Rn U R(RnURRSU SU SU RS3U US.S9 M GM gs snnf)u Adds a list of `GraphDocument` objects that represent nodes and relationships in a graph to a Kùzu backend. Parameters: - graph_documents (List[GraphDocument]): A list of `GraphDocument` objects that contain the nodes and relationships to be added to the graph. Each `GraphDocument` should encapsulate the structure of part of the graph, including nodes, relationships, and the source document information. - allowed_relationships (List[Tuple[str, str, str]]): A list of allowed relationships that exist in the graph. Each tuple contains three elements: the source node type, the relationship type, and the target node type. Required for Kùzu, as the names of the relationship tables that need to pre-exist are derived from these tuples. - include_source (bool): If True, stores the source document and links it to nodes in the graph using the `MENTIONS` relationship. This is useful for tracing back the origin of data. Merges source documents based on the `id` property from the source document metadata if available; otherwise it calculates the MD5 hash of `page_content` for merging process. Defaults to False. idzutf-8z MERGE (c:Chunk {id: $id}) SET c.text = $text, c.type = "text_chunk" )rhtext) parametersz MERGE (e:zN {id: $id}) SET e.type = "entity" z/CREATE REL TABLE GROUP IF NOT EXISTS MENTIONS (zFROM Chunk TO z, z), label STRING, triplet_source_id STRING)z] MATCH (c:Chunk {id: $id}), (e:z {id: $node_id}) MERGE (c)-[m:MENTIONS]->(e) SET m.triplet_source_id = $id )rhnode_idz MATCH (e1:z4 {id: $source_id}), (e2:z4 {id: $target_id}) MERGE (e1)-[:z]->(e2) ) source_id target_idN)listnodesr4rXr`metadatagetr page_contentencode hexdigestrr%r\rhr)setjoinrNrbra)rrdrerfdocumentnode node_labelsrZddl table_namesr^ source_labelrl target_labelrms radd_graph_documentsKuzuGraph.add_graph_documentss<'6 R8>>4YY>Y R (H--///33D9958 44;;GD6ikOO,,T2 !! 'oo66t< ( < <  " * ..z:*! !!"ii[)!%dgg "">113KC"$K&1 #**^J<+HI'2"&s;'7"8K499[11CFFC ))#.yyK/ ))!&&*ii[1 '/oo&>&>t&D+/77(* 3'N --66s;"zz JJMM "zz JJMM  !!+n-!!-/""%((, &/%.  " .E( Ss&L )rrr r)rF)rN)F)__name__ __module__ __qualname____firstlineno____doc__rstrboolrpropertyrr*rrr"rrXr\r rbrrr~__static_attributes__r!rr r s QV!$IM 2C023d4S>6J3 j    C  D   \ d  % um,u $E#sC-$89u u  uur!r N) hashlibrtypingrrrr)langchain_community.graphs.graph_documentrr r rr!rrs))QAAr!