diff options
Diffstat (limited to 'storage/innobase/include/row0mysql.h')
| -rw-r--r-- | storage/innobase/include/row0mysql.h | 420 |
1 files changed, 247 insertions, 173 deletions
diff --git a/storage/innobase/include/row0mysql.h b/storage/innobase/include/row0mysql.h index 71e3b9bb19e..2d508c1a7df 100644 --- a/storage/innobase/include/row0mysql.h +++ b/storage/innobase/include/row0mysql.h @@ -27,7 +27,8 @@ Created 9/17/2000 Heikki Tuuri #ifndef row0mysql_h #define row0mysql_h -#include "univ.i" +#include "ha_prototypes.h" + #include "data0data.h" #include "que0types.h" #include "dict0types.h" @@ -36,6 +37,7 @@ Created 9/17/2000 Heikki Tuuri #include "btr0pcur.h" #include "trx0types.h" #include "fil0crypt.h" +#include "sess0sess.h" // Forward declaration struct SysIndexCallback; @@ -46,7 +48,6 @@ struct row_prebuilt_t; /*******************************************************************//** Frees the blob heap in prebuilt when no longer needed. */ -UNIV_INTERN void row_mysql_prebuilt_free_blob_heap( /*==============================*/ @@ -57,7 +58,6 @@ Stores a >= 5.0.3 format true VARCHAR length to dest, in the MySQL row format. @return pointer to the data, we skip the 1 or 2 bytes at the start that are used to store the len */ -UNIV_INTERN byte* row_mysql_store_true_var_len( /*=========================*/ @@ -69,7 +69,6 @@ Reads a >= 5.0.3 format true VARCHAR length, in the MySQL row format, and returns a pointer to the data. @return pointer to the data, we skip the 1 or 2 bytes at the start that are used to store the len */ -UNIV_INTERN const byte* row_mysql_read_true_varchar( /*========================*/ @@ -79,7 +78,6 @@ row_mysql_read_true_varchar( or 2 bytes */ /*******************************************************************//** Stores a reference to a BLOB in the MySQL format. */ -UNIV_INTERN void row_mysql_store_blob_ref( /*=====================*/ @@ -96,8 +94,7 @@ row_mysql_store_blob_ref( header! */ /*******************************************************************//** Reads a reference to a BLOB in the MySQL format. -@return pointer to BLOB data */ -UNIV_INTERN +@return pointer to BLOB data */ const byte* row_mysql_read_blob_ref( /*====================*/ @@ -106,9 +103,36 @@ row_mysql_read_blob_ref( MySQL format */ ulint col_len); /*!< in: BLOB reference length (not BLOB length) */ +/*******************************************************************//** +Converts InnoDB geometry data format to MySQL data format. */ +void +row_mysql_store_geometry( +/*=====================*/ + byte* dest, /*!< in/out: where to store */ + ulint dest_len, /*!< in: dest buffer size: determines into + how many bytes the geometry length is stored, + the space for the length may vary from 1 + to 4 bytes */ + const byte* src, /*!< in: geometry data; if the value to store + is SQL NULL this should be NULL pointer */ + ulint src_len); /*!< in: geometry length; if the value to store + is SQL NULL this should be 0; remember + also to set the NULL bit in the MySQL record + header! */ +/*******************************************************************//** +Reads a reference to a geometry data in the MySQL format. +@return pointer to geometry data */ +const byte* +row_mysql_read_geometry( +/*====================*/ + ulint* len, /*!< out: geometry data length */ + const byte* ref, /*!< in: reference in the + MySQL format */ + ulint col_len) /*!< in: BLOB reference length + (not BLOB length) */ + MY_ATTRIBUTE((nonnull(1,2), warn_unused_result)); /**************************************************************//** Pad a column with spaces. */ -UNIV_INTERN void row_mysql_pad_col( /*==============*/ @@ -121,8 +145,7 @@ row_mysql_pad_col( Stores a non-SQL-NULL field given in the MySQL format in the InnoDB format. The counterpart of this function is row_sel_field_store_in_mysql_format() in row0sel.cc. -@return up to which byte we used buf in the conversion */ -UNIV_INTERN +@return up to which byte we used buf in the conversion */ byte* row_mysql_store_col_in_innobase_format( /*===================================*/ @@ -158,7 +181,6 @@ row_mysql_store_col_in_innobase_format( Handles user errors and lock waits detected by the database engine. @return true if it was a lock wait and we should continue running the query thread */ -UNIV_INTERN bool row_mysql_handle_errors( /*====================*/ @@ -171,8 +193,7 @@ row_mysql_handle_errors( MY_ATTRIBUTE((nonnull(1,2))); /********************************************************************//** Create a prebuilt struct for a MySQL table handle. -@return own: a prebuilt struct */ -UNIV_INTERN +@return own: a prebuilt struct */ row_prebuilt_t* row_create_prebuilt( /*================*/ @@ -181,7 +202,6 @@ row_create_prebuilt( the MySQL format */ /********************************************************************//** Free a prebuilt struct for a MySQL table handle. */ -UNIV_INTERN void row_prebuilt_free( /*==============*/ @@ -190,7 +210,6 @@ row_prebuilt_free( /*********************************************************************//** Updates the transaction pointers in query graphs stored in the prebuilt struct. */ -UNIV_INTERN void row_update_prebuilt_trx( /*====================*/ @@ -203,18 +222,17 @@ AUTO_INC lock gives exclusive access to the auto-inc counter of the table. The lock is reserved only for the duration of an SQL statement. It is not compatible with another AUTO_INC or exclusive lock on the table. -@return error code or DB_SUCCESS */ -UNIV_INTERN +@return error code or DB_SUCCESS */ dberr_t row_lock_table_autoinc_for_mysql( /*=============================*/ row_prebuilt_t* prebuilt) /*!< in: prebuilt struct in the MySQL table handle */ MY_ATTRIBUTE((nonnull, warn_unused_result)); + /*********************************************************************//** Sets a table lock on the table mentioned in prebuilt. -@return error code or DB_SUCCESS */ -UNIV_INTERN +@return error code or DB_SUCCESS */ dberr_t row_lock_table_for_mysql( /*=====================*/ @@ -227,20 +245,19 @@ row_lock_table_for_mysql( ulint mode) /*!< in: lock mode of table (ignored if table==NULL) */ MY_ATTRIBUTE((nonnull(1))); -/*********************************************************************//** -Does an insert for MySQL. -@return error code or DB_SUCCESS */ -UNIV_INTERN + +/** Does an insert for MySQL. +@param[in] mysql_rec row in the MySQL format +@param[in,out] prebuilt prebuilt struct in MySQL handle +@return error code or DB_SUCCESS*/ dberr_t row_insert_for_mysql( -/*=================*/ - byte* mysql_rec, /*!< in: row in the MySQL format */ - row_prebuilt_t* prebuilt) /*!< in: prebuilt struct in MySQL - handle */ - MY_ATTRIBUTE((nonnull, warn_unused_result)); + const byte* mysql_rec, + row_prebuilt_t* prebuilt) + MY_ATTRIBUTE((warn_unused_result)); + /*********************************************************************//** Builds a dummy query graph used in selects. */ -UNIV_INTERN void row_prebuild_sel_graph( /*===================*/ @@ -250,8 +267,7 @@ row_prebuild_sel_graph( Gets pointer to a prebuilt update vector used in updates. If the update graph has not yet been built in the prebuilt struct, then this function first builds it. -@return prebuilt update vector */ -UNIV_INTERN +@return prebuilt update vector */ upd_t* row_get_prebuilt_update_vector( /*===========================*/ @@ -260,50 +276,52 @@ row_get_prebuilt_update_vector( /*********************************************************************//** Checks if a table is such that we automatically created a clustered index on it (on row id). -@return TRUE if the clustered index was generated automatically */ -UNIV_INTERN +@return TRUE if the clustered index was generated automatically */ ibool row_table_got_default_clust_index( /*==============================*/ const dict_table_t* table); /*!< in: table */ -/*********************************************************************//** -Does an update or delete of a row for MySQL. -@return error code or DB_SUCCESS */ -UNIV_INTERN + +/** Does an update or delete of a row for MySQL. +@param[in] mysql_rec row in the MySQL format +@param[in,out] prebuilt prebuilt struct in MySQL handle +@return error code or DB_SUCCESS */ dberr_t row_update_for_mysql( -/*=================*/ - byte* mysql_rec, /*!< in: the row to be updated, in - the MySQL format */ - row_prebuilt_t* prebuilt) /*!< in: prebuilt struct in MySQL - handle */ - MY_ATTRIBUTE((nonnull, warn_unused_result)); -/*********************************************************************//** -This can only be used when srv_locks_unsafe_for_binlog is TRUE or this + const byte* mysql_rec, + row_prebuilt_t* prebuilt) + MY_ATTRIBUTE((warn_unused_result)); + +/** Delete all rows for the given table by freeing/truncating indexes. +@param[in,out] table table handler +@return error code or DB_SUCCESS */ +dberr_t +row_delete_all_rows( + dict_table_t* table) + MY_ATTRIBUTE((warn_unused_result)); + +/** This can only be used when srv_locks_unsafe_for_binlog is TRUE or this session is using a READ COMMITTED or READ UNCOMMITTED isolation level. Before calling this function row_search_for_mysql() must have initialized prebuilt->new_rec_locks to store the information which new record locks really were set. This function removes a newly set clustered index record lock under prebuilt->pcur or prebuilt->clust_pcur. Thus, this implements a 'mini-rollback' that -releases the latest clustered index record lock we set. */ -UNIV_INTERN +releases the latest clustered index record lock we set. +@param[in,out] prebuilt prebuilt struct in MySQL handle +@param[in] has_latches_on_recs TRUE if called so that we have the + latches on the records under pcur + and clust_pcur, and we do not need + to reposition the cursors. */ void row_unlock_for_mysql( -/*=================*/ - row_prebuilt_t* prebuilt, /*!< in/out: prebuilt struct in MySQL - handle */ - ibool has_latches_on_recs)/*!< in: TRUE if called - so that we have the latches on - the records under pcur and - clust_pcur, and we do not need - to reposition the cursors. */ - MY_ATTRIBUTE((nonnull)); + row_prebuilt_t* prebuilt, + ibool has_latches_on_recs); + /*********************************************************************//** Checks if a table name contains the string "/#sql" which denotes temporary tables in MySQL. @return true if temporary table */ -UNIV_INTERN bool row_is_mysql_tmp_table_name( /*========================*/ @@ -314,29 +332,15 @@ row_is_mysql_tmp_table_name( /*********************************************************************//** Creates an query graph node of 'update' type to be used in the MySQL interface. -@return own: update node */ -UNIV_INTERN +@return own: update node */ upd_node_t* row_create_update_node_for_mysql( /*=============================*/ dict_table_t* table, /*!< in: table to update */ mem_heap_t* heap); /*!< in: mem heap from which allocated */ -/**********************************************************************//** -Does a cascaded delete or set null in a foreign key operation. -@return error code or DB_SUCCESS */ -UNIV_INTERN -dberr_t -row_update_cascade_for_mysql( -/*=========================*/ - que_thr_t* thr, /*!< in: query thread */ - upd_node_t* node, /*!< in: update node used in the cascade - or set null operation */ - dict_table_t* table) /*!< in: table where we do the operation */ - MY_ATTRIBUTE((nonnull, warn_unused_result)); /*********************************************************************//** Locks the data dictionary exclusively for performing a table create or other data dictionary modification operation. */ -UNIV_INTERN void row_mysql_lock_data_dictionary_func( /*================================*/ @@ -347,7 +351,6 @@ row_mysql_lock_data_dictionary_func( row_mysql_lock_data_dictionary_func(trx, __FILE__, __LINE__) /*********************************************************************//** Unlocks the data dictionary exclusive lock. */ -UNIV_INTERN void row_mysql_unlock_data_dictionary( /*=============================*/ @@ -355,7 +358,6 @@ row_mysql_unlock_data_dictionary( /*********************************************************************//** Locks the data dictionary in shared mode from modifications, for performing foreign key check, rollback, or other operation invisible to MySQL. */ -UNIV_INTERN void row_mysql_freeze_data_dictionary_func( /*==================================*/ @@ -366,50 +368,48 @@ row_mysql_freeze_data_dictionary_func( row_mysql_freeze_data_dictionary_func(trx, __FILE__, __LINE__) /*********************************************************************//** Unlocks the data dictionary shared lock. */ -UNIV_INTERN void row_mysql_unfreeze_data_dictionary( /*===============================*/ trx_t* trx); /*!< in/out: transaction */ /*********************************************************************//** -Creates a table for MySQL. If the name of the table ends in -one of "innodb_monitor", "innodb_lock_monitor", "innodb_tablespace_monitor", -"innodb_table_monitor", then this will also start the printing of monitor -output by the master thread. If the table name ends in "innodb_mem_validate", -InnoDB will try to invoke mem_validate(). On failure the transaction will -be rolled back. -@return error code or DB_SUCCESS */ -UNIV_INTERN +Creates a table for MySQL. On failure the transaction will be rolled back +and the 'table' object will be freed. +@return error code or DB_SUCCESS */ dberr_t row_create_table_for_mysql( /*=======================*/ dict_table_t* table, /*!< in, own: table definition (will be freed, or on DB_SUCCESS added to the data dictionary cache) */ + const char* compression, + /*!< in: compression algorithm to use, + can be NULL */ trx_t* trx, /*!< in/out: transaction */ bool commit, /*!< in: if true, commit the transaction */ fil_encryption_t mode, /*!< in: encryption mode */ ulint key_id) /*!< in: encryption key_id */ - __attribute__((nonnull, warn_unused_result)); + MY_ATTRIBUTE((warn_unused_result)); + /*********************************************************************//** Does an index creation operation for MySQL. TODO: currently failure to create an index results in dropping the whole table! This is no problem currently as all indexes must be created at the same time as the table. -@return error number or DB_SUCCESS */ -UNIV_INTERN +@return error number or DB_SUCCESS */ dberr_t row_create_index_for_mysql( /*=======================*/ dict_index_t* index, /*!< in, own: index definition (will be freed) */ trx_t* trx, /*!< in: transaction handle */ - const ulint* field_lengths) /*!< in: if not NULL, must contain + const ulint* field_lengths, /*!< in: if not NULL, must contain dict_index_get_n_fields(index) actual field lengths for the index columns, which are then checked for not being too large. */ - MY_ATTRIBUTE((nonnull(1,2), warn_unused_result)); + dict_table_t* handler) /* ! in/out: table handler. */ + MY_ATTRIBUTE((warn_unused_result)); /*********************************************************************//** Scans a table create SQL string and adds to the data dictionary the foreign key constraints declared in the string. This function @@ -417,46 +417,50 @@ should be called after the indexes for a table have been created. Each foreign key constraint must be accompanied with indexes in bot participating tables. The indexes are allowed to contain more fields than mentioned in the constraint. -@return error code or DB_SUCCESS */ -UNIV_INTERN + +@param[in] trx transaction +@param[in] sql_string table create statement where + foreign keys are declared like: + FOREIGN KEY (a, b) REFERENCES table2(c, d), + table2 can be written also with the database + name before it: test.table2; the default + database id the database of parameter name +@param[in] sql_length length of sql_string +@param[in] name table full name in normalized form +@param[in] is_temp_table true if table is temporary +@param[in,out] handler table handler if table is intrinsic +@param[in] reject_fks if TRUE, fail with error code + DB_CANNOT_ADD_CONSTRAINT if any + foreign keys are found. +@return error code or DB_SUCCESS */ dberr_t row_table_add_foreign_constraints( -/*==============================*/ - trx_t* trx, /*!< in: transaction */ - const char* sql_string, /*!< in: table create statement where - foreign keys are declared like: - FOREIGN KEY (a, b) REFERENCES table2(c, d), - table2 can be written also with the - database name before it: test.table2 */ - size_t sql_length, /*!< in: length of sql_string */ - const char* name, /*!< in: table full name in the - normalized form - database_name/table_name */ - ibool reject_fks) /*!< in: if TRUE, fail with error - code DB_CANNOT_ADD_CONSTRAINT if - any foreign keys are found. */ - MY_ATTRIBUTE((nonnull, warn_unused_result)); + trx_t* trx, + const char* sql_string, + size_t sql_length, + const char* name, + ibool reject_fks) + MY_ATTRIBUTE((warn_unused_result)); + /*********************************************************************//** The master thread in srv0srv.cc calls this regularly to drop tables which we must drop in background after queries to them have ended. Such lazy dropping of tables is needed in ALTER TABLE on Unix. -@return how many tables dropped + remaining tables in list */ -UNIV_INTERN +@return how many tables dropped + remaining tables in list */ ulint row_drop_tables_for_mysql_in_background(void); /*=========================================*/ /*********************************************************************//** Get the background drop list length. NOTE: the caller must own the kernel mutex! -@return how many tables in list */ -UNIV_INTERN +@return how many tables in list */ ulint row_get_background_drop_list_len_low(void); /*======================================*/ + /*********************************************************************//** Sets an exclusive lock on a table. -@return error code or DB_SUCCESS */ -UNIV_INTERN +@return error code or DB_SUCCESS */ dberr_t row_mysql_lock_table( /*=================*/ @@ -468,8 +472,7 @@ row_mysql_lock_table( /*********************************************************************//** Truncates a table for MySQL. -@return error code or DB_SUCCESS */ -UNIV_INTERN +@return error code or DB_SUCCESS */ dberr_t row_truncate_table_for_mysql( /*=========================*/ @@ -477,14 +480,10 @@ row_truncate_table_for_mysql( trx_t* trx) /*!< in: transaction handle */ MY_ATTRIBUTE((nonnull, warn_unused_result)); /*********************************************************************//** -Drops a table for MySQL. If the name of the dropped table ends in -one of "innodb_monitor", "innodb_lock_monitor", "innodb_tablespace_monitor", -"innodb_table_monitor", then this will also stop the printing of monitor -output by the master thread. If the data dictionary was not already locked +Drops a table for MySQL. If the data dictionary was not already locked by the transaction, the transaction will be committed. Otherwise, the data dictionary will remain locked. -@return error code or DB_SUCCESS */ -UNIV_INTERN +@return error code or DB_SUCCESS */ dberr_t row_drop_table_for_mysql( /*=====================*/ @@ -492,15 +491,15 @@ row_drop_table_for_mysql( trx_t* trx, /*!< in: dictionary transaction handle */ bool drop_db,/*!< in: true=dropping whole database */ ibool create_failed,/*!<in: TRUE=create table failed - because e.g. foreign key column - type mismatch. */ - bool nonatomic = true) + because e.g. foreign key column + type mismatch. */ + bool nonatomic = true, /*!< in: whether it is permitted to release and reacquire dict_operation_lock */ - MY_ATTRIBUTE((nonnull)); + dict_table_t* handler = NULL); + /*!< in/out: table handler. */ /*********************************************************************//** Drop all temporary tables during crash recovery. */ -UNIV_INTERN void row_mysql_drop_temp_tables(void); /*============================*/ @@ -509,8 +508,7 @@ row_mysql_drop_temp_tables(void); Discards the tablespace of a table which stored in an .ibd file. Discarding means that this function deletes the .ibd file and assigns a new table id for the table. Also the flag table->ibd_file_missing is set TRUE. -@return error code or DB_SUCCESS */ -UNIV_INTERN +@return error code or DB_SUCCESS */ dberr_t row_discard_tablespace_for_mysql( /*=============================*/ @@ -520,28 +518,28 @@ row_discard_tablespace_for_mysql( /*****************************************************************//** Imports a tablespace. The space id in the .ibd file must match the space id of the table in the data dictionary. -@return error code or DB_SUCCESS */ -UNIV_INTERN +@return error code or DB_SUCCESS */ dberr_t row_import_tablespace_for_mysql( /*============================*/ dict_table_t* table, /*!< in/out: table */ row_prebuilt_t* prebuilt) /*!< in: prebuilt struct in MySQL */ MY_ATTRIBUTE((nonnull, warn_unused_result)); -/*********************************************************************//** -Drops a database for MySQL. -@return error code or DB_SUCCESS */ -UNIV_INTERN + +/** Drop a database for MySQL. +@param[in] name database name which ends at '/' +@param[in] trx transaction handle +@param[out] found number of dropped tables/partitions +@return error code or DB_SUCCESS */ dberr_t row_drop_database_for_mysql( -/*========================*/ - const char* name, /*!< in: database name which ends to '/' */ - trx_t* trx) /*!< in: transaction handle */ - MY_ATTRIBUTE((nonnull)); + const char* name, + trx_t* trx, + ulint* found); + /*********************************************************************//** Renames a table for MySQL. -@return error code or DB_SUCCESS */ -UNIV_INTERN +@return error code or DB_SUCCESS */ dberr_t row_rename_table_for_mysql( /*=======================*/ @@ -550,49 +548,52 @@ row_rename_table_for_mysql( trx_t* trx, /*!< in/out: transaction */ bool commit) /*!< in: whether to commit trx */ MY_ATTRIBUTE((nonnull, warn_unused_result)); + +/** Renames a partitioned table for MySQL. +@param[in] old_name Old table name. +@param[in] new_name New table name. +@param[in,out] trx Transaction. +@return error code or DB_SUCCESS */ +dberr_t +row_rename_partitions_for_mysql( + const char* old_name, + const char* new_name, + trx_t* trx) + MY_ATTRIBUTE((nonnull, warn_unused_result)); + /*********************************************************************//** -Checks that the index contains entries in an ascending order, unique -constraint is not broken, and calculates the number of index entries +Scans an index for either COOUNT(*) or CHECK TABLE. +If CHECK TABLE; Checks that the index contains entries in an ascending order, +unique constraint is not broken, and calculates the number of index entries in the read view of the current transaction. -@return true if ok */ -UNIV_INTERN -bool -row_check_index_for_mysql( -/*======================*/ +@return DB_SUCCESS or other error */ +dberr_t +row_scan_index_for_mysql( +/*=====================*/ row_prebuilt_t* prebuilt, /*!< in: prebuilt struct in MySQL handle */ const dict_index_t* index, /*!< in: index */ + bool check_keys, /*!< in: true=check for mis- + ordered or duplicate records, + false=count the rows only */ ulint* n_rows) /*!< out: number of entries seen in the consistent read */ - MY_ATTRIBUTE((nonnull, warn_unused_result)); -/*********************************************************************//** -Determines if a table is a magic monitor table. -@return true if monitor table */ -UNIV_INTERN -bool -row_is_magic_monitor_table( -/*=======================*/ - const char* table_name) /*!< in: name of the table, in the - form database/table_name */ - MY_ATTRIBUTE((nonnull, warn_unused_result)); + MY_ATTRIBUTE((warn_unused_result)); /*********************************************************************//** Initialize this module */ -UNIV_INTERN void row_mysql_init(void); /*================*/ /*********************************************************************//** Close this module */ -UNIV_INTERN void row_mysql_close(void); /*=================*/ /*********************************************************************//** Reassigns the table identifier of a table. -@return error code or DB_SUCCESS */ -UNIV_INTERN +@return error code or DB_SUCCESS */ dberr_t row_mysql_table_id_reassign( /*========================*/ @@ -655,6 +656,7 @@ struct mysql_row_templ_t { ulint is_unsigned; /*!< if a column type is an integer type and this field is != 0, then it is an unsigned integer type */ + ulint is_virtual; /*!< if a column is a virtual column */ }; #define MYSQL_FETCH_CACHE_SIZE 8 @@ -680,10 +682,6 @@ struct row_prebuilt_t { an SQL statement: we may have to set an intention lock on the table, create a consistent read view etc. */ - unsigned mysql_has_locked:1;/*!< this is set TRUE when MySQL - calls external_lock on this handle - with a lock flag, and set FALSE when - with the F_UNLOCK flag */ unsigned clust_index_was_generated:1; /*!< if the user did not define a primary key in MySQL, then Innobase @@ -723,11 +721,18 @@ struct row_prebuilt_t { is set but we later optimize out the clustered index lookup */ unsigned templ_contains_blob:1;/*!< TRUE if the template contains - a column with DATA_BLOB == - get_innobase_type_from_mysql_type(); + a column with DATA_LARGE_MTYPE( + get_innobase_type_from_mysql_type()) + is TRUE; not to be confused with InnoDB externally stored columns (VARCHAR can be off-page too) */ + unsigned templ_contains_fixed_point:1;/*!< TRUE if the + template contains a column with + DATA_POINT. Since InnoDB regards + DATA_POINT as non-BLOB type, the + templ_contains_blob can't tell us + if there is DATA_POINT */ mysql_row_templ_t* mysql_template;/*!< template used to transform rows fast between MySQL and Innobase formats; memory for this template @@ -761,9 +766,9 @@ struct row_prebuilt_t { trx_id or n_indexes mismatch. */ que_fork_t* upd_graph; /*!< Innobase SQL query graph used in updates or deletes */ - btr_pcur_t pcur; /*!< persistent cursor used in selects + btr_pcur_t* pcur; /*!< persistent cursor used in selects and updates */ - btr_pcur_t clust_pcur; /*!< persistent cursor used in + btr_pcur_t* clust_pcur; /*!< persistent cursor used in some selects and updates */ que_fork_t* sel_graph; /*!< dummy query graph used in selects */ @@ -856,6 +861,8 @@ struct row_prebuilt_t { mem_heap_t* old_vers_heap; /*!< memory heap where a previous version is built in consistent read */ bool in_fts_query; /*!< Whether we are in a FTS query */ + bool fts_doc_id_in_read_set; /*!< true if table has externally + defined FTS_DOC_ID coulmn. */ /*----------------------*/ ulonglong autoinc_last_value; /*!< last value of AUTO-INC interval */ @@ -879,12 +886,22 @@ struct row_prebuilt_t { ulint idx_cond_n_cols;/*!< Number of fields in idx_cond_cols. 0 if and only if idx_cond == NULL. */ /*----------------------*/ - ulint magic_n2; /*!< this should be the same as - magic_n */ - /*----------------------*/ unsigned innodb_api:1; /*!< whether this is a InnoDB API query */ const rec_t* innodb_api_rec; /*!< InnoDB API search result */ + /*----------------------*/ + + /*----------------------*/ + rtr_info_t* rtr_info; /*!< R-tree Search Info */ + /*----------------------*/ + + ulint magic_n2; /*!< this should be the same as + magic_n */ + + bool ins_sel_stmt; /*!< if true then ins_sel_statement. */ + + innodb_session_t* + session; /*!< InnoDB session handler. */ byte* srch_key_val1; /*!< buffer used in converting search key values from MySQL format to InnoDB format.*/ @@ -892,7 +909,17 @@ struct row_prebuilt_t { search key values from MySQL format to InnoDB format.*/ uint srch_key_val_len; /*!< Size of search key */ + /** Disable prefetch. */ + bool m_no_prefetch; + + /** Return materialized key for secondary index scan */ + bool m_read_virtual_key; + /** The MySQL table object */ + TABLE* m_mysql_table; + + /** limit value to avoid fts result overflow */ + ulonglong m_fts_limit; }; /** Callback for row_mysql_sys_index_iterate() */ @@ -900,11 +927,52 @@ struct SysIndexCallback { virtual ~SysIndexCallback() { } /** Callback method - @param mtr - current mini transaction - @param pcur - persistent cursor. */ + @param mtr current mini transaction + @param pcur persistent cursor. */ virtual void operator()(mtr_t* mtr, btr_pcur_t* pcur) throw() = 0; }; +/** Get the computed value by supplying the base column values. +@param[in,out] row the data row +@param[in] col virtual column +@param[in] index index on the virtual column +@param[in,out] local_heap heap memory for processing large data etc. +@param[in,out] heap memory heap that copies the actual index row +@param[in] ifield index field +@param[in] thd MySQL thread handle +@param[in,out] mysql_table mysql table object +@param[in] old_table during ALTER TABLE, this is the old table + or NULL. +@param[in] parent_update update vector for the parent row +@param[in] foreign foreign key information +@return the field filled with computed value */ +dfield_t* +innobase_get_computed_value( + const dtuple_t* row, + const dict_v_col_t* col, + const dict_index_t* index, + mem_heap_t** local_heap, + mem_heap_t* heap, + const dict_field_t* ifield, + THD* thd, + TABLE* mysql_table, + const dict_table_t* old_table, + upd_t* parent_update, + dict_foreign_t* foreign); + +/** Get the computed value by supplying the base column values. +@param[in,out] table the table whose virtual column template to be built */ +void +innobase_init_vc_templ( + dict_table_t* table); + +/** Change dbname and table name in table->vc_templ. +@param[in,out] table the table whose virtual column template +dbname and tbname to be renamed. */ +void +innobase_rename_vc_templ( + dict_table_t* table); + #define ROW_PREBUILT_FETCH_MAGIC_N 465765687 #define ROW_MYSQL_WHOLE_ROW 0 @@ -926,4 +994,10 @@ struct SysIndexCallback { #include "row0mysql.ic" #endif +#ifdef UNIV_DEBUG +/** Wait for the background drop list to become empty. */ +void +row_wait_for_background_drop_list_empty(); +#endif /* UNIV_DEBUG */ + #endif /* row0mysql.h */ |