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
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
|
#ifndef SQL_TRIGGER_INCLUDED
#define SQL_TRIGGER_INCLUDED
/*
Copyright (c) 2004, 2025, Oracle and/or its affiliates.
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License, version 2.0,
as published by the Free Software Foundation.
This program is designed to work with certain software (including
but not limited to OpenSSL) that is licensed under separate terms,
as designated in a particular file or component or in included license
documentation. The authors of MySQL hereby grant you an additional
permission to link the program and your derivative works with the
separately licensed software that they have either included with
the program or referenced in the documentation.
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, version 2.0, 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-1301 USA */
///////////////////////////////////////////////////////////////////////////
/**
@file
@brief
This file contains declarations of global public functions which are used
directly from parser/executioner to perform basic operations on triggers
(CREATE TRIGGER, DROP TRIGGER, ALTER TABLE, DROP TABLE, ...)
*/
///////////////////////////////////////////////////////////////////////////
#include "lex_string.h"
#include "my_psi_config.h"
#include "my_sqlcommand.h" // SQLCOM_CREATE_TRIGGER, SQLCOM_DROP_TRIGGER
#include "sql/mdl.h" // enum_mdl_type
#include "sql/sql_cmd.h" // Sql_cmd
class THD;
struct TABLE;
class Table_ref;
namespace dd {
class Table;
}
///////////////////////////////////////////////////////////////////////////
/**
Find trigger's table from trigger identifier.
@param[in] thd Thread context.
@param[in] db_name Schema name.
@param[in] trigger_name Trigger name.
@param[in] continue_if_not_exist true if SQL statement contains
"IF EXISTS" clause. That means a warning
instead of error should be thrown if trigger
with given name does not exist.
@param[out] table Pointer to Table_ref object for the
table trigger.
@return Operation status
@retval false On success.
@retval true Otherwise.
*/
bool get_table_for_trigger(THD *thd, const LEX_CSTRING &db_name,
const LEX_STRING &trigger_name,
bool continue_if_not_exist, Table_ref **table);
/**
Check for table with triggers that old database name and new database name
are the same. This functions is called while handling the statement
RENAME TABLE to ensure that table moved within the same database.
@param[in] db_name Schema name.
@param[in] table Table.
@param[in] new_db_name New schema name
@note
Set error ER_TRG_IN_WRONG_SCHEMA in Diagnostics_area in case
function returns true.
@return Operation status
@retval false Either there is no triggers assigned to a table or
old and new schema name are the same.
@retval true Old and new schema name aren't the same.
*/
bool check_table_triggers_are_not_in_the_same_schema(const char *db_name,
const dd::Table &table,
const char *new_db_name);
/**
Acquire either exclusive or shared MDL lock for a trigger
in specified schema.
@param[in] thd Current thread context
@param[in] db Schema name
@param[in] trg_name Trigger name
@param[in] trigger_name_mdl_type Type of MDL to acquire for trigger name
@return Operation status.
@retval false Success
@retval true Failure
*/
bool acquire_mdl_for_trigger(THD *thd, const char *db, const char *trg_name,
enum_mdl_type trigger_name_mdl_type);
/**
Acquire exclusive MDL lock for a trigger in specified schema.
@param[in] thd Current thread context
@param[in] db Schema name
@param[in] trg_name Trigger name
@return Operation status.
@retval false Success
@retval true Failure
*/
bool acquire_exclusive_mdl_for_trigger(THD *thd, const char *db,
const char *trg_name);
/**
Acquire shared MDL lock for a trigger in specified schema.
@param[in] thd Current thread context
@param[in] db Schema name
@param[in] trg_name Trigger name
@return Operation status.
@retval false Success
@retval true Failure
*/
inline bool acquire_shared_mdl_for_trigger(THD *thd, const char *db,
const char *trg_name) {
return acquire_mdl_for_trigger(thd, db, trg_name, MDL_SHARED_HIGH_PRIO);
}
/**
Drop statistics from performance schema for every trigger
associated with a table.
@param schema_name Name of schema containing the table.
@param table Table reference, for that associated
triggers statistics has to be deleted.
*/
#ifdef HAVE_PSI_SP_INTERFACE
void remove_all_triggers_from_perfschema(const char *schema_name,
const dd::Table &table);
#endif
///////////////////////////////////////////////////////////////////////////
/**
This class has common code for CREATE/DROP TRIGGER statements.
*/
class Sql_cmd_ddl_trigger_common : public Sql_cmd {
public:
/**
Set a table associated with a trigger.
@param trigger_table a table associated with a trigger.
*/
void set_table(Table_ref *trigger_table) { m_trigger_table = trigger_table; }
protected:
Sql_cmd_ddl_trigger_common() : m_trigger_table(nullptr) {}
bool check_trg_priv_on_subj_table(THD *thd, Table_ref *table) const;
TABLE *open_and_lock_subj_table(THD *thd, Table_ref *tables,
MDL_ticket **mdl_ticket) const;
/**
Restore original state of meta-data locks.
@param thd current thread context
@param mdl_ticket granted metadata lock
*/
void restore_original_mdl_state(THD *thd, MDL_ticket *mdl_ticket) const;
Table_ref *m_trigger_table{nullptr};
};
/**
This class implements the CREATE TRIGGER statement.
*/
class Sql_cmd_create_trigger : public Sql_cmd_ddl_trigger_common {
public:
/**
Return the command code for CREATE TRIGGER
*/
enum_sql_command sql_command_code() const final {
return SQLCOM_CREATE_TRIGGER;
}
bool execute(THD *thd) final;
};
/**
This class implements the DROP TRIGGER statement.
*/
class Sql_cmd_drop_trigger : public Sql_cmd_ddl_trigger_common {
public:
/**
Return the command code for DROP TRIGGER
*/
enum_sql_command sql_command_code() const final {
return SQLCOM_DROP_TRIGGER;
}
bool execute(THD *thd) final;
};
#endif /* SQL_TRIGGER_INCLUDED */
|
