mirror of
https://github.com/MariaDB/server.git
synced 2025-02-05 13:22:17 +01:00
024a18dbcb
In the bug report MDEV-32817 it occurred that the function
row_mysql_get_table_status() is outputting a fil_space_t*
as if it were a numeric tablespace identifier.
ib_push_warning(): Remove. Let us invoke push_warning_printf() directly.
innodb_decryption_failed(): Report a decryption failure and set the
dict_table_t::file_unreadable flag. This code was being duplicated in
very many places. We return the constant value DB_DECRYPTION_FAILED
in order to avoid code duplication in the callers and to allow tail calls.
innodb_fk_error(): Report a FOREIGN KEY error.
dict_foreign_def_get(), dict_foreign_def_get_fields(): Remove.
This code was being used in dict_create_add_foreign_to_dictionary()
in an apparently uncovered code path. That ib_push_warning() call
would pass the integer i+1 instead of a pointer to NUL terminated
string ("%s"), and therefore the call should have resulted in a crash.
dict_print_info_on_foreign_key_in_create_format(),
innobase_quote_identifier(): Add const qualifiers.
row_mysql_get_table_error(): Replaces row_mysql_get_table_status().
Display no message on DB_CORRUPTION; it should be properly reported at
the SQL layer anyway.
277 lines
9.9 KiB
C
277 lines
9.9 KiB
C
/*****************************************************************************
|
|
|
|
Copyright (c) 1996, 2016, Oracle and/or its affiliates. All Rights Reserved.
|
|
Copyright (c) 2017, 2021, MariaDB Corporation.
|
|
|
|
This program is free software; you can redistribute it and/or modify it under
|
|
the terms of the GNU General Public License as published by the Free Software
|
|
Foundation; version 2 of the License.
|
|
|
|
This program is distributed in the hope that it will be useful, but WITHOUT
|
|
ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
|
|
FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License along with
|
|
this program; if not, write to the Free Software Foundation, Inc.,
|
|
51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA
|
|
|
|
*****************************************************************************/
|
|
|
|
/**************************************************//**
|
|
@file include/dict0crea.h
|
|
Database object creation
|
|
|
|
Created 1/8/1996 Heikki Tuuri
|
|
*******************************************************/
|
|
|
|
#ifndef dict0crea_h
|
|
#define dict0crea_h
|
|
|
|
#include "dict0dict.h"
|
|
#include "que0types.h"
|
|
#include "row0types.h"
|
|
#include "mtr0mtr.h"
|
|
#include "fil0crypt.h"
|
|
|
|
/*********************************************************************//**
|
|
Creates a table create graph.
|
|
@return own: table create node */
|
|
tab_node_t*
|
|
tab_create_graph_create(
|
|
/*====================*/
|
|
dict_table_t* table, /*!< in: table to create, built as
|
|
a memory data structure */
|
|
mem_heap_t* heap); /*!< in: heap where created */
|
|
|
|
/** Creates an index create graph.
|
|
@param[in] index index to create, built as a memory data structure
|
|
@param[in] table table name
|
|
@param[in,out] heap heap where created
|
|
@param[in] mode encryption mode (for creating a table)
|
|
@param[in] key_id encryption key identifier (for creating a table)
|
|
@param[in] add_v new virtual columns added in the same clause with
|
|
add index
|
|
@return own: index create node */
|
|
ind_node_t*
|
|
ind_create_graph_create(
|
|
dict_index_t* index,
|
|
const char* table,
|
|
mem_heap_t* heap,
|
|
fil_encryption_t mode,
|
|
uint32_t key_id,
|
|
const dict_add_v_col_t* add_v = NULL);
|
|
|
|
/***********************************************************//**
|
|
Creates a table. This is a high-level function used in SQL execution graphs.
|
|
@return query thread to run next or NULL */
|
|
que_thr_t*
|
|
dict_create_table_step(
|
|
/*===================*/
|
|
que_thr_t* thr); /*!< in: query thread */
|
|
|
|
/***********************************************************//**
|
|
Creates an index. This is a high-level function used in SQL execution
|
|
graphs.
|
|
@return query thread to run next or NULL */
|
|
que_thr_t*
|
|
dict_create_index_step(
|
|
/*===================*/
|
|
que_thr_t* thr); /*!< in: query thread */
|
|
|
|
/***************************************************************//**
|
|
Builds an index definition but doesn't update sys_table.
|
|
@return DB_SUCCESS or error code */
|
|
void
|
|
dict_build_index_def(
|
|
/*=================*/
|
|
const dict_table_t* table, /*!< in: table */
|
|
dict_index_t* index, /*!< in/out: index */
|
|
trx_t* trx); /*!< in/out: InnoDB transaction
|
|
handle */
|
|
/***************************************************************//**
|
|
Creates an index tree for the index if it is not a member of a cluster.
|
|
Don't update SYSTEM TABLES.
|
|
@return DB_SUCCESS or DB_OUT_OF_FILE_SPACE */
|
|
dberr_t
|
|
dict_create_index_tree(
|
|
/*===================*/
|
|
dict_index_t* index, /*!< in/out: index */
|
|
const trx_t* trx); /*!< in: InnoDB transaction handle */
|
|
|
|
/** Drop the index tree associated with a row in SYS_INDEXES table.
|
|
@param[in,out] pcur persistent cursor on rec
|
|
@param[in,out] trx dictionary transaction
|
|
@param[in,out] mtr mini-transaction
|
|
@return tablespace ID to drop (if this is the clustered index)
|
|
@retval 0 if no tablespace is to be dropped */
|
|
uint32_t dict_drop_index_tree(btr_pcur_t *pcur, trx_t *trx, mtr_t *mtr)
|
|
MY_ATTRIBUTE((nonnull(1,3), warn_unused_result));
|
|
|
|
/***************************************************************//**
|
|
Creates an index tree for the index if it is not a member of a cluster.
|
|
Don't update SYSTEM TABLES.
|
|
@return error code */
|
|
dberr_t
|
|
dict_create_index_tree_in_mem(
|
|
/*==========================*/
|
|
dict_index_t* index, /*!< in/out: index */
|
|
const trx_t* trx); /*!< in: InnoDB transaction handle */
|
|
|
|
/********************************************************************//**
|
|
Generate a foreign key constraint name when it was not named by the user.
|
|
A generated constraint has a name of the format dbname/tablename_ibfk_NUMBER,
|
|
where the numbers start from 1, and are given locally for this table, that is,
|
|
the number is not global, as it used to be before MySQL 4.0.18. */
|
|
UNIV_INLINE
|
|
dberr_t
|
|
dict_create_add_foreign_id(
|
|
/*=======================*/
|
|
ulint* id_nr, /*!< in/out: number to use in id
|
|
generation; incremented if used */
|
|
const char* name, /*!< in: table name */
|
|
dict_foreign_t* foreign); /*!< in/out: foreign key */
|
|
|
|
/** Adds the given set of foreign key objects to the dictionary tables
|
|
in the database. This function does not modify the dictionary cache. The
|
|
caller must ensure that all foreign key objects contain a valid constraint
|
|
name in foreign->id.
|
|
@param[in] local_fk_set set of foreign key objects, to be added to
|
|
the dictionary tables
|
|
@param[in] table table to which the foreign key objects in
|
|
local_fk_set belong to
|
|
@param[in,out] trx transaction
|
|
@return error code or DB_SUCCESS */
|
|
dberr_t
|
|
dict_create_add_foreigns_to_dictionary(
|
|
/*===================================*/
|
|
const dict_foreign_set& local_fk_set,
|
|
const dict_table_t* table,
|
|
trx_t* trx)
|
|
MY_ATTRIBUTE((nonnull, warn_unused_result));
|
|
|
|
/** Check if a foreign constraint is on columns server as base columns
|
|
of any stored column. This is to prevent creating SET NULL or CASCADE
|
|
constraint on such columns
|
|
@param[in] local_fk_set set of foreign key objects, to be added to
|
|
the dictionary tables
|
|
@param[in] table table to which the foreign key objects in
|
|
local_fk_set belong to
|
|
@return true if yes, otherwise, false */
|
|
bool
|
|
dict_foreigns_has_s_base_col(
|
|
const dict_foreign_set& local_fk_set,
|
|
const dict_table_t* table);
|
|
|
|
/********************************************************************//**
|
|
Add a foreign key definition to the data dictionary tables.
|
|
@return error code or DB_SUCCESS */
|
|
dberr_t
|
|
dict_create_add_foreign_to_dictionary(
|
|
/*==================================*/
|
|
const char* name, /*!< in: table name */
|
|
const dict_foreign_t* foreign,/*!< in: foreign key */
|
|
trx_t* trx) /*!< in/out: dictionary transaction */
|
|
MY_ATTRIBUTE((nonnull, warn_unused_result));
|
|
|
|
/* Table create node structure */
|
|
struct tab_node_t{
|
|
que_common_t common; /*!< node type: QUE_NODE_TABLE_CREATE */
|
|
dict_table_t* table; /*!< table to create, built as a
|
|
memory data structure with
|
|
dict_mem_... functions */
|
|
ins_node_t* tab_def; /*!< child node which does the insert of
|
|
the table definition; the row to be
|
|
inserted is built by the parent node */
|
|
ins_node_t* col_def; /*!< child node which does the inserts
|
|
of the column definitions; the row to
|
|
be inserted is built by the parent
|
|
node */
|
|
ins_node_t* v_col_def; /*!< child node which does the inserts
|
|
of the sys_virtual row definitions;
|
|
the row to be inserted is built by
|
|
the parent node */
|
|
/*----------------------*/
|
|
/* Local storage for this graph node */
|
|
ulint state; /*!< node execution state */
|
|
ulint col_no; /*!< next column definition to insert */
|
|
ulint base_col_no; /*!< next base column to insert */
|
|
mem_heap_t* heap; /*!< memory heap used as auxiliary
|
|
storage */
|
|
};
|
|
|
|
/* Table create node states */
|
|
#define TABLE_BUILD_TABLE_DEF 1
|
|
#define TABLE_BUILD_COL_DEF 2
|
|
#define TABLE_BUILD_V_COL_DEF 3
|
|
#define TABLE_ADD_TO_CACHE 4
|
|
#define TABLE_COMPLETED 5
|
|
|
|
/* Index create node struct */
|
|
|
|
struct ind_node_t{
|
|
que_common_t common; /*!< node type: QUE_NODE_INDEX_CREATE */
|
|
dict_index_t* index; /*!< index to create, built as a
|
|
memory data structure with
|
|
dict_mem_... functions */
|
|
const char* table_name; /*!< table name */
|
|
ins_node_t* ind_def; /*!< child node which does the insert of
|
|
the index definition; the row to be
|
|
inserted is built by the parent node */
|
|
ins_node_t* field_def; /*!< child node which does the inserts
|
|
of the field definitions; the row to
|
|
be inserted is built by the parent
|
|
node */
|
|
/*----------------------*/
|
|
/* Local storage for this graph node */
|
|
ulint state; /*!< node execution state */
|
|
uint32_t page_no; /* root page number of the index */
|
|
dtuple_t* ind_row; /* index definition row built */
|
|
ulint field_no; /* next field definition to insert */
|
|
mem_heap_t* heap; /*!< memory heap used as auxiliary
|
|
storage */
|
|
uint key_id; /*!< encryption key_id */
|
|
fil_encryption_t mode; /*!< encryption mode */
|
|
const dict_add_v_col_t*
|
|
add_v; /*!< new virtual columns that being
|
|
added along with an add index call */
|
|
};
|
|
|
|
/** Compose a column number for a virtual column, stored in the "POS" field
|
|
of Sys_columns. The column number includes both its virtual column sequence
|
|
(the "nth" virtual column) and its actual column position in original table
|
|
@param[in] v_pos virtual column sequence
|
|
@param[in] col_pos column position in original table definition
|
|
@return composed column position number */
|
|
UNIV_INLINE
|
|
ulint
|
|
dict_create_v_col_pos(
|
|
ulint v_pos,
|
|
ulint col_pos);
|
|
|
|
/** Get the column number for a virtual column (the column position in
|
|
original table), stored in the "POS" field of Sys_columns
|
|
@param[in] pos virtual column position
|
|
@return column position in original table */
|
|
UNIV_INLINE
|
|
ulint
|
|
dict_get_v_col_mysql_pos(
|
|
ulint pos);
|
|
|
|
/** Get a virtual column sequence (the "nth" virtual column) for a
|
|
virtual column, stord in the "POS" field of Sys_columns
|
|
@param[in] pos virtual column position
|
|
@return virtual column sequence */
|
|
UNIV_INLINE
|
|
ulint
|
|
dict_get_v_col_pos(
|
|
ulint pos);
|
|
|
|
/* Index create node states */
|
|
#define INDEX_BUILD_INDEX_DEF 1
|
|
#define INDEX_BUILD_FIELD_DEF 2
|
|
#define INDEX_CREATE_INDEX_TREE 3
|
|
#define INDEX_ADD_TO_CACHE 4
|
|
|
|
#include "dict0crea.inl"
|
|
|
|
#endif
|