|
static void | sql_kill (THD *thd, my_thread_id id, bool only_kill_query) |
|
bool | command_satisfy_acl_cache_requirement (unsigned command) |
|
bool | all_tables_not_ok (THD *thd, Table_ref *tables) |
| Returns true if all tables should be ignored. More...
|
|
bool | is_normal_transaction_boundary_stmt (enum_sql_command sql_cmd) |
| This function checks if the sql_command is one that identifies the boundaries (begin, end or savepoint) of a transaction. More...
|
|
bool | is_xa_transaction_boundary_stmt (enum_sql_command sql_cmd) |
| This function checks if the sql_command is one that identifies the boundaries (begin, end or savepoint) of an XA transaction. More...
|
|
bool | check_database_filters (THD *thd, const char *db, enum_sql_command sql_cmd) |
| Checks whether the event for the given database, db, should be ignored or not. More...
|
|
bool | some_non_temp_table_to_be_updated (THD *thd, Table_ref *tables) |
|
bool | stmt_causes_implicit_commit (const THD *thd, uint mask) |
| Returns whether the command in thd->lex->sql_command should cause an implicit commit. More...
|
|
static bool | run_post_replication_filters_actions (THD *thd) |
| Iterates over all post replication filter actions registered and executes them. More...
|
|
static bool | check_and_report_require_row_format_violation (THD *thd) |
| This function determines if the current statement parsed violates the require_row_format check. More...
|
|
void | init_sql_command_flags () |
|
bool | sqlcom_can_generate_row_events (enum enum_sql_command command) |
|
bool | is_update_query (enum enum_sql_command command) |
|
bool | is_explainable_query (enum enum_sql_command command) |
|
bool | is_log_table_write_query (enum enum_sql_command command) |
| Check if a sql command is allowed to write to log tables. More...
|
|
static bool | sqlcom_needs_autocommit_off (const LEX *lex) |
| Check if statement (typically DDL) needs auto-commit mode temporarily turned off. More...
|
|
void | execute_init_command (THD *thd, LEX_STRING *init_command, mysql_rwlock_t *var_lock) |
|
void | free_items (Item *item) |
|
void | cleanup_items (Item *item) |
| This works because items are allocated with (*THR_MALLOC)->Alloc(). More...
|
|
void | bind_fields (Item *first) |
| Bind Item fields to Field objects. More...
|
|
bool | do_command (THD *thd) |
| Read one command from connection and execute it (query or simple command). More...
|
|
static bool | deny_updates_if_read_only_option (THD *thd, Table_ref *all_tables) |
| Determine if an attempt to update a non-temporary table while the read-only option was enabled has been made. More...
|
|
static void | check_secondary_engine_statement (THD *thd, Parser_state *parser_state, const char *query_string, size_t query_length) |
| Check if a failed statement should be restarted in another storage engine, and restart the statement if needed. More...
|
|
void | set_gr_incoming_connection (gr_incoming_connection_cb x) |
|
gr_incoming_connection_cb | get_gr_incoming_connection () |
|
int | call_gr_incoming_connection_cb (THD *thd, int fd, SSL *ssl_ctx) |
| Call the registered GR callback that delegates an incoming connection which is destined to GR. More...
|
|
void | wait_for_gr_connection_end (THD *thd) |
| Wait for a delegated connection to GR, until it ends or GR is shutdown. More...
|
|
static void | copy_bind_parameter_values (THD *thd, PS_PARAM *parameters, unsigned long count) |
| Deep copy the name and value of named parameters into the THD memory. More...
|
|
bool | dispatch_command (THD *thd, const COM_DATA *com_data, enum enum_server_command command) |
| Perform one connection-level (COM_XXXX) command. More...
|
|
bool | shutdown (THD *thd, enum mysql_enum_shutdown_level level) |
| Shutdown the mysqld server. More...
|
|
int | prepare_schema_table (THD *thd, LEX *lex, Table_ident *table_ident, enum enum_schema_tables schema_table_idx) |
| Create a Table_ref object for an INFORMATION_SCHEMA table. More...
|
|
bool | alloc_query (THD *thd, const char *packet, size_t packet_length) |
| Read query from packet and store in thd->query. More...
|
|
static bool | sp_process_definer (THD *thd) |
|
static bool | lock_tables_open_and_lock_tables (THD *thd, Table_ref *tables) |
| Auxiliary call that opens and locks tables for LOCK TABLES statement and initializes the list of locked tables. More...
|
|
static void | binlog_gtid_end_transaction (THD *thd) |
| This is a wrapper for MYSQL_BIN_LOG::gtid_end_transaction. More...
|
|
int | mysql_execute_command (THD *thd, bool first_level) |
| Execute command saved in thd and lex->sql_command. More...
|
|
bool | show_precheck (THD *thd, LEX *lex, bool lock) |
| Do special checking for SHOW statements. More...
|
|
bool | my_yyoverflow (short **yyss, MY_SQL_PARSER_STYPE **yyvs, POS **yyls, ulong *yystacksize) |
|
void | mysql_reset_thd_for_next_command (THD *thd) |
| Reset the part of THD responsible for the state of command processing. More...
|
|
void | statement_id_to_session (THD *thd) |
|
void | dispatch_sql_command (THD *thd, Parser_state *parser_state) |
| Parse an SQL command from a text string and pass the resulting AST to the query executor. More...
|
|
bool | mysql_test_parse_for_slave (THD *thd) |
| Usable by the replication SQL thread only: just parse a query to know if it can be ignored because of replicate-*-table rules. More...
|
|
void | add_to_list (SQL_I_List< ORDER > &list, ORDER *order) |
| save order by and tables in own lists. More...
|
|
static bool | reparse_common_table_expr (THD *thd, const char *text, size_t text_length, uint text_offset, PT_subquery **node) |
| Produces a PT_subquery object from a subquery's text. More...
|
|
Table_ref * | nest_join (THD *thd, Query_block *select, Table_ref *embedding, mem_root_deque< Table_ref * > *jlist, size_t table_cnt, const char *legend) |
| Plumbing for nest_last_join, q.v. More...
|
|
bool | push_new_name_resolution_context (Parse_context *pc, Table_ref *left_op, Table_ref *right_op) |
| Push a new name resolution context for a JOIN ... ON clause to the context stack of a query block. More...
|
|
void | add_join_on (Table_ref *b, Item *expr) |
| Add an ON condition to the second operand of a JOIN ... ON. More...
|
|
const CHARSET_INFO * | get_bin_collation (const CHARSET_INFO *cs) |
|
static uint | kill_one_thread (THD *thd, my_thread_id id, bool only_kill_query) |
| kill on thread. More...
|
|
void | killall_non_super_threads (THD *thd) |
|
bool | prepare_index_and_data_dir_path (THD *thd, const char **data_file_name, const char **index_file_name, const char *table_name) |
| prepares the index and data directory path. More...
|
|
int | append_file_to_dir (THD *thd, const char **filename_ptr, const char *table_name) |
| If pointer is not a null pointer, append filename to it. More...
|
|
Comp_creator * | comp_eq_creator (bool invert) |
|
Comp_creator * | comp_equal_creator (bool invert) |
|
Comp_creator * | comp_ge_creator (bool invert) |
|
Comp_creator * | comp_gt_creator (bool invert) |
|
Comp_creator * | comp_le_creator (bool invert) |
|
Comp_creator * | comp_lt_creator (bool invert) |
|
Comp_creator * | comp_ne_creator (bool invert) |
|
Item * | all_any_subquery_creator (Item *left_expr, chooser_compare_func_creator cmp, bool all, Query_block *query_block) |
| Construct ALL/ANY/SOME subquery Item. More...
|
|
void | create_table_set_open_action_and_adjust_tables (LEX *lex) |
| Set proper open mode and table type for element representing target table of CREATE TABLE statement, also adjust statement table list if necessary. More...
|
|
void | get_default_definer (THD *thd, LEX_USER *definer) |
| Set the specified definer to the default value, which is the current user in the thread. More...
|
|
LEX_USER * | create_default_definer (THD *thd) |
| Create default definer for the specified THD. More...
|
|
LEX_USER * | get_current_user (THD *thd, LEX_USER *user) |
| Returns information about user or current user. More...
|
|
static bool | check_string_byte_length (const LEX_CSTRING &str, const char *err_msg, size_t max_byte_length) |
| Check that byte length of a string does not exceed some limit. More...
|
|
bool | check_string_char_length (const LEX_CSTRING &str, const char *err_msg, size_t max_char_length, const CHARSET_INFO *cs, bool no_error) |
|
int | test_if_data_home_dir (const char *dir) |
|
bool | check_host_name (const LEX_CSTRING &str) |
| Check that host name string is valid. More...
|
|
bool | parse_sql (THD *thd, Parser_state *parser_state, Object_creation_ctx *creation_ctx) |
| Transform an SQL statement into an AST that is ready for resolving, using the supplied parser state and object creation context. More...
|
|
bool | merge_charset_and_collation (const CHARSET_INFO *charset, const CHARSET_INFO *collation, const CHARSET_INFO **to) |
| (end of group Runtime_Environment) More...
|
|
bool | merge_sp_var_charset_and_collation (const CHARSET_INFO *charset, const CHARSET_INFO *collation, const CHARSET_INFO **to) |
|