1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
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_ */
|
