/***************************************************************************** Copyright (c) 2007, 2009, Innobase Oy. All Rights Reserved. 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA *****************************************************************************/ /**************************************************//** @file handler/i_s.cc InnoDB INFORMATION SCHEMA tables interface to MySQL. Created July 18, 2007 Vasil Dimov *******************************************************/ #include #include // PROCESS_ACL #include #include #include #include #include #include "i_s.h" #include #include extern "C" { #include "btr0pcur.h" /* for file sys_tables related info. */ #include "btr0types.h" #include "buf0buddy.h" /* for i_s_cmpmem */ #include "buf0buf.h" /* for buf_pool and PAGE_ZIP_MIN_SIZE */ #include "dict0load.h" /* for file sys_tables related info. */ #include "dict0mem.h" #include "dict0types.h" #include "ha_prototypes.h" /* for innobase_convert_name() */ #include "srv0start.h" /* for srv_was_started */ #include "trx0i_s.h" #include "trx0trx.h" /* for TRX_QUE_STATE_STR_MAX_LEN */ } static const char plugin_author[] = "Innobase Oy"; #define OK(expr) \ if ((expr) != 0) { \ DBUG_RETURN(1); \ } #define RETURN_IF_INNODB_NOT_STARTED(plugin_name) \ do { \ if (!srv_was_started) { \ push_warning_printf(thd, MYSQL_ERROR::WARN_LEVEL_WARN, \ ER_CANT_FIND_SYSTEM_REC, \ "InnoDB: SELECTing from " \ "INFORMATION_SCHEMA.%s but " \ "the InnoDB storage engine " \ "is not installed", plugin_name); \ DBUG_RETURN(0); \ } \ } while (0) #if !defined __STRICT_ANSI__ && defined __GNUC__ && (__GNUC__) > 2 && !defined __INTEL_COMPILER #define STRUCT_FLD(name, value) name: value #else #define STRUCT_FLD(name, value) value #endif /* Don't use a static const variable here, as some C++ compilers (notably HPUX aCC: HP ANSI C++ B3910B A.03.65) can't handle it. */ #define END_OF_ST_FIELD_INFO \ {STRUCT_FLD(field_name, NULL), \ STRUCT_FLD(field_length, 0), \ STRUCT_FLD(field_type, MYSQL_TYPE_NULL), \ STRUCT_FLD(value, 0), \ STRUCT_FLD(field_flags, 0), \ STRUCT_FLD(old_name, ""), \ STRUCT_FLD(open_method, SKIP_OPEN_TABLE)} /* Use the following types mapping: C type ST_FIELD_INFO::field_type --------------------------------- long MYSQL_TYPE_LONGLONG (field_length=MY_INT64_NUM_DECIMAL_DIGITS) long unsigned MYSQL_TYPE_LONGLONG (field_length=MY_INT64_NUM_DECIMAL_DIGITS, field_flags=MY_I_S_UNSIGNED) char* MYSQL_TYPE_STRING (field_length=n) float MYSQL_TYPE_FLOAT (field_length=0 is ignored) void* MYSQL_TYPE_LONGLONG (field_length=MY_INT64_NUM_DECIMAL_DIGITS, field_flags=MY_I_S_UNSIGNED) boolean (if else) MYSQL_TYPE_LONG (field_length=1) time_t MYSQL_TYPE_DATETIME (field_length=0 ignored) --------------------------------- */ /*******************************************************************//** Common function to fill any of the dynamic tables: INFORMATION_SCHEMA.innodb_trx INFORMATION_SCHEMA.innodb_locks INFORMATION_SCHEMA.innodb_lock_waits @return 0 on success */ static int trx_i_s_common_fill_table( /*======================*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond); /*!< in: condition (not used) */ /*******************************************************************//** Unbind a dynamic INFORMATION_SCHEMA table. @return 0 on success */ static int i_s_common_deinit( /*==============*/ void* p); /*!< in/out: table schema object */ /*******************************************************************//** Auxiliary function to store time_t value in MYSQL_TYPE_DATETIME field. @return 0 on success */ static int field_store_time_t( /*===============*/ Field* field, /*!< in/out: target field for storage */ time_t time) /*!< in: value to store */ { MYSQL_TIME my_time; struct tm tm_time; #if 0 /* use this if you are sure that `variables' and `time_zone' are always initialized */ thd->variables.time_zone->gmt_sec_to_TIME( &my_time, (my_time_t) time); #else localtime_r(&time, &tm_time); localtime_to_TIME(&my_time, &tm_time); my_time.time_type = MYSQL_TIMESTAMP_DATETIME; #endif return(field->store_time(&my_time, MYSQL_TIMESTAMP_DATETIME)); } /*******************************************************************//** Auxiliary function to store char* value in MYSQL_TYPE_STRING field. @return 0 on success */ static int field_store_string( /*===============*/ Field* field, /*!< in/out: target field for storage */ const char* str) /*!< in: NUL-terminated utf-8 string, or NULL */ { int ret; if (str != NULL) { ret = field->store(str, strlen(str), system_charset_info); field->set_notnull(); } else { ret = 0; /* success */ field->set_null(); } return(ret); } /*******************************************************************//** Auxiliary function to store ulint value in MYSQL_TYPE_LONGLONG field. If the value is ULINT_UNDEFINED then the field it set to NULL. @return 0 on success */ static int field_store_ulint( /*==============*/ Field* field, /*!< in/out: target field for storage */ ulint n) /*!< in: value to store */ { int ret; if (n != ULINT_UNDEFINED) { ret = field->store(n); field->set_notnull(); } else { ret = 0; /* success */ field->set_null(); } return(ret); } /* Fields of the dynamic table INFORMATION_SCHEMA.innodb_trx */ static ST_FIELD_INFO innodb_trx_fields_info[] = { #define IDX_TRX_ID 0 {STRUCT_FLD(field_name, "trx_id"), STRUCT_FLD(field_length, TRX_ID_MAX_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_STATE 1 {STRUCT_FLD(field_name, "trx_state"), STRUCT_FLD(field_length, TRX_QUE_STATE_STR_MAX_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_STARTED 2 {STRUCT_FLD(field_name, "trx_started"), STRUCT_FLD(field_length, 0), STRUCT_FLD(field_type, MYSQL_TYPE_DATETIME), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_REQUESTED_LOCK_ID 3 {STRUCT_FLD(field_name, "trx_requested_lock_id"), STRUCT_FLD(field_length, TRX_I_S_LOCK_ID_MAX_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_WAIT_STARTED 4 {STRUCT_FLD(field_name, "trx_wait_started"), STRUCT_FLD(field_length, 0), STRUCT_FLD(field_type, MYSQL_TYPE_DATETIME), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_WEIGHT 5 {STRUCT_FLD(field_name, "trx_weight"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_MYSQL_THREAD_ID 6 {STRUCT_FLD(field_name, "trx_mysql_thread_id"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_QUERY 7 {STRUCT_FLD(field_name, "trx_query"), STRUCT_FLD(field_length, TRX_I_S_TRX_QUERY_MAX_LEN), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_OPERATION_STATE 8 {STRUCT_FLD(field_name, "trx_operation_state"), STRUCT_FLD(field_length, TRX_I_S_TRX_OP_STATE_MAX_LEN), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_TABLES_IN_USE 9 {STRUCT_FLD(field_name, "trx_tables_in_use"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_TABLES_LOCKED 10 {STRUCT_FLD(field_name, "trx_tables_locked"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_LOCK_STRUCTS 11 {STRUCT_FLD(field_name, "trx_lock_structs"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_LOCK_MEMORY_BYTES 12 {STRUCT_FLD(field_name, "trx_lock_memory_bytes"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_ROWS_LOCKED 13 {STRUCT_FLD(field_name, "trx_rows_locked"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_ROWS_MODIFIED 14 {STRUCT_FLD(field_name, "trx_rows_modified"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_CONNCURRENCY_TICKETS 15 {STRUCT_FLD(field_name, "trx_concurrency_tickets"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_ISOLATION_LEVEL 16 {STRUCT_FLD(field_name, "trx_isolation_level"), STRUCT_FLD(field_length, TRX_I_S_TRX_ISOLATION_LEVEL_MAX_LEN), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_UNIQUE_CHECKS 17 {STRUCT_FLD(field_name, "trx_unique_checks"), STRUCT_FLD(field_length, 1), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 1), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_FOREIGN_KEY_CHECKS 18 {STRUCT_FLD(field_name, "trx_foreign_key_checks"), STRUCT_FLD(field_length, 1), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 1), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_LAST_FOREIGN_KEY_ERROR 19 {STRUCT_FLD(field_name, "trx_last_foreign_key_error"), STRUCT_FLD(field_length, TRX_I_S_TRX_FK_ERROR_MAX_LEN), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_ADAPTIVE_HASH_LATCHED 20 {STRUCT_FLD(field_name, "trx_apative_hash_latched"), STRUCT_FLD(field_length, 1), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_ADAPTIVE_HASH_TIMEOUT 21 {STRUCT_FLD(field_name, "trx_adaptive_hash_timeout"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_OPERATION_STATE 8 {STRUCT_FLD(field_name, "trx_operation_state"), STRUCT_FLD(field_length, TRX_I_S_TRX_OP_STATE_MAX_LEN), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_TABLES_IN_USE 9 {STRUCT_FLD(field_name, "trx_tables_in_use"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_TABLES_LOCKED 10 {STRUCT_FLD(field_name, "trx_tables_locked"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_LOCK_STRUCTS 11 {STRUCT_FLD(field_name, "trx_lock_structs"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_LOCK_MEMORY_BYTES 12 {STRUCT_FLD(field_name, "trx_lock_memory_bytes"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_ROWS_LOCKED 13 {STRUCT_FLD(field_name, "trx_rows_locked"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_ROWS_MODIFIED 14 {STRUCT_FLD(field_name, "trx_rows_modified"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_CONNCURRENCY_TICKETS 15 {STRUCT_FLD(field_name, "trx_concurrency_tickets"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_ISOLATION_LEVEL 16 {STRUCT_FLD(field_name, "trx_isolation_level"), STRUCT_FLD(field_length, TRX_I_S_TRX_ISOLATION_LEVEL_MAX_LEN), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_UNIQUE_CHECKS 17 {STRUCT_FLD(field_name, "trx_unique_checks"), STRUCT_FLD(field_length, 1), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 1), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_FOREIGN_KEY_CHECKS 18 {STRUCT_FLD(field_name, "trx_foreign_key_checks"), STRUCT_FLD(field_length, 1), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 1), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_LAST_FOREIGN_KEY_ERROR 19 {STRUCT_FLD(field_name, "trx_last_foreign_key_error"), STRUCT_FLD(field_length, TRX_I_S_TRX_FK_ERROR_MAX_LEN), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_ADAPTIVE_HASH_LATCHED 20 {STRUCT_FLD(field_name, "trx_apative_hash_latched"), STRUCT_FLD(field_length, 1), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_TRX_ADAPTIVE_HASH_TIMEOUT 21 {STRUCT_FLD(field_name, "trx_adaptive_hash_timeout"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, END_OF_ST_FIELD_INFO }; /*******************************************************************//** Read data from cache buffer and fill the INFORMATION_SCHEMA.innodb_trx table with it. @return 0 on success */ static int fill_innodb_trx_from_cache( /*=======================*/ trx_i_s_cache_t* cache, /*!< in: cache to read from */ THD* thd, /*!< in: used to call schema_table_store_record() */ TABLE* table) /*!< in/out: fill this table */ { Field** fields; ulint rows_num; char lock_id[TRX_I_S_LOCK_ID_MAX_LEN + 1]; ulint i; DBUG_ENTER("fill_innodb_trx_from_cache"); fields = table->field; rows_num = trx_i_s_cache_get_rows_used(cache, I_S_INNODB_TRX); for (i = 0; i < rows_num; i++) { i_s_trx_row_t* row; char trx_id[TRX_ID_MAX_LEN + 1]; row = (i_s_trx_row_t*) trx_i_s_cache_get_nth_row( cache, I_S_INNODB_TRX, i); /* trx_id */ ut_snprintf(trx_id, sizeof(trx_id), TRX_ID_FMT, row->trx_id); OK(field_store_string(fields[IDX_TRX_ID], trx_id)); /* trx_state */ OK(field_store_string(fields[IDX_TRX_STATE], row->trx_state)); /* trx_started */ OK(field_store_time_t(fields[IDX_TRX_STARTED], (time_t) row->trx_started)); /* trx_requested_lock_id */ /* trx_wait_started */ if (row->trx_wait_started != 0) { OK(field_store_string( fields[IDX_TRX_REQUESTED_LOCK_ID], trx_i_s_create_lock_id( row->requested_lock_row, lock_id, sizeof(lock_id)))); /* field_store_string() sets it no notnull */ OK(field_store_time_t( fields[IDX_TRX_WAIT_STARTED], (time_t) row->trx_wait_started)); fields[IDX_TRX_WAIT_STARTED]->set_notnull(); } else { fields[IDX_TRX_REQUESTED_LOCK_ID]->set_null(); fields[IDX_TRX_WAIT_STARTED]->set_null(); } /* trx_weight */ OK(fields[IDX_TRX_WEIGHT]->store((longlong) row->trx_weight, true)); /* trx_mysql_thread_id */ OK(fields[IDX_TRX_MYSQL_THREAD_ID]->store( row->trx_mysql_thread_id)); /* trx_query */ OK(field_store_string(fields[IDX_TRX_QUERY], row->trx_query)); /* trx_operation_state */ OK(field_store_string(fields[IDX_TRX_OPERATION_STATE], row->trx_operation_state)); /* trx_tables_in_use */ OK(fields[IDX_TRX_TABLES_IN_USE]->store( (longlong) row->trx_tables_in_use, true)); /* trx_tables_locked */ OK(fields[IDX_TRX_TABLES_LOCKED]->store( (longlong) row->trx_tables_locked, true)); /* trx_lock_structs */ OK(fields[IDX_TRX_LOCK_STRUCTS]->store( (longlong) row->trx_lock_structs, true)); /* trx_lock_memory_bytes */ OK(fields[IDX_TRX_LOCK_MEMORY_BYTES]->store( (longlong) row->trx_lock_memory_bytes, true)); /* trx_rows_locked */ OK(fields[IDX_TRX_ROWS_LOCKED]->store( (longlong) row->trx_rows_locked, true)); /* trx_rows_modified */ OK(fields[IDX_TRX_ROWS_MODIFIED]->store( (longlong) row->trx_rows_modified, true)); /* trx_concurrency_tickets */ OK(fields[IDX_TRX_CONNCURRENCY_TICKETS]->store( (longlong) row->trx_concurrency_tickets, true)); /* trx_isolation_level */ OK(field_store_string(fields[IDX_TRX_ISOLATION_LEVEL], row->trx_isolation_level)); /* trx_unique_checks */ OK(fields[IDX_TRX_UNIQUE_CHECKS]->store( row->trx_unique_checks)); /* trx_foreign_key_checks */ OK(fields[IDX_TRX_FOREIGN_KEY_CHECKS]->store( row->trx_foreign_key_checks)); /* trx_last_foreign_key_error */ OK(field_store_string(fields[IDX_TRX_LAST_FOREIGN_KEY_ERROR], row->trx_foreign_key_error)); /* trx_apative_hash_latched */ OK(fields[IDX_TRX_ADAPTIVE_HASH_LATCHED]->store( row->trx_has_search_latch)); /* trx_adaptive_hash_timeout */ OK(fields[IDX_TRX_ADAPTIVE_HASH_TIMEOUT]->store( (longlong) row->trx_search_latch_timeout, true)); OK(schema_table_store_record(thd, table)); } DBUG_RETURN(0); } /*******************************************************************//** Bind the dynamic table INFORMATION_SCHEMA.innodb_trx @return 0 on success */ static int innodb_trx_init( /*============*/ void* p) /*!< in/out: table schema object */ { ST_SCHEMA_TABLE* schema; DBUG_ENTER("innodb_trx_init"); schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = innodb_trx_fields_info; schema->fill_table = trx_i_s_common_fill_table; DBUG_RETURN(0); } static struct st_mysql_information_schema i_s_info = { MYSQL_INFORMATION_SCHEMA_INTERFACE_VERSION }; UNIV_INTERN struct st_mysql_plugin i_s_innodb_trx = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_TRX"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "InnoDB transactions"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, innodb_trx_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; /* Fields of the dynamic table INFORMATION_SCHEMA.innodb_locks */ static ST_FIELD_INFO innodb_locks_fields_info[] = { #define IDX_LOCK_ID 0 {STRUCT_FLD(field_name, "lock_id"), STRUCT_FLD(field_length, TRX_I_S_LOCK_ID_MAX_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_LOCK_TRX_ID 1 {STRUCT_FLD(field_name, "lock_trx_id"), STRUCT_FLD(field_length, TRX_ID_MAX_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_LOCK_MODE 2 {STRUCT_FLD(field_name, "lock_mode"), /* S[,GAP] X[,GAP] IS[,GAP] IX[,GAP] AUTO_INC UNKNOWN */ STRUCT_FLD(field_length, 32), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_LOCK_TYPE 3 {STRUCT_FLD(field_name, "lock_type"), STRUCT_FLD(field_length, 32 /* RECORD|TABLE|UNKNOWN */), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_LOCK_TABLE 4 {STRUCT_FLD(field_name, "lock_table"), STRUCT_FLD(field_length, 1024), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_LOCK_INDEX 5 {STRUCT_FLD(field_name, "lock_index"), STRUCT_FLD(field_length, 1024), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_LOCK_SPACE 6 {STRUCT_FLD(field_name, "lock_space"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED | MY_I_S_MAYBE_NULL), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_LOCK_PAGE 7 {STRUCT_FLD(field_name, "lock_page"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED | MY_I_S_MAYBE_NULL), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_LOCK_REC 8 {STRUCT_FLD(field_name, "lock_rec"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED | MY_I_S_MAYBE_NULL), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_LOCK_DATA 9 {STRUCT_FLD(field_name, "lock_data"), STRUCT_FLD(field_length, TRX_I_S_LOCK_DATA_MAX_LEN), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_MAYBE_NULL), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, END_OF_ST_FIELD_INFO }; /*******************************************************************//** Read data from cache buffer and fill the INFORMATION_SCHEMA.innodb_locks table with it. @return 0 on success */ static int fill_innodb_locks_from_cache( /*=========================*/ trx_i_s_cache_t* cache, /*!< in: cache to read from */ THD* thd, /*!< in: MySQL client connection */ TABLE* table) /*!< in/out: fill this table */ { Field** fields; ulint rows_num; char lock_id[TRX_I_S_LOCK_ID_MAX_LEN + 1]; ulint i; DBUG_ENTER("fill_innodb_locks_from_cache"); fields = table->field; rows_num = trx_i_s_cache_get_rows_used(cache, I_S_INNODB_LOCKS); for (i = 0; i < rows_num; i++) { i_s_locks_row_t* row; /* note that the decoded database or table name is never expected to be longer than NAME_LEN; NAME_LEN for database name 2 for surrounding quotes around database name NAME_LEN for table name 2 for surrounding quotes around table name 1 for the separating dot (.) 9 for the #mysql50# prefix */ char buf[2 * NAME_LEN + 14]; const char* bufend; char lock_trx_id[TRX_ID_MAX_LEN + 1]; row = (i_s_locks_row_t*) trx_i_s_cache_get_nth_row( cache, I_S_INNODB_LOCKS, i); /* lock_id */ trx_i_s_create_lock_id(row, lock_id, sizeof(lock_id)); OK(field_store_string(fields[IDX_LOCK_ID], lock_id)); /* lock_trx_id */ ut_snprintf(lock_trx_id, sizeof(lock_trx_id), TRX_ID_FMT, row->lock_trx_id); OK(field_store_string(fields[IDX_LOCK_TRX_ID], lock_trx_id)); /* lock_mode */ OK(field_store_string(fields[IDX_LOCK_MODE], row->lock_mode)); /* lock_type */ OK(field_store_string(fields[IDX_LOCK_TYPE], row->lock_type)); /* lock_table */ bufend = innobase_convert_name(buf, sizeof(buf), row->lock_table, strlen(row->lock_table), thd, TRUE); OK(fields[IDX_LOCK_TABLE]->store(buf, bufend - buf, system_charset_info)); /* lock_index */ if (row->lock_index != NULL) { bufend = innobase_convert_name(buf, sizeof(buf), row->lock_index, strlen(row->lock_index), thd, FALSE); OK(fields[IDX_LOCK_INDEX]->store(buf, bufend - buf, system_charset_info)); fields[IDX_LOCK_INDEX]->set_notnull(); } else { fields[IDX_LOCK_INDEX]->set_null(); } /* lock_space */ OK(field_store_ulint(fields[IDX_LOCK_SPACE], row->lock_space)); /* lock_page */ OK(field_store_ulint(fields[IDX_LOCK_PAGE], row->lock_page)); /* lock_rec */ OK(field_store_ulint(fields[IDX_LOCK_REC], row->lock_rec)); /* lock_data */ OK(field_store_string(fields[IDX_LOCK_DATA], row->lock_data)); OK(schema_table_store_record(thd, table)); } DBUG_RETURN(0); } /*******************************************************************//** Bind the dynamic table INFORMATION_SCHEMA.innodb_locks @return 0 on success */ static int innodb_locks_init( /*==============*/ void* p) /*!< in/out: table schema object */ { ST_SCHEMA_TABLE* schema; DBUG_ENTER("innodb_locks_init"); schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = innodb_locks_fields_info; schema->fill_table = trx_i_s_common_fill_table; DBUG_RETURN(0); } UNIV_INTERN struct st_mysql_plugin i_s_innodb_locks = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_LOCKS"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "InnoDB conflicting locks"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, innodb_locks_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; /* Fields of the dynamic table INFORMATION_SCHEMA.innodb_lock_waits */ static ST_FIELD_INFO innodb_lock_waits_fields_info[] = { #define IDX_REQUESTING_TRX_ID 0 {STRUCT_FLD(field_name, "requesting_trx_id"), STRUCT_FLD(field_length, TRX_ID_MAX_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_REQUESTED_LOCK_ID 1 {STRUCT_FLD(field_name, "requested_lock_id"), STRUCT_FLD(field_length, TRX_I_S_LOCK_ID_MAX_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_BLOCKING_TRX_ID 2 {STRUCT_FLD(field_name, "blocking_trx_id"), STRUCT_FLD(field_length, TRX_ID_MAX_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define IDX_BLOCKING_LOCK_ID 3 {STRUCT_FLD(field_name, "blocking_lock_id"), STRUCT_FLD(field_length, TRX_I_S_LOCK_ID_MAX_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, END_OF_ST_FIELD_INFO }; /*******************************************************************//** Read data from cache buffer and fill the INFORMATION_SCHEMA.innodb_lock_waits table with it. @return 0 on success */ static int fill_innodb_lock_waits_from_cache( /*==============================*/ trx_i_s_cache_t* cache, /*!< in: cache to read from */ THD* thd, /*!< in: used to call schema_table_store_record() */ TABLE* table) /*!< in/out: fill this table */ { Field** fields; ulint rows_num; char requested_lock_id[TRX_I_S_LOCK_ID_MAX_LEN + 1]; char blocking_lock_id[TRX_I_S_LOCK_ID_MAX_LEN + 1]; ulint i; DBUG_ENTER("fill_innodb_lock_waits_from_cache"); fields = table->field; rows_num = trx_i_s_cache_get_rows_used(cache, I_S_INNODB_LOCK_WAITS); for (i = 0; i < rows_num; i++) { i_s_lock_waits_row_t* row; char requesting_trx_id[TRX_ID_MAX_LEN + 1]; char blocking_trx_id[TRX_ID_MAX_LEN + 1]; row = (i_s_lock_waits_row_t*) trx_i_s_cache_get_nth_row( cache, I_S_INNODB_LOCK_WAITS, i); /* requesting_trx_id */ ut_snprintf(requesting_trx_id, sizeof(requesting_trx_id), TRX_ID_FMT, row->requested_lock_row->lock_trx_id); OK(field_store_string(fields[IDX_REQUESTING_TRX_ID], requesting_trx_id)); /* requested_lock_id */ OK(field_store_string( fields[IDX_REQUESTED_LOCK_ID], trx_i_s_create_lock_id( row->requested_lock_row, requested_lock_id, sizeof(requested_lock_id)))); /* blocking_trx_id */ ut_snprintf(blocking_trx_id, sizeof(blocking_trx_id), TRX_ID_FMT, row->blocking_lock_row->lock_trx_id); OK(field_store_string(fields[IDX_BLOCKING_TRX_ID], blocking_trx_id)); /* blocking_lock_id */ OK(field_store_string( fields[IDX_BLOCKING_LOCK_ID], trx_i_s_create_lock_id( row->blocking_lock_row, blocking_lock_id, sizeof(blocking_lock_id)))); OK(schema_table_store_record(thd, table)); } DBUG_RETURN(0); } /*******************************************************************//** Bind the dynamic table INFORMATION_SCHEMA.innodb_lock_waits @return 0 on success */ static int innodb_lock_waits_init( /*===================*/ void* p) /*!< in/out: table schema object */ { ST_SCHEMA_TABLE* schema; DBUG_ENTER("innodb_lock_waits_init"); schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = innodb_lock_waits_fields_info; schema->fill_table = trx_i_s_common_fill_table; DBUG_RETURN(0); } UNIV_INTERN struct st_mysql_plugin i_s_innodb_lock_waits = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_LOCK_WAITS"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, "Innobase Oy"), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "InnoDB which lock is blocking which"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, innodb_lock_waits_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; /*******************************************************************//** Common function to fill any of the dynamic tables: INFORMATION_SCHEMA.innodb_trx INFORMATION_SCHEMA.innodb_locks INFORMATION_SCHEMA.innodb_lock_waits @return 0 on success */ static int trx_i_s_common_fill_table( /*======================*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond) /*!< in: condition (not used) */ { const char* table_name; int ret; trx_i_s_cache_t* cache; DBUG_ENTER("trx_i_s_common_fill_table"); /* deny access to non-superusers */ if (check_global_access(thd, PROCESS_ACL)) { DBUG_RETURN(0); } /* minimize the number of places where global variables are referenced */ cache = trx_i_s_cache; /* which table we have to fill? */ table_name = tables->schema_table_name; /* or table_name = tables->schema_table->table_name; */ RETURN_IF_INNODB_NOT_STARTED(table_name); /* update the cache */ trx_i_s_cache_start_write(cache); trx_i_s_possibly_fetch_data_into_cache(cache); trx_i_s_cache_end_write(cache); if (trx_i_s_cache_is_truncated(cache)) { /* XXX show warning to user if possible */ fprintf(stderr, "Warning: data in %s truncated due to " "memory limit of %d bytes\n", table_name, TRX_I_S_MEM_LIMIT); } ret = 0; trx_i_s_cache_start_read(cache); if (innobase_strcasecmp(table_name, "innodb_trx") == 0) { if (fill_innodb_trx_from_cache( cache, thd, tables->table) != 0) { ret = 1; } } else if (innobase_strcasecmp(table_name, "innodb_locks") == 0) { if (fill_innodb_locks_from_cache( cache, thd, tables->table) != 0) { ret = 1; } } else if (innobase_strcasecmp(table_name, "innodb_lock_waits") == 0) { if (fill_innodb_lock_waits_from_cache( cache, thd, tables->table) != 0) { ret = 1; } } else { /* huh! what happened!? */ fprintf(stderr, "InnoDB: trx_i_s_common_fill_table() was " "called to fill unknown table: %s.\n" "This function only knows how to fill " "innodb_trx, innodb_locks and " "innodb_lock_waits tables.\n", table_name); ret = 1; } trx_i_s_cache_end_read(cache); #if 0 DBUG_RETURN(ret); #else /* if this function returns something else than 0 then a deadlock occurs between the mysqld server and mysql client, see http://bugs.mysql.com/29900 ; when that bug is resolved we can enable the DBUG_RETURN(ret) above */ DBUG_RETURN(0); #endif } /* Fields of the dynamic table information_schema.innodb_cmp. */ static ST_FIELD_INFO i_s_cmp_fields_info[] = { {STRUCT_FLD(field_name, "page_size"), STRUCT_FLD(field_length, 5), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, "Compressed Page Size"), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, {STRUCT_FLD(field_name, "compress_ops"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, "Total Number of Compressions"), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, {STRUCT_FLD(field_name, "compress_ops_ok"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, "Total Number of" " Successful Compressions"), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, {STRUCT_FLD(field_name, "compress_time"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, "Total Duration of Compressions," " in Seconds"), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, {STRUCT_FLD(field_name, "uncompress_ops"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, "Total Number of Decompressions"), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, {STRUCT_FLD(field_name, "uncompress_time"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, "Total Duration of Decompressions," " in Seconds"), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, END_OF_ST_FIELD_INFO }; /*******************************************************************//** Fill the dynamic table information_schema.innodb_cmp or innodb_cmp_reset. @return 0 on success, 1 on failure */ static int i_s_cmp_fill_low( /*=============*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond, /*!< in: condition (ignored) */ ibool reset) /*!< in: TRUE=reset cumulated counts */ { TABLE* table = (TABLE *) tables->table; int status = 0; DBUG_ENTER("i_s_cmp_fill_low"); /* deny access to non-superusers */ if (check_global_access(thd, PROCESS_ACL)) { DBUG_RETURN(0); } RETURN_IF_INNODB_NOT_STARTED(tables->schema_table_name); for (uint i = 0; i < PAGE_ZIP_NUM_SSIZE - 1; i++) { page_zip_stat_t* zip_stat = &page_zip_stat[i]; table->field[0]->store(PAGE_ZIP_MIN_SIZE << i); /* The cumulated counts are not protected by any mutex. Thus, some operation in page0zip.c could increment a counter between the time we read it and clear it. We could introduce mutex protection, but it could cause a measureable performance hit in page0zip.c. */ table->field[1]->store(zip_stat->compressed); table->field[2]->store(zip_stat->compressed_ok); table->field[3]->store( (ulong) (zip_stat->compressed_usec / 1000000)); table->field[4]->store(zip_stat->decompressed); table->field[5]->store( (ulong) (zip_stat->decompressed_usec / 1000000)); if (reset) { memset(zip_stat, 0, sizeof *zip_stat); } if (schema_table_store_record(thd, table)) { status = 1; break; } } DBUG_RETURN(status); } /*******************************************************************//** Fill the dynamic table information_schema.innodb_cmp. @return 0 on success, 1 on failure */ static int i_s_cmp_fill( /*=========*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond) /*!< in: condition (ignored) */ { return(i_s_cmp_fill_low(thd, tables, cond, FALSE)); } /*******************************************************************//** Fill the dynamic table information_schema.innodb_cmp_reset. @return 0 on success, 1 on failure */ static int i_s_cmp_reset_fill( /*===============*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond) /*!< in: condition (ignored) */ { return(i_s_cmp_fill_low(thd, tables, cond, TRUE)); } /*******************************************************************//** Bind the dynamic table information_schema.innodb_cmp. @return 0 on success */ static int i_s_cmp_init( /*=========*/ void* p) /*!< in/out: table schema object */ { DBUG_ENTER("i_s_cmp_init"); ST_SCHEMA_TABLE* schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = i_s_cmp_fields_info; schema->fill_table = i_s_cmp_fill; DBUG_RETURN(0); } /*******************************************************************//** Bind the dynamic table information_schema.innodb_cmp_reset. @return 0 on success */ static int i_s_cmp_reset_init( /*===============*/ void* p) /*!< in/out: table schema object */ { DBUG_ENTER("i_s_cmp_reset_init"); ST_SCHEMA_TABLE* schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = i_s_cmp_fields_info; schema->fill_table = i_s_cmp_reset_fill; DBUG_RETURN(0); } UNIV_INTERN struct st_mysql_plugin i_s_innodb_cmp = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_CMP"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "Statistics for the InnoDB compression"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, i_s_cmp_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; UNIV_INTERN struct st_mysql_plugin i_s_innodb_cmp_reset = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_CMP_RESET"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "Statistics for the InnoDB compression;" " reset cumulated counts"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, i_s_cmp_reset_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; /* Fields of the dynamic table information_schema.innodb_cmpmem. */ static ST_FIELD_INFO i_s_cmpmem_fields_info[] = { {STRUCT_FLD(field_name, "page_size"), STRUCT_FLD(field_length, 5), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, "Buddy Block Size"), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, {STRUCT_FLD(field_name, "buffer_pool_instance"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, "Buffer Pool Id"), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, {STRUCT_FLD(field_name, "pages_used"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, "Currently in Use"), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, {STRUCT_FLD(field_name, "pages_free"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, "Currently Available"), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, {STRUCT_FLD(field_name, "relocation_ops"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, "Total Number of Relocations"), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, {STRUCT_FLD(field_name, "relocation_time"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, "Total Duration of Relocations," " in Seconds"), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, END_OF_ST_FIELD_INFO }; /*******************************************************************//** Fill the dynamic table information_schema.innodb_cmpmem or innodb_cmpmem_reset. @return 0 on success, 1 on failure */ static int i_s_cmpmem_fill_low( /*================*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond, /*!< in: condition (ignored) */ ibool reset) /*!< in: TRUE=reset cumulated counts */ { int status = 0; TABLE* table = (TABLE *) tables->table; DBUG_ENTER("i_s_cmpmem_fill_low"); /* deny access to non-superusers */ if (check_global_access(thd, PROCESS_ACL)) { DBUG_RETURN(0); } RETURN_IF_INNODB_NOT_STARTED(tables->schema_table_name); for (ulint i = 0; i < srv_buf_pool_instances; i++) { buf_pool_t* buf_pool; status = 0; buf_pool = buf_pool_from_array(i); buf_pool_mutex_enter(buf_pool); for (uint x = 0; x <= BUF_BUDDY_SIZES; x++) { buf_buddy_stat_t* buddy_stat; buddy_stat = &buf_pool->buddy_stat[x]; table->field[0]->store(BUF_BUDDY_LOW << x); table->field[1]->store(i); table->field[2]->store(buddy_stat->used); table->field[3]->store(UNIV_LIKELY(x < BUF_BUDDY_SIZES) ? UT_LIST_GET_LEN(buf_pool->zip_free[x]) : 0); table->field[4]->store((longlong) buddy_stat->relocated, true); table->field[5]->store( (ulong) (buddy_stat->relocated_usec / 1000000)); if (reset) { /* This is protected by buf_pool->mutex. */ buddy_stat->relocated = 0; buddy_stat->relocated_usec = 0; } if (schema_table_store_record(thd, table)) { status = 1; break; } } buf_pool_mutex_exit(buf_pool); if (status) { break; } } DBUG_RETURN(status); } /*******************************************************************//** Fill the dynamic table information_schema.innodb_cmpmem. @return 0 on success, 1 on failure */ static int i_s_cmpmem_fill( /*============*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond) /*!< in: condition (ignored) */ { return(i_s_cmpmem_fill_low(thd, tables, cond, FALSE)); } /*******************************************************************//** Fill the dynamic table information_schema.innodb_cmpmem_reset. @return 0 on success, 1 on failure */ static int i_s_cmpmem_reset_fill( /*==================*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond) /*!< in: condition (ignored) */ { return(i_s_cmpmem_fill_low(thd, tables, cond, TRUE)); } /*******************************************************************//** Bind the dynamic table information_schema.innodb_cmpmem. @return 0 on success */ static int i_s_cmpmem_init( /*============*/ void* p) /*!< in/out: table schema object */ { DBUG_ENTER("i_s_cmpmem_init"); ST_SCHEMA_TABLE* schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = i_s_cmpmem_fields_info; schema->fill_table = i_s_cmpmem_fill; DBUG_RETURN(0); } /*******************************************************************//** Bind the dynamic table information_schema.innodb_cmpmem_reset. @return 0 on success */ static int i_s_cmpmem_reset_init( /*==================*/ void* p) /*!< in/out: table schema object */ { DBUG_ENTER("i_s_cmpmem_reset_init"); ST_SCHEMA_TABLE* schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = i_s_cmpmem_fields_info; schema->fill_table = i_s_cmpmem_reset_fill; DBUG_RETURN(0); } UNIV_INTERN struct st_mysql_plugin i_s_innodb_cmpmem = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_CMPMEM"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "Statistics for the InnoDB compressed buffer pool"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, i_s_cmpmem_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; UNIV_INTERN struct st_mysql_plugin i_s_innodb_cmpmem_reset = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_CMPMEM_RESET"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "Statistics for the InnoDB compressed buffer pool;" " reset cumulated counts"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, i_s_cmpmem_reset_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; /*******************************************************************//** Unbind a dynamic INFORMATION_SCHEMA table. @return 0 on success */ static int i_s_common_deinit( /*==============*/ void* p) /*!< in/out: table schema object */ { DBUG_ENTER("i_s_common_deinit"); /* Do nothing */ DBUG_RETURN(0); } /* Fields of the dynamic table INFORMATION_SCHEMA.SYS_TABLES */ static ST_FIELD_INFO innodb_sys_tables_fields_info[] = { #define SYS_TABLE_ID 0 {STRUCT_FLD(field_name, "TABLE_ID"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_TABLE_NAME 1 {STRUCT_FLD(field_name, "NAME"), STRUCT_FLD(field_length, NAME_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_TABLE_FLAG 2 {STRUCT_FLD(field_name, "FLAG"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_TABLE_NUM_COLUMN 3 {STRUCT_FLD(field_name, "N_COLS"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_TABLE_SPACE 4 {STRUCT_FLD(field_name, "SPACE"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, END_OF_ST_FIELD_INFO }; /**********************************************************************//** Populate information_schema.innodb_sys_tables table with information from SYS_TABLES. @return 0 on success */ static int i_s_dict_fill_sys_tables( /*=====================*/ THD* thd, /*!< in: thread */ dict_table_t* table, /*!< in: table */ TABLE* table_to_fill) /*!< in/out: fill this table */ { longlong table_id; Field** fields; DBUG_ENTER("i_s_dict_fill_sys_tables"); fields = table_to_fill->field; table_id = ut_conv_dulint_to_longlong(table->id); OK(fields[SYS_TABLE_ID]->store(table_id)); OK(field_store_string(fields[SYS_TABLE_NAME], table->name)); OK(fields[SYS_TABLE_FLAG]->store(table->flags)); OK(fields[SYS_TABLE_NUM_COLUMN]->store(table->n_cols)); OK(fields[SYS_TABLE_SPACE]->store(table->space)); OK(schema_table_store_record(thd, table_to_fill)); DBUG_RETURN(0); } /*******************************************************************//** Function to go through each record in SYS_TABLES table, and fill the information_schema.innodb_sys_tables table with related table information @return 0 on success */ static int i_s_sys_tables_fill_table( /*======================*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond) /*!< in: condition (not used) */ { btr_pcur_t pcur; const rec_t* rec; mem_heap_t* heap; mtr_t mtr; DBUG_ENTER("i_s_sys_tables_fill_table"); /* deny access to non-superusers */ if (check_global_access(thd, PROCESS_ACL)) { DBUG_RETURN(0); } heap = mem_heap_create(1000); mutex_enter(&(dict_sys->mutex)); mtr_start(&mtr); rec = dict_startscan_system(&pcur, &mtr, SYS_TABLES); while (rec) { const char* err_msg; dict_table_t* table_rec; /* Create and populate a dict_table_t structure with information from SYS_TABLES row */ err_msg = dict_process_sys_tables_rec( heap, rec, &table_rec, DICT_TABLE_LOAD_FROM_RECORD); mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); if (!err_msg) { i_s_dict_fill_sys_tables(thd, table_rec, tables->table); } else { push_warning_printf(thd, MYSQL_ERROR::WARN_LEVEL_WARN, ER_CANT_FIND_SYSTEM_REC, err_msg); } /* Since dict_process_sys_tables_rec() is called with DICT_TABLE_LOAD_FROM_RECORD, the table_rec is created in dict_process_sys_tables_rec(), we will need to free it */ if (table_rec) { dict_mem_table_free(table_rec); } mem_heap_empty(heap); /* Get the next record */ mutex_enter(&dict_sys->mutex); mtr_start(&mtr); rec = dict_getnext_system(&pcur, &mtr); } mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); mem_heap_free(heap); DBUG_RETURN(0); } /*******************************************************************//** Bind the dynamic table INFORMATION_SCHEMA.innodb_sys_tables @return 0 on success */ static int innodb_sys_tables_init( /*===================*/ void* p) /*!< in/out: table schema object */ { ST_SCHEMA_TABLE* schema; DBUG_ENTER("innodb_sys_tables_init"); schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = innodb_sys_tables_fields_info; schema->fill_table = i_s_sys_tables_fill_table; DBUG_RETURN(0); } UNIV_INTERN struct st_mysql_plugin i_s_innodb_sys_tables = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_SYS_TABLES"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "InnoDB SYS_TABLES"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, innodb_sys_tables_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; /* Fields of the dynamic table INFORMATION_SCHEMA.SYS_TABLESTATS */ static ST_FIELD_INFO innodb_sys_tablestats_fields_info[] = { #define SYS_TABLESTATS_ID 0 {STRUCT_FLD(field_name, "TABLE_ID"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_TABLESTATS_NAME 1 {STRUCT_FLD(field_name, "NAME"), STRUCT_FLD(field_length, NAME_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_TABLESTATS_INIT 2 {STRUCT_FLD(field_name, "STATS_INITIALIZED"), STRUCT_FLD(field_length, NAME_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_TABLESTATS_NROW 3 {STRUCT_FLD(field_name, "NUM_ROWS"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_TABLESTATS_CLUST_SIZE 4 {STRUCT_FLD(field_name, "CLUST_INDEX_SIZE"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_TABLESTATS_INDEX_SIZE 5 {STRUCT_FLD(field_name, "OTHER_INDEX_SIZE"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_TABLESTATS_MODIFIED 6 {STRUCT_FLD(field_name, "MODIFIED_COUNTER"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_TABLESTATS_AUTONINC 7 {STRUCT_FLD(field_name, "AUTOINC"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_TABLESTATS_MYSQL_OPEN_HANDLE 8 {STRUCT_FLD(field_name, "MYSQL_HANDLES_OPENED"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, END_OF_ST_FIELD_INFO }; /**********************************************************************//** Populate information_schema.innodb_sys_tablestats table with information from SYS_TABLES. @return 0 on success */ static int i_s_dict_fill_sys_tablestats( /*=========================*/ THD* thd, /*!< in: thread */ dict_table_t* table, /*!< in: table */ TABLE* table_to_fill) /*!< in/out: fill this table */ { longlong table_id; Field** fields; DBUG_ENTER("i_s_dict_fill_sys_tablestats"); fields = table_to_fill->field; table_id = ut_conv_dulint_to_longlong(table->id); OK(fields[SYS_TABLESTATS_ID]->store(table_id)); OK(field_store_string(fields[SYS_TABLESTATS_NAME], table->name)); if (table->stat_initialized) { OK(field_store_string(fields[SYS_TABLESTATS_INIT], "Initialized")); } else { OK(field_store_string(fields[SYS_TABLESTATS_INIT], "Uninitialized")); } OK(fields[SYS_TABLESTATS_NROW]->store(table->stat_n_rows)); OK(fields[SYS_TABLESTATS_CLUST_SIZE]->store( table->stat_clustered_index_size)); OK(fields[SYS_TABLESTATS_INDEX_SIZE]->store( table->stat_sum_of_other_index_sizes)); OK(fields[SYS_TABLESTATS_MODIFIED]->store( table->stat_modified_counter)); OK(fields[SYS_TABLESTATS_AUTONINC]->store(table->autoinc)); OK(fields[SYS_TABLESTATS_MYSQL_OPEN_HANDLE]->store( table->n_mysql_handles_opened)); OK(schema_table_store_record(thd, table_to_fill)); DBUG_RETURN(0); } /*******************************************************************//** Function to go through each record in SYS_TABLES table, and fill the information_schema.innodb_sys_tablestats table with table statistics related information @return 0 on success */ static int i_s_sys_tables_fill_table_stats( /*============================*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond) /*!< in: condition (not used) */ { btr_pcur_t pcur; const rec_t* rec; mem_heap_t* heap; mtr_t mtr; DBUG_ENTER("i_s_sys_tables_fill_table_stats"); /* deny access to non-superusers */ if (check_global_access(thd, PROCESS_ACL)) { DBUG_RETURN(0); } heap = mem_heap_create(1000); mutex_enter(&dict_sys->mutex); mtr_start(&mtr); rec = dict_startscan_system(&pcur, &mtr, SYS_TABLES); while (rec) { const char* err_msg; dict_table_t* table_rec; /* Fetch the dict_table_t structure corresponding to this SYS_TABLES record */ err_msg = dict_process_sys_tables_rec( heap, rec, &table_rec, DICT_TABLE_LOAD_FROM_CACHE); mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); if (!err_msg) { i_s_dict_fill_sys_tablestats(thd, table_rec, tables->table); } else { push_warning_printf(thd, MYSQL_ERROR::WARN_LEVEL_WARN, ER_CANT_FIND_SYSTEM_REC, err_msg); } mem_heap_empty(heap); /* Get the next record */ mutex_enter(&dict_sys->mutex); mtr_start(&mtr); rec = dict_getnext_system(&pcur, &mtr); } mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); mem_heap_free(heap); DBUG_RETURN(0); } /*******************************************************************//** Bind the dynamic table INFORMATION_SCHEMA.innodb_sys_tablestats @return 0 on success */ static int innodb_sys_tablestats_init( /*=======================*/ void* p) /*!< in/out: table schema object */ { ST_SCHEMA_TABLE* schema; DBUG_ENTER("innodb_sys_tablestats_init"); schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = innodb_sys_tablestats_fields_info; schema->fill_table = i_s_sys_tables_fill_table_stats; DBUG_RETURN(0); } UNIV_INTERN struct st_mysql_plugin i_s_innodb_sys_tablestats = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_SYS_TABLESTATS"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "InnoDB SYS_TABLESTATS"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, innodb_sys_tablestats_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; /* Fields of the dynamic table INFORMATION_SCHEMA.SYS_INDEXES */ static ST_FIELD_INFO innodb_sysindex_fields_info[] = { #define SYS_INDEX_ID 0 {STRUCT_FLD(field_name, "INDEX_ID"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_INDEX_NAME 1 {STRUCT_FLD(field_name, "NAME"), STRUCT_FLD(field_length, NAME_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_INDEX_TABLE_ID 2 {STRUCT_FLD(field_name, "TABLE_ID"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_INDEX_TYPE 3 {STRUCT_FLD(field_name, "TYPE"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_INDEX_NUM_FIELDS 4 {STRUCT_FLD(field_name, "N_FIELDS"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_INDEX_PAGE_NO 5 {STRUCT_FLD(field_name, "PAGE_NO"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_INDEX_SPACE 6 {STRUCT_FLD(field_name, "SPACE"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, END_OF_ST_FIELD_INFO }; /**********************************************************************//** Function to populate the information_schema.innodb_sys_indexes table with collected index information @return 0 on success */ static int i_s_dict_fill_sys_indexes( /*======================*/ THD* thd, /*!< in: thread */ dulint tableid, /*!< in: table id */ dict_index_t* index, /*!< in: populated dict_index_t struct with index info */ TABLE* table_to_fill) /*!< in/out: fill this table */ { longlong table_id; longlong index_id; Field** fields; DBUG_ENTER("i_s_dict_fill_sys_indexes"); fields = table_to_fill->field; table_id = ut_conv_dulint_to_longlong(tableid); index_id = ut_conv_dulint_to_longlong(index->id); OK(fields[SYS_INDEX_ID]->store(index_id)); OK(field_store_string(fields[SYS_INDEX_NAME], index->name)); OK(fields[SYS_INDEX_TABLE_ID]->store(table_id)); OK(fields[SYS_INDEX_TYPE]->store(index->type)); OK(fields[SYS_INDEX_NUM_FIELDS]->store(index->n_fields)); OK(fields[SYS_INDEX_PAGE_NO]->store(index->page)); OK(fields[SYS_INDEX_SPACE]->store(index->space)); OK(schema_table_store_record(thd, table_to_fill)); DBUG_RETURN(0); } /*******************************************************************//** Function to go through each record in SYS_INDEXES table, and fill the information_schema.innodb_sys_indexes table with related index information @return 0 on success */ static int i_s_sys_indexes_fill_table( /*=======================*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond) /*!< in: condition (not used) */ { btr_pcur_t pcur; const rec_t* rec; mem_heap_t* heap; mtr_t mtr; DBUG_ENTER("i_s_sys_indexes_fill_table"); /* deny access to non-superusers */ if (check_global_access(thd, PROCESS_ACL)) { DBUG_RETURN(0); } heap = mem_heap_create(1000); mutex_enter(&dict_sys->mutex); mtr_start(&mtr); /* Start scan the SYS_INDEXES table */ rec = dict_startscan_system(&pcur, &mtr, SYS_INDEXES); /* Process each record in the table */ while (rec) { const char* err_msg;; dulint table_id; dict_index_t index_rec; /* Populate a dict_index_t structure with information from a SYS_INDEXES row */ err_msg = dict_process_sys_indexes_rec(heap, rec, &index_rec, &table_id); mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); if (!err_msg) { i_s_dict_fill_sys_indexes(thd, table_id, &index_rec, tables->table); } else { push_warning_printf(thd, MYSQL_ERROR::WARN_LEVEL_WARN, ER_CANT_FIND_SYSTEM_REC, err_msg); } mem_heap_empty(heap); /* Get the next record */ mutex_enter(&dict_sys->mutex); mtr_start(&mtr); rec = dict_getnext_system(&pcur, &mtr); } mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); mem_heap_free(heap); DBUG_RETURN(0); } /*******************************************************************//** Bind the dynamic table INFORMATION_SCHEMA.innodb_sys_indexes @return 0 on success */ static int innodb_sys_indexes_init( /*====================*/ void* p) /*!< in/out: table schema object */ { ST_SCHEMA_TABLE* schema; DBUG_ENTER("innodb_sys_index_init"); schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = innodb_sysindex_fields_info; schema->fill_table = i_s_sys_indexes_fill_table; DBUG_RETURN(0); } UNIV_INTERN struct st_mysql_plugin i_s_innodb_sys_indexes = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_SYS_INDEXES"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "InnoDB SYS_INDEXES"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, innodb_sys_indexes_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; /* Fields of the dynamic table INFORMATION_SCHEMA.SYS_COLUMNS */ static ST_FIELD_INFO innodb_sys_columns_fields_info[] = { #define SYS_COLUMN_TABLE_ID 0 {STRUCT_FLD(field_name, "TABLE_ID"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_COLUMN_NAME 1 {STRUCT_FLD(field_name, "NAME"), STRUCT_FLD(field_length, NAME_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_COLUMN_POSITION 2 {STRUCT_FLD(field_name, "POS"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_COLUMN_MTYPE 3 {STRUCT_FLD(field_name, "MTYPE"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_COLUMN__PRTYPE 4 {STRUCT_FLD(field_name, "PRTYPE"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_COLUMN_COLUMN_LEN 5 {STRUCT_FLD(field_name, "LEN"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, END_OF_ST_FIELD_INFO }; /**********************************************************************//** Function to populate the information_schema.innodb_sys_columns with related column information @return 0 on success */ static int i_s_dict_fill_sys_columns( /*======================*/ THD* thd, /*!< in: thread */ dulint tableid, /*!< in: table ID */ const char* col_name, /*!< in: column name */ dict_col_t* column, /*!< in: dict_col_t struct holding more column information */ TABLE* table_to_fill) /*!< in/out: fill this table */ { longlong table_id; Field** fields; DBUG_ENTER("i_s_dict_fill_sys_columns"); fields = table_to_fill->field; table_id = ut_conv_dulint_to_longlong(tableid); OK(fields[SYS_COLUMN_TABLE_ID]->store(table_id)); OK(field_store_string(fields[SYS_COLUMN_NAME], col_name)); OK(fields[SYS_COLUMN_POSITION]->store(column->ind)); OK(fields[SYS_COLUMN_MTYPE]->store(column->mtype)); OK(fields[SYS_COLUMN__PRTYPE]->store(column->prtype)); OK(fields[SYS_COLUMN_COLUMN_LEN]->store(column->len)); OK(schema_table_store_record(thd, table_to_fill)); DBUG_RETURN(0); } /*******************************************************************//** Function to fill information_schema.innodb_sys_columns with information collected by scanning SYS_COLUMNS table. @return 0 on success */ static int i_s_sys_columns_fill_table( /*=======================*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond) /*!< in: condition (not used) */ { btr_pcur_t pcur; const rec_t* rec; const char* col_name; mem_heap_t* heap; mtr_t mtr; DBUG_ENTER("i_s_sys_columns_fill_table"); /* deny access to non-superusers */ if (check_global_access(thd, PROCESS_ACL)) { DBUG_RETURN(0); } heap = mem_heap_create(1000); mutex_enter(&dict_sys->mutex); mtr_start(&mtr); rec = dict_startscan_system(&pcur, &mtr, SYS_COLUMNS); while (rec) { const char* err_msg; dict_col_t column_rec; dulint table_id; /* populate a dict_col_t structure with information from a SYS_COLUMNS row */ err_msg = dict_process_sys_columns_rec(heap, rec, &column_rec, &table_id, &col_name); mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); if (!err_msg) { i_s_dict_fill_sys_columns(thd, table_id, col_name, &column_rec, tables->table); } else { push_warning_printf(thd, MYSQL_ERROR::WARN_LEVEL_WARN, ER_CANT_FIND_SYSTEM_REC, err_msg); } mem_heap_empty(heap); /* Get the next record */ mutex_enter(&dict_sys->mutex); mtr_start(&mtr); rec = dict_getnext_system(&pcur, &mtr); } mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); mem_heap_free(heap); DBUG_RETURN(0); } /*******************************************************************//** Bind the dynamic table INFORMATION_SCHEMA.innodb_sys_columns @return 0 on success */ static int innodb_sys_columns_init( /*====================*/ void* p) /*!< in/out: table schema object */ { ST_SCHEMA_TABLE* schema; DBUG_ENTER("innodb_sys_columns_init"); schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = innodb_sys_columns_fields_info; schema->fill_table = i_s_sys_columns_fill_table; DBUG_RETURN(0); } UNIV_INTERN struct st_mysql_plugin i_s_innodb_sys_columns = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_SYS_COLUMNS"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "InnoDB SYS_COLUMNS"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, innodb_sys_columns_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; /* Fields of the dynamic table INFORMATION_SCHEMA.innodb_sys_fields */ static ST_FIELD_INFO innodb_sys_fields_fields_info[] = { #define SYS_FIELD_INDEX_ID 0 {STRUCT_FLD(field_name, "INDEX_ID"), STRUCT_FLD(field_length, MY_INT64_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONGLONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_FIELD_NAME 1 {STRUCT_FLD(field_name, "NAME"), STRUCT_FLD(field_length, NAME_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_FIELD_POS 2 {STRUCT_FLD(field_name, "POS"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, END_OF_ST_FIELD_INFO }; /**********************************************************************//** Function to fill information_schema.innodb_sys_fields with information collected by scanning SYS_FIELDS table. @return 0 on success */ static int i_s_dict_fill_sys_fields( /*=====================*/ THD* thd, /*!< in: thread */ dulint indexid, /*!< in: index id for the field */ dict_field_t* field, /*!< in: table */ ulint pos, /*!< in: Field position */ TABLE* table_to_fill) /*!< in/out: fill this table */ { longlong index_id; Field** fields; DBUG_ENTER("i_s_dict_fill_sys_fields"); fields = table_to_fill->field; index_id = ut_conv_dulint_to_longlong(indexid); OK(fields[SYS_FIELD_INDEX_ID]->store(index_id)); OK(field_store_string(fields[SYS_FIELD_NAME], field->name)); OK(fields[SYS_FIELD_POS]->store(pos)); OK(schema_table_store_record(thd, table_to_fill)); DBUG_RETURN(0); } /*******************************************************************//** Function to go through each record in SYS_FIELDS table, and fill the information_schema.innodb_sys_fields table with related index field information @return 0 on success */ static int i_s_sys_fields_fill_table( /*======================*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond) /*!< in: condition (not used) */ { btr_pcur_t pcur; const rec_t* rec; mem_heap_t* heap; dulint last_id; mtr_t mtr; DBUG_ENTER("i_s_sys_fields_fill_table"); /* deny access to non-superusers */ if (check_global_access(thd, PROCESS_ACL)) { DBUG_RETURN(0); } heap = mem_heap_create(1000); mutex_enter(&dict_sys->mutex); mtr_start(&mtr); /* will save last index id so that we know whether we move to the next index. This is used to calculate prefix length */ last_id = ut_dulint_create(0, 0); rec = dict_startscan_system(&pcur, &mtr, SYS_FIELDS); while (rec) { ulint pos; const char* err_msg; dulint index_id; dict_field_t field_rec; /* Populate a dict_field_t structure with information from a SYS_FIELDS row */ err_msg = dict_process_sys_fields_rec(heap, rec, &field_rec, &pos, &index_id, last_id); mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); if (!err_msg) { i_s_dict_fill_sys_fields(thd, index_id, &field_rec, pos, tables->table); last_id = index_id; } else { push_warning_printf(thd, MYSQL_ERROR::WARN_LEVEL_WARN, ER_CANT_FIND_SYSTEM_REC, err_msg); } mem_heap_empty(heap); /* Get the next record */ mutex_enter(&dict_sys->mutex); mtr_start(&mtr); rec = dict_getnext_system(&pcur, &mtr); } mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); mem_heap_free(heap); DBUG_RETURN(0); } /*******************************************************************//** Bind the dynamic table INFORMATION_SCHEMA.innodb_sys_fields @return 0 on success */ static int innodb_sys_fields_init( /*===================*/ void* p) /*!< in/out: table schema object */ { ST_SCHEMA_TABLE* schema; DBUG_ENTER("innodb_sys_field_init"); schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = innodb_sys_fields_fields_info; schema->fill_table = i_s_sys_fields_fill_table; DBUG_RETURN(0); } UNIV_INTERN struct st_mysql_plugin i_s_innodb_sys_fields = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_SYS_FIELDS"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "InnoDB SYS_FIELDS"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, innodb_sys_fields_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; /* Fields of the dynamic table INFORMATION_SCHEMA.innodb_sys_foreign */ static ST_FIELD_INFO innodb_sys_foreign_fields_info[] = { #define SYS_FOREIGN_ID 0 {STRUCT_FLD(field_name, "ID"), STRUCT_FLD(field_length, NAME_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_FOREIGN_FOR_NAME 1 {STRUCT_FLD(field_name, "FOR_NAME"), STRUCT_FLD(field_length, NAME_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_FOREIGN_REF_NAME 2 {STRUCT_FLD(field_name, "REF_NAME"), STRUCT_FLD(field_length, NAME_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_FOREIGN_NUM_COL 3 {STRUCT_FLD(field_name, "N_COLS"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_FOREIGN_TYPE 4 {STRUCT_FLD(field_name, "TYPE"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, END_OF_ST_FIELD_INFO }; /**********************************************************************//** Function to fill information_schema.innodb_sys_foreign with information collected by scanning SYS_FOREIGN table. @return 0 on success */ static int i_s_dict_fill_sys_foreign( /*======================*/ THD* thd, /*!< in: thread */ dict_foreign_t* foreign, /*!< in: table */ TABLE* table_to_fill) /*!< in/out: fill this table */ { Field** fields; DBUG_ENTER("i_s_dict_fill_sys_foreign"); fields = table_to_fill->field; OK(field_store_string(fields[SYS_FOREIGN_ID], foreign->id)); OK(field_store_string(fields[SYS_FOREIGN_FOR_NAME], foreign->foreign_table_name)); OK(field_store_string(fields[SYS_FOREIGN_REF_NAME], foreign->referenced_table_name)); OK(fields[SYS_FOREIGN_NUM_COL]->store(foreign->n_fields)); OK(fields[SYS_FOREIGN_TYPE]->store(foreign->type)); OK(schema_table_store_record(thd, table_to_fill)); DBUG_RETURN(0); } /*******************************************************************//** Function to populate INFORMATION_SCHEMA.innodb_sys_foreign table. Loop through each record in SYS_FOREIGN, and extract the foreign key information. @return 0 on success */ static int i_s_sys_foreign_fill_table( /*=======================*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond) /*!< in: condition (not used) */ { btr_pcur_t pcur; const rec_t* rec; mem_heap_t* heap; mtr_t mtr; DBUG_ENTER("i_s_sys_foreign_fill_table"); /* deny access to non-superusers */ if (check_global_access(thd, PROCESS_ACL)) { DBUG_RETURN(0); } heap = mem_heap_create(1000); mutex_enter(&dict_sys->mutex); mtr_start(&mtr); rec = dict_startscan_system(&pcur, &mtr, SYS_FOREIGN); while (rec) { const char* err_msg; dict_foreign_t foreign_rec; /* Populate a dict_foreign_t structure with information from a SYS_FOREIGN row */ err_msg = dict_process_sys_foreign_rec(heap, rec, &foreign_rec); mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); if (!err_msg) { i_s_dict_fill_sys_foreign(thd, &foreign_rec, tables->table); } else { push_warning_printf(thd, MYSQL_ERROR::WARN_LEVEL_WARN, ER_CANT_FIND_SYSTEM_REC, err_msg); } mem_heap_empty(heap); /* Get the next record */ mtr_start(&mtr); mutex_enter(&dict_sys->mutex); rec = dict_getnext_system(&pcur, &mtr); } mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); mem_heap_free(heap); DBUG_RETURN(0); } /*******************************************************************//** Bind the dynamic table INFORMATION_SCHEMA.innodb_sys_foreign @return 0 on success */ static int innodb_sys_foreign_init( /*====================*/ void* p) /*!< in/out: table schema object */ { ST_SCHEMA_TABLE* schema; DBUG_ENTER("innodb_sys_foreign_init"); schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = innodb_sys_foreign_fields_info; schema->fill_table = i_s_sys_foreign_fill_table; DBUG_RETURN(0); } UNIV_INTERN struct st_mysql_plugin i_s_innodb_sys_foreign = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_SYS_FOREIGN"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "InnoDB SYS_FOREIGN"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, innodb_sys_foreign_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) }; /* Fields of the dynamic table INFORMATION_SCHEMA.innodb_sys_foreign_cols */ static ST_FIELD_INFO innodb_sys_foreign_cols_fields_info[] = { #define SYS_FOREIGN_COL_ID 0 {STRUCT_FLD(field_name, "ID"), STRUCT_FLD(field_length, NAME_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_FOREIGN_COL_FOR_NAME 1 {STRUCT_FLD(field_name, "FOR_COL_NAME"), STRUCT_FLD(field_length, NAME_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_FOREIGN_COL_REF_NAME 2 {STRUCT_FLD(field_name, "REF_COL_NAME"), STRUCT_FLD(field_length, NAME_LEN + 1), STRUCT_FLD(field_type, MYSQL_TYPE_STRING), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, 0), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, #define SYS_FOREIGN_COL_POS 3 {STRUCT_FLD(field_name, "POS"), STRUCT_FLD(field_length, MY_INT32_NUM_DECIMAL_DIGITS), STRUCT_FLD(field_type, MYSQL_TYPE_LONG), STRUCT_FLD(value, 0), STRUCT_FLD(field_flags, MY_I_S_UNSIGNED), STRUCT_FLD(old_name, ""), STRUCT_FLD(open_method, SKIP_OPEN_TABLE)}, END_OF_ST_FIELD_INFO }; /**********************************************************************//** Function to fill information_schema.innodb_sys_foreign_cols with information collected by scanning SYS_FOREIGN_COLS table. @return 0 on success */ static int i_s_dict_fill_sys_foreign_cols( /*==========================*/ THD* thd, /*!< in: thread */ const char* name, /*!< in: foreign key constraint name */ const char* for_col_name, /*!< in: referencing column name*/ const char* ref_col_name, /*!< in: referenced column name */ ulint pos, /*!< in: column position */ TABLE* table_to_fill) /*!< in/out: fill this table */ { Field** fields; DBUG_ENTER("i_s_dict_fill_sys_foreign_cols"); fields = table_to_fill->field; OK(field_store_string(fields[SYS_FOREIGN_COL_ID], name)); OK(field_store_string(fields[SYS_FOREIGN_COL_FOR_NAME], for_col_name)); OK(field_store_string(fields[SYS_FOREIGN_COL_REF_NAME], ref_col_name)); OK(fields[SYS_FOREIGN_COL_POS]->store(pos)); OK(schema_table_store_record(thd, table_to_fill)); DBUG_RETURN(0); } /*******************************************************************//** Function to populate INFORMATION_SCHEMA.innodb_sys_foreign_cols table. Loop through each record in SYS_FOREIGN_COLS, and extract the foreign key column information and fill the INFORMATION_SCHEMA.innodb_sys_foreign_cols table. @return 0 on success */ static int i_s_sys_foreign_cols_fill_table( /*============================*/ THD* thd, /*!< in: thread */ TABLE_LIST* tables, /*!< in/out: tables to fill */ COND* cond) /*!< in: condition (not used) */ { btr_pcur_t pcur; const rec_t* rec; mem_heap_t* heap; mtr_t mtr; DBUG_ENTER("i_s_sys_foreign_cols_fill_table"); /* deny access to non-superusers */ if (check_global_access(thd, PROCESS_ACL)) { DBUG_RETURN(0); } heap = mem_heap_create(1000); mutex_enter(&dict_sys->mutex); mtr_start(&mtr); rec = dict_startscan_system(&pcur, &mtr, SYS_FOREIGN_COLS); while (rec) { const char* err_msg; const char* name; const char* for_col_name; const char* ref_col_name; ulint pos; /* Extract necessary information from a SYS_FOREIGN_COLS row */ err_msg = dict_process_sys_foreign_col_rec( heap, rec, &name, &for_col_name, &ref_col_name, &pos); mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); if (!err_msg) { i_s_dict_fill_sys_foreign_cols( thd, name, for_col_name, ref_col_name, pos, tables->table); } else { push_warning_printf(thd, MYSQL_ERROR::WARN_LEVEL_WARN, ER_CANT_FIND_SYSTEM_REC, err_msg); } mem_heap_empty(heap); /* Get the next record */ mutex_enter(&dict_sys->mutex); mtr_start(&mtr); rec = dict_getnext_system(&pcur, &mtr); } mtr_commit(&mtr); mutex_exit(&dict_sys->mutex); mem_heap_free(heap); DBUG_RETURN(0); } /*******************************************************************//** Bind the dynamic table INFORMATION_SCHEMA.innodb_sys_foreign_cols @return 0 on success */ static int innodb_sys_foreign_cols_init( /*========================*/ void* p) /*!< in/out: table schema object */ { ST_SCHEMA_TABLE* schema; DBUG_ENTER("innodb_sys_foreign_cols_init"); schema = (ST_SCHEMA_TABLE*) p; schema->fields_info = innodb_sys_foreign_cols_fields_info; schema->fill_table = i_s_sys_foreign_cols_fill_table; DBUG_RETURN(0); } UNIV_INTERN struct st_mysql_plugin i_s_innodb_sys_foreign_cols = { /* the plugin type (a MYSQL_XXX_PLUGIN value) */ /* int */ STRUCT_FLD(type, MYSQL_INFORMATION_SCHEMA_PLUGIN), /* pointer to type-specific plugin descriptor */ /* void* */ STRUCT_FLD(info, &i_s_info), /* plugin name */ /* const char* */ STRUCT_FLD(name, "INNODB_SYS_FOREIGN_COLS"), /* plugin author (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(author, plugin_author), /* general descriptive text (for SHOW PLUGINS) */ /* const char* */ STRUCT_FLD(descr, "InnoDB SYS_FOREIGN_COLS"), /* the plugin license (PLUGIN_LICENSE_XXX) */ /* int */ STRUCT_FLD(license, PLUGIN_LICENSE_GPL), /* the function to invoke when plugin is loaded */ /* int (*)(void*); */ STRUCT_FLD(init, innodb_sys_foreign_cols_init), /* the function to invoke when plugin is unloaded */ /* int (*)(void*); */ STRUCT_FLD(deinit, i_s_common_deinit), /* plugin version (for SHOW PLUGINS) */ /* unsigned int */ STRUCT_FLD(version, INNODB_VERSION_SHORT), /* struct st_mysql_show_var* */ STRUCT_FLD(status_vars, NULL), /* struct st_mysql_sys_var** */ STRUCT_FLD(system_vars, NULL), /* reserved for dependency checking */ /* void* */ STRUCT_FLD(__reserved1, NULL) };