Adding upstream version 1:10.11.6.upstream/1%10.11.6upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

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_ */