summaryrefslogtreecommitdiffstats
path: root/sql/event_data_objects.h
diff options
context:
space:
mode:
Diffstat (limited to 'sql/event_data_objects.h')
-rw-r--r--sql/event_data_objects.h207
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_ */