Viewing file:  event_data_objects.h (4.09 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
#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) override;
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) override;
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) override;
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_ */
|