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
|
/* Copyright (c) 2008, 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 */
#ifndef LOCKED_TABLES_LIST_INCLUDED
#define LOCKED_TABLES_LIST_INCLUDED
#include <sys/types.h>
#include <vector>
#include "my_alloc.h"
#include "sql/psi_memory_key.h"
#include "sql/sql_const.h"
struct MYSQL_LOCK;
class MDL_context;
class MDL_ticket;
struct TABLE;
class Table_ref;
class THD;
/**
Type of locked tables mode.
See comment for THD::locked_tables_mode for complete description.
While adding new enum values add them to the getter method for this enum
declared below and defined in binlog.cc as well.
*/
enum enum_locked_tables_mode {
LTM_NONE = 0,
LTM_LOCK_TABLES,
LTM_PRELOCKED,
LTM_PRELOCKED_UNDER_LOCK_TABLES
};
#ifndef NDEBUG
/**
Getter for the enum enum_locked_tables_mode
@param locked_tables_mode enum for types of locked tables mode
@return The string representation of that enum value
*/
const char *get_locked_tables_mode_name(
enum_locked_tables_mode locked_tables_mode);
#endif
/**
Tables that were locked with LOCK TABLES statement.
Encapsulates a list of Table_ref instances for tables
locked by LOCK TABLES statement, memory root for metadata locks,
and, generally, the context of LOCK TABLES statement.
In LOCK TABLES mode, the locked tables are kept open between
statements.
Therefore, we can't allocate metadata locks on execution memory
root -- as well as tables, the locks need to stay around till
UNLOCK TABLES is called.
The locks are allocated in the memory root encapsulated in this
class.
Some SQL commands, like FLUSH TABLE or ALTER TABLE, demand that
the tables they operate on are closed, at least temporarily.
This class encapsulates a list of Table_ref instances, one
for each base table from LOCK TABLES list,
which helps conveniently close the TABLEs when it's necessary
and later reopen them.
*/
class Locked_tables_list {
private:
MEM_ROOT m_locked_tables_root{key_memory_locked_table_list,
MEM_ROOT_BLOCK_SIZE};
Table_ref *m_locked_tables;
Table_ref **m_locked_tables_last;
/** An auxiliary array used only in reopen_tables(). */
TABLE **m_reopen_array;
/**
Count the number of tables in m_locked_tables list. We can't
rely on thd->lock->table_count because it excludes
non-transactional temporary tables. We need to know
an exact number of TABLE objects.
*/
size_t m_locked_tables_count;
struct MDL_ticket_pair {
MDL_ticket *m_src;
MDL_ticket *m_dst;
};
using MDL_ticket_pairs = std::vector<MDL_ticket_pair>;
MDL_ticket_pairs m_rename_tablespace_mdls;
public:
Locked_tables_list();
void unlock_locked_tables(THD *thd);
~Locked_tables_list() {
unlock_locked_tables(nullptr);
assert(m_rename_tablespace_mdls.empty());
}
bool init_locked_tables(THD *thd);
Table_ref *locked_tables() const { return m_locked_tables; }
void unlink_from_list(const THD *thd, Table_ref *table_list,
bool remove_from_locked_tables);
void unlink_all_closed_tables(THD *thd, MYSQL_LOCK *lock,
size_t reopen_count);
bool reopen_tables(THD *thd);
void rename_locked_table(Table_ref *old_table_list, const char *new_db,
const char *new_table_name,
MDL_ticket *target_mdl_ticket);
void add_rename_tablespace_mdls(MDL_ticket *src, MDL_ticket *dst);
void adjust_renamed_tablespace_mdls(MDL_context *mctx);
void discard_renamed_tablespace_mdls() { m_rename_tablespace_mdls.clear(); }
};
#endif /*not defined LOCK_TABLES_LIST_INCLUDED */
|
