Pf(ddlmZddlmZddlmZddlmZddlm Z m Z dZ dZ d Z d Zd Zd Zd ZdZGddZGddeZdS)) DataError) ResponseError)VersionMismatchException) ExecutionPlan)AsyncQueryResult QueryResultz GRAPH.PROFILEzGRAPH.RO_QUERYz GRAPH.QUERYz GRAPH.DELETEz GRAPH.SLOWLOGz GRAPH.CONFIGz GRAPH.LISTz GRAPH.EXPLAINcbeZdZdZdZddZdZdZdZd Z d Z d Z dd Z d Z ddZddZdS) GraphCommandszRedisGraph Commandscvt|jdkrt|jdkrdSd}|jD]\}}|t |dzz }|dd|jDz }|ddkr |dd}||S)z& Create entire graph. rNzCREATE ,c,g|]}t|S)str).0edges O/var/www/html/env/lib/python3.11/site-packages/redis/commands/graph/commands.py z(GraphCommands.commit.. s<<<3t99<<<)lennodesedgesitemsrjoinquery)selfr_nodes rcommitzGraphCommands.commits tz??a  C OOq$8$84z'')) % %GAt SYY_ $EE <<<<<=== 9  #2#JEzz%   rNFcR|}|||z}|rt}n|rtnt}||j|dg}t |t r|d|gn|td |j |} t|| |S#t$r8} dt| vr |r| |||dcYd} ~ S| d} ~ wt$rB} | 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 rqparamsr#r'profilercmdcommandresponsees rrzGraphCommands.query(sy*))&11E9  ;CC"+:,,C 5+6 gs # # K NNIw/ 0 0 0 0  IJJ J =+t+W5HtXw77 7    CFF**y*zz!VWzFFFFFFFFG' = = =9DL  " " "::a)<< < < < < < <  =s6?B D&$+CD&C D&$7D!D&!D&cTd}|t|z }||S)z Merge pattern. zMERGE )rr)rpatternrs rmergezGraphCommands.mergebs+ Wzz%   rcj||t|jS)z| Deletes graph. For more information see `DELETE `_. # noqa ) _clear_schemar1 DELETE_CMDr,rs rdeletezGraphCommands.deleteks. ##J :::rcJ|i|_g|_dSzT Commit the graph and reset the edges and the nodes to zero length. Nr rrrBs rflushzGraphCommands.flushts#   rc td)zInternal only. Not supported.zVGRAPH.BULK is internal only. Use https://github.com/redisgraph/redisgraph-bulk-loader.)NotImplementedError)rkwargss rbulkzGraphCommands.bulk|s! H   rc0||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)r7)r)rrs rr7zGraphCommands.profileszz%z...rcB|t|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. )r1 SLOWLOG_CMDr,rBs rslowlogzGraphCommands.slowlogs##K;;;rc|rdnd|g}|'|r||ntd|jtg|RS)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. SETGETNz3``value`` can be provided only when ``set`` is True)appendrr1 CONFIG_CMD)rr,valuesetr6s rconfigzGraphCommands.configsl)%%E40    e$$$$I$t#J88888rc6|tS)z Lists all graph keys in the keyspace. For more information see `GRAPH.LIST `_. # noqa )r1LIST_CMDrBs r list_keyszGraphCommands.list_keyss ##H---rc|||z}|t|j|}t |dt r d|D}d|S) 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 rc6g|]}|Srdecoderbs rrz0GraphCommands.execution_plan.. ---1AHHJJ---r r(r1 EXPLAIN_CMDr,r-bytesrrrr6plans rexecution_planzGraphCommands.execution_plansn))&11E9##KEBB d1gu % % .-----Dyyrc|||z}|t|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(r1rer,rrgs rexplainzGraphCommands.explainsC))&11E9##KEBBT"""rNNFF)NFN)__name__ __module__ __qualname____doc__r rr>rCrGrKr7rOrWrZrirlrrrr r s!!!&8=8=8=8=t!!!;;;   /// < < <99990... # # # # # #rr c,eZdZddZddZddZdZdS) AsyncGraphCommandsNFcK|}|||z}|rt}n|rtnt}||j|dg}t |t r|d|gn|td |j |d{V} t || |d{VS#t$r>} dt| vr&|r$||||dd{VcYd} ~ S| d} ~ wt$rH} | j|_||||||d{VcYd} ~ Sd} ~ wwxYw)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. r"r#Nr$r%Fr&)r(r)r*r+r,r-r.r/r0r1r initializerrrrr2r3r4s rrzAsyncGraphCommands.querys*))&11E9  ;CC"+:,,C 5+6 gs # # K NNIw/ 0 0 0 0  IJJ J C1T17;;;;;;;H)++66tXwOOOOOOOO O    CFF**y*!ZZ67eZLLLLLLLLLLLLLLG' C C C9DL  " " "Avw BBBBBBBB B B B B B B  Cs68B:: E1C=5E;C== E =E E EcK|||z}|t|j|d{V}t |dt r d|D}d|S)r\Nrc6g|]}|Srr^r`s rrz5AsyncGraphCommands.execution_plan.."rbrrcrdrgs rriz!AsyncGraphCommands.execution_plans))&11E9))+ty%HHHHHHHH d1gu % % .-----DyyrcK|||z}|t|j|d{V}t |S)z Get the execution plan for given query, GRAPH.EXPLAIN returns ExecutionPlan object. Args: query: the query that will be executed params: query parameters Nrkrgs rrlzAsyncGraphCommands.explain%sY))&11E9))+ty%HHHHHHHHT"""rcZK|d{Vi|_g|_dSrErFrBs rrGzAsyncGraphCommands.flush3s:kkmm  rrmrn)rorprqrrirlrGrrrrtrtsd8C8C8C8Ct # # # #rrtN)redisrredis.exceptionsr exceptionsrrir query_resultrr r)r*r+rArNrTrYrer rtrrrrs******000000))))))77777777       E#E#E#E#E#E#E#E#P__________r