diff options
Diffstat (limited to '')
| -rw-r--r-- | sql/event_data_objects.h | 207 |
1 files changed, 207 insertions, 0 deletions
diff --git a/sql/event_data_objects.h b/sql/event_data_objects.h new file mode 100644 index 00000000..c51d5433 --- /dev/null +++ b/sql/event_data_objects.h @@ -0,0 +1,207 @@ +#ifndef _EVENT_DATA_OBJECTS_H_ +#define _EVENT_DATA_OBJECTS_H_ +/* Copyright (c) 2004, 2010, Oracle and/or its affiliates. All rights reserved. + + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; version 2 of the License. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1335 USA */ + +/** + @addtogroup Event_Scheduler + @{ + + @file event_data_objects.h +*/ + +#include "event_parse_data.h" +#include "thr_lock.h" /* thr_lock_type */ + +class Field; +class THD; +class Time_zone; +struct TABLE; + +void init_scheduler_psi_keys(void); + +class Event_queue_element_for_exec +{ +public: + Event_queue_element_for_exec() : dbname{nullptr, 0}, name{nullptr, 0} {} + ~Event_queue_element_for_exec(); + + bool + init(const LEX_CSTRING &dbname, const LEX_CSTRING &name); + + LEX_CSTRING dbname; + LEX_CSTRING name; + bool dropped; + THD *thd; + +private: + /* Prevent use of these */ + Event_queue_element_for_exec(const Event_queue_element_for_exec &); + void operator=(Event_queue_element_for_exec &); +#ifdef HAVE_PSI_INTERFACE +public: + PSI_statement_info* get_psi_info() + { + return & psi_info; + } + + static PSI_statement_info psi_info; +#endif +}; + + +class Event_basic +{ +protected: + MEM_ROOT mem_root; + +public: + + LEX_CSTRING dbname; + LEX_CSTRING name; + LEX_CSTRING definer;// combination of user and host + + Time_zone *time_zone; + + Event_basic(); + virtual ~Event_basic(); + + virtual bool + load_from_row(THD *thd, TABLE *table) = 0; + +protected: + bool + load_string_fields(Field **fields, ...); + + bool + load_time_zone(THD *thd, const LEX_CSTRING *tz_name); +}; + + + +class Event_queue_element : public Event_basic +{ +public: + int on_completion; + int status; + uint32 originator; + + my_time_t last_executed; + my_time_t execute_at; + my_time_t starts; + my_time_t ends; + bool starts_null; + bool ends_null; + bool execute_at_null; + + longlong expression; + interval_type interval; + + bool dropped; + + uint execution_count; + + Event_queue_element(); + virtual ~Event_queue_element(); + + virtual bool + load_from_row(THD *thd, TABLE *table); + + bool + compute_next_execution_time(); + + void + mark_last_executed(THD *thd); +}; + + +class Event_timed : public Event_queue_element +{ + Event_timed(const Event_timed &); /* Prevent use of these */ + void operator=(Event_timed &); + +public: + LEX_CSTRING body; + + LEX_CSTRING definer_user; + LEX_CSTRING definer_host; + + LEX_CSTRING comment; + + ulonglong created; + ulonglong modified; + + sql_mode_t sql_mode; + + class Stored_program_creation_ctx *creation_ctx; + LEX_CSTRING body_utf8; + + Event_timed(); + virtual ~Event_timed(); + + void + init(); + + virtual bool + load_from_row(THD *thd, TABLE *table); + + int + get_create_event(THD *thd, String *buf); +}; + + +class Event_job_data : public Event_basic +{ +public: + LEX_CSTRING body; + LEX_CSTRING definer_user; + LEX_CSTRING definer_host; + + sql_mode_t sql_mode; + + class Stored_program_creation_ctx *creation_ctx; + + Event_job_data(); + + virtual bool + load_from_row(THD *thd, TABLE *table); + + bool + execute(THD *thd, bool drop); +private: + bool + construct_sp_sql(THD *thd, String *sp_sql); + bool + construct_drop_event_sql(THD *thd, String *sp_sql); + + Event_job_data(const Event_job_data &); /* Prevent use of these */ + void operator=(Event_job_data &); +}; + + +/* Compares only the schema part of the identifier */ +bool +event_basic_db_equal(const LEX_CSTRING *db, Event_basic *et); + +/* Compares the whole identifier*/ +bool +event_basic_identifier_equal(const LEX_CSTRING *db, const LEX_CSTRING *name, + Event_basic *b); + +/** + @} (End of group Event_Scheduler) +*/ + +#endif /* _EVENT_DATA_OBJECTS_H_ */ |