+h(ddlmZddlmZddlmZddlmZddlm Z m Z dZ dZ d Z d Zd Zd Zd ZdZGddZGddeZy)) DataError) ResponseError)VersionMismatchException) ExecutionPlan)AsyncQueryResult QueryResultz GRAPH.PROFILEzGRAPH.RO_QUERYz GRAPH.QUERYz GRAPH.DELETEz GRAPH.SLOWLOGz GRAPH.CONFIGz GRAPH.LISTz GRAPH.EXPLAINc`eZdZdZdZddZdZdZdZdZ d Z d Z dd Z d Z dd ZddZy) GraphCommandszRedisGraph Commandsc ~t|jdk(rt|jdk(ryd}|jjD]\}}|t |dzz }|dj |jDcgc] }t |c}z }|ddk(r|dd}|j |Scc}w)z& Create entire graph. rNzCREATE ,)lennodesedgesitemsstrjoinquery)selfr_nodeedges P/var/www/html/venv/lib/python3.12/site-packages/redis/commands/graph/commands.pycommitzGraphCommands.commits tzz?a C Oq$8zz'') %GAt SY_ $E % <3t9<== 9 #2JEzz%  =sB: Nc|}|j||z}|rt}n|rtnt}||j|dg}t |t r|jd|gn | td |j|} t|| |S#t$r0} dt| vr|r|j|||dcYd} ~ S| d} ~ wt$r?} | j|_|j!|j||||cYd} ~ Sd} ~ wwxYw)a Executes a query against the graph. For more information see `GRAPH.QUERY `_. # noqa Args: q : str The query. params : dict Query parameters. timeout : int Maximum runtime for read queries in milliseconds. read_only : bool Executes a readonly query if set to True. profile : bool Return details on results produced by and time spent in each operation. --compacttimeoutN+Timeout argument must be a positive integerunknown commandF read_only)_build_params_header PROFILE_CMD RO_QUERY_CMD QUERY_CMDname isinstanceintextend Exceptionexecute_commandr rrrrversion_refresh_schema rqparamsrr"profilercmdcommandresponsees rrzGraphCommands.query(s *))&1E9 C"+,C 5+6 gs # NNIw/ 0  IJ J =+t++W5HtXw7 7  CF*yzz!VWzFFG' =99DL  "::a)< <  =s60B D #C8D >C D  4DD D cDd}|t|z }|j|S)z Merge pattern. zMERGE )rr)rpatternrs rmergezGraphCommands.mergebs& Wzz%  cb|j|jt|jS)z| Deletes graph. For more information see `DELETE `_. # noqa ) _clear_schemar, DELETE_CMDr'rs rdeletezGraphCommands.deleteks' ##J ::r:c@|ji|_g|_yzT Commit the graph and reset the edges and the nodes to zero length. Nrrrr>s rflushzGraphCommands.flushts   r:c td)zInternal only. Not supported.zVGRAPH.BULK is internal only. Use https://github.com/redisgraph/redisgraph-bulk-loader.)NotImplementedError)rkwargss rbulkzGraphCommands.bulk|s! H  r:c(|j|dS)ar Execute a query and produce an execution plan augmented with metrics for each operation's execution. Return a string representation of a query execution plan, with details on results produced by and time spent in each operation. For more information see `GRAPH.PROFILE `_. # noqa T)r2)r)rrs rr2zGraphCommands.profileszz%z..r:cB|jt|jS)a Get a list containing up to 10 of the slowest queries issued against the given graph ID. For more information see `GRAPH.SLOWLOG `_. # noqa Each item in the list has the following structure: 1. A unix timestamp at which the log entry was processed. 2. The issued command. 3. The issued query. 4. The amount of time needed for its execution, in milliseconds. )r, SLOWLOG_CMDr'r>s rslowlogzGraphCommands.slowlogs##K;;r:c|rdnd|g}||r|j|n td|jtg|S)a Retrieve or update a RedisGraph configuration. For more information see `https://redis.io/commands/graph.config-get/>`_. # noqa Args: name : str The name of the configuration value : The value we want to set (can be used only when `set` is on) set : bool Turn on to set a configuration. Default behavior is get. SETGETz3``value`` can be provided only when ``set`` is True)appendrr, CONFIG_CMD)rr'valuesetr1s rconfigzGraphCommands.configsQ%E40   e$I$t##J888r:c,|jtS)z Lists all graph keys in the keyspace. For more information see `GRAPH.LIST `_. # noqa )r,LIST_CMDr>s r list_keyszGraphCommands.list_keyss ##H--r:c|j||z}|jt|j|}t |dt r|Dcgc]}|j }}dj|Scc}w) Get the execution plan for given query, GRAPH.EXPLAIN returns an array of operations. Args: query: the query that will be executed params: query parameters r r#r, EXPLAIN_CMDr'r(bytesdecoderrrr1planbs rexecution_planzGraphCommands.execution_plansk))&1E9##KEB d1gu %(,-1AHHJ-D-yy.s A7c|j||z}|jt|j|}t |S)a8 Get the execution plan for given query, GRAPH.EXPLAIN returns ExecutionPlan object. For more information see `GRAPH.EXPLAIN `_. # noqa Args: query: the query that will be executed params: query parameters r#r,r[r'rrrr1r_s rexplainzGraphCommands.explains<))&1E9##KEBT""r:NNFF)NFN)__name__ __module__ __qualname____doc__rrr9r?rCrGr2rKrSrVrarer:rr r sB!&8=t!; / <90. #r:r c*eZdZddZddZddZdZy)AsyncGraphCommandsNcK|}|j||z}|rt}n|rtnt}||j|dg}t |t r|jd|gn | td |j|d{} tj|| |d{S7'7#t$r9} dt| vr%|r#|j|||dd{7cYd} ~ S| d} ~ wt$rH} | j |_|j#|j||||d{7cYd} ~ Sd} ~ wwxYww)a1 Executes a query against the graph. For more information see `GRAPH.QUERY `_. # noqa Args: q : str The query. params : dict Query parameters. timeout : int Maximum runtime for read queries in milliseconds. read_only : bool Executes a readonly query if set to True. profile : bool Return details on results produced by and time spent in each operation. rrNrr Fr!)r#r$r%r&r'r(r)r*r+r,r initializerrrrr-r.r/s rrzAsyncGraphCommands.querys5*))&1E9 C"+,C 5+6 gs # NNIw/ 0  IJ J C1T117;;H)+66tXwOO O<O  CF*y!ZZ67eZLLLLG' C99DL  "Avw BBB B  CsA/E2B0B,"B0'B.(B0+E,B0.B00 E9'C- C#!C-%E&E+C-- E98D<1D42D<6E7E<EEcK|j||z}|jt|j|d{}t |dt r|Dcgc]}|j }}dj|S7Ecc}ww)rXNrrYrZr^s rraz!AsyncGraphCommands.execution_plansv))&1E9))+tyy%HH d1gu %(,-1AHHJ-D-yyI-s!9BBBB.BBcK|j||z}|jt|j|d{}t |S7w)z Get the execution plan for given query, GRAPH.EXPLAIN returns ExecutionPlan object. Args: query: the query that will be executed params: query parameters Nrcrds rrezAsyncGraphCommands.explain%sI))&1E9))+tyy%HHT""Is9A A A c\K|jd{i|_g|_y7wrArBr>s rrCzAsyncGraphCommands.flush3s*kkm   s ,*,rfrg)rhrirjrrarerCrlr:rrnrns8Ct #r:rnN)redisrredis.exceptionsr exceptionsrrar query_resultrr r$r%r&r=rJrPrUr[r rnrlr:rrxsW*0)7       E#E#P__r: