diff options
Diffstat (limited to 'storage/innobase/include/que0que.h')
| -rw-r--r-- | storage/innobase/include/que0que.h | 20 |
1 files changed, 19 insertions, 1 deletions
diff --git a/storage/innobase/include/que0que.h b/storage/innobase/include/que0que.h index 4e31e2db4b7..c3314a1167b 100644 --- a/storage/innobase/include/que0que.h +++ b/storage/innobase/include/que0que.h @@ -277,6 +277,15 @@ que_node_get_parent( /*================*/ /* out: parent node or NULL */ que_node_t* node); /* in: node */ +/******************************************************************** +Get the first containing loop node (e.g. while_node_t or for_node_t) for the +given node, or NULL if the node is not within a loop. */ + +que_node_t* +que_node_get_containing_loop_node( +/*==============================*/ + /* out: containing loop node, or NULL. */ + que_node_t* node); /* in: node */ /************************************************************************* Catenates a query graph node to a list of them, possible empty list. */ UNIV_INLINE @@ -322,8 +331,15 @@ void que_node_print_info( /*================*/ que_node_t* node); /* in: query graph node */ +/************************************************************************* +Evaluate the given SQL */ - +ulint +que_eval_sql( +/*=========*/ + pars_info_t* info, /* out: error code or DB_SUCCESS */ + const char* sql, /* in: info struct, or NULL */ + trx_t* trx); /* in: trx */ /* Query graph query thread node: the fields are protected by the kernel mutex with the exceptions named below */ @@ -388,6 +404,7 @@ struct que_fork_struct{ sym_tab_t* sym_tab; /* symbol table of the query, generated by the parser, or NULL if the graph was created 'by hand' */ + pars_info_t* info; /* in: info struct, or NULL */ /* The following cur_... fields are relevant only in a select graph */ ulint cur_end; /* QUE_CUR_NOT_DEFINED, QUE_CUR_START, @@ -469,6 +486,7 @@ struct que_fork_struct{ #define QUE_NODE_ROW_PRINTF 29 #define QUE_NODE_ELSIF 30 #define QUE_NODE_CALL 31 +#define QUE_NODE_EXIT 32 /* Query thread states */ #define QUE_THR_RUNNING 1 |