MySQL 9.6.0
Source Code Documentation
sql_table.h
Go to the documentation of this file.
1/* Copyright (c) 2006, 2025, Oracle and/or its affiliates.
2
3 This program is free software; you can redistribute it and/or modify
4 it under the terms of the GNU General Public License, version 2.0,
5 as published by the Free Software Foundation.
6
7 This program is designed to work with certain software (including
8 but not limited to OpenSSL) that is licensed under separate terms,
9 as designated in a particular file or component or in included license
10 documentation. The authors of MySQL hereby grant you an additional
11 permission to link the program and your derivative works with the
12 separately licensed software that they have either included with
13 the program or referenced in the documentation.
14
15 This program is distributed in the hope that it will be useful,
16 but WITHOUT ANY WARRANTY; without even the implied warranty of
17 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 GNU General Public License, version 2.0, for more details.
19
20 You should have received a copy of the GNU General Public License
21 along with this program; if not, write to the Free Software
22 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
23
24#ifndef SQL_TABLE_INCLUDED
25#define SQL_TABLE_INCLUDED
26
27#include <stddef.h>
28#include <sys/types.h>
29
30#include <map>
31#include <set>
32#include <string>
33#include <utility>
34#include <vector>
35
36#include "my_inttypes.h"
37#include "my_sharedlib.h"
39#include "mysqld_error.h"
40#include "sql/dd/string_type.h"
41#include "sql/handler.h"
42#include "sql/mdl.h"
43
44class Alter_info;
45class Alter_table_ctx;
46class Create_field;
47class FOREIGN_KEY;
48class KEY;
49class THD;
50class handler;
51struct CHARSET_INFO;
52struct MEM_ROOT;
53struct TABLE;
54class Table_ref;
55struct handlerton;
56
57namespace dd {
58class Foreign_key;
59class Schema;
60class Table;
61class View;
62} // namespace dd
63
64struct HA_CHECK_OPT;
65struct HA_CREATE_INFO;
66
68template <typename T>
69class List;
70
75};
76
77/* Flags for conversion functions. */
78static const uint FN_FROM_IS_TMP = 1 << 0;
79static const uint FN_TO_IS_TMP = 1 << 1;
81/** Don't check foreign key constraints while renaming table */
82static const uint NO_FK_CHECKS = 1 << 2;
83/**
84 Don't commit transaction after updating data-dictionary while renaming
85 the table.
86*/
87static const uint NO_DD_COMMIT = 1 << 3;
88/** Don't change generated foreign key names while renaming table. */
89static const uint NO_FK_RENAME = 1 << 4;
90/** Don't change generated check constraint names while renaming table. */
91static const uint NO_CC_RENAME = 1 << 5;
92
94 const HA_CREATE_INFO &ci);
95
96size_t filename_to_tablename(const char *from, char *to, size_t to_length,
97 bool stay_quiet = false,
98 bool *has_errors = nullptr);
99size_t tablename_to_filename(const char *from, char *to, size_t to_length);
100size_t build_table_filename(char *buff, size_t bufflen, const char *db,
101 const char *table, const char *ext, uint flags,
102 bool *was_truncated);
103// For caller's who are mostly sure that path do not truncate
104size_t inline build_table_filename(char *buff, size_t bufflen, const char *db,
105 const char *table, const char *ext,
106 uint flags) {
107 bool truncated_not_used;
108 return build_table_filename(buff, bufflen, db, table, ext, flags,
109 &truncated_not_used);
110}
111size_t build_tmptable_filename(THD *thd, char *buff, size_t bufflen);
113 HA_CREATE_INFO *create_info, Alter_info *alter_info);
114bool mysql_create_table_no_lock(THD *thd, const char *db,
115 const char *table_name,
116 HA_CREATE_INFO *create_info,
117 Alter_info *alter_info, uint select_field_count,
118 bool find_parent_keys, bool *is_trans,
119 handlerton **post_ddl_ht);
121
122/**
123 Helper class for keeping track for which tables we need to invalidate
124 data-dictionary cache entries and performing such invalidation.
125*/
127 public:
131 };
132
133 private:
134 typedef std::map<std::pair<dd::String_type, dd::String_type>,
135 std::pair<handlerton *, enum_invalidation_type>>
138
139 public:
140 void add(
141 const char *db_name, const char *table_name, handlerton *hton,
143 // Usually tables added to a Foreign_key_parents_invalidator instance are
144 // closed by the invalidate member function. However, occasionally tables
145 // are added that we subsequently discover should only be invalidated and
146 // not closed by the invalidate member function as they will be closed
147 // elsewhere.
148 // See bool Query_result_create::send_eof(THD *thd) for an example.
149 // The mark_for_reopen_if_added member function updates the
150 // corresponding Parent_map entry if necessary in this situation.
151 void mark_for_reopen_if_added(const char *db_name, const char *table_name);
152 void invalidate(THD *thd);
153 const Parent_map &parents() const { return m_parent_map; }
154 bool is_empty() const { return m_parent_map.empty(); }
155 void clear() { m_parent_map.clear(); }
156};
157
158/**
159 Auxiliary class implementing RAII principle for getting permission for/
160 notification about finished DDL statements from interested storage engines.
161
162 @see handlerton::ha_notify_table_ddl for details.
163*/
165 public:
167 THD *thd, const MDL_key *key, ha_ddl_type ddl_type,
168 const char *old_db_name = nullptr, const char *old_table_name = nullptr,
169 const char *new_db_name = nullptr,
170 const char *new_table_name = nullptr) noexcept
171 : m_hton_notified(false),
172 m_thd(thd),
173 m_key(*key),
174 m_ddl_type(ddl_type),
175 m_old_db_name(old_db_name),
176 m_old_table_name(old_table_name),
177 m_new_db_name(new_db_name),
178 m_new_table_name(new_table_name) {}
179
180 [[nodiscard]] bool notify() noexcept {
184 m_hton_notified = true;
185 return false;
186 }
187 my_error(ER_LOCK_REFUSED_BY_ENGINE, MYF(0));
188 return true;
189 }
190
192 if (m_hton_notified)
196 }
197
198 private:
203 const char *m_old_db_name;
204 const char *m_old_table_name;
205 const char *m_new_db_name;
206 const char *m_new_table_name;
207};
208
209/*
210 Reload the foreign key parent information of the referenced
211 tables and for the table itself.
212
213 @param thd Thread handle.
214 @param db Table schema name.
215 @param name Table name.
216 @param reload_self Reload FK parent info also for the
217 table itself.
218 @param fk_invalidator Object keeping track of which dd::Table
219 objects to invalidate. If submitted, use this
220 to restrict which FK parents should have their
221 FK parent information reloaded.
222
223 @retval operation outcome, false if no error.
224*/
225bool adjust_fk_parents(THD *thd, const char *db, const char *name,
226 bool reload_self,
227 const Foreign_key_parents_invalidator *fk_invalidator);
228
229/**
230 Check if new definition of parent table is compatible with foreign keys
231 which reference it. Update the unique constraint names and referenced
232 column names for the foreign keys accordingly.
233
234 @param thd Thread handle.
235 @param check_charsets Indicates whether we need to check charsets of
236 columns participating in foreign keys.
237 @param parent_table_db Parent table schema name.
238 @param parent_table_name Parent table name.
239 @param hton Handlerton for table's storage engine.
240 @param parent_table_def Table object representing the referenced table.
241 @param parent_alter_info Alter_info containing information about renames
242 of parent columns. Can be nullptr if there are
243 no such renames.
244 @param invalidate_tdc Indicates whether we need to invalidate TDC for
245 referencing tables after updating their
246 definitions.
247
248 @retval operation outcome, false if no error.
249*/
251 THD *thd, bool check_charsets, const char *parent_table_db,
252 const char *parent_table_name, handlerton *hton,
253 const dd::Table *parent_table_def, Alter_info *parent_alter_info,
254 bool invalidate_tdc);
255
256/**
257 Check if new definition of parent table is compatible with foreign keys
258 which reference it. Update the unique constraint names and referenced
259 column names for the foreign keys accordingly. Do mandatory character
260 set checks and TDC invalidation.
261*/
263 THD *thd, const char *parent_table_db, const char *parent_table_name,
264 handlerton *hton, const dd::Table *parent_table_def,
265 Alter_info *parent_alter_info) {
267 thd, true, parent_table_db, parent_table_name, hton, parent_table_def,
268 parent_alter_info, true);
269}
270
271/**
272 Add MDL requests for specified lock type on all tables referencing the given
273 schema qualified table name to the list.
274
275 @param thd Thread handle.
276 @param schema Schema name.
277 @param table_name Table name.
278 @param hton Handlerton for table's storage engine.
279 @param lock_type Type of MDL requests to add.
280 @param[in,out] mdl_requests List to which MDL requests are to be added.
281
282 @retval operation outcome, false if no error.
283*/
284[[nodiscard]] bool collect_fk_children(THD *thd, const char *schema,
285 const char *table_name, handlerton *hton,
286 enum_mdl_type lock_type,
287 MDL_request_list *mdl_requests);
288
289/**
290 Add MDL requests for lock of specified type on tables referenced by the
291 foreign keys to be added by the CREATE TABLE or ALTER TABLE operation.
292 Also add the referenced table names to the foreign key invalidator,
293 to be used at a later stage to invalidate the dd::Table objects.
294
295 @param thd Thread handle.
296 @param db_name Table's database name.
297 @param table_name Table name.
298 @param alter_info Alter_info object with the list of FKs
299 to be added.
300 @param lock_type Type of metadata lock to be requested.
301 @param hton Handlerton for table's storage engine.
302 @param[in,out] mdl_requests List to which MDL requests are to be added.
303 @param[in,out] fk_invalidator Object keeping track of which dd::Table
304 objects to invalidate.
305
306 @retval operation outcome, false if no error.
307*/
308[[nodiscard]] bool collect_fk_parents_for_new_fks(
309 THD *thd, const char *db_name, const char *table_name,
310 const Alter_info *alter_info, enum_mdl_type lock_type, handlerton *hton,
311 MDL_request_list *mdl_requests,
312 Foreign_key_parents_invalidator *fk_invalidator);
313
314/**
315 Add MDL requests for exclusive metadata locks on names of foreign keys
316 to be added by the CREATE TABLE or ALTER TABLE operation.
317
318 @param thd Thread context.
319 @param db_name Table's database name.
320 @param table_name Table name.
321 @param alter_info Alter_info object with the
322 list of FKs to be added.
323 @param hton Table's storage engine.
324 @param fk_max_generated_name_number Max value of number component
325 among existing generated foreign
326 key names.
327 @param[in,out] mdl_requests List to which MDL requests
328 are to be added.
329
330 @retval operation outcome, false if no error.
331*/
332bool collect_fk_names_for_new_fks(THD *thd, const char *db_name,
333 const char *table_name,
334 const Alter_info *alter_info,
335 handlerton *hton,
336 uint fk_max_generated_name_number,
337 MDL_request_list *mdl_requests);
338
339/**
340 Acquire exclusive metadata locks on tables which definitions need to
341 be updated or invalidated since they are related through foreign keys
342 to the table to be renamed,
343 Also add the referenced table names for the FKs on this table to the
344 foreign key invalidator, to be used at a later stage to invalidate the
345 dd::Table objects.
346
347 @param thd Thread handle.
348 @param db Table's old schema.
349 @param table_name Table's old name.
350 @param table_def Table definition of table being RENAMEd.
351 @param new_db Table's new schema.
352 @param new_table_name Table's new name.
353 @param hton Table's SE.
354 @param[in,out] fk_invalidator Object keeping track of which dd::Table
355 objects to invalidate.
356
357 @retval operation outcome, false if no error.
358*/
360 THD *thd, const char *db, const char *table_name,
361 const dd::Table *table_def, const char *new_db, const char *new_table_name,
362 handlerton *hton, Foreign_key_parents_invalidator *fk_invalidator);
363
364/**
365 As a result of simple rename table operation, orphan non-self-referencing
366 foreign keys may become non-orphan/adopted self-referencing foreign keys.
367 For such transformed foreign key, check that table has compatible referenced
368 column and parent key. Also, update DD.UNIQUE_CONSTRAINT_NAME.
369
370 @param thd Thread handle.
371 @param db Table's old schema.
372 @param table_name Table's old name.
373 @param new_db Table's new schema.
374 @param new_table_name Table's new name.
375 @param hton Table's SE.
376
377 @retval operation outcome, false if no error.
378*/
380 THD *thd, const char *db, const char *table_name, const char *new_db,
381 const char *new_table_name, handlerton *hton);
382
383/**
384 Update referenced table names and the unique constraint name for FKs
385 affected by RENAME TABLE operation.
386
387 @param thd Thread handle.
388 @param db Table's old schema.
389 @param table_name Table's old name.
390 @param new_db Table's new schema.
391 @param new_table_name Table's new name.
392 @param hton Table's SE.
393
394 @retval operation outcome, false if no error.
395*/
396[[nodiscard]] bool adjust_fks_for_rename_table(THD *thd, const char *db,
397 const char *table_name,
398 const char *new_db,
399 const char *new_table_name,
400 handlerton *hton);
401
402/*
403 Check if parent key for the foreign key exists, set foreign key's unique
404 constraint name accordingly. Emit error if no parent key found.
405
406 @note Prefer unique key if possible. If parent key is non-unique
407 unique constraint name is set to NULL.
408
409 @note DDL code use this function for non-self-referencing foreign keys.
410
411 @sa prepare_fk_parent_key(THD, handlerton, FOREIGN_KEY)
412
413 @param thd Thread handle.
414 @param hton Handlerton for tables' storage engine.
415 @param parent_table_def Object describing new version of parent table.
416 @param old_child_table_def Object describing old version of child table.
417 Can be nullptr if old_parent_table_def is
418 nullptr. Used for error reporting.
419 @param old_parent_table_def Object describing old version of parent table.
420 nullptr indicates that this is not ALTER TABLE
421 operation. Used for error reporting.
422 @param is_self_referencing_fk If the parent and child is the same table.
423 @param fk[in,out] Object describing the foreign key,
424 its unique_constraint_name member
425 will be updated if matching parent
426 unique constraint is found.
427
428 @retval Operation result. False if success.
429*/
430[[nodiscard]] bool prepare_fk_parent_key(THD *thd, handlerton *hton,
431 const dd::Table *parent_table_def,
432 const dd::Table *old_parent_table_def,
433 const dd::Table *old_child_table_def,
434 bool is_self_referencing_fk,
435 dd::Foreign_key *fk);
436
437/**
438 Prepare Create_field and Key_spec objects for ALTER and upgrade.
439 @param[in,out] thd thread handle. Used as a memory pool
440 and source of environment information.
441 @param[in] src_table DD table object. Will be nullptr for temporary
442 tables and during upgrade.
443 @param[in] table the source table, open and locked
444 Used as an interface to the storage engine
445 to acquire additional information about
446 the original table.
447 @param[in,out] create_info A blob with CREATE/ALTER TABLE
448 parameters
449 @param[in,out] alter_info Another blob with ALTER/CREATE parameters.
450 Originally create_info was used only in
451 CREATE TABLE and alter_info only in ALTER TABLE.
452 But since ALTER might end-up doing CREATE,
453 this distinction is gone and we just carry
454 around two structures.
455 @param[in,out] alter_ctx Runtime context for ALTER TABLE.
456 @param[in] used_fields used_fields from HA_CREATE_INFO.
457
458 @retval true error, out of memory or a semantical error in ALTER
459 TABLE instructions
460 @retval false success
461
462*/
463bool prepare_fields_and_keys(THD *thd, const dd::Table *src_table, TABLE *table,
464 HA_CREATE_INFO *create_info,
465 Alter_info *alter_info, Alter_table_ctx *alter_ctx,
466 const uint &used_fields);
467
468bool mysql_prepare_alter_table(THD *thd, const dd::Table *src_table,
469 TABLE *table, HA_CREATE_INFO *create_info,
470 Alter_info *alter_info,
471 Alter_table_ctx *alter_ctx);
474bool mysql_alter_table(THD *thd, const char *new_db, const char *new_name,
475 HA_CREATE_INFO *create_info, Table_ref *table_list,
476 Alter_info *alter_info);
477bool mysql_compare_tables(THD *thd, TABLE *table, Alter_info *alter_info,
478 HA_CREATE_INFO *create_info, bool *metadata_equal);
479bool mysql_recreate_table(THD *thd, Table_ref *table_list, bool table_copy);
480bool mysql_create_like_table(THD *thd, Table_ref *table, Table_ref *src_table,
481 HA_CREATE_INFO *create_info, uint open_flags = 0,
482 bool skip_post_ddl_operations = false);
483bool mysql_rename_table(THD *thd, handlerton *base, const char *old_db,
484 const char *old_name, const char *old_fk_db,
485 const char *old_fk_name, const dd::Schema &new_schema,
486 const char *new_db, const char *new_name, uint flags);
487
488bool mysql_checksum_table(THD *thd, Table_ref *table_list,
489 HA_CHECK_OPT *check_opt);
490bool mysql_rm_table(THD *thd, Table_ref *tables, bool if_exists,
491 bool drop_temporary);
492bool mysql_rm_table_no_locks(THD *thd, Table_ref *tables, bool if_exists,
493 bool drop_temporary, bool drop_database,
494 const char *database_name,
495 const bool should_drop_schema_ddl_log,
496 bool *dropped_non_atomic_flag,
497 std::set<handlerton *> *post_ddl_htons,
498 Foreign_key_parents_invalidator *fk_invalidator,
499 std::vector<MDL_ticket *> *safe_to_release_mdl);
500
501/**
502 Discover missing tables in SE and acquire locks on tables which participate
503 in FKs on tables to be dropped by DROP TABLES/DATABASE and which definitions
504 will have to be updated or invalidated during this operation.
505
506 @param thd Thread context.
507 @param tables Tables to be dropped by DROP TABLES/DATABASE.
508
509 @retval False - Success.
510 @retval True - Failure.
511*/
512[[nodiscard]] bool rm_table_do_discovery_and_lock_fk_tables(THD *thd,
513 Table_ref *tables);
514
515bool quick_rm_table(THD *thd, handlerton *base, const char *db,
516 const char *table_name, uint flags);
517bool prepare_sp_create_field(THD *thd, Create_field *field_def);
518bool prepare_pack_create_field(THD *thd, Create_field *sql_field,
519 longlong table_flags);
520
521const CHARSET_INFO *get_sql_field_charset(const Create_field *sql_field,
522 const HA_CREATE_INFO *create_info);
523bool validate_comment_length(THD *thd, const char *comment_str,
524 size_t *comment_len, uint max_len, uint err_code,
525 const char *comment_name);
526int write_bin_log(THD *thd, bool clear_error, const char *query,
527 size_t query_length, bool is_trans = false);
528void promote_first_timestamp_column(List<Create_field> *column_definitions);
529
530/**
531 Prepares the column definitions for table creation.
532
533 @param thd Thread object.
534 @param error_schema_name Schema name of the table used for error
535 reporting.
536 @param error_table_name Table name used for error reporting.
537 @param create_info Create information.
538 @param[in,out] create_list List of columns to create.
539 @param[in,out] select_field_pos Position where the SELECT columns start
540 for CREATE TABLE ... SELECT.
541 @param file The handler for the new table.
542 @param[in,out] sql_field Create_field to populate.
543 @param field_no Column number.
544
545 @retval false OK
546 @retval true error
547*/
548
549bool prepare_create_field(THD *thd, const char *error_schema_name,
550 const char *error_table_name,
551 HA_CREATE_INFO *create_info,
552 List<Create_field> *create_list,
553 int *select_field_pos, handler *file,
554 Create_field *sql_field, int field_no);
555
556/**
557 Prepares the table and key structures for table creation.
558
559 @param thd Thread object.
560 @param error_schema_name Schema name of the table to create/alter,
561 only error reporting.
562 @param error_table_name Name of table to create/alter, only used for
563 error reporting.
564 @param create_info Create information (like MAX_ROWS).
565 @param alter_info List of columns and indexes to create
566 @param file The handler for the new table.
567 @param is_partitioned Indicates whether table is partitioned.
568 @param[out] key_info_buffer An array of KEY structs for the indexes.
569 @param[out] key_count The number of elements in the array.
570 @param[out] fk_key_info_buffer An array of FOREIGN_KEY structs for the
571 foreign keys.
572 @param[out] fk_key_count The number of elements in the array.
573 @param[in] existing_fks An array of pre-existing FOREIGN KEYS
574 (in case of ALTER).
575 @param[in] existing_fks_count The number of pre-existing foreign keys.
576 @param[in] existing_fks_table dd::Table object for table version from
577 which pre-existing foreign keys come from.
578 Needed for error reporting.
579 @param[in] fk_max_generated_name_number Max value of number component among
580 existing generated foreign key names.
581 @param select_field_count The number of fields coming from a select
582 table.
583 @param find_parent_keys Indicates whether we need to lookup name of
584 unique constraint in parent table for foreign
585 keys.
586
587 @retval false OK
588 @retval true error
589*/
590
592 THD *thd, const char *error_schema_name, const char *error_table_name,
593 HA_CREATE_INFO *create_info, Alter_info *alter_info, handler *file,
594 bool is_partitioned, KEY **key_info_buffer, uint *key_count,
595 FOREIGN_KEY **fk_key_info_buffer, uint *fk_key_count,
596 FOREIGN_KEY *existing_fks, uint existing_fks_count,
597 const dd::Table *existing_fks_table, uint fk_max_generated_name_number,
598 int select_field_count, bool find_parent_keys);
599
600size_t explain_filename(THD *thd, const char *from, char *to, size_t to_length,
601 enum_explain_filename_mode explain_mode);
602
603extern MYSQL_PLUGIN_IMPORT const char *primary_key_name;
604
605/**
606 Acquire metadata lock on triggers associated with a list of tables.
607
608 @param[in] thd Current thread context
609 @param[in] tables Tables for that associated triggers have to locked.
610
611 @return Operation status.
612 @retval false Success
613 @retval true Failure
614*/
615
616bool lock_trigger_names(THD *thd, Table_ref *tables);
617struct TYPELIB;
619
620/**
621 Method to collect check constraint names for the all the tables and acquire
622 MDL lock on them.
623
624 @param[in] thd Thread handle.
625 @param[in] tables Check constraints of tables to be locked.
626
627 @retval false Success.
628 @retval true Failure.
629*/
630bool lock_check_constraint_names(THD *thd, Table_ref *tables);
631
632/**
633 Method to lock check constraint names for rename table operation.
634 Method acquire locks on the constraint names of source table and
635 also on the name of check constraint in the target table.
636
637 @param[in] thd Thread handle.
638 @param[in] db Database name.
639 @param[in] table_name Table name.
640 @param[in] table_def DD table object of source table.
641 @param[in] target_db Target database name.
642 @param[in] target_table_name Target table name.
643
644 @retval false Success.
645 @retval true Failure.
646*/
647bool lock_check_constraint_names_for_rename(THD *thd, const char *db,
648 const char *table_name,
649 const dd::Table *table_def,
650 const char *target_db,
651 const char *target_table_name);
652
653/**
654 Method to prepare check constraints for the CREATE operation. If name of the
655 check constraint is not specified then name is generated, check constraint
656 is pre-validated and MDL on check constraint is acquired.
657
658 @param thd Thread handle.
659 @param db_name Database name.
660 @param table_name Table name.
661 @param alter_info Alter_info object with list of
662 check constraints to be created.
663
664 @retval false Success.
665 @retval true Failure.
666*/
668 const char *table_name,
669 Alter_info *alter_info);
670
671extern std::atomic_ulong deprecated_use_fk_on_non_standard_key_count;
673
674/**
675 Unloads the materialized view from a secondary engine, where it might be
676 materialized.
677 */
679 const dd::View *view_def);
680
681/**
682 Resolves the secondary engine handled via its name and calls the unload
683 table function
684*/
685bool secondary_engine_unload_table_inner(THD *thd, const char *db_name,
686 const char *table_name,
688 bool is_partitioned,
689 bool error_if_not_loaded);
690
691/**
692 Validation on create temporary table statements with secondary engine defined:
693 1. Check that the create table statement contains a query.
694 2. Set the lex state indicating that the query can execute only
695 on the secondary engine.
696*/
698 HA_CREATE_INFO *create_info);
699
700#endif /* SQL_TABLE_INCLUDED */
Data describing the table being created by CREATE TABLE or altered by ALTER TABLE.
Definition: sql_alter.h:205
Runtime context for ALTER TABLE.
Definition: sql_alter.h:523
Create_field is a description a field/column that may or may not exists in a table.
Definition: create_field.h:51
Definition: key.h:43
Helper class for keeping track for which tables we need to invalidate data-dictionary cache entries a...
Definition: sql_table.h:126
void invalidate(THD *thd)
Definition: sql_table.cc:1540
void mark_for_reopen_if_added(const char *db_name, const char *table_name)
Definition: sql_table.cc:1530
const Parent_map & parents() const
Definition: sql_table.h:153
enum_invalidation_type
Definition: sql_table.h:128
@ INVALIDATE_AND_MARK_FOR_REOPEN
Definition: sql_table.h:130
@ INVALIDATE_AND_CLOSE_TABLE
Definition: sql_table.h:129
std::map< std::pair< dd::String_type, dd::String_type >, std::pair< handlerton *, enum_invalidation_type > > Parent_map
Definition: sql_table.h:136
void clear()
Definition: sql_table.h:155
void add(const char *db_name, const char *table_name, handlerton *hton, enum_invalidation_type invalidation_type=INVALIDATE_AND_CLOSE_TABLE)
Definition: sql_table.cc:1522
Parent_map m_parent_map
Definition: sql_table.h:137
bool is_empty() const
Definition: sql_table.h:154
Intrusive parameterized list.
Definition: sql_plist.h:75
Definition: key.h:113
Definition: sql_list.h:494
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:36
Auxiliary class implementing RAII principle for getting permission for/ notification about finished D...
Definition: sql_table.h:164
bool m_hton_notified
Definition: sql_table.h:199
const MDL_key m_key
Definition: sql_table.h:201
THD * m_thd
Definition: sql_table.h:200
bool notify() noexcept
Definition: sql_table.h:180
const char * m_old_db_name
Definition: sql_table.h:203
const char * m_new_table_name
Definition: sql_table.h:206
const ha_ddl_type m_ddl_type
Definition: sql_table.h:202
const char * m_old_table_name
Definition: sql_table.h:204
const char * m_new_db_name
Definition: sql_table.h:205
Table_ddl_hton_notification_guard(THD *thd, const MDL_key *key, ha_ddl_type ddl_type, const char *old_db_name=nullptr, const char *old_table_name=nullptr, const char *new_db_name=nullptr, const char *new_table_name=nullptr) noexcept
Definition: sql_table.h:166
~Table_ddl_hton_notification_guard()
Definition: sql_table.h:191
Definition: table.h:2952
Definition: foreign_key.h:47
Definition: schema.h:64
Definition: table.h:47
Definition: view.h:39
The handler class is the interface for dynamically loadable storage engines.
Definition: handler.h:4754
A table definition from the master.
Definition: rpl_utility.h:249
static MEM_ROOT mem_root
Definition: client_plugin.cc:114
void my_error(int nr, myf MyFlags,...)
Fill in and print a previously registered error message.
Definition: my_error.cc:217
PFS_table * create_table(PFS_table_share *share, PFS_thread *opening_thread, const void *identity)
Create instrumentation for a table instance.
Definition: pfs_instr.cc:1307
static int flags[50]
Definition: hp_test1.cc:40
Some integer typedefs for easier portability.
long long int longlong
Definition: my_inttypes.h:55
#define MYF(v)
Definition: my_inttypes.h:97
Functions related to handling of plugins and other dynamically loaded libraries.
#define MYSQL_PLUGIN_IMPORT
Definition: my_sharedlib.h:71
static char * query
Definition: myisam_ftdump.cc:47
ABI for instrumented mutexes.
static Secondary_engine * secondary_engine
Definition: mysqltest.cc:260
static PFS_engine_table_share_proxy table
Definition: pfs.cc:61
borrowable::session_track::Schema< true > Schema
Definition: classic_protocol_session_track.h:288
The version of the current data dictionary table definitions.
Definition: dictionary_client.h:44
Definition: os0file.h:89
Json_data_extension ext
Definition: backend.cc:50
entry::Table Table
Definition: select.h:51
noexcept
The return type for any call_and_catch(f, args...) call where f(args...) returns Type.
Definition: call_and_catch.h:76
const char * table_name
Definition: rules_table_service.cc:56
const char * db_name
Definition: rules_table_service.cc:55
required string key
Definition: replication_asynchronous_connection_failover.proto:60
bool ha_notify_table_ddl(THD *thd, const MDL_key *mdl_key, ha_notification_type notification_type, ha_ddl_type ddl_type, const char *old_db_name, const char *old_table_name, const char *new_db_name, const char *new_table_name)
Notify/get permission from all interested storage engines before or after executed DDL (ALTER TABLE,...
Definition: handler.cc:8926
ha_ddl_type
Definition: handler.h:964
@ HA_NOTIFY_POST_EVENT
Definition: handler.h:963
@ HA_NOTIFY_PRE_EVENT
Definition: handler.h:963
enum_mdl_type
Type of metadata lock request.
Definition: sql_lexer_yacc_state.h:106
static const uint NO_DD_COMMIT
Don't commit transaction after updating data-dictionary while renaming the table.
Definition: sql_table.h:87
bool collect_fk_parents_for_new_fks(THD *thd, const char *db_name, const char *table_name, const Alter_info *alter_info, enum_mdl_type lock_type, handlerton *hton, MDL_request_list *mdl_requests, Foreign_key_parents_invalidator *fk_invalidator)
Add MDL requests for lock of specified type on tables referenced by the foreign keys to be added by t...
Definition: sql_table.cc:10788
bool lock_check_constraint_names_for_rename(THD *thd, const char *db, const char *table_name, const dd::Table *table_def, const char *target_db, const char *target_table_name)
Method to lock check constraint names for rename table operation.
Definition: sql_table.cc:20751
static const uint FN_TO_IS_TMP
Definition: sql_table.h:79
int write_bin_log(THD *thd, bool clear_error, const char *query, size_t query_length, bool is_trans=false)
Definition: sql_table.cc:1265
size_t tablename_to_filename(const char *from, char *to, size_t to_length)
Definition: sql_table.cc:845
void promote_first_timestamp_column(List< Create_field > *column_definitions)
Modifies the first column definition whose SQL type is TIMESTAMP by adding the features DEFAULT CURRE...
Definition: sql_table.cc:4378
bool adjust_fk_parents(THD *thd, const char *db, const char *name, bool reload_self, const Foreign_key_parents_invalidator *fk_invalidator)
Definition: sql_table.cc:10241
bool lock_trigger_names(THD *thd, Table_ref *tables)
Acquire metadata lock on triggers associated with a list of tables.
Definition: sql_table.cc:1280
bool lock_check_constraint_names(THD *thd, Table_ref *tables)
Method to collect check constraint names for the all the tables and acquire MDL lock on them.
Definition: sql_table.cc:20811
bool quick_rm_table(THD *thd, handlerton *base, const char *db, const char *table_name, uint flags)
Quickly remove a table.
Definition: sql_table.cc:4021
bool rm_table_do_discovery_and_lock_fk_tables(THD *thd, Table_ref *tables)
Discover missing tables in SE and acquire locks on tables which participate in FKs on tables to be dr...
Definition: sql_table.cc:1450
bool mysql_prepare_create_table(THD *thd, const char *error_schema_name, const char *error_table_name, HA_CREATE_INFO *create_info, Alter_info *alter_info, handler *file, bool is_partitioned, KEY **key_info_buffer, uint *key_count, FOREIGN_KEY **fk_key_info_buffer, uint *fk_key_count, FOREIGN_KEY *existing_fks, uint existing_fks_count, const dd::Table *existing_fks_table, uint fk_max_generated_name_number, int select_field_count, bool find_parent_keys)
Prepares the table and key structures for table creation.
Definition: sql_table.cc:8277
bool collect_fk_names_for_new_fks(THD *thd, const char *db_name, const char *table_name, const Alter_info *alter_info, handlerton *hton, uint fk_max_generated_name_number, MDL_request_list *mdl_requests)
Add MDL requests for exclusive metadata locks on names of foreign keys to be added by the CREATE TABL...
Definition: sql_table.cc:10825
bool adjust_adopted_self_ref_fk_for_simple_rename_table(THD *thd, const char *db, const char *table_name, const char *new_db, const char *new_table_name, handlerton *hton)
As a result of simple rename table operation, orphan non-self-referencing foreign keys may become non...
Definition: sql_table.cc:16647
std::atomic_ullong deprecated_use_fk_on_non_standard_key_last_timestamp
Last time fk is created on non standard index key, as usec since epoch.
Definition: sql_table.cc:224
handlerton * get_viable_handlerton_for_create(THD *thd, const char *table_name, const HA_CREATE_INFO &ci)
Checks if the handlerton for the specified ENGINE is enabled AND NOT explicitly disabled (listed in t...
Definition: sql_table.cc:438
const CHARSET_INFO * get_sql_field_charset(const Create_field *sql_field, const HA_CREATE_INFO *create_info)
Get the character set from field object generated by the parser, using default values when not set.
Definition: sql_table.cc:4345
mysql_mutex_t mysql_mutex_t
Definition: sql_table.h:65
bool mysql_compare_tables(THD *thd, TABLE *table, Alter_info *alter_info, HA_CREATE_INFO *create_info, bool *metadata_equal)
Compare two tables to see if their metadata are compatible.
Definition: sql_table.cc:13611
bool mysql_prepare_alter_table(THD *thd, const dd::Table *src_table, TABLE *table, HA_CREATE_INFO *create_info, Alter_info *alter_info, Alter_table_ctx *alter_ctx)
Prepare column and key definitions for CREATE TABLE in ALTER TABLE.
Definition: sql_table.cc:16249
bool prepare_sp_create_field(THD *thd, Create_field *field_def)
Prepare an instance of Create_field for field creation (fill all necessary attributes).
Definition: sql_table.cc:4324
bool mysql_rename_table(THD *thd, handlerton *base, const char *old_db, const char *old_name, const char *old_fk_db, const char *old_fk_name, const dd::Schema &new_schema, const char *new_db, const char *new_name, uint flags)
Rename a table.
Definition: sql_table.cc:11474
bool mysql_rm_table_no_locks(THD *thd, Table_ref *tables, bool if_exists, bool drop_temporary, bool drop_database, const char *database_name, const bool should_drop_schema_ddl_log, bool *dropped_non_atomic_flag, std::set< handlerton * > *post_ddl_htons, Foreign_key_parents_invalidator *fk_invalidator, std::vector< MDL_ticket * > *safe_to_release_mdl)
Execute the drop of a normal or temporary table.
Definition: sql_table.cc:3286
bool collect_fk_children(THD *thd, const char *schema, const char *table_name, handlerton *hton, enum_mdl_type lock_type, MDL_request_list *mdl_requests)
Add MDL requests for specified lock type on all tables referencing the given schema qualified table n...
Definition: sql_table.cc:10173
bool prepare_fk_parent_key(THD *thd, handlerton *hton, const dd::Table *parent_table_def, const dd::Table *old_parent_table_def, const dd::Table *old_child_table_def, bool is_self_referencing_fk, dd::Foreign_key *fk)
Definition: sql_table.cc:6704
bool prepare_fields_and_keys(THD *thd, const dd::Table *src_table, TABLE *table, HA_CREATE_INFO *create_info, Alter_info *alter_info, Alter_table_ctx *alter_ctx, const uint &used_fields)
Prepare Create_field and Key_spec objects for ALTER and upgrade.
Definition: sql_table.cc:15582
MYSQL_PLUGIN_IMPORT const char * primary_key_name
Definition: sql_table.cc:234
size_t filename_to_tablename(const char *from, char *to, size_t to_length, bool stay_quiet=false, bool *has_errors=nullptr)
Definition: sql_table.cc:800
bool prepare_pack_create_field(THD *thd, Create_field *sql_field, longlong table_flags)
Prepare a create_table instance for packing.
Definition: sql_table.cc:4172
static const uint NO_CC_RENAME
Don't change generated check constraint names while renaming table.
Definition: sql_table.h:91
static const uint FN_FROM_IS_TMP
Definition: sql_table.h:78
bool mysql_rm_table(THD *thd, Table_ref *tables, bool if_exists, bool drop_temporary)
Definition: sql_table.cc:1613
size_t build_tmptable_filename(THD *thd, char *buff, size_t bufflen)
Create path to a temporary table, like mysql_tmpdir/#sql1234_12_1 (i.e.
Definition: sql_table.cc:952
static const uint FN_IS_TMP
Definition: sql_table.h:80
static const uint NO_FK_RENAME
Don't change generated foreign key names while renaming table.
Definition: sql_table.h:89
size_t explain_filename(THD *thd, const char *from, char *to, size_t to_length, enum_explain_filename_mode explain_mode)
Explain a path name by split it to database, table etc.
Definition: sql_table.cc:645
bool mysql_create_like_table(THD *thd, Table_ref *table, Table_ref *src_table, HA_CREATE_INFO *create_info, uint open_flags=0, bool skip_post_ddl_operations=false)
Definition: sql_table.cc:11717
bool mysql_create_table_no_lock(THD *thd, const char *db, const char *table_name, HA_CREATE_INFO *create_info, Alter_info *alter_info, uint select_field_count, bool find_parent_keys, bool *is_trans, handlerton **post_ddl_ht)
Simple wrapper around create_table_impl() to be used in various version of CREATE TABLE statement.
Definition: sql_table.cc:9998
bool mysql_create_table(THD *thd, Table_ref *create_table, HA_CREATE_INFO *create_info, Alter_info *alter_info)
Implementation of SQLCOM_CREATE_TABLE.
Definition: sql_table.cc:10903
bool collect_and_lock_fk_tables_for_rename_table(THD *thd, const char *db, const char *table_name, const dd::Table *table_def, const char *new_db, const char *new_table_name, handlerton *hton, Foreign_key_parents_invalidator *fk_invalidator)
Acquire exclusive metadata locks on tables which definitions need to be updated or invalidated since ...
Definition: sql_table.cc:16623
std::atomic_ulong deprecated_use_fk_on_non_standard_key_count
Count number of times foreign key is created on non standard index keys.
Definition: sql_table.cc:221
bool mysql_alter_table(THD *thd, const char *new_db, const char *new_name, HA_CREATE_INFO *create_info, Table_ref *table_list, Alter_info *alter_info)
Alter table.
Definition: sql_table.cc:17242
size_t build_table_filename(char *buff, size_t bufflen, const char *db, const char *table, const char *ext, uint flags, bool *was_truncated)
Definition: sql_table.cc:894
bool secondary_engine_unload_table_inner(THD *thd, const char *db_name, const char *table_name, LEX_CSTRING secondary_engine, bool is_partitioned, bool error_if_not_loaded)
Resolves the secondary engine handled via its name and calls the unload table function.
Definition: sql_table.cc:2868
bool mysql_recreate_table(THD *thd, Table_ref *table_list, bool table_copy)
Definition: sql_table.cc:19718
bool secondary_engine_unload_materialized_view(THD *thd, const Table_ref *view, const dd::View *view_def)
Unloads the materialized view from a secondary engine, where it might be materialized.
Definition: sql_table.cc:2852
bool prepare_create_field(THD *thd, const char *error_schema_name, const char *error_table_name, HA_CREATE_INFO *create_info, List< Create_field > *create_list, int *select_field_pos, handler *file, Create_field *sql_field, int field_no)
Prepares the column definitions for table creation.
Definition: sql_table.cc:4700
bool mysql_trans_prepare_alter_copy_data(THD *thd)
Prepare the transaction for the alter table's copy phase.
Definition: sql_table.cc:19354
static const uint NO_FK_CHECKS
Don't check foreign key constraints while renaming table.
Definition: sql_table.h:82
bool adjust_fks_for_rename_table(THD *thd, const char *db, const char *table_name, const char *new_db, const char *new_table_name, handlerton *hton)
Update referenced table names and the unique constraint name for FKs affected by RENAME TABLE operati...
Definition: sql_table.cc:16686
enum_explain_filename_mode
Definition: sql_table.h:71
@ EXPLAIN_PARTITIONS_VERBOSE
Definition: sql_table.h:73
@ EXPLAIN_ALL_VERBOSE
Definition: sql_table.h:72
@ EXPLAIN_PARTITIONS_AS_COMMENT
Definition: sql_table.h:74
TYPELIB * create_typelib(MEM_ROOT *mem_root, Create_field *field_def)
Definition: sql_table.cc:4263
bool adjust_fk_children_after_parent_def_change(THD *thd, bool check_charsets, const char *parent_table_db, const char *parent_table_name, handlerton *hton, const dd::Table *parent_table_def, Alter_info *parent_alter_info, bool invalidate_tdc)
Check if new definition of parent table is compatible with foreign keys which reference it.
Definition: sql_table.cc:10541
bool validate_comment_length(THD *thd, const char *comment_str, size_t *comment_len, uint max_len, uint err_code, const char *comment_name)
check comment length of table, column, index and partition
Definition: sql_table.cc:8743
bool prepare_check_constraints_for_create(THD *thd, const char *db_name, const char *table_name, Alter_info *alter_info)
Method to prepare check constraints for the CREATE operation.
Definition: sql_table.cc:20033
bool mysql_trans_commit_alter_copy_data(THD *thd)
Commit the copy phase of the alter table.
Definition: sql_table.cc:19374
bool mysql_checksum_table(THD *thd, Table_ref *table_list, HA_CHECK_OPT *check_opt)
Definition: sql_table.cc:19744
bool mysql_discard_or_import_tablespace(THD *thd, Table_ref *table_list)
bool validate_secondary_engine_temporary_table(THD *thd, HA_CREATE_INFO *create_info)
Validation on create temporary table statements with secondary engine defined:
Definition: sql_table.cc:9008
case opt name
Definition: sslopt-case.h:29
Definition: m_ctype.h:421
Definition: handler.h:3967
Struct to hold information about the table that should be created.
Definition: handler.h:3360
Metadata lock object key.
Definition: mdl.h:366
The MEM_ROOT is a simple arena, where allocations are carved out of larger blocks.
Definition: my_alloc.h:83
Definition: mysql_lex_string.h:40
Definition: table.h:1450
Definition: typelib.h:35
handlerton is a singleton structure - one instance per storage engine - to provide access to storage ...
Definition: handler.h:2856
An instrumented mutex structure.
Definition: mysql_mutex_bits.h:50