20
20
#ifndef DRIZZLE_SERVER_SQL_PARSE_H
21
21
#define DRIZZLE_SERVER_SQL_PARSE_H
23
bool begin_trans(THD *thd);
24
bool end_active_trans(THD *thd);
25
int end_trans(THD *thd, enum enum_mysql_completiontype completion);
27
bool execute_sqlcom_select(THD *thd, TableList *all_tables);
28
bool multi_update_precheck(THD *thd, TableList *tables);
29
bool multi_delete_precheck(THD *thd, TableList *tables);
30
int mysql_multi_update_prepare(THD *thd);
31
int mysql_multi_delete_prepare(THD *thd);
32
bool mysql_insert_select_prepare(THD *thd);
33
bool update_precheck(THD *thd, TableList *tables);
34
bool delete_precheck(THD *thd, TableList *tables);
35
bool insert_precheck(THD *thd, TableList *tables);
36
bool create_table_precheck(THD *thd, TableList *tables,
25
#include <drizzled/definitions.h>
26
#include <drizzled/common.h>
27
#include <drizzled/lex_string.h>
28
#include <drizzled/comp_creator.h>
30
#include <mystrings/m_ctype.h>
34
class Lex_input_stream;
39
typedef class Select_Lex Select_Lex;
41
bool execute_sqlcom_select(Session *session, TableList *all_tables);
42
bool multi_update_precheck(Session *session, TableList *tables);
43
bool multi_delete_precheck(Session *session, TableList *tables);
44
int mysql_multi_update_prepare(Session *session);
45
int mysql_multi_delete_prepare(Session *session);
46
bool mysql_insert_select_prepare(Session *session);
47
bool update_precheck(Session *session, TableList *tables);
48
bool delete_precheck(Session *session, TableList *tables);
49
bool insert_precheck(Session *session, TableList *tables);
50
bool create_table_precheck(Session *session, TableList *tables,
37
51
TableList *create_table);
38
bool parse_sql(THD *thd, class Lex_input_stream *lip);
52
bool parse_sql(Session *session, Lex_input_stream *lip);
40
Item *negate_expression(THD *thd, Item *expr);
54
Item *negate_expression(Session *session, Item *expr);
42
56
bool test_if_data_home_dir(const char *dir);
44
bool check_identifier_name(LEX_STRING *str, uint32_t max_char_length,
45
uint32_t err_code, const char *param_for_err_msg);
46
inline bool check_identifier_name(LEX_STRING *str, uint32_t err_code)
48
return check_identifier_name(str, NAME_CHAR_LEN, err_code, "");
50
inline bool check_identifier_name(LEX_STRING *str)
52
return check_identifier_name(str, NAME_CHAR_LEN, 0, "");
58
bool check_identifier_name(LEX_STRING *str, uint32_t err_code= 0,
59
uint32_t max_char_length= NAME_CHAR_LEN,
60
const char *param_for_err_msg= "");
55
62
bool check_string_byte_length(LEX_STRING *str, const char *err_msg,
56
63
uint32_t max_byte_length);
58
65
uint32_t max_char_length, const CHARSET_INFO * const cs,
69
void mysql_parse(Session *session, const char *inBuf, uint32_t length,
70
const char ** semicolon);
72
bool mysql_test_parse_for_slave(Session *session, char *inBuf,
75
bool is_update_query(enum enum_sql_command command);
77
void mysql_reset_session_for_next_command(Session *session);
79
void create_select_for_variable(const char *var_name);
81
void mysql_init_multi_delete(LEX *lex);
83
bool multi_delete_set_locks_and_link_aux_tables(LEX *lex);
85
void init_update_queries(void);
87
bool dispatch_command(enum enum_server_command command, Session *session,
88
char* packet, uint32_t packet_length);
90
void log_slow_statement(Session *session);
92
bool append_file_to_dir(Session *session, const char **filename_ptr,
93
const char *table_name);
95
bool reload_cache(Session *session, ulong options, TableList *tables);
97
bool check_simple_select();
99
void mysql_init_select(LEX *lex);
100
bool mysql_new_select(LEX *lex, bool move_down);
102
int prepare_schema_table(Session *session, LEX *lex, Table_ident *table_ident,
103
enum enum_schema_tables schema_table_idx);
105
Item * all_any_subquery_creator(Item *left_expr,
106
chooser_compare_func_creator cmp,
108
Select_Lex *select_lex);
61
110
#endif /* DRIZZLE_SERVER_SQL_PARSE_H */