MySQL 8.4.2
Source Code Documentation
ha_innodb.h
Go to the documentation of this file.
1/*****************************************************************************
2
3Copyright (c) 2000, 2024, Oracle and/or its affiliates.
4
5This program is free software; you can redistribute it and/or modify it under
6the terms of the GNU General Public License, version 2.0, as published by the
7Free Software Foundation.
8
9This program is designed to work with certain software (including
10but not limited to OpenSSL) that is licensed under separate terms,
11as designated in a particular file or component or in included license
12documentation. The authors of MySQL hereby grant you an additional
13permission to link the program and your derivative works with the
14separately licensed software that they have either included with
15the program or referenced in the documentation.
16
17This program is distributed in the hope that it will be useful, but WITHOUT
18ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
19FOR A PARTICULAR PURPOSE. See the GNU General Public License, version 2.0,
20for more details.
21
22You should have received a copy of the GNU General Public License along with
23this program; if not, write to the Free Software Foundation, Inc.,
2451 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
25
26*****************************************************************************/
27
28#ifndef ha_innodb_h
29#define ha_innodb_h
30
31/* The InnoDB handler: the interface between MySQL and InnoDB. */
32
33#include <assert.h>
34#include <sys/types.h>
35#include "create_field.h"
36#include "field.h"
37#include "handler.h"
39
40#include "row0pread-adapter.h"
41#include "row0pread-histogram.h"
42#include "trx0trx.h"
43
44/** "GEN_CLUST_INDEX" is the name reserved for InnoDB default
45system clustered index when there is no primary key. */
46extern const char innobase_index_reserve_name[];
47
48/** Clone protocol service. */
49extern SERVICE_TYPE(clone_protocol) * clone_protocol_svc;
50
51/* Structure defines translation table between mysql index and InnoDB
52index structures */
54 ulint index_count; /*!< number of valid index entries
55 in the index_mapping array */
56
57 ulint array_size; /*!< array size of index_mapping */
58
59 dict_index_t **index_mapping; /*!< index pointer array directly
60 maps to index in InnoDB from MySQL
61 array index */
62};
63
64/** InnoDB table share */
66 const char *table_name; /*!< InnoDB table name */
67 uint use_count; /*!< reference count,
68 incremented in get_share()
69 and decremented in
70 free_share() */
72 /*!< hash table chain node */
73 innodb_idx_translate_t idx_trans_tbl; /*!< index translation table between
74 MySQL and InnoDB */
75};
76
77/** Prebuilt structures in an InnoDB table handle used within MySQL */
78struct row_prebuilt_t;
79
80namespace dd {
81namespace cache {
82class Dictionary_client;
83}
84} // namespace dd
85
86/** The class defining a handle to an InnoDB table */
87class ha_innobase : public handler {
88 public:
89 ha_innobase(handlerton *hton, TABLE_SHARE *table_arg);
90 ~ha_innobase() override = default;
91
92 row_type get_real_row_type(const HA_CREATE_INFO *create_info) const override;
93
94 const char *table_type() const override;
95
97 return HA_KEY_ALG_BTREE;
98 }
99
100 /** Check if SE supports specific key algorithm. */
101 bool is_index_algorithm_supported(enum ha_key_alg key_alg) const override {
102 /* This method is never used for FULLTEXT or SPATIAL keys.
103 We rely on handler::ha_table_flags() to check if such keys
104 are supported. */
105 assert(key_alg != HA_KEY_ALG_FULLTEXT && key_alg != HA_KEY_ALG_RTREE);
106 return key_alg == HA_KEY_ALG_BTREE;
107 }
108
109 Table_flags table_flags() const override;
110
111 ulong index_flags(uint idx, uint part, bool all_parts) const override;
112
113 uint max_supported_keys() const override;
114
115 uint max_supported_key_length() const override;
116
118 HA_CREATE_INFO *create_info) const override;
119
120 int open(const char *name, int, uint open_flags,
121 const dd::Table *table_def) override;
122
123 handler *clone(const char *name, MEM_ROOT *mem_root) override;
124
125 int close(void) override;
126
127 double scan_time() override;
128
129 double read_time(uint index, uint ranges, ha_rows rows) override;
130
131 longlong get_memory_buffer_size() const override;
132
133 int write_row(uchar *buf) override;
134
135 int update_row(const uchar *old_data, uchar *new_data) override;
136
137 int delete_row(const uchar *buf) override;
138
139 /** Delete all rows from the table.
140 @retval HA_ERR_WRONG_COMMAND if the table is transactional
141 @retval 0 on success */
142 int delete_all_rows() override;
143
144 bool was_semi_consistent_read() override;
145
146 void try_semi_consistent_read(bool yes) override;
147
148 void unlock_row() override;
149
150 int index_init(uint index, bool sorted) override;
151
152 int index_end() override;
153
154 int index_read(uchar *buf, const uchar *key, uint key_len,
155 ha_rkey_function find_flag) override;
156
157 int index_read_last(uchar *buf, const uchar *key, uint key_len) override;
158
159 int index_next(uchar *buf) override;
160
161 int index_next_same(uchar *buf, const uchar *key, uint keylen) override;
162
163 int index_prev(uchar *buf) override;
164
165 int index_first(uchar *buf) override;
166
167 int index_last(uchar *buf) override;
168
169 int read_range_first(const key_range *start_key, const key_range *end_key,
170 bool eq_range_arg, bool sorted) override;
171
172 int read_range_next() override;
173
174 int rnd_init(bool scan) override;
175
176 int rnd_end() override;
177
178 int rnd_next(uchar *buf) override;
179
180 int rnd_pos(uchar *buf, uchar *pos) override;
181
182 int ft_init() override;
183
184 void ft_end();
185
186 FT_INFO *ft_init_ext(uint flags, uint inx, String *key) override;
187
189 Ft_hints *hints) override;
190
191 int ft_read(uchar *buf) override;
192
193 void position(const uchar *record) override;
194
195 int info(uint) override;
196
197 int enable_indexes(uint mode) override;
198
199 int disable_indexes(uint mode) override;
200
201 int analyze(THD *thd, HA_CHECK_OPT *check_opt) override;
202
203 int optimize(THD *thd, HA_CHECK_OPT *check_opt) override;
204
205 int discard_or_import_tablespace(bool discard, dd::Table *table_def) override;
206
207 int extra(ha_extra_function operation) override;
208
209 int reset() override;
210
211 int external_lock(THD *thd, int lock_type) override;
212
213 /** Initialize sampling.
214 @param[out] scan_ctx A scan context created by this method that has to be
215 used in sample_next
216 @param[in] sampling_percentage percentage of records that need to be sampled
217 @param[in] sampling_seed random seed that the random generator will use
218 @param[in] sampling_method sampling method to be used; currently only
219 SYSTEM sampling is supported
220 @param[in] tablesample true if the sampling is for tablesample
221 @return 0 for success, else one of the HA_xxx values in case of error. */
222 int sample_init(void *&scan_ctx, double sampling_percentage,
223 int sampling_seed, enum_sampling_method sampling_method,
224 const bool tablesample) override;
225
226 /** Get the next record for sampling.
227 @param[in] scan_ctx Scan context of the sampling
228 @param[in] buf buffer to place the read record
229 @return 0 for success, else one of the HA_xxx values in case of error. */
230 int sample_next(void *scan_ctx, uchar *buf) override;
231
232 /** End sampling.
233 @param[in] scan_ctx Scan context of the sampling
234 @return 0 for success, else one of the HA_xxx values in case of error. */
235 int sample_end(void *scan_ctx) override;
236
237 /** MySQL calls this function at the start of each SQL statement
238 inside LOCK TABLES. Inside LOCK TABLES the "::external_lock" method
239 does not work to mark SQL statement borders. Note also a special case:
240 if a temporary table is created inside LOCK TABLES, MySQL has not
241 called external_lock() at all on that table.
242 MySQL-5.0 also calls this before each statement in an execution of a
243 stored procedure. To make the execution more deterministic for
244 binlogging, MySQL-5.0 locks all tables involved in a stored procedure
245 with full explicit table locks (thd_in_lock_tables(thd) holds in
246 store_lock()) before executing the procedure.
247 @param[in] thd handle to the user thread
248 @param[in] lock_type lock type
249 @return 0 or error code */
250 int start_stmt(THD *thd, thr_lock_type lock_type) override;
251
253
254 int records(ha_rows *num_rows) override;
255
256 ha_rows records_in_range(uint inx, key_range *min_key,
257 key_range *max_key) override;
258
260
261 void update_create_info(HA_CREATE_INFO *create_info) override;
262
263 /** Get storage-engine private data for a data dictionary table.
264 @param[in,out] dd_table data dictionary table definition
265 @param reset reset counters
266 @retval true an error occurred
267 @retval false success */
268 bool get_se_private_data(dd::Table *dd_table, bool reset) override;
269
270 /** Add hidden columns and indexes to an InnoDB table definition.
271 @param[in,out] dd_table data dictionary cache object
272 @return error number
273 @retval 0 on success */
275 const List<Create_field> *, const KEY *, uint,
276 dd::Table *dd_table) override;
277
278 /** Set Engine specific data to dd::Table object for upgrade.
279 @param[in,out] thd thread handle
280 @param[in] db_name database name
281 @param[in] table_name table name
282 @param[in,out] dd_table data dictionary cache object
283 @return 0 on success, non-zero on failure */
284 bool upgrade_table(THD *thd, const char *db_name, const char *table_name,
285 dd::Table *dd_table) override;
286
287 /** Create an InnoDB table.
288 @param[in] name table name in filename-safe encoding
289 @param[in] form table structure
290 @param[in] create_info more information on the table
291 @param[in,out] table_def dd::Table describing table to be
292 created. Can be adjusted by SE, the changes will be saved into data-dictionary
293 at statement commit time.
294 @return error number
295 @retval 0 on success */
296 int create(const char *name, TABLE *form, HA_CREATE_INFO *create_info,
297 dd::Table *table_def) override;
298
299 /** Drop a table.
300 @param[in] name table name
301 @param[in] table_def dd::Table describing table to
302 be dropped
303 @return error number
304 @retval 0 on success */
305 int delete_table(const char *name, const dd::Table *table_def) override;
306
307 protected:
308 /** Drop a table.
309 @param[in] name table name
310 @param[in] table_def dd::Table describing table to
311 be dropped
312 @param[in] sqlcom type of operation that the DROP is part of
313 @return error number
314 @retval 0 on success */
315 int delete_table(const char *name, const dd::Table *table_def,
316 enum enum_sql_command sqlcom);
317
318 public:
319 int rename_table(const char *from, const char *to,
320 const dd::Table *from_table, dd::Table *to_table) override;
321
322 int check(THD *thd, HA_CHECK_OPT *check_opt) override;
323
324 uint lock_count(void) const override;
325
327 thr_lock_type lock_type) override;
328
329 void init_table_handle_for_HANDLER() override;
330
331 void get_auto_increment(ulonglong offset, ulonglong increment,
332 ulonglong nb_desired_values, ulonglong *first_value,
333 ulonglong *nb_reserved_values) override;
334
335 /** Do cleanup for auto increment calculation. */
336 void release_auto_increment() override;
337
338 bool get_error_message(int error, String *buf) override;
339
340 bool get_foreign_dup_key(char *, uint, char *, uint) override;
341
342 bool primary_key_is_clustered() const override;
343
344 int cmp_ref(const uchar *ref1, const uchar *ref2) const override;
345
346 /** @defgroup ALTER_TABLE_INTERFACE On-line ALTER TABLE interface
347 @see handler0alter.cc
348 @{ */
349
350 /** Check if InnoDB supports a particular alter table in-place
351 @param altered_table TABLE object for new version of table.
352 @param ha_alter_info Structure describing changes to be done
353 by ALTER TABLE and holding data used during in-place alter.
354
355 @retval HA_ALTER_INPLACE_NOT_SUPPORTED Not supported
356 @retval HA_ALTER_INPLACE_NO_LOCK Supported
357 @retval HA_ALTER_INPLACE_SHARED_LOCK_AFTER_PREPARE Supported, but requires
358 lock during main phase and exclusive lock during prepare phase.
359 @retval HA_ALTER_INPLACE_NO_LOCK_AFTER_PREPARE Supported, prepare phase
360 requires exclusive lock (any transactions that have accessed the table
361 must commit or roll back first, and no transactions can access the table
362 while prepare_inplace_alter_table() is executing)
363 */
365 TABLE *altered_table, Alter_inplace_info *ha_alter_info) override;
366
367 /** Allows InnoDB to update internal structures with concurrent
368 writes blocked (provided that check_if_supported_inplace_alter()
369 did not return HA_ALTER_INPLACE_NO_LOCK).
370 This will be invoked before inplace_alter_table().
371 @param[in] altered_table TABLE object for new version of table.
372 @param[in,out] ha_alter_info Structure describing changes to be done
373 by ALTER TABLE and holding data used during in-place alter.
374 @param[in] old_dd_tab dd::Table object describing old version
375 of the table.
376 @param[in,out] new_dd_tab dd::Table object for the new version of
377 the table. Can be adjusted by this call. Changes to the table definition will
378 be persisted in the data-dictionary at statement commit time.
379 @retval true Failure
380 @retval false Success
381 */
382 bool prepare_inplace_alter_table(TABLE *altered_table,
383 Alter_inplace_info *ha_alter_info,
384 const dd::Table *old_dd_tab,
385 dd::Table *new_dd_tab) override;
386
387 /** Alter the table structure in-place with operations
388 specified using HA_ALTER_FLAGS and Alter_inplace_information.
389 The level of concurrency allowed during this operation depends
390 on the return value from check_if_supported_inplace_alter().
391 @param[in] altered_table TABLE object for new version of table.
392 @param[in,out] ha_alter_info Structure describing changes to be done
393 by ALTER TABLE and holding data used during in-place alter.
394 @param[in] old_dd_tab dd::Table object describing old version
395 of the table.
396 @param[in,out] new_dd_tab dd::Table object for the new version of
397 the table. Can be adjusted by this call. Changes to the table definition will
398 be persisted in the data-dictionary at statement commit time.
399 @retval true Failure
400 @retval false Success
401 */
402 bool inplace_alter_table(TABLE *altered_table,
403 Alter_inplace_info *ha_alter_info,
404 const dd::Table *old_dd_tab,
405 dd::Table *new_dd_tab) override;
406
407 /** Commit or rollback the changes made during
408 prepare_inplace_alter_table() and inplace_alter_table() inside
409 the storage engine. Note that the allowed level of concurrency
410 during this operation will be the same as for
411 inplace_alter_table() and thus might be higher than during
412 prepare_inplace_alter_table(). (E.g concurrent writes were
413 blocked during prepare, but might not be during commit).
414 @param[in] altered_table TABLE object for new version of table.
415 @param[in,out] ha_alter_info Structure describing changes to be done
416 by ALTER TABLE and holding data used during in-place alter.
417 @param[in] commit True to commit or false to rollback.
418 @param[in] old_dd_tab dd::Table object representing old
419 version of the table
420 @param[in,out] new_dd_tab dd::Table object representing new
421 version of the table. Can be adjusted by this call. Changes to the table
422 definition will be persisted in the data-dictionary at statement
423 commit time.
424 @retval true Failure
425 @retval false Success */
426 bool commit_inplace_alter_table(TABLE *altered_table,
427 Alter_inplace_info *ha_alter_info,
428 bool commit, const dd::Table *old_dd_tab,
429 dd::Table *new_dd_tab) override;
430 /** @} */
431
433
434 /** Initializes a parallel scan. It creates a scan_ctx that has to
435 be used across all parallel_scan methods. Also, gets the number of threads
436 that would be spawned for parallel scan.
437 @param[out] scan_ctx A scan context created by this method
438 that has to be used in parallel_scan
439 @param[out] num_threads Number of threads to be spawned
440 @param[in] use_reserved_threads true if reserved threads are to be used
441 if we exhaust the max cap of number of
442 parallel read threads that can be
443 spawned at a time
444 @param[in] max_desired_threads Maximum number of desired read threads;
445 passing 0 has no effect, it is ignored;
446 upper-limited by the current value of
447 innodb_parallel_read_threads.
448 @return error code
449 @retval 0 on success */
450 int parallel_scan_init(void *&scan_ctx, size_t *num_threads,
451 bool use_reserved_threads,
452 size_t max_desired_threads) override;
453
454 /** Start parallel read of InnoDB records.
455 @param[in] scan_ctx A scan context created by parallel_scan_init
456 @param[in] thread_ctxs Context for each of the spawned threads
457 @param[in] init_fn Callback called by each parallel load
458 thread at the beginning of the parallel load.
459 @param[in] load_fn Callback called by each parallel load
460 thread when processing of rows is required.
461 @param[in] end_fn Callback called by each parallel load
462 thread when processing of rows has ended.
463 @return error code
464 @retval 0 on success */
465 int parallel_scan(void *scan_ctx, void **thread_ctxs, Reader::Init_fn init_fn,
466 Reader::Load_fn load_fn, Reader::End_fn end_fn) override;
467
468 /** End of the parallel scan.
469 @param[in] scan_ctx A scan context created by parallel_scan_init. */
470 void parallel_scan_end(void *scan_ctx) override;
471
472 /** Check if the table is ready for bulk load
473 @param[in] thd user session
474 @return true iff bulk load can be done on the table. */
475 bool bulk_load_check(THD *thd) const override;
476
477 /** Get the total memory available for bulk load in innodb buffer pool.
478 @param[in] thd user session
479 @return available memory for bulk load */
480 size_t bulk_load_available_memory(THD *thd) const override;
481
482 /** Begin parallel bulk data load to the table.
483 @param[in] thd user session
484 @param[in] data_size total data size in bytes
485 @param[in] memory buffer pool memory to be used
486 @param[in] num_threads Number of concurrent threads used for load.
487 @return bulk load context or nullptr if unsuccessful. */
488 void *bulk_load_begin(THD *thd, size_t data_size, size_t memory,
489 size_t num_threads) override;
490
491 /** Execute bulk load operation. To be called by each of the concurrent
492 threads idenified by thread index.
493 @param[in,out] thd user session
494 @param[in,out] load_ctx load execution context
495 @param[in] thread_idx index of the thread executing
496 @param[in] rows rows to be loaded to the table
497 @param[in] wait_cbk Stat callbacks
498 @return error code. */
499 int bulk_load_execute(THD *thd, void *load_ctx, size_t thread_idx,
500 const Rows_mysql &rows,
501 Bulk_load::Stat_callbacks &wait_cbk) override;
502
503 /** End bulk load operation. Must be called after all execution threads have
504 completed. Must be called even if the bulk load execution failed.
505 @param[in,out] thd user session
506 @param[in,out] load_ctx load execution context
507 @param[in] is_error true, if bulk load execution have failed
508 @return error code. */
509 int bulk_load_end(THD *thd, void *load_ctx, bool is_error) override;
510
512 uint table_changes) override;
513
514 private:
515 /** @name Multi Range Read interface
516 @{ */
517
518 /** Initialize multi range read @see DsMrr_impl::dsmrr_init */
519 int multi_range_read_init(RANGE_SEQ_IF *seq, void *seq_init_param,
520 uint n_ranges, uint mode,
521 HANDLER_BUFFER *buf) override;
522
523 /** Process next multi range read @see DsMrr_impl::dsmrr_next */
524 int multi_range_read_next(char **range_info) override;
525
526 /** Initialize multi range read and get information.
527 @see ha_myisam::multi_range_read_info_const
528 @see DsMrr_impl::dsmrr_info_const */
530 void *seq_init_param, uint n_ranges,
531 uint *bufsz, uint *flags,
532 Cost_estimate *cost) override;
533
534 /** Initialize multi range read and get information.
535 @see DsMrr_impl::dsmrr_info */
536 ha_rows multi_range_read_info(uint keyno, uint n_ranges, uint keys,
537 uint *bufsz, uint *flags,
538 Cost_estimate *cost) override;
539
540 /** Attempt to push down an index condition.
541 @param[in] keyno MySQL key number
542 @param[in] idx_cond Index condition to be checked
543 @return idx_cond if pushed; NULL if not pushed */
544 Item *idx_cond_push(uint keyno, Item *idx_cond) override;
545 /** @} */
546
547 private:
548 void update_thd();
549
550 int change_active_index(uint keynr);
551
553
555
557
559
560 /** Resets a query execution 'template'.
561 @see build_template() */
562 void reset_template();
563
564 /** Write Row Interface optimized for Intrinsic table. */
566
567 /** Find out if a Record_buffer is wanted by this handler, and what is
568 the maximum buffer size the handler wants.
569
570 @param[out] max_rows gets set to the maximum number of records to
571 allocate space for in the buffer
572 @retval true if the handler wants a buffer
573 @retval false if the handler does not want a buffer */
574 bool is_record_buffer_wanted(ha_rows *const max_rows) const override;
575
576 /** TRUNCATE an InnoDB table.
577 @param[in] name table name
578 @param[in] form table definition
579 @param[in,out] table_def dd::Table describing table to be
580 truncated. Can be adjusted by SE, the changes will be saved into
581 the data-dictionary at statement commit time.
582 @return error number
583 @retval 0 on success */
584 int truncate_impl(const char *name, TABLE *form, dd::Table *table_def);
585
586 protected:
587 /** Enter InnoDB engine after checking max allowed threads.
588 @return mysql error code. */
590
591 /** Leave Innodb, if no more tickets are left */
593
594 void update_thd(THD *thd);
595
596 int general_fetch(uchar *buf, uint direction, uint match_mode);
597
598 virtual dict_index_t *innobase_get_index(uint keynr);
599
600 /** Builds a 'template' to the m_prebuilt struct. The template is used in fast
601 retrieval of just those column values MySQL needs in its processing.
602 @param[in] whole_row true if access is needed to a whole row, false if
603 accessing individual fields is enough */
604 void build_template(bool whole_row);
605
606 /** Returns statistics information of the table to the MySQL interpreter, in
607 various fields of the handle object.
608 @param[in] flag what information is requested
609 @param[in] is_analyze True if called from "::analyze()".
610 @return HA_ERR_* error code or 0 */
611 virtual int info_low(uint flag, bool is_analyze);
612
613 /**
614 MySQL calls this method at the end of each statement. This method
615 exists for readability only, called from reset(). The name reset()
616 doesn't give any clue that it is called at the end of a statement. */
617 int end_stmt();
618
619 /** Implementation of prepare_inplace_alter_table()
620 @tparam Table dd::Table or dd::Partition
621 @param[in] altered_table TABLE object for new version of table.
622 @param[in,out] ha_alter_info Structure describing changes to be done
623 by ALTER TABLE and holding data used
624 during in-place alter.
625 @param[in] old_dd_tab dd::Table object representing old
626 version of the table
627 @param[in,out] new_dd_tab dd::Table object representing new
628 version of the table
629 @retval true Failure
630 @retval false Success */
631 template <typename Table>
632 bool prepare_inplace_alter_table_impl(TABLE *altered_table,
633 Alter_inplace_info *ha_alter_info,
634 const Table *old_dd_tab,
635 Table *new_dd_tab);
636
637 /** Implementation of inplace_alter_table()
638 @tparam Table dd::Table or dd::Partition
639 @param[in] altered_table TABLE object for new version of table.
640 @param[in,out] ha_alter_info Structure describing changes to be done
641 by ALTER TABLE and holding data used
642 during in-place alter.
643 the table. Can be adjusted by this call. Changes to the table definition will
644 be persisted in the data-dictionary at statement commit time.
645 @retval true Failure
646 @retval false Success
647 */
648 template <typename Table>
649 bool inplace_alter_table_impl(TABLE *altered_table,
650 Alter_inplace_info *ha_alter_info);
651
652 /** Implementation of commit_inplace_alter_table()
653 @tparam Table dd::Table or dd::Partition
654 @param[in] altered_table TABLE object for new version of table.
655 @param[in,out] ha_alter_info Structure describing changes to be done
656 by ALTER TABLE and holding data used
657 during in-place alter.
658 @param[in] commit True to commit or false to rollback.
659 @param[in,out] new_dd_tab Table object for the new version of the
660 table. Can be adjusted by this call.
661 Changes to the table definition
662 will be persisted in the data-dictionary
663 at statement version of it.
664 @retval true Failure
665 @retval false Success */
666 template <typename Table>
667 bool commit_inplace_alter_table_impl(TABLE *altered_table,
668 Alter_inplace_info *ha_alter_info,
669 bool commit, Table *new_dd_tab);
670
671 /**
672 Return max limits for a single set of multi-valued keys
673
674 @param[out] num_keys number of keys to store
675 @param[out] keys_length total length of keys, bytes
676 */
677 void mv_key_capacity(uint *num_keys, size_t *keys_length) const override;
678
679 /** Can reuse the template. Mainly used for partition.
680 @retval true Can reuse the mysql_template */
681 virtual bool can_reuse_mysql_template() const { return false; }
682
683 /** The multi range read session object */
685
686 /** Save CPU time with prebuilt/cached data structures */
688
689 /** Thread handle of the user currently using the handler;
690 this is set in external_lock function */
692
693 /** information for MySQL table locking */
695
696 /** buffer used in updates */
698
699 /** the size of upd_buf in bytes */
701
702 /** Flags that specify the handler instance (table) capability. */
704
705 /** this is set to 1 when we are starting a table scan but have
706 not yet fetched any row, else false */
708
709 /*!< match mode of the latest search: ROW_SEL_EXACT,
710 ROW_SEL_EXACT_PREFIX, or undefined */
712
713 /** this field is used to remember the original select_lock_type that
714 was decided in ha_innodb.cc,":: store_lock()", "::external_lock()",
715 etc. */
717
718 /** If mysql has locked with external_lock() */
720};
721
722struct trx_t;
723
724extern const struct _ft_vft ft_vft_result;
725
726/** Return the number of read threads for this session.
727@param[in] thd Session instance, or nullptr to query the global
728 innodb_parallel_read_threads value. */
730
731/** Structure Returned by ha_innobase::ft_init_ext() */
732typedef struct new_ft_info {
738
739/** Allocates an InnoDB transaction for a MySQL handler object for DML.
740@param[in] hton Innobase handlerton.
741@param[in] thd MySQL thd (connection) object.
742@param[in] trx transaction to register. */
743void innobase_register_trx(handlerton *hton, THD *thd, trx_t *trx);
744
745/**
746Allocates an InnoDB transaction for a MySQL handler object.
747@return InnoDB transaction handle */
748trx_t *innobase_trx_allocate(THD *thd); /*!< in: user thread handle */
749
750/** Maps a MySQL trx isolation level code to the InnoDB isolation level code.
751@param[in] iso MySQL isolation level code
752@return InnoDB isolation level */
755
756/** Match index columns between MySQL and InnoDB.
757This function checks whether the index column information
758is consistent between KEY info from mysql and that from innodb index.
759@param[in] key_info Index info from mysql
760@param[in] index_info Index info from InnoDB
761@return true if all column types match. */
762bool innobase_match_index_columns(const KEY *key_info,
763 const dict_index_t *index_info);
764
765/** This function checks each index name for a table against reserved
766 system default primary index name 'GEN_CLUST_INDEX'. If a name
767 matches, this function pushes an warning message to the client,
768 and returns true.
769 @return true if the index name matches the reserved name */
770[[nodiscard]] bool innobase_index_name_is_reserved(
771 THD *thd, /*!< in/out: MySQL connection */
772 const KEY *key_info, /*!< in: Indexes to be
773 created */
774 ulint num_of_keys); /*!< in: Number of indexes to
775 be created. */
776
777/** Check if the explicit tablespace targeted is file_per_table.
778@param[in] create_info Metadata for the table to create.
779@return true if the table is intended to use a file_per_table tablespace. */
781 const HA_CREATE_INFO *create_info) {
782 return (create_info->tablespace != nullptr &&
783 (0 ==
784 strcmp(create_info->tablespace, dict_sys_t::s_file_per_table_name)));
785}
786
787/** Check if table will be explicitly put in an existing shared general
788or system tablespace.
789@param[in] create_info Metadata for the table to create.
790@return true if the table will use a shared general or system tablespace. */
791static inline bool tablespace_is_shared_space(
792 const HA_CREATE_INFO *create_info) {
793 return (create_info->tablespace != nullptr &&
794 create_info->tablespace[0] != '\0' &&
795 (0 !=
796 strcmp(create_info->tablespace, dict_sys_t::s_file_per_table_name)));
797}
798
799/** Check if table will be explicitly put in a general tablespace.
800@param[in] create_info Metadata for the table to create.
801@return true if the table will use a general tablespace. */
803 const HA_CREATE_INFO *create_info) {
804 return (
805 create_info->tablespace != nullptr &&
806 create_info->tablespace[0] != '\0' &&
807 (0 !=
808 strcmp(create_info->tablespace, dict_sys_t::s_file_per_table_name)) &&
809 (0 != strcmp(create_info->tablespace, dict_sys_t::s_temp_space_name)) &&
810 (0 != strcmp(create_info->tablespace, dict_sys_t::s_sys_space_name)));
811}
812
813/** Check if tablespace is shared tablespace.
814@param[in] tablespace_name Name of the tablespace
815@return true if tablespace is a shared tablespace. */
816static inline bool is_shared_tablespace(const char *tablespace_name) {
817 if (tablespace_name != nullptr && tablespace_name[0] != '\0' &&
818 (strcmp(tablespace_name, dict_sys_t::s_file_per_table_name) != 0)) {
819 return true;
820 }
821 return false;
822}
823
824constexpr uint32_t SIZE_MB = 1024 * 1024;
825
826/** Validate AUTOEXTEND_SIZE attribute for a tablespace.
827@param[in] ext_size Value of autoextend_size attribute
828@return DB_SUCCESS if the value of AUTOEXTEND_SIZE is valid. */
829static inline int validate_autoextend_size_value(uint64_t ext_size) {
830 ut_ad(ext_size > 0);
831
832 page_no_t extent_size_pages = fsp_get_extent_size_in_pages(
833 {static_cast<uint32_t>(srv_page_size),
834 static_cast<uint32_t>(srv_page_size), false});
835
836 /* Validate following for the AUTOEXTEND_SIZE attribute
837 1. The autoextend_size should be a multiple of size of 4 extents
838 2. The autoextend_size value should be between size of 4 extents and 4G */
839 if (ext_size < (FSP_FREE_ADD * extent_size_pages * srv_page_size) ||
840 ext_size > FSP_MAX_AUTOEXTEND_SIZE) {
841 my_error(ER_INNODB_AUTOEXTEND_SIZE_OUT_OF_RANGE, MYF(0),
842 (FSP_FREE_ADD * extent_size_pages * srv_page_size) / SIZE_MB,
844 return ER_INNODB_AUTOEXTEND_SIZE_OUT_OF_RANGE;
845 }
846
847 if ((ext_size / srv_page_size) % (FSP_FREE_ADD * extent_size_pages) != 0) {
848 my_error(ER_INNODB_INVALID_AUTOEXTEND_SIZE_VALUE, MYF(0),
849 FSP_FREE_ADD * extent_size_pages * srv_page_size / SIZE_MB);
850 return ER_INNODB_INVALID_AUTOEXTEND_SIZE_VALUE;
851 }
852
853 return DB_SUCCESS;
854}
855
856/** Parse hint for table and its indexes, and update the information
857in dictionary.
858@param[in] thd Connection thread
859@param[in,out] table Target table
860@param[in] table_share Table definition */
862 const TABLE_SHARE *table_share);
863
864/** Obtain the InnoDB transaction of a MySQL thread.
865@param[in,out] thd MySQL thread handler.
866@return reference to transaction pointer */
867trx_t *&thd_to_trx(THD *thd);
868
869/** Class for handling create table information. */
871 public:
872 /** Constructor.
873 Used in two ways:
874 - all but file_per_table is used, when creating the table.
875 - all but name/path is used, when validating options and using flags. */
877 char *table_name, char *remote_path, char *tablespace,
878 bool file_per_table, bool skip_strict, uint32_t old_flags,
879 uint32_t old_flags2, bool is_partition)
880 : m_thd(thd),
882 m_form(form),
883 m_create_info(create_info),
885 m_remote_path(remote_path),
886 m_tablespace(tablespace),
887 m_innodb_file_per_table(file_per_table),
888 m_flags(old_flags),
889 m_flags2(old_flags2),
892
893 /** Initialize the object. */
894 int initialize();
895
896 /** Set m_tablespace_type. */
897 void set_tablespace_type(bool table_being_altered_is_file_per_table);
898
899 /** Create the internal innodb table.
900 @param[in] dd_table dd::Table or nullptr for intrinsic table
901 @param[in] old_part_table dd::Table from an old partition for partitioned
902 table, NULL otherwise.
903 @return 0 or error number */
904 int create_table(const dd::Table *dd_table, const dd::Table *old_part_table);
905
906 /** Update the internal data dictionary. */
908
909 /** Update the global data dictionary.
910 @param[in] dd_table dd::Table or dd::Partition
911 @retval 0 On success
912 @retval error number On failure */
913 template <typename Table>
914 int create_table_update_global_dd(Table *dd_table);
915
916 /** Validates the create options. Checks that the options
917 KEY_BLOCK_SIZE, ROW_FORMAT, DATA DIRECTORY, TEMPORARY & TABLESPACE
918 are compatible with each other and other settings.
919 These CREATE OPTIONS are not validated here unless innodb_strict_mode
920 is on. With strict mode, this function will report each problem it
921 finds using a custom message with error code
922 ER_ILLEGAL_HA_CREATE_OPTION, not its built-in message.
923 @return NULL if valid, string name of bad option if not. */
924 const char *create_options_are_invalid();
925
926 private:
927 /** Put a warning or error message to the error log for the
928 DATA DIRECTORY option.
929 @param[in] msg The reason that data directory is wrong.
930 @param[in] ignore If true, append a message about ignoring
931 the data directory location. */
932 void log_error_invalid_location(std::string &msg, bool ignore);
933
934 public:
935 /** Validate DATA DIRECTORY option. */
937
938 /** Validate TABLESPACE option. */
940
941 /** Validate COMPRESSION option. */
943
944 /** Prepare to create a table. */
945 int prepare_create_table(const char *name);
946
947 /** Determine InnoDB table flags.
948 If strict_mode=OFF, this will adjust the flags to what should be assumed.
949 However, if an existing general tablespace is being targeted, we will NOT
950 assume anything or adjust these flags.
951 @retval true if successful, false if error */
953
954 /** Set flags and append '/' to remote path if necessary. */
956
957 /** Get table flags. */
958 uint32_t flags() const { return (m_flags); }
959
960 /** Get table flags2. */
961 uint32_t flags2() const { return (m_flags2); }
962
963 /** Reset table flags. */
964 void flags_reset() { m_flags = 0; }
965
966 /** Reset table flags2. */
967 void flags2_reset() { m_flags2 = 0; }
968
969 /** whether to skip strict check. */
970 bool skip_strict() const { return (m_skip_strict); }
971
972 /** Return table name. */
973 const char *table_name() const { return (m_table_name); }
974
975 THD *thd() const { return (m_thd); }
976
977 inline bool is_intrinsic_temp_table() const {
978 /* DICT_TF2_INTRINSIC implies DICT_TF2_TEMPORARY */
980 return ((m_flags2 & DICT_TF2_INTRINSIC) != 0);
981 }
982
983 /** @return true only if table is temporary and not intrinsic */
984 inline bool is_temp_table() const {
985 return (((m_flags2 & DICT_TF2_TEMPORARY) != 0) &&
986 ((m_flags2 & DICT_TF2_INTRINSIC) == 0));
987 }
988
989 /** Detach the just created table and its auxiliary tables if exist. */
990 void detach();
991
992 /** Normalizes a table name string.
993 A normalized name consists of the database name catenated to '/' and
994 table name. An example: test/mytable. On case insensitive file system
995 normalization converts name to lower case.
996 @param[in,out] norm_name Buffer to return the normalized name in.
997 @param[in] name Table name string.
998 @return true if successful. */
999 static bool normalize_table_name(char *norm_name, const char *name);
1000
1001 private:
1002 /** Parses the table name into normal name and either temp path or
1003 remote path if needed.*/
1004 int parse_table_name(const char *name);
1005
1006 /** Create a table definition to an InnoDB database.
1007 @param[in] dd_table dd::Table or nullptr for intrinsic table
1008 @param[in] old_part_table dd::Table from an old partition for partitioned
1009 table, NULL otherwise.
1010 @return HA_* level error */
1011 int create_table_def(const dd::Table *dd_table,
1012 const dd::Table *old_part_table);
1013
1014 /** Initialize the autoinc of this table if necessary, which should
1015 be called before we flush logs, so autoinc counter can be persisted. */
1016 void initialize_autoinc();
1017
1018 /** Connection thread handle. */
1020
1021 /** InnoDB transaction handle. */
1023
1024 /** Information on table columns and indexes. */
1026
1027 /** Create options. */
1029
1030 /** Table name */
1032 /** Remote path (DATA DIRECTORY) or zero length-string */
1034 /** Tablespace name or zero length-string. */
1036
1037 /** The newly created InnoDB table object. This is currently only
1038 used in this class, since the new table is not evictable until
1039 final success/failure, it can be accessed directly. */
1041
1042 /** Local copy of srv_file_per_table. */
1044
1045 /** Allow file_per_table for this table either because:
1046 1) the setting innodb_file_per_table=on,
1047 2) it was explicitly requested by tablespace=innodb_file_per_table.
1048 3) the table being altered is currently file_per_table */
1050
1051 /** After all considerations, this shows whether we will actually
1052 create a table and tablespace using file-per-table. */
1054
1055 /** Using DATA DIRECTORY */
1057
1058 /** Using a Shared General Tablespace */
1060
1061 /** Table flags */
1062 uint32_t m_flags;
1063
1064 /** Table flags2 */
1065 uint32_t m_flags2;
1066
1067 /** Skip strict check */
1069
1070 /** True if this table is a partition */
1072};
1073
1074/** Class of basic DDL implementation, for CREATE/DROP/RENAME TABLE */
1076 public:
1077 /** Create an InnoDB table.
1078 @tparam Table dd::Table or dd::Partition
1079 @param[in,out] thd THD object
1080 @param[in] name Table name, format: "db/table_name"
1081 @param[in] form Table format; columns and index
1082 information
1083 @param[in] create_info Create info(including create statement
1084 string)
1085 @param[in,out] dd_tab dd::Table describing table to be created
1086 @param[in] file_per_table whether to create a tablespace too
1087 @param[in] evictable whether the caller wants the
1088 dict_table_t to be kept in memory
1089 @param[in] skip_strict whether to skip strict check for create
1090 option
1091 @param[in] old_flags old Table flags
1092 @param[in] old_flags2 old Table flags2
1093 @param[in] old_dd_table Table def for old table. Used in truncate or
1094 while adding a new partition
1095 @return error number
1096 @retval 0 on success */
1097 template <typename Table>
1098 static int create_impl(THD *thd, const char *name, TABLE *form,
1099 HA_CREATE_INFO *create_info, Table *dd_tab,
1100 bool file_per_table, bool evictable, bool skip_strict,
1101 uint32_t old_flags, uint32_t old_flags2,
1102 const dd::Table *old_dd_table);
1103
1104 /** Drop an InnoDB table.
1105 @tparam Table dd::Table or dd::Partition
1106 @param[in,out] thd THD object
1107 @param[in] name table name
1108 @param[in] dd_tab dd::Table describing table to be dropped
1109 @param[in] td MySQL table definition
1110 @return error number
1111 @retval 0 on success */
1112
1113 template <typename Table>
1114 static int delete_impl(THD *thd, const char *name, const Table *dd_tab,
1115 const TABLE *td);
1116
1117 /** Renames an InnoDB table.
1118 @tparam Table dd::Table or dd::Partition
1119 @param[in,out] thd THD object
1120 @param[in] from old name of the table
1121 @param[in] to new name of the table
1122 @param[in] from_table dd::Table or dd::Partition of the table
1123 with old name
1124 @param[in] to_table dd::Table or dd::Partition of the table
1125 with new name
1126 @param[in] td MySQL table definition
1127 @return error number
1128 @retval 0 on success */
1129
1130 template <typename Table>
1131 static int rename_impl(THD *thd, const char *from, const char *to,
1132 const Table *from_table, const Table *to_table,
1133 const TABLE *td);
1134};
1135
1136/** Class to handle TRUNCATE for one InnoDB table or one partition */
1137template <typename Table>
1139 public:
1140 /** Constructor
1141 @param[in] thd THD object
1142 @param[in] name normalized table name
1143 @param[in] form Table format; columns and index information
1144 @param[in] dd_table dd::Table or dd::Partition
1145 @param[in] keep_autoinc true to remember original autoinc counter
1146 @param[in] table_truncate true if this is full table truncate */
1147 innobase_truncate(THD *thd, const char *name, TABLE *form, Table *dd_table,
1148 bool keep_autoinc, bool table_truncate)
1149 : m_thd(thd),
1150 m_name(name),
1151 m_dd_table(dd_table),
1152 m_trx(nullptr),
1154 m_form(form),
1155 m_create_info(),
1156 m_file_per_table(false),
1157 m_keep_autoinc(keep_autoinc),
1158 m_table_truncate(table_truncate),
1159 m_flags(0),
1160 m_flags2(0) {}
1161
1162 /** Destructor */
1164
1165 /** Open the table/partition to be truncated
1166 @param[out] innodb_table InnoDB table object opened
1167 @return error number or 0 on success */
1168 int open_table(dict_table_t *&innodb_table);
1169
1170 /** Do the truncate of the table/partition
1171 @return error number or 0 on success */
1172 int exec();
1173
1174 private:
1175 /** Prepare for truncate
1176 @return error number or 0 on success */
1177 int prepare();
1178
1179 /** Do the real truncation
1180 @return error number or 0 on success */
1181 int truncate();
1182
1183 /** Rename tablespace file name
1184 @return error number or 0 on success */
1185 int rename_tablespace();
1186
1187 /** Cleanup */
1188 void cleanup();
1189
1190 /** Reload the FK related information
1191 @return error number or 0 on success */
1192 int load_fk();
1193
1194 private:
1195 /** THD object */
1197
1198 /** Normalized table name */
1199 const char *m_name;
1200
1201 /** dd::Table or dd::Partition */
1203
1204 /** Transaction attached to current thd */
1206
1207 /** InnoDB table object for the table/partition */
1209
1210 /** Table format */
1212
1213 /** Create information */
1215
1216 /** True if this table/partition is file per table */
1218
1219 /** True if the original autoinc counter should be kept. It's
1220 specified by caller, however if the table has no AUTOINC column,
1221 it would be reset to false internally */
1223
1224 /** For a prtition table, this is true if full table is truncated. If only
1225 a partition is truncated, it is set to false. */
1227
1228 /** flags of the table to be truncated, which should not change */
1229 uint32_t m_flags;
1230
1231 /** flags2 of the table to be truncated, which should not change */
1232 uint32_t m_flags2;
1233};
1234
1235/**
1236Initialize the table FTS stopword list
1237@return true if success */
1238[[nodiscard]] bool innobase_fts_load_stopword(
1239 dict_table_t *table, /*!< in: Table has the FTS */
1240 trx_t *trx, /*!< in: transaction */
1241 THD *thd); /*!< in: current thread */
1242
1243/** Some defines for innobase_fts_check_doc_id_index() return value */
1249
1250/**
1251Check whether the table has a unique index with FTS_DOC_ID_INDEX_NAME
1252on the Doc ID column.
1253@return the status of the FTS_DOC_ID index */
1255 const dict_table_t *table, /*!< in: table definition */
1256 const TABLE *altered_table, /*!< in: MySQL table
1257 that is being altered */
1258 ulint *fts_doc_col_no); /*!< out: The column number for
1259 Doc ID */
1260
1261/**
1262Check whether the table has a unique index with FTS_DOC_ID_INDEX_NAME
1263on the Doc ID column in MySQL create index definition.
1264@return FTS_EXIST_DOC_ID_INDEX if there exists the FTS_DOC_ID index,
1265FTS_INCORRECT_DOC_ID_INDEX if the FTS_DOC_ID index is of wrong format */
1267 ulint n_key, /*!< in: Number of keys */
1268 const KEY *key_info); /*!< in: Key definitions */
1269
1270/**
1271Copy table flags from MySQL's TABLE_SHARE into an InnoDB table object.
1272Those flags are stored in .frm file and end up in the MySQL table object,
1273but are frequently used inside InnoDB so we keep their copies into the
1274InnoDB table object. */
1276 dict_table_t *innodb_table, /*!< in/out: InnoDB table */
1277 const TABLE_SHARE *table_share); /*!< in: table share */
1278
1279/** Set up base columns for virtual column
1280@param[in] table the InnoDB table
1281@param[in] field MySQL field
1282@param[in,out] v_col virtual column to be set up */
1283void innodb_base_col_setup(dict_table_t *table, const Field *field,
1284 dict_v_col_t *v_col);
1285
1286/** Set up base columns for stored column
1287@param[in] table InnoDB table
1288@param[in] field MySQL field
1289@param[in,out] s_col stored column */
1291 const Field *field, dict_s_col_t *s_col);
1292
1293/** whether this is a stored column */
1294static inline bool innobase_is_s_fld(const Field *field) {
1295 return field->gcol_info && field->stored_in_db;
1296}
1297
1298/** Whether this is a computed multi-value virtual column.
1299This condition check should be equal to the following one:
1300(innobase_is_v_fld(field) && (field)->gcol_info->expr_item &&
1301 field->gcol_info->expr_item->returns_array())
1302*/
1303static inline bool innobase_is_multi_value_fld(const Field *field) {
1304 return field->is_array();
1305}
1306
1307static inline bool normalize_table_name(char *norm_name, const char *name) {
1309}
1310
1311/** Note that a transaction has been registered with MySQL.
1312@param[in] trx Transaction.
1313@return true if transaction is registered with MySQL 2PC coordinator */
1314inline bool trx_is_registered_for_2pc(const trx_t *trx) {
1315 return (trx->is_registered == 1);
1316}
1317
1318/** Converts an InnoDB error code to a MySQL error code.
1319Also tells to MySQL about a possible transaction rollback inside InnoDB caused
1320by a lock wait timeout or a deadlock.
1321@param[in] error InnoDB error code.
1322@param[in] flags InnoDB table flags or 0.
1323@param[in] thd MySQL thread or NULL.
1324@return MySQL error code */
1326
1327/** Converts a search mode flag understood by MySQL to a flag understood
1328by InnoDB.
1329@param[in] find_flag MySQL search mode flag.
1330@return InnoDB search mode flag. */
1332 enum ha_rkey_function find_flag);
1333
1334extern bool innobase_stats_on_metadata;
1335
1336/** Calculate Record Per Key value.
1337Need to exclude the NULL value if innodb_stats_method is set to "nulls_ignored"
1338@param[in] index InnoDB index.
1339@param[in] i The column we are calculating rec per key.
1340@param[in] records Estimated total records.
1341@return estimated record per key value */
1343 ha_rows records);
1344
1345/** Build template for the virtual columns and their base columns. This
1346is done when the table first opened.
1347@param[in] table MySQL TABLE
1348@param[in] ib_table InnoDB dict_table_t
1349@param[in,out] s_templ InnoDB template structure
1350@param[in] add_v new virtual columns added along with
1351 add index call
1352@param[in] locked true if dict_sys mutex is held
1353@param[in] share_tbl_name original MySQL table name */
1354void innobase_build_v_templ(const TABLE *table, const dict_table_t *ib_table,
1355 dict_vcol_templ_t *s_templ,
1356 const dict_add_v_col_t *add_v, bool locked,
1357 const char *share_tbl_name);
1358
1359/** Callback used by MySQL server layer to initialize
1360the table virtual columns' template
1361@param[in] table MySQL TABLE
1362@param[in,out] ib_table InnoDB table */
1363void innobase_build_v_templ_callback(const TABLE *table, void *ib_table);
1364
1365/** Callback function definition, used by MySQL server layer to initialized
1366the table virtual columns' template */
1367typedef void (*my_gcolumn_templatecallback_t)(const TABLE *, void *);
1368
1369/** Drop the statistics for a specified table, and mark it as discard
1370after DDL
1371@param[in,out] thd THD object
1372@param[in,out] table InnoDB table object */
1374#endif /* ha_innodb_h */
uint32_t page_no_t
Page number.
Definition: api0api.h:45
app_data_ptr new_data(u_int n, char *val, cons_type consensus)
Kerberos Client Authentication nullptr
Definition: auth_kerberos_client_plugin.cc:251
Class describing changes to be done by ALTER TABLE.
Definition: handler.h:3353
Used to store optimizer cost estimates.
Definition: handler.h:3865
Definition: handler.h:7271
Definition: field.h:575
virtual bool is_array() const
Whether the field is a typed array.
Definition: field.h:1801
Value_generator * gcol_info
Definition: field.h:813
bool stored_in_db
Indication that the field is physically stored in tables rather than just generated on SQL queries.
Definition: field.h:819
Wrapper for struct ft_hints.
Definition: handler.h:4125
Base class that is used to represent any kind of expression in a relational query.
Definition: item.h:936
Definition: key.h:113
Definition: sql_list.h:467
Traverse an index in the leaf page block list order and send records to adapter.
Definition: row0pread-adapter.h:43
handler::Load_init_cbk Init_fn
Definition: row0pread-adapter.h:55
handler::Load_end_cbk End_fn
Definition: row0pread-adapter.h:53
handler::Load_cbk Load_fn
Definition: row0pread-adapter.h:51
Implements the row and column memory management for parse and load operations.
Definition: bulk_data_service.h:86
Using this class is fraught with peril, and you need to be very careful when doing so.
Definition: sql_string.h:167
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:36
Class for handling create table information.
Definition: ha_innodb.h:870
bool is_intrinsic_temp_table() const
Definition: ha_innodb.h:977
bool m_use_file_per_table
After all considerations, this shows whether we will actually create a table and tablespace using fil...
Definition: ha_innodb.h:1053
int prepare_create_table(const char *name)
Prepare to create a table.
Definition: ha_innodb.cc:13854
const char * table_name() const
Return table name.
Definition: ha_innodb.h:973
uint32_t m_flags
Table flags.
Definition: ha_innodb.h:1062
THD * m_thd
Connection thread handle.
Definition: ha_innodb.h:1019
bool create_option_tablespace_is_valid()
Validate TABLESPACE option.
Definition: ha_innodb.cc:12592
char * m_remote_path
Remote path (DATA DIRECTORY) or zero length-string.
Definition: ha_innodb.h:1033
int create_table_update_global_dd(Table *dd_table)
Update the global data dictionary.
Definition: ha_innodb.cc:14227
bool create_option_compression_is_valid()
Validate COMPRESSION option.
Definition: ha_innodb.cc:12835
void flags2_reset()
Reset table flags2.
Definition: ha_innodb.h:967
void initialize_autoinc()
Initialize the autoinc of this table if necessary, which should be called before we flush logs,...
Definition: ha_innodb.cc:13791
HA_CREATE_INFO * m_create_info
Create options.
Definition: ha_innodb.h:1028
bool is_temp_table() const
Definition: ha_innodb.h:984
int initialize()
Initialize the object.
Definition: ha_innodb.cc:13763
dict_table_t * m_table
The newly created InnoDB table object.
Definition: ha_innodb.h:1040
void detach()
Detach the just created table and its auxiliary tables if exist.
Definition: ha_innodb.cc:13602
trx_t * m_trx
InnoDB transaction handle.
Definition: ha_innodb.h:1022
bool m_partition
True if this table is a partition.
Definition: ha_innodb.h:1071
uint32_t flags2() const
Get table flags2.
Definition: ha_innodb.h:961
int create_table(const dd::Table *dd_table, const dd::Table *old_part_table)
Create the internal innodb table.
Definition: ha_innodb.cc:13968
static bool normalize_table_name(char *norm_name, const char *name)
Normalizes a table name string.
Definition: ha_innodb.cc:6650
bool m_use_data_dir
Using DATA DIRECTORY.
Definition: ha_innodb.h:1056
char * m_tablespace
Tablespace name or zero length-string.
Definition: ha_innodb.h:1035
bool m_allow_file_per_table
Allow file_per_table for this table either because: 1) the setting innodb_file_per_table=on,...
Definition: ha_innodb.h:1049
bool m_use_shared_space
Using a Shared General Tablespace.
Definition: ha_innodb.h:1059
uint32_t m_flags2
Table flags2.
Definition: ha_innodb.h:1065
bool m_skip_strict
Skip strict check.
Definition: ha_innodb.h:1068
int parse_table_name(const char *name)
Parses the table name into normal name and either temp path or remote path if needed.
Definition: ha_innodb.cc:13268
create_table_info_t(THD *thd, TABLE *form, HA_CREATE_INFO *create_info, char *table_name, char *remote_path, char *tablespace, bool file_per_table, bool skip_strict, uint32_t old_flags, uint32_t old_flags2, bool is_partition)
Constructor.
Definition: ha_innodb.h:876
int create_table_update_dict()
Update the internal data dictionary.
Definition: ha_innodb.cc:14176
void set_tablespace_type(bool table_being_altered_is_file_per_table)
Set m_tablespace_type.
Definition: ha_innodb.cc:13732
bool m_innodb_file_per_table
Local copy of srv_file_per_table.
Definition: ha_innodb.h:1043
bool innobase_table_flags()
Determine InnoDB table flags.
Definition: ha_innodb.cc:13336
const TABLE * m_form
Information on table columns and indexes.
Definition: ha_innodb.h:1025
void set_remote_path_flags()
Set flags and append '/' to remote path if necessary.
Definition: ha_innopart.cc:2375
char * m_table_name
Table name.
Definition: ha_innodb.h:1031
void log_error_invalid_location(std::string &msg, bool ignore)
Put a warning or error message to the error log for the DATA DIRECTORY option.
Definition: ha_innodb.cc:12404
uint32_t flags() const
Get table flags.
Definition: ha_innodb.h:958
bool skip_strict() const
whether to skip strict check.
Definition: ha_innodb.h:970
void flags_reset()
Reset table flags.
Definition: ha_innodb.h:964
THD * thd() const
Definition: ha_innodb.h:975
const char * create_options_are_invalid()
Validates the create options.
Definition: ha_innodb.cc:12899
bool create_option_data_directory_is_valid(bool ignore=false)
Validate DATA DIRECTORY option.
Definition: ha_innodb.cc:12425
int create_table_def(const dd::Table *dd_table, const dd::Table *old_part_table)
Create a table definition to an InnoDB database.
Definition: ha_innodb.cc:11557
Definition: table.h:47
The class defining a handle to an InnoDB table.
Definition: ha_innodb.h:87
THD * m_user_thd
Thread handle of the user currently using the handler; this is set in external_lock function.
Definition: ha_innodb.h:691
void mv_key_capacity(uint *num_keys, size_t *keys_length) const override
Return max limits for a single set of multi-valued keys.
Definition: ha_innodb.cc:24049
int reset() override
MySQL calls this method at the end of each statement.
Definition: ha_innodb.cc:18668
int ft_init() override
Initialize FT index scan.
Definition: ha_innodb.cc:11100
int parallel_scan_init(void *&scan_ctx, size_t *num_threads, bool use_reserved_threads, size_t max_desired_threads) override
Initializes a parallel scan.
Definition: handler0alter.cc:1458
Table_flags table_flags() const override
Get the table flags to use for the statement.
Definition: ha_innodb.cc:6539
DsMrr_impl m_ds_mrr
The multi range read session object.
Definition: ha_innodb.h:684
int disable_indexes(uint mode) override
Disable indexes.
Definition: ha_innodb.cc:18273
int sample_init(void *&scan_ctx, double sampling_percentage, int sampling_seed, enum_sampling_method sampling_method, const bool tablesample) override
Initialize sampling.
Definition: ha_innodb.cc:10895
int delete_table(const char *name, const dd::Table *table_def, enum enum_sql_command sqlcom)
Drop a table.
uchar * m_upd_buf
buffer used in updates
Definition: ha_innodb.h:697
Item * idx_cond_push(uint keyno, Item *idx_cond) override
Attempt to push down an index condition.
Definition: ha_innodb.cc:24007
int general_fetch(uchar *buf, uint direction, uint match_mode)
Reads the next or previous row from a cursor, which must have previously been positioned using index_...
Definition: ha_innodb.cc:10737
uint m_last_match_mode
Definition: ha_innodb.h:711
int rnd_pos(uchar *buf, uchar *pos) override
Fetches a row from the table based on a row reference.
Definition: ha_innodb.cc:11069
int extra(ha_extra_function operation) override
Tells something additional to the handler about how to do things.
Definition: ha_innodb.cc:18547
void build_template(bool whole_row)
Builds a 'template' to the m_prebuilt struct.
Definition: ha_innodb.cc:8587
int create(const char *name, TABLE *form, HA_CREATE_INFO *create_info, dd::Table *table_def) override
Create an InnoDB table.
Definition: ha_innodb.cc:15304
bool is_record_buffer_wanted(ha_rows *const max_rows) const override
Find out if a Record_buffer is wanted by this handler, and what is the maximum buffer size the handle...
Definition: ha_innodb.cc:24026
double scan_time() override
How many seeks it will take to read through the table.
Definition: ha_innodb.cc:17064
void innobase_initialize_autoinc()
Set the autoinc column max value.
Definition: ha_innodb.cc:7267
int discard_or_import_tablespace(bool discard, dd::Table *table_def) override
Discards or imports an InnoDB tablespace.
Definition: ha_innodb.cc:15337
handler * clone(const char *name, MEM_ROOT *mem_root) override
Definition: ha_innodb.cc:7856
void srv_concurrency_exit()
Leave Innodb, if no more tickets are left.
Definition: ha_innodb.cc:2934
ha_rows multi_range_read_info(uint keyno, uint n_ranges, uint keys, uint *bufsz, uint *flags, Cost_estimate *cost) override
Initialize multi range read and get information.
Definition: ha_innodb.cc:23679
bool primary_key_is_clustered() const override
Determines if the primary key is clustered index.
Definition: ha_innodb.cc:6648
int intrinsic_table_write_row(uchar *record)
Write Row Interface optimized for Intrinsic table.
Definition: ha_innodb.cc:8979
int start_stmt(THD *thd, thr_lock_type lock_type) override
MySQL calls this function at the start of each SQL statement inside LOCK TABLES.
Definition: ha_innodb.cc:18682
ulong index_flags(uint idx, uint part, bool all_parts) const override
Returns the operations supported for indexes.
Definition: ha_innodb.cc:6578
int rnd_end() override
Ends a table scan.
Definition: ha_innodb.cc:11034
int update_row(const uchar *old_data, uchar *new_data) override
Updates a row given as a parameter to a new value.
Definition: ha_innodb.cc:9967
int index_end() override
Currently does nothing.
Definition: ha_innodb.cc:10277
ha_rows records_in_range(uint inx, key_range *min_key, key_range *max_key) override
Estimates the number of index records in a range.
Definition: ha_innodb.cc:16897
virtual dict_index_t * innobase_get_index(uint keynr)
Get the index for a handle.
Definition: ha_innodb.cc:10592
uint max_supported_key_part_length(HA_CREATE_INFO *create_info) const override
Definition: ha_innodb.cc:7873
int get_extra_columns_and_keys(const HA_CREATE_INFO *, const List< Create_field > *, const KEY *, uint, dd::Table *dd_table) override
Add hidden columns and indexes to an InnoDB table definition.
Definition: ha_innodb.cc:14992
int multi_range_read_next(char **range_info) override
Process next multi range read.
Definition: ha_innodb.cc:23663
row_prebuilt_t * m_prebuilt
Save CPU time with prebuilt/cached data structures.
Definition: ha_innodb.h:687
bool m_mysql_has_locked
If mysql has locked with external_lock()
Definition: ha_innodb.h:719
int index_next_same(uchar *buf, const uchar *key, uint keylen) override
Reads the next row matching to the key value given as the parameter.
Definition: ha_innodb.cc:10832
int rnd_next(uchar *buf) override
Reads the next row in a table scan (also used to read the FIRST row in a table scan).
Definition: ha_innodb.cc:11040
bool prepare_inplace_alter_table_impl(TABLE *altered_table, Alter_inplace_info *ha_alter_info, const Table *old_dd_tab, Table *new_dd_tab)
Implementation of prepare_inplace_alter_table()
Definition: handler0alter.cc:5417
int enable_indexes(uint mode) override
Enable indexes.
Definition: ha_innodb.cc:18247
ha_innobase(handlerton *hton, TABLE_SHARE *table_arg)
Construct ha_innobase handler.
Definition: ha_innodb.cc:2940
void update_thd()
Updates the user_thd field in a handle and also allocates a new InnoDB transaction handle if needed,...
Definition: ha_innodb.cc:2990
int rnd_init(bool scan) override
Initialize a table scan.
Definition: ha_innodb.cc:11013
int index_next(uchar *buf) override
Reads the next row from a cursor, which must have previously been positioned using index_read.
Definition: ha_innodb.cc:10821
INNOBASE_SHARE * m_share
information for MySQL table locking
Definition: ha_innodb.h:694
int parallel_scan(void *scan_ctx, void **thread_ctxs, Reader::Init_fn init_fn, Reader::Load_fn load_fn, Reader::End_fn end_fn) override
Start parallel read of InnoDB records.
Definition: handler0alter.cc:1527
int bulk_load_end(THD *thd, void *load_ctx, bool is_error) override
End bulk load operation.
Definition: handler0alter.cc:11195
ulint m_stored_select_lock_type
this field is used to remember the original select_lock_type that was decided in ha_innodb....
Definition: ha_innodb.h:716
dberr_t innobase_set_max_autoinc(ulonglong auto_inc)
Store the autoinc value in the table.
Definition: ha_innodb.cc:8960
virtual bool can_reuse_mysql_template() const
Can reuse the template.
Definition: ha_innodb.h:681
void position(const uchar *record) override
Store a reference to the current row to 'ref' field of the handle.
Definition: ha_innodb.cc:11455
int multi_range_read_init(RANGE_SEQ_IF *seq, void *seq_init_param, uint n_ranges, uint mode, HANDLER_BUFFER *buf) override
Initialize multi range read.
Definition: ha_innodb.cc:23655
void unlock_row() override
Removes a new lock set on a row, if it was not read optimistically.
Definition: ha_innodb.cc:10197
bool commit_inplace_alter_table_impl(TABLE *altered_table, Alter_inplace_info *ha_alter_info, bool commit, Table *new_dd_tab)
Implementation of commit_inplace_alter_table()
Definition: handler0alter.cc:7402
bool m_start_of_scan
this is set to 1 when we are starting a table scan but have not yet fetched any row,...
Definition: ha_innodb.h:707
int rename_table(const char *from, const char *to, const dd::Table *from_table, dd::Table *to_table) override
Renames an InnoDB table.
Definition: ha_innodb.cc:16768
void position(uchar *record)
bool was_semi_consistent_read() override
Definition: ha_innodb.cc:10245
int close(void) override
Closes a handle to an InnoDB table.
Definition: ha_innodb.cc:7890
int srv_concurrency_enter()
Enter InnoDB engine after checking max allowed threads.
Definition: ha_innodb.cc:2927
int end_stmt()
MySQL calls this method at the end of each statement.
Definition: ha_innodb.cc:18626
bool get_se_private_data(dd::Table *dd_table, bool reset) override
Get storage-engine private data for a data dictionary table.
Definition: ha_innodb.cc:15226
bool is_index_algorithm_supported(enum ha_key_alg key_alg) const override
Check if SE supports specific key algorithm.
Definition: ha_innodb.h:101
ha_rows estimate_rows_upper_bound() override
Gives an UPPER BOUND to the number of rows in a table.
Definition: ha_innodb.cc:17017
void ft_end()
Definition: ha_innodb.cc:11440
bool get_error_message(int error, String *buf) override
See comment in handler.cc.
Definition: ha_innodb.cc:20005
int open(const char *name, int, uint open_flags, const dd::Table *table_def) override
Open an InnoDB table.
Definition: ha_innodb.cc:7388
uint max_supported_key_length() const override
Returns the maximum key length.
Definition: ha_innodb.cc:6622
longlong get_memory_buffer_size() const override
Return the size of the InnoDB memory buffer.
Definition: ha_innodb.cc:17128
int change_active_index(uint keynr)
Changes the active index of a handle.
Definition: ha_innodb.cc:10636
int records(ha_rows *num_rows) override
Returns the exact number of records that this client can see using this handler object.
Definition: ha_innodb.cc:16806
THR_LOCK_DATA ** store_lock(THD *thd, THR_LOCK_DATA **to, thr_lock_type lock_type) override
Supposed to convert a MySQL table lock stored in the 'lock' field of the handle to a proper type befo...
Definition: ha_innodb.cc:19650
uint lock_count(void) const override
Returns number of THR_LOCK locks used for one instance of InnoDB table.
Definition: ha_innodb.cc:19634
bool check_if_incompatible_data(HA_CREATE_INFO *info, uint table_changes) override
Part of old, deprecated in-place ALTER API.
Definition: ha_innodb.cc:20408
dberr_t innobase_get_autoinc(ulonglong *value)
Read the next autoinc value.
Definition: ha_innodb.cc:19828
void reset_template()
Resets a query execution 'template'.
Definition: ha_innodb.cc:3140
ulint m_upd_buf_size
the size of upd_buf in bytes
Definition: ha_innodb.h:700
void get_auto_increment(ulonglong offset, ulonglong increment, ulonglong nb_desired_values, ulonglong *first_value, ulonglong *nb_reserved_values) override
Returns the value of the auto-inc counter in *first_value and ~0 on failure.
Definition: ha_innodb.cc:19866
size_t bulk_load_available_memory(THD *thd) const override
Get the total memory available for bulk load in innodb buffer pool.
Definition: handler0alter.cc:11124
int info(uint) override
Returns statistics information of the table to the MySQL interpreter, in various fields of the handle...
Definition: ha_innodb.cc:17719
int delete_table(const char *name, const dd::Table *table_def) override
Drop a table.
Definition: ha_innodb.cc:15537
FT_INFO * ft_init_ext(uint flags, uint inx, String *key) override
Initialize FT index scan.
Definition: ha_innodb.cc:11120
uint max_supported_keys() const override
Returns the maximum number of keys.
Definition: ha_innodb.cc:6617
int external_lock(THD *thd, int lock_type) override
As MySQL will execute an external lock for every new table it uses when it starts to process an SQL s...
Definition: ha_innodb.cc:18826
int cmp_ref(const uchar *ref1, const uchar *ref2) const override
Compares two 'refs'.
Definition: ha_innodb.cc:20073
int analyze(THD *thd, HA_CHECK_OPT *check_opt) override
Updates index cardinalities of the table, based on random dives into each index tree.
Definition: ha_innodb.cc:18301
int index_first(uchar *buf) override
Positions a cursor on the first record in an index and reads the corresponding row to buf.
Definition: ha_innodb.cc:10857
bool inplace_alter_table_impl(TABLE *altered_table, Alter_inplace_info *ha_alter_info)
Implementation of inplace_alter_table()
Definition: handler0alter.cc:6114
int ft_read(uchar *buf) override
Fetch next result from the FT result set.
Definition: ha_innodb.cc:11304
bool upgrade_table(THD *thd, const char *db_name, const char *table_name, dd::Table *dd_table) override
Set Engine specific data to dd::Table object for upgrade.
Definition: ha_innodb.cc:15216
void init_table_handle_for_HANDLER() override
Call this when you have opened a new table handle in HANDLER, before you call index_read_map() etc.
Definition: ha_innodb.cc:3170
int index_last(uchar *buf) override
Positions a cursor on the last record in an index and reads the corresponding row to buf.
Definition: ha_innodb.cc:10878
int truncate_impl(const char *name, TABLE *form, dd::Table *table_def)
TRUNCATE an InnoDB table.
Definition: ha_innodb.cc:15463
int sample_end(void *scan_ctx) override
End sampling.
Definition: ha_innodb.cc:10989
int index_init(uint index, bool sorted) override
Initializes a handle to use an index.
Definition: ha_innodb.cc:10264
int read_range_next() override
Read next row between two endpoints.
Definition: ha_innodb.cc:11004
Table_flags m_int_table_flags
Flags that specify the handler instance (table) capability.
Definition: ha_innodb.h:703
int index_read_last(uchar *buf, const uchar *key, uint key_len) override
The following functions works like index_read, but it find the last row with the current key value or...
Definition: ha_innodb.cc:10579
void try_semi_consistent_read(bool yes) override
Tell the engine whether it should avoid unnecessary lock waits.
Definition: ha_innodb.cc:10251
dberr_t innobase_lock_autoinc()
This special handling is really to overcome the limitations of MySQL's binlogging.
Definition: ha_innodb.cc:8894
row_type get_real_row_type(const HA_CREATE_INFO *create_info) const override
Get real row type for the table created based on one specified by user, CREATE TABLE options and SE c...
Definition: ha_innodb.cc:6489
FT_INFO * ft_init_ext_with_hints(uint inx, String *key, Ft_hints *hints) override
Initialize FT index scan.
Definition: ha_innodb.cc:11248
int index_read(uchar *buf, const uchar *key, uint key_len, ha_rkey_function find_flag) override
Positions an index cursor to the index specified in the handle.
Definition: ha_innodb.cc:10387
void parallel_scan_end(void *scan_ctx) override
End of the parallel scan.
Definition: handler0alter.cc:1550
void update_create_info(HA_CREATE_INFO *create_info) override
Update create_info.
Definition: ha_innodb.cc:13070
void release_auto_increment() override
Do cleanup for auto increment calculation.
Definition: ha_innodb.cc:19849
int index_prev(uchar *buf) override
Reads the previous row from a cursor, which must have previously been positioned using index_read.
Definition: ha_innodb.cc:10845
ha_rows multi_range_read_info_const(uint keyno, RANGE_SEQ_IF *seq, void *seq_init_param, uint n_ranges, uint *bufsz, uint *flags, Cost_estimate *cost) override
Initialize multi range read and get information.
Definition: ha_innodb.cc:23667
int write_row(uchar *buf) override
Stores a row in an InnoDB database, to the table specified in this handle.
Definition: ha_innodb.cc:9214
enum ha_key_alg get_default_index_algorithm() const override
Get default key algorithm for SE.
Definition: ha_innodb.h:96
int check(THD *thd, HA_CHECK_OPT *check_opt) override
Tries to check that an InnoDB table is not corrupted.
Definition: ha_innodb.cc:18350
int read_range_first(const key_range *start_key, const key_range *end_key, bool eq_range_arg, bool sorted) override
Read first row between two ranges.
Definition: ha_innodb.cc:10997
int delete_all_rows() override
Delete all rows from the table.
Definition: ha_innodb.cc:10178
bool bulk_load_check(THD *thd) const override
Check if the table is ready for bulk load.
Definition: handler0alter.cc:11083
int bulk_load_execute(THD *thd, void *load_ctx, size_t thread_idx, const Rows_mysql &rows, Bulk_load::Stat_callbacks &wait_cbk) override
Execute bulk load operation.
Definition: handler0alter.cc:11173
virtual int info_low(uint flag, bool is_analyze)
Returns statistics information of the table to the MySQL interpreter, in various fields of the handle...
Definition: ha_innodb.cc:17403
int sample_next(void *scan_ctx, uchar *buf) override
Get the next record for sampling.
Definition: ha_innodb.cc:10972
const char * table_type() const override
Returns the table type (storage engine name).
Definition: ha_innodb.cc:6573
double read_time(uint index, uint ranges, ha_rows rows) override
Calculate the time it takes to read a set of ranges through an index This enables us to optimise read...
Definition: ha_innodb.cc:17098
int optimize(THD *thd, HA_CHECK_OPT *check_opt) override
This is mapped to "ALTER TABLE tablename ENGINE=InnoDB", which rebuilds the table in MySQL.
Definition: ha_innodb.cc:18319
bool get_foreign_dup_key(char *, uint, char *, uint) override
Retrieves the names of the table and the key for which there was a duplicate entry in the case of HA_...
Definition: ha_innodb.cc:20029
~ha_innobase() override=default
int delete_row(const uchar *buf) override
Deletes a row given as the parameter.
Definition: ha_innodb.cc:10125
void * bulk_load_begin(THD *thd, size_t data_size, size_t memory, size_t num_threads) override
Begin parallel bulk data load to the table.
Definition: handler0alter.cc:11130
The handler class is the interface for dynamically loadable storage engines.
Definition: handler.h:4573
ulonglong Table_flags
Definition: handler.h:4577
Class of basic DDL implementation, for CREATE/DROP/RENAME TABLE.
Definition: ha_innodb.h:1075
static int rename_impl(THD *thd, const char *from, const char *to, const Table *from_table, const Table *to_table, const TABLE *td)
Renames an InnoDB table.
Definition: ha_innodb.cc:14534
static int create_impl(THD *thd, const char *name, TABLE *form, HA_CREATE_INFO *create_info, Table *dd_tab, bool file_per_table, bool evictable, bool skip_strict, uint32_t old_flags, uint32_t old_flags2, const dd::Table *old_dd_table)
Create an InnoDB table.
Definition: ha_innodb.cc:14316
static int delete_impl(THD *thd, const char *name, const Table *dd_tab, const TABLE *td)
Drop an InnoDB table.
Definition: ha_innodb.cc:14431
Class to handle TRUNCATE for one InnoDB table or one partition.
Definition: ha_innodb.h:1138
dict_table_t * m_table
InnoDB table object for the table/partition.
Definition: ha_innodb.h:1208
trx_t * m_trx
Transaction attached to current thd.
Definition: ha_innodb.h:1205
int open_table(dict_table_t *&innodb_table)
Open the table/partition to be truncated.
Definition: ha_innodb.cc:14665
bool m_keep_autoinc
True if the original autoinc counter should be kept.
Definition: ha_innodb.h:1222
Table * m_dd_table
dd::Table or dd::Partition
Definition: ha_innodb.h:1202
int truncate()
Do the real truncation.
Definition: ha_innodb.cc:14763
uint32_t m_flags2
flags2 of the table to be truncated, which should not change
Definition: ha_innodb.h:1232
TABLE * m_form
Table format.
Definition: ha_innodb.h:1211
HA_CREATE_INFO m_create_info
Create information.
Definition: ha_innodb.h:1214
int rename_tablespace()
Rename tablespace file name.
Definition: ha_innodb.cc:14858
bool m_file_per_table
True if this table/partition is file per table.
Definition: ha_innodb.h:1217
int load_fk()
Reload the FK related information.
Definition: ha_innodb.cc:14922
int prepare()
Prepare for truncate.
Definition: ha_innodb.cc:14696
int exec()
Do the truncate of the table/partition.
Definition: ha_innodb.cc:14953
innobase_truncate(THD *thd, const char *name, TABLE *form, Table *dd_table, bool keep_autoinc, bool table_truncate)
Constructor.
Definition: ha_innodb.h:1147
~innobase_truncate()
Destructor.
Definition: ha_innodb.cc:14654
uint32_t m_flags
flags of the table to be truncated, which should not change
Definition: ha_innodb.h:1229
void cleanup()
Cleanup.
Definition: ha_innodb.cc:14905
bool m_table_truncate
For a prtition table, this is true if full table is truncated.
Definition: ha_innodb.h:1226
THD * m_thd
THD object.
Definition: ha_innodb.h:1196
const char * m_name
Normalized table name.
Definition: ha_innodb.h:1199
A table definition from the master.
Definition: rpl_utility.h:248
static MEM_ROOT mem_root
Definition: client_plugin.cc:114
This service provides functions for clone plugin to connect and interact with remote server's clone p...
dberr_t
Definition: db0err.h:39
@ DB_SUCCESS
Definition: db0err.h:43
constexpr uint32_t DICT_TF2_TEMPORARY
TEMPORARY; true for tables from CREATE TEMPORARY TABLE.
Definition: dict0mem.h:269
constexpr uint32_t DICT_TF2_INTRINSIC
Intrinsic table bit Intrinsic table is table created internally by MySQL modules viz.
Definition: dict0mem.h:292
static page_no_t fsp_get_extent_size_in_pages(const page_size_t &page_size)
Calculate the number of physical pages in an extent for this file.
Definition: fsp0fsp.h:356
constexpr uint64_t FSP_MAX_AUTOEXTEND_SIZE
Definition: fsp0fsp.h:181
bool commit_inplace_alter_table(TABLE *altered_table, Alter_inplace_info *ha_alter_info, bool commit, const dd::Table *old_dd_tab, dd::Table *new_dd_tab) override
Commit or rollback the changes made during prepare_inplace_alter_table() and inplace_alter_table() in...
Definition: handler0alter.cc:1592
enum_alter_inplace_result check_if_supported_inplace_alter(TABLE *altered_table, Alter_inplace_info *ha_alter_info) override
Check if InnoDB supports a particular alter table in-place.
Definition: handler0alter.cc:964
bool inplace_alter_table(TABLE *altered_table, Alter_inplace_info *ha_alter_info, const dd::Table *old_dd_tab, dd::Table *new_dd_tab) override
Alter the table structure in-place with operations specified using HA_ALTER_FLAGS and Alter_inplace_i...
Definition: handler0alter.cc:1556
bool prepare_inplace_alter_table(TABLE *altered_table, Alter_inplace_info *ha_alter_info, const dd::Table *old_dd_tab, dd::Table *new_dd_tab) override
Allows InnoDB to update internal structures with concurrent writes blocked (provided that check_if_su...
Definition: handler0alter.cc:1432
void my_error(int nr, myf MyFlags,...)
Fill in and print a previously registered error message.
Definition: my_error.cc:216
constexpr uint32_t FSP_FREE_ADD
This many free extents are added to the free list from above FSP_FREE_LIMIT at a time.
Definition: fsp0fsp.h:176
bool innobase_match_index_columns(const KEY *key_info, const dict_index_t *index_info)
Match index columns between MySQL and InnoDB.
Definition: ha_innodb.cc:6837
void innodb_base_col_setup_for_stored(const dict_table_t *table, const Field *field, dict_s_col_t *s_col)
Set up base columns for stored column.
Definition: ha_innodb.cc:11523
const struct _ft_vft ft_vft_result
Definition: ha_innodb.cc:595
static bool normalize_table_name(char *norm_name, const char *name)
Definition: ha_innodb.h:1307
static bool tablespace_is_shared_space(const HA_CREATE_INFO *create_info)
Check if table will be explicitly put in an existing shared general or system tablespace.
Definition: ha_innodb.h:791
rec_per_key_t innodb_rec_per_key(const dict_index_t *index, ulint i, ha_rows records)
Calculate Record Per Key value.
Definition: ha_innodb.cc:17229
static bool is_shared_tablespace(const char *tablespace_name)
Check if tablespace is shared tablespace.
Definition: ha_innodb.h:816
void innobase_discard_table(THD *thd, dict_table_t *table)
Drop the statistics for a specified table, and mark it as discard after DDL.
Definition: handler0alter.cc:705
int convert_error_code_to_mysql(dberr_t error, uint32_t flags, THD *thd)
Converts an InnoDB error code to a MySQL error code.
Definition: ha_innodb.cc:2078
const char innobase_index_reserve_name[]
"GEN_CLUST_INDEX" is the name reserved for InnoDB default system clustered index when there is no pri...
Definition: dict0mem.h:1030
void innobase_build_v_templ_callback(const TABLE *table, void *ib_table)
Callback used by MySQL server layer to initialize the table virtual columns' template.
Definition: ha_innodb.cc:6984
bool trx_is_registered_for_2pc(const trx_t *trx)
Note that a transaction has been registered with MySQL.
Definition: ha_innodb.h:1314
static int validate_autoextend_size_value(uint64_t ext_size)
Validate AUTOEXTEND_SIZE attribute for a tablespace.
Definition: ha_innodb.h:829
void innobase_parse_hint_from_comment(THD *thd, dict_table_t *table, const TABLE_SHARE *table_share)
Parse hint for table and its indexes, and update the information in dictionary.
Definition: ha_innodb.cc:13658
static bool tablespace_is_file_per_table(const HA_CREATE_INFO *create_info)
Check if the explicit tablespace targeted is file_per_table.
Definition: ha_innodb.h:780
void innodb_base_col_setup(dict_table_t *table, const Field *field, dict_v_col_t *v_col)
Set up base columns for virtual column.
Definition: ha_innodb.cc:11492
fts_doc_id_index_enum
Some defines for innobase_fts_check_doc_id_index() return value.
Definition: ha_innodb.h:1244
@ FTS_EXIST_DOC_ID_INDEX
Definition: ha_innodb.h:1246
@ FTS_INCORRECT_DOC_ID_INDEX
Definition: ha_innodb.h:1245
@ FTS_NOT_EXIST_DOC_ID_INDEX
Definition: ha_innodb.h:1247
trx_t * innobase_trx_allocate(THD *thd)
Allocates an InnoDB transaction for a MySQL handler object.
Definition: ha_innodb.cc:2753
void innobase_build_v_templ(const TABLE *table, const dict_table_t *ib_table, dict_vcol_templ_t *s_templ, const dict_add_v_col_t *add_v, bool locked, const char *share_tbl_name)
Build template for the virtual columns and their base columns.
Definition: ha_innodb.cc:7000
const mysql_service_clone_protocol_t * clone_protocol_svc
Clone protocol service.
Definition: ha_innodb.cc:279
static bool tablespace_is_general_space(const HA_CREATE_INFO *create_info)
Check if table will be explicitly put in a general tablespace.
Definition: ha_innodb.h:802
fts_doc_id_index_enum innobase_fts_check_doc_id_index(const dict_table_t *table, const TABLE *altered_table, ulint *fts_doc_col_no)
Check whether the table has a unique index with FTS_DOC_ID_INDEX_NAME on the Doc ID column.
Definition: handler0alter.cc:2845
void innobase_register_trx(handlerton *hton, THD *thd, trx_t *trx)
Allocates an InnoDB transaction for a MySQL handler object for DML.
Definition: ha_innodb.cc:3003
static bool innobase_is_s_fld(const Field *field)
whether this is a stored column
Definition: ha_innodb.h:1294
static bool innobase_is_multi_value_fld(const Field *field)
Whether this is a computed multi-value virtual column.
Definition: ha_innodb.h:1303
void innobase_copy_frm_flags_from_table_share(dict_table_t *innodb_table, const TABLE_SHARE *table_share)
Copy table flags from MySQL's TABLE_SHARE into an InnoDB table object.
Definition: ha_innodb.cc:2902
bool innobase_fts_load_stopword(dict_table_t *table, trx_t *trx, THD *thd)
Initialize the table FTS stopword list.
Definition: ha_innodb.cc:13100
void(* my_gcolumn_templatecallback_t)(const TABLE *, void *)
Callback function definition, used by MySQL server layer to initialized the table virtual columns' te...
Definition: ha_innodb.h:1367
trx_t *& thd_to_trx(THD *thd)
Obtain the InnoDB transaction of a MySQL thread.
Definition: ha_innodb.cc:2011
page_cur_mode_t convert_search_mode_to_innobase(enum ha_rkey_function find_flag)
Converts a search mode flag understood by MySQL to a flag understood by InnoDB.
Definition: ha_innodb.cc:10295
fts_doc_id_index_enum innobase_fts_check_doc_id_index_in_def(ulint n_key, const KEY *key_info)
Check whether the table has a unique index with FTS_DOC_ID_INDEX_NAME on the Doc ID column in MySQL c...
Definition: handler0alter.cc:2931
struct new_ft_info NEW_FT_INFO
Structure Returned by ha_innobase::ft_init_ext()
trx_t::isolation_level_t innobase_trx_map_isolation_level(enum_tx_isolation iso)
Maps a MySQL trx isolation level code to the InnoDB isolation level code.
Definition: ha_innodb.cc:18793
bool innobase_index_name_is_reserved(THD *thd, const KEY *key_info, ulint num_of_keys)
This function checks each index name for a table against reserved system default primary index name '...
Definition: ha_innodb.cc:21714
constexpr uint32_t SIZE_MB
Definition: ha_innodb.h:824
bool innobase_stats_on_metadata
Definition: ha_innodb.cc:347
ulong thd_parallel_read_threads(THD *thd)
Return the number of read threads for this session.
Definition: ha_innodb.cc:2018
static int flags[50]
Definition: hp_test1.cc:40
static int flag
Definition: hp_test1.cc:40
static uint keys
Definition: hp_test2.cc:49
float rec_per_key_t
Data type for records per key estimates that are stored in the KEY::rec_per_key_float[] array.
Definition: key.h:96
ha_key_alg
Definition: my_base.h:98
@ HA_KEY_ALG_RTREE
Definition: my_base.h:109
@ HA_KEY_ALG_BTREE
Definition: my_base.h:108
@ HA_KEY_ALG_FULLTEXT
Definition: my_base.h:111
ha_rkey_function
Definition: my_base.h:78
my_off_t ha_rows
Definition: my_base.h:1141
ha_extra_function
Definition: my_base.h:185
unsigned long long int ulonglong
Definition: my_inttypes.h:56
unsigned char uchar
Definition: my_inttypes.h:52
long long int longlong
Definition: my_inttypes.h:55
#define MYF(v)
Definition: my_inttypes.h:97
enum_sql_command
Definition: my_sqlcommand.h:46
void error(const char *format,...)
static bool ignore
Definition: mysqlimport.cc:70
static int record
Definition: mysqltest.cc:195
static PFS_engine_table_share_proxy table
Definition: pfs.cc:61
Definition: buf0block_hint.cc:30
The version of the current data dictionary table definitions.
Definition: dictionary_client.h:43
bool is_partition(const std::string &dict_name)
Check if it is a table partition.
Definition: dict0dd.cc:7452
Definition: aligned_atomic.h:44
const char * table_name
Definition: rules_table_service.cc:56
const char * db_name
Definition: rules_table_service.cc:55
mode
Definition: file_handle.h:61
page_cur_mode_t
Definition: page0types.h:176
required string key
Definition: replication_asynchronous_connection_failover.proto:60
Parallel read adapter interface.
Parallel read histogram interface.
#define SERVICE_TYPE(name)
Generates the standard Service type name.
Definition: service.h:76
enum_alter_inplace_result
Return values for check_if_supported_inplace_alter().
Definition: handler.h:200
enum_tx_isolation
Definition: handler.h:3186
row_type
Definition: handler.h:684
enum_sampling_method
Definition: handler.h:715
static bool commit(THD *thd)
Commit the current statement and transaction.
Definition: sql_cmd_srs.cc:152
case opt name
Definition: sslopt-case.h:29
TempTable public handler API declaration.
Callbacks for collecting time statistics.
Definition: bulk_data_service.h:324
Definition: ft_global.h:72
Definition: handler.h:3804
Definition: handler.h:3791
Struct to hold information about the table that should be created.
Definition: handler.h:3202
const char * tablespace
Definition: handler.h:3208
InnoDB table share.
Definition: ha_innodb.h:65
const char * table_name
InnoDB table name.
Definition: ha_innodb.h:66
innodb_idx_translate_t idx_trans_tbl
index translation table between MySQL and InnoDB
Definition: ha_innodb.h:73
void * table_name_hash
hash table chain node
Definition: ha_innodb.h:71
uint use_count
reference count, incremented in get_share() and decremented in free_share()
Definition: ha_innodb.h:67
The MEM_ROOT is a simple arena, where allocations are carved out of larger blocks.
Definition: my_alloc.h:83
Definition: handler.h:3812
This structure is shared between different table objects.
Definition: table.h:701
Definition: table.h:1406
Definition: thr_lock.h:124
Definition: ft_global.h:57
Definition: ft_global.h:48
Data structure for newly added virtual column in a table.
Definition: dict0mem.h:835
Data structure for an index.
Definition: dict0mem.h:1046
Data structure for a stored column in a table.
Definition: dict0mem.h:847
static const char * s_file_per_table_name
The hard-coded tablespace name innodb_file_per_table.
Definition: dict0dict.h:1151
static const char * s_sys_space_name
The name of the hard-coded system tablespace.
Definition: dict0dict.h:1142
static const char * s_temp_space_name
The name of the predefined temporary tablespace.
Definition: dict0dict.h:1145
Data structure for a database table.
Definition: dict0mem.h:1909
Data structure for a virtual column in a table.
Definition: dict0mem.h:815
Structure defines template related to virtual columns and their base columns.
Definition: dict0mem.h:1846
Query result.
Definition: fts0fts.h:314
handlerton is a singleton structure - one instance per storage engine - to provide access to storage ...
Definition: handler.h:2734
Definition: ha_innodb.h:53
dict_index_t ** index_mapping
index pointer array directly maps to index in InnoDB from MySQL array index
Definition: ha_innodb.h:59
ulint array_size
array size of index_mapping
Definition: ha_innodb.h:57
ulint index_count
number of valid index entries in the index_mapping array
Definition: ha_innodb.h:54
Definition: my_base.h:1125
Structure Returned by ha_innobase::ft_init_ext()
Definition: ha_innodb.h:732
struct _ft_vft_ext * could_you
Definition: ha_innodb.h:734
row_prebuilt_t * ft_prebuilt
Definition: ha_innodb.h:735
fts_result_t * ft_result
Definition: ha_innodb.h:736
struct _ft_vft * please
Definition: ha_innodb.h:733
A struct for (sometimes lazily) prebuilt structures in an Innobase table handle used within MySQL; th...
Definition: row0mysql.h:515
Definition: trx0trx.h:684
bool is_registered
Definition: trx0trx.h:876
isolation_level_t
Definition: trx0trx.h:685
thr_lock_type
Definition: thr_lock.h:51
The transaction.
ulong srv_page_size
Definition: srv0srv.cc:399
unsigned long int ulint
Definition: univ.i:406
#define ut_ad(EXPR)
Debug assertion.
Definition: ut0dbg.h:105