My Project
|
#include <handler.h>
Public Types | |
enum | enum_range_scan_direction { RANGE_SCAN_ASC, RANGE_SCAN_DESC } |
enum | { NONE = 0, INDEX, RND } |
typedef ulonglong | Table_flags |
Public Member Functions | |
virtual void | unbind_psi () |
virtual void | rebind_psi () |
handler (handlerton *ht_arg, TABLE_SHARE *share_arg) | |
virtual handler * | clone (const char *name, MEM_ROOT *mem_root) |
void | init () |
int | ha_open (TABLE *table, const char *name, int mode, int test_if_locked) |
Open database-handler. | |
int | ha_close (void) |
int | ha_index_init (uint idx, bool sorted) |
int | ha_index_end () |
int | ha_rnd_init (bool scan) |
int | ha_rnd_end () |
int | ha_rnd_next (uchar *buf) |
int | ha_rnd_pos (uchar *buf, uchar *pos) |
int | ha_index_read_map (uchar *buf, const uchar *key, key_part_map keypart_map, enum ha_rkey_function find_flag) |
int | ha_index_read_last_map (uchar *buf, const uchar *key, key_part_map keypart_map) |
int | ha_index_read_idx_map (uchar *buf, uint index, const uchar *key, key_part_map keypart_map, enum ha_rkey_function find_flag) |
int | ha_index_next (uchar *buf) |
int | ha_index_prev (uchar *buf) |
int | ha_index_first (uchar *buf) |
int | ha_index_last (uchar *buf) |
int | ha_index_next_same (uchar *buf, const uchar *key, uint keylen) |
int | ha_index_read (uchar *buf, const uchar *key, uint key_len, enum ha_rkey_function find_flag) |
int | ha_index_read_last (uchar *buf, const uchar *key, uint key_len) |
int | ha_reset () |
Check handler usage and reset state of file to after 'open'. | |
int | ha_index_or_rnd_end () |
Table_flags | ha_table_flags () const |
int | ha_external_lock (THD *thd, int lock_type) |
int | ha_write_row (uchar *buf) |
int | ha_update_row (const uchar *old_data, uchar *new_data) |
int | ha_delete_row (const uchar *buf) |
void | ha_release_auto_increment () |
int | check_collation_compatibility () |
int | ha_check_for_upgrade (HA_CHECK_OPT *check_opt) |
int | ha_check (THD *thd, HA_CHECK_OPT *check_opt) |
int | ha_repair (THD *thd, HA_CHECK_OPT *check_opt) |
void | ha_start_bulk_insert (ha_rows rows) |
int | ha_end_bulk_insert () |
int | ha_bulk_update_row (const uchar *old_data, uchar *new_data, uint *dup_key_found) |
int | ha_delete_all_rows () |
int | ha_truncate () |
int | ha_reset_auto_increment (ulonglong value) |
int | ha_optimize (THD *thd, HA_CHECK_OPT *check_opt) |
int | ha_analyze (THD *thd, HA_CHECK_OPT *check_opt) |
bool | ha_check_and_repair (THD *thd) |
int | ha_disable_indexes (uint mode) |
int | ha_enable_indexes (uint mode) |
int | ha_discard_or_import_tablespace (my_bool discard) |
int | ha_rename_table (const char *from, const char *to) |
int | ha_delete_table (const char *name) |
void | ha_drop_table (const char *name) |
int | ha_create (const char *name, TABLE *form, HA_CREATE_INFO *info) |
int | ha_create_handler_files (const char *name, const char *old_name, int action_flag, HA_CREATE_INFO *info) |
int | ha_change_partitions (HA_CREATE_INFO *create_info, const char *path, ulonglong *const copied, ulonglong *const deleted, const uchar *pack_frm_data, size_t pack_frm_len) |
int | ha_drop_partitions (const char *path) |
int | ha_rename_partitions (const char *path) |
void | adjust_next_insert_id_after_explicit_value (ulonglong nr) |
int | update_auto_increment () |
virtual void | print_error (int error, myf errflag) |
virtual bool | get_error_message (int error, String *buf) |
uint | get_dup_key (int error) |
virtual bool | get_foreign_dup_key (char *child_table_name, uint child_table_name_len, char *child_key_name, uint child_key_name_len) |
virtual void | change_table_ptr (TABLE *table_arg, TABLE_SHARE *share) |
virtual double | scan_time () |
virtual double | read_time (uint index, uint ranges, ha_rows rows) |
virtual double | index_only_read_time (uint keynr, double records) |
virtual longlong | get_memory_buffer_size () const |
virtual ha_rows | multi_range_read_info_const (uint keyno, RANGE_SEQ_IF *seq, void *seq_init_param, uint n_ranges, uint *bufsz, uint *flags, Cost_estimate *cost) |
virtual ha_rows | multi_range_read_info (uint keyno, uint n_ranges, uint keys, uint *bufsz, uint *flags, Cost_estimate *cost) |
virtual int | multi_range_read_init (RANGE_SEQ_IF *seq, void *seq_init_param, uint n_ranges, uint mode, HANDLER_BUFFER *buf) |
virtual int | multi_range_read_next (char **range_info) |
virtual const key_map * | keys_to_use_for_scanning () |
bool | has_transactions () |
virtual uint | extra_rec_buf_length () const |
virtual bool | is_fatal_error (int error, uint flags) |
virtual ha_rows | records () |
virtual ha_rows | estimate_rows_upper_bound () |
virtual enum row_type | get_row_type () const |
virtual const char * | index_type (uint key_number) |
virtual void | column_bitmaps_signal () |
MySQL signal that it changed the column bitmap. | |
uint | get_index (void) const |
virtual bool | start_bulk_update () |
virtual bool | start_bulk_delete () |
virtual int | exec_bulk_update (uint *dup_key_found) |
virtual void | end_bulk_update () |
virtual int | end_bulk_delete () |
virtual int | read_range_first (const key_range *start_key, const key_range *end_key, bool eq_range, bool sorted) |
Read first row between two ranges. Store ranges for future calls to read_range_next. | |
virtual int | read_range_next () |
Read next row between two endpoints. | |
void | set_end_range (const key_range *range, enum_range_scan_direction direction) |
int | compare_key (key_range *range) |
int | compare_key_icp (const key_range *range) const |
virtual int | ft_init () |
void | ft_end () |
virtual FT_INFO * | ft_init_ext (uint flags, uint inx, String *key) |
virtual int | ft_read (uchar *buf) |
virtual int | rnd_pos_by_record (uchar *record) |
virtual int | read_first_row (uchar *buf, uint primary_key) |
virtual int | restart_rnd_next (uchar *buf, uchar *pos) |
virtual int | rnd_same (uchar *buf, uint inx) |
virtual ha_rows | records_in_range (uint inx, key_range *min_key, key_range *max_key) |
virtual void | position (const uchar *record)=0 |
virtual int | info (uint)=0 |
virtual void | get_dynamic_partition_info (PARTITION_STATS *stat_info, uint part_id) |
virtual uint32 | calculate_key_hash_value (Field **field_array) |
virtual int | extra (enum ha_extra_function operation) |
virtual int | extra_opt (enum ha_extra_function operation, ulong cache_size) |
virtual bool | start_read_removal (void) |
virtual ha_rows | end_read_removal (void) |
virtual bool | was_semi_consistent_read () |
virtual void | try_semi_consistent_read (bool) |
virtual void | unlock_row () |
virtual int | start_stmt (THD *thd, thr_lock_type lock_type) |
virtual void | get_auto_increment (ulonglong offset, ulonglong increment, ulonglong nb_desired_values, ulonglong *first_value, ulonglong *nb_reserved_values) |
void | set_next_insert_id (ulonglong id) |
void | restore_auto_increment (ulonglong prev_insert_id) |
virtual void | update_create_info (HA_CREATE_INFO *create_info) |
int | check_old_types () |
virtual int | assign_to_keycache (THD *thd, HA_CHECK_OPT *check_opt) |
virtual int | preload_keys (THD *thd, HA_CHECK_OPT *check_opt) |
virtual int | indexes_are_disabled (void) |
virtual char * | update_table_comment (const char *comment) |
virtual void | append_create_info (String *packet) |
virtual bool | is_fk_defined_on_table_or_index (uint index) |
virtual char * | get_foreign_key_create_info () |
virtual bool | can_switch_engines () |
virtual int | get_foreign_key_list (THD *thd, List< FOREIGN_KEY_INFO > *f_key_list) |
virtual int | get_parent_foreign_key_list (THD *thd, List< FOREIGN_KEY_INFO > *f_key_list) |
virtual uint | referenced_by_foreign_key () |
virtual void | init_table_handle_for_HANDLER () |
virtual void | free_foreign_key_create_info (char *str) |
virtual const char * | table_type () const =0 |
virtual const char ** | bas_ext () const =0 |
virtual int | get_default_no_partitions (HA_CREATE_INFO *info) |
virtual void | set_auto_partitions (partition_info *part_info) |
virtual bool | get_no_parts (const char *name, uint *no_parts) |
virtual void | set_part_info (partition_info *part_info, bool early) |
virtual ulong | index_flags (uint idx, uint part, bool all_parts) const =0 |
uint | max_record_length () const |
uint | max_keys () const |
uint | max_key_parts () const |
uint | max_key_length () const |
uint | max_key_part_length () const |
virtual uint | max_supported_record_length () const |
virtual uint | max_supported_keys () const |
virtual uint | max_supported_key_parts () const |
virtual uint | max_supported_key_length () const |
virtual uint | max_supported_key_part_length () const |
virtual uint | min_record_length (uint options) const |
virtual bool | low_byte_first () const |
virtual uint | checksum () const |
virtual bool | is_crashed () const |
virtual bool | auto_repair () const |
virtual uint | lock_count (void) const |
virtual THR_LOCK_DATA ** | store_lock (THD *thd, THR_LOCK_DATA **to, enum thr_lock_type lock_type)=0 |
virtual uint8 | table_cache_type () |
virtual my_bool | register_query_cache_table (THD *thd, char *table_key, uint key_length, qc_engine_callback *engine_callback, ulonglong *engine_data) |
Register a named table with a call back function to the query cache. | |
virtual bool | primary_key_is_clustered () |
virtual int | cmp_ref (const uchar *ref1, const uchar *ref2) |
virtual const Item * | cond_push (const Item *cond) |
virtual void | cond_pop () |
virtual Item * | idx_cond_push (uint keyno, Item *idx_cond) |
virtual void | cancel_pushed_idx_cond () |
virtual uint | number_of_pushed_joins () const |
virtual const TABLE * | root_of_pushed_join () const |
virtual const TABLE * | parent_of_pushed_join () const |
virtual int | index_read_pushed (uchar *buf, const uchar *key, key_part_map keypart_map) |
virtual int | index_next_pushed (uchar *buf) |
virtual bool | check_if_incompatible_data (HA_CREATE_INFO *create_info, uint table_changes) |
virtual enum_alter_inplace_result | check_if_supported_inplace_alter (TABLE *altered_table, Alter_inplace_info *ha_alter_info) |
bool | ha_prepare_inplace_alter_table (TABLE *altered_table, Alter_inplace_info *ha_alter_info) |
bool | ha_inplace_alter_table (TABLE *altered_table, Alter_inplace_info *ha_alter_info) |
bool | ha_commit_inplace_alter_table (TABLE *altered_table, Alter_inplace_info *ha_alter_info, bool commit) |
void | ha_notify_table_changed () |
virtual void | use_hidden_primary_key () |
virtual uint | alter_table_flags (uint flags) |
virtual int | bulk_update_row (const uchar *old_data, uchar *new_data, uint *dup_key_found) |
virtual int | delete_all_rows () |
virtual int | truncate () |
virtual int | reset_auto_increment (ulonglong value) |
virtual int | optimize (THD *thd, HA_CHECK_OPT *check_opt) |
virtual int | analyze (THD *thd, HA_CHECK_OPT *check_opt) |
virtual bool | check_and_repair (THD *thd) |
virtual int | disable_indexes (uint mode) |
virtual int | enable_indexes (uint mode) |
virtual int | discard_or_import_tablespace (my_bool discard) |
virtual void | drop_table (const char *name) |
virtual int | create (const char *name, TABLE *form, HA_CREATE_INFO *info)=0 |
virtual int | create_handler_files (const char *name, const char *old_name, int action_flag, HA_CREATE_INFO *info) |
virtual int | change_partitions (HA_CREATE_INFO *create_info, const char *path, ulonglong *const copied, ulonglong *const deleted, const uchar *pack_frm_data, size_t pack_frm_len) |
virtual int | drop_partitions (const char *path) |
virtual int | rename_partitions (const char *path) |
virtual bool | set_ha_share_ref (Handler_share **arg_ha_share) |
int | get_lock_type () const |
Public Attributes | |
handlerton * | ht |
uchar * | ref |
uchar * | dup_ref |
ha_statistics | stats |
range_seq_t | mrr_iter |
RANGE_SEQ_IF | mrr_funcs |
HANDLER_BUFFER * | multi_range_buffer |
uint | ranges_in_seq |
bool | mrr_is_output_sorted |
bool | mrr_have_range |
KEY_MULTI_RANGE | mrr_cur_range |
key_range * | end_range |
uint | errkey |
uint | key_used_on_scan |
uint | active_index |
uint | ref_length |
FT_INFO * | ft_handler |
enum handler:: { ... } | inited |
bool | implicit_emptied |
const Item * | pushed_cond |
Item * | pushed_idx_cond |
uint | pushed_idx_cond_keyno |
ulonglong | next_insert_id |
ulonglong | insert_id_for_cur_row |
Discrete_interval | auto_inc_interval_for_cur_row |
uint | auto_inc_intervals_count |
PSI_table * | m_psi |
Protected Member Functions | |
virtual int | index_read_map (uchar *buf, const uchar *key, key_part_map keypart_map, enum ha_rkey_function find_flag) |
Positions an index cursor to the index specified in the handle ('active_index'). Fetches the row if available. If the key value is null, begin at the first key of the index. | |
virtual int | index_read_idx_map (uchar *buf, uint index, const uchar *key, key_part_map keypart_map, enum ha_rkey_function find_flag) |
Positions an index cursor to the index specified in argument. Fetches the row if available. If the key value is null, begin at the first key of the index. | |
virtual int | index_next (uchar *buf) |
virtual int | index_prev (uchar *buf) |
virtual int | index_first (uchar *buf) |
virtual int | index_last (uchar *buf) |
virtual int | index_next_same (uchar *buf, const uchar *key, uint keylen) |
virtual int | index_read_last_map (uchar *buf, const uchar *key, key_part_map keypart_map) |
The following functions works like index_read, but it find the last row with the current key value or prefix. | |
virtual int | rnd_next (uchar *buf)=0 |
virtual int | rnd_pos (uchar *buf, uchar *pos)=0 |
virtual bool | prepare_inplace_alter_table (TABLE *altered_table, Alter_inplace_info *ha_alter_info) |
virtual bool | inplace_alter_table (TABLE *altered_table, Alter_inplace_info *ha_alter_info) |
virtual bool | commit_inplace_alter_table (TABLE *altered_table, Alter_inplace_info *ha_alter_info, bool commit) |
virtual void | notify_table_changed () |
void | ha_statistic_increment (ulonglong SSV::*offset) const |
void ** | ha_data (THD *) const |
THD * | ha_thd (void) const |
PSI_table_share * | ha_table_share_psi (const TABLE_SHARE *share) const |
virtual int | rename_table (const char *from, const char *to) |
virtual int | delete_table (const char *name) |
virtual int | index_read (uchar *buf, const uchar *key, uint key_len, enum ha_rkey_function find_flag) |
virtual int | index_read_last (uchar *buf, const uchar *key, uint key_len) |
Handler_share * | get_ha_share_ptr () |
void | set_ha_share_ptr (Handler_share *arg_ha_share) |
void | lock_shared_ha_data () |
void | unlock_shared_ha_data () |
Protected Attributes | |
TABLE_SHARE * | table_share |
TABLE * | table |
Table_flags | cached_table_flags |
ha_rows | estimation_rows_to_insert |
KEY_PART_INFO * | range_key_part |
bool | eq_range |
bool | in_range_check_pushed_down |
Friends | |
class | DsMrr_impl |
The handler class is the interface for dynamically loadable storage engines. Do not add ifdefs and take care when adding or changing virtual functions to avoid vtable confusion
Functions in this class accept and return table columns data. Two data representation formats are used: 1. TableRecordFormat - Used to pass [partial] table records to/from storage engine
2. KeyTupleFormat - used to pass index search tuples (aka "keys") to storage engine. See opt_range.cc for description of this format.
TableRecordFormat ================= [Warning: this description is work in progress and may be incomplete] The table record is stored in a fixed-size buffer:
record: null_bytes, column1_data, column2_data, ...
The offsets of the parts of the buffer are also fixed: every column has an offset to its column{i}_data, and if it is nullable it also has its own bit in null_bytes.
The record buffer only includes data about columns that are marked in the relevant column set (table->read_set and/or table->write_set, depending on the situation). <not-sure>It could be that it is required that null bits of non-present columns are set to 1</not-sure>
VARIOUS EXCEPTIONS AND SPECIAL CASES
f the table has no nullable columns, then null_bytes is still present, its length is one byte <not-sure> which must be set to 0xFF at all times. </not-sure>
If the table has columns of type BIT, then certain bits from those columns may be stored in null_bytes as well. Grep around for Field_bit for details.
For blob columns (see Field_blob), the record buffer stores length of the data, following by memory pointer to the blob data. The pointer is owned by the storage engine and is valid until the next operation.
If a blob column has NULL value, then its length and blob data pointer must be set to 0.
virtual const char** handler::bas_ext | ( | ) | const [pure virtual] |
If frm_error() is called then we will use this to find out what file extentions exist for the storage engine. This is also used by the default rename_table and delete_table method in handler.cc.
For engines that have two file name extentions (separate meta/index file and data file), the order of elements is relevant. First element of engine file name extentions array should be meta/index file extention. Second element - data file extention. This order is assumed by prepare_for_repair() when REPAIR TABLE ... USE_FRM is issued.
Implemented in ha_partition, ha_ndbcluster, and ha_ndbinfo.
virtual int handler::bulk_update_row | ( | const uchar * | old_data, |
uchar * | new_data, | ||
uint * | dup_key_found | ||
) | [inline, virtual] |
This method is similar to update_row, however the handler doesn't need to execute the updates at this point in time. The handler can be certain that another call to bulk_update_row will occur OR a call to exec_bulk_update before the set of updates in this query is concluded.
Note: If HA_ERR_FOUND_DUPP_KEY is returned, the handler must read all columns of the row so MySQL can create an error message. If the columns required for the error message are not read, the error message will contain garbage.
old_data | Old record |
new_data | New record |
dup_key_found | Number of duplicate keys found |
Reimplemented in ha_ndbcluster.
virtual bool handler::can_switch_engines | ( | ) | [inline, virtual] |
Used in ALTER TABLE to check if changing storage engine is allowed.
true | Changing storage engine is allowed. |
false | Changing storage engine not allowed. |
Reimplemented in ha_partition.
virtual void handler::cancel_pushed_idx_cond | ( | ) | [inline, virtual] |
Reset information about pushed index conditions
Check for incompatible collation changes.
HA_ADMIN_NEEDS_UPGRADE | Table may have data requiring upgrade. |
0 | No upgrade required. |
virtual bool handler::check_if_incompatible_data | ( | HA_CREATE_INFO * | create_info, |
uint | table_changes | ||
) | [inline, virtual] |
Part of old, deprecated in-place ALTER API.
Reimplemented in ha_partition.
enum_alter_inplace_result handler::check_if_supported_inplace_alter | ( | TABLE * | altered_table, |
Alter_inplace_info * | ha_alter_info | ||
) | [virtual] |
Check if a storage engine supports a particular alter table in-place
altered_table | TABLE object for new version of table. |
ha_alter_info | Structure describing changes to be done by ALTER TABLE and holding data used during in-place alter. |
HA_ALTER_ERROR | Unexpected error. |
HA_ALTER_INPLACE_NOT_SUPPORTED | Not supported, must use copy. |
HA_ALTER_INPLACE_EXCLUSIVE_LOCK | Supported, but requires X lock. |
HA_ALTER_INPLACE_SHARED_LOCK_AFTER_PREPARE | Supported, but requires SNW lock during main phase. Prepare phase requires X lock. |
HA_ALTER_INPLACE_SHARED_LOCK | Supported, but requires SNW lock. |
HA_ALTER_INPLACE_NO_LOCK_AFTER_PREPARE | Supported, concurrent reads/writes allowed. However, prepare phase requires X lock. |
HA_ALTER_INPLACE_NO_LOCK | Supported, concurrent reads/writes allowed. |
Reimplemented in ha_partition.
void handler::column_bitmaps_signal | ( | ) | [virtual] |
MySQL signal that it changed the column bitmap.
Signal that the table->read_set and table->write_set table maps changed The handler is allowed to set additional bits in the above map in this call. Normally the handler should ignore all calls until we have done a ha_rnd_init() or ha_index_init(), write_row(), update_row or delete_row() as there may be several calls to this routine.
USAGE This is for handlers that needs to setup their own column bitmaps. Normally the handler should set up their own column bitmaps in index_init() or rnd_init() and in any column_bitmaps_signal() call after this.
The handler is allowd to do changes to the bitmap after a index_init or rnd_init() call is made as after this, MySQL will not use the bitmap for any program logic checking.
virtual bool handler::commit_inplace_alter_table | ( | TABLE * | altered_table, |
Alter_inplace_info * | ha_alter_info, | ||
bool | commit | ||
) | [inline, protected, virtual] |
Commit or rollback the changes made during prepare_inplace_alter_table() and inplace_alter_table() inside the storage engine. Note that in case of rollback the allowed level of concurrency during this operation will be the same as for inplace_alter_table() and thus might be higher than during prepare_inplace_alter_table(). (For example, concurrent writes were blocked during prepare, but might not be during rollback).
altered_table | TABLE object for new version of table. |
ha_alter_info | Structure describing changes to be done by ALTER TABLE and holding data used during in-place alter. |
commit | True => Commit, False => Rollback. |
true | Error |
false | Success |
Reimplemented in ha_partition.
int handler::compare_key | ( | key_range * | range | ) |
virtual void handler::cond_pop | ( | ) | [inline, virtual] |
Pop the top condition from the condition stack of the handler instance.
Pops the top if condition stack, if stack is not empty.
Reimplemented in ha_ndbcluster.
virtual const Item* handler::cond_push | ( | const Item * | cond | ) | [inline, virtual] |
Push condition down to the table handler.
cond | Condition to be pushed. The condition tree must not be modified by the by the caller. |
handler->ha_reset() call empties the condition stack. Calls to rnd_init/rnd_end, index_init/index_end etc do not affect the condition stack.
Reimplemented in ha_ndbcluster.
virtual int handler::delete_all_rows | ( | void | ) | [inline, virtual] |
This is called to delete all rows in a table If the handler don't support this, then this function will return HA_ERR_WRONG_COMMAND and MySQL will delete the rows one by one.
Reimplemented in ha_partition.
int handler::delete_table | ( | const char * | name | ) | [protected, virtual] |
Delete a table in the engine. Called for base as well as temporary tables.
Delete all files with extension from bas_ext().
name | Base name of table |
0 | If we successfully deleted at least one file from base_ext and didn't get any other errors than ENOENT |
!0 | Error |
Reimplemented in ha_ndbcluster, and ha_partition.
virtual int handler::end_bulk_delete | ( | ) | [inline, virtual] |
Execute all outstanding deletes and close down the bulk delete.
0 | Success |
>0 | Error code |
virtual void handler::end_bulk_update | ( | ) | [inline, virtual] |
Perform any needed clean-up, no outstanding updates are there at the moment.
Reimplemented in ha_ndbcluster.
virtual ha_rows handler::end_read_removal | ( | void | ) | [inline, virtual] |
End read (before write) removal and return the number of rows really written
Reimplemented in ha_ndbcluster.
virtual ha_rows handler::estimate_rows_upper_bound | ( | ) | [inline, virtual] |
Return upper bound of current number of records in the table (max. of how many records one will retrieve when doing a full table scan) If upper bound is not known, HA_POS_ERROR should be returned as a max possible upper bound.
Reimplemented in ha_partition, and ha_ndbcluster.
virtual int handler::exec_bulk_update | ( | uint * | dup_key_found | ) | [inline, virtual] |
After this call all outstanding updates must be performed. The number of duplicate key errors are reported in the duplicate key parameter. It is allowed to continue to the batched update after this call, the handler has to wait until end_bulk_update with changing state.
dup_key_found | Number of duplicate keys found |
0 | Success |
>0 | Error code |
Reimplemented in ha_ndbcluster.
void handler::get_auto_increment | ( | ulonglong | offset, |
ulonglong | increment, | ||
ulonglong | nb_desired_values, | ||
ulonglong * | first_value, | ||
ulonglong * | nb_reserved_values | ||
) | [virtual] |
Reserves an interval of auto_increment values from the handler.
offset | offset (modulus increment) | |
increment | increment between calls | |
nb_desired_values | how many values we want | |
[out] | first_value | the first value reserved by the handler |
[out] | nb_reserved_values | how many values the handler reserved |
offset and increment means that we want values to be of the form offset + N * increment, where N>=0 is integer. If the function sets *first_value to ULONGLONG_MAX it means an error. If the function sets *nb_reserved_values to ULONGLONG_MAX it means it has reserved to "positive infinite".
Reimplemented in ha_partition.
uint handler::get_dup_key | ( | int | error | ) |
bool handler::get_error_message | ( | int | error, |
String * | buf | ||
) | [virtual] |
Return an error message specific to this handler.
error | error code previously returned by handler |
buf | pointer to String where to add error message |
Reimplemented in ha_partition, ha_ndbcluster, and ha_ndbinfo.
virtual bool handler::get_foreign_dup_key | ( | char * | child_table_name, |
uint | child_table_name_len, | ||
char * | child_key_name, | ||
uint | child_key_name_len | ||
) | [inline, virtual] |
Retrieves the names of the table and the key for which there was a duplicate entry in the case of HA_ERR_FOREIGN_DUPLICATE_KEY.
If any of the table or key name is not available this method will return false and will not change any of child_table_name or child_key_name.
child_table_name[out] | Table name |
child_table_name_len[in] | Table name buffer size |
child_key_name[out] | Key name |
child_key_name_len[in] | Key name buffer size |
true | table and key names were available and were written into the corresponding out parameters. |
false | table and key names were not available, the out parameters were not touched. |
virtual int handler::get_foreign_key_list | ( | THD * | thd, |
List< FOREIGN_KEY_INFO > * | f_key_list | ||
) | [inline, virtual] |
Get the list of foreign keys in this table.
thd | The thread handle. |
f_key_list[out] | The list of foreign keys. |
Handler_share * handler::get_ha_share_ptr | ( | ) | [protected] |
Get an initialized ha_share.
NULL | ha_share is not yet initialized. |
!= | NULL previous initialized ha_share. |
virtual longlong handler::get_memory_buffer_size | ( | ) | const [inline, virtual] |
Return an estimate on the amount of memory the storage engine will use for caching data in memory. If this is unknown or the storage engine does not cache data in memory -1 is returned.
virtual bool handler::get_no_parts | ( | const char * | name, |
uint * | no_parts | ||
) | [inline, virtual] |
Get number of partitions for table in SE
name | normalized path(same as open) to the table | |
[out] | no_parts | Number of partitions |
false | for success |
true | for failure, for example table didn't exist in engine |
Reimplemented in ha_partition, and ha_ndbcluster.
virtual int handler::get_parent_foreign_key_list | ( | THD * | thd, |
List< FOREIGN_KEY_INFO > * | f_key_list | ||
) | [inline, virtual] |
Get the list of foreign keys referencing this table.
thd | The thread handle. |
f_key_list[out] | The list of foreign keys. |
virtual enum row_type handler::get_row_type | ( | ) | const [inline, virtual] |
Get the row type from the storage engine. If this method returns ROW_TYPE_NOT_USED, the information in HA_CREATE_INFO should be used.
Reimplemented in ha_partition.
int handler::ha_analyze | ( | THD * | thd, |
HA_CHECK_OPT * | check_opt | ||
) |
Analyze table: public interface.
int handler::ha_bulk_update_row | ( | const uchar * | old_data, |
uchar * | new_data, | ||
uint * | dup_key_found | ||
) |
Bulk update row: public interface.
int handler::ha_change_partitions | ( | HA_CREATE_INFO * | create_info, |
const char * | path, | ||
ulonglong *const | copied, | ||
ulonglong *const | deleted, | ||
const uchar * | pack_frm_data, | ||
size_t | pack_frm_len | ||
) |
Change partitions: public interface.
int handler::ha_check | ( | THD * | thd, |
HA_CHECK_OPT * | check_opt | ||
) |
to be actually called to get 'check()' functionality
Performs checks upon the table.
thd | thread doing CHECK TABLE operation |
check_opt | options from the parser |
HA_ADMIN_OK | Successful upgrade |
HA_ADMIN_NEEDS_UPGRADE | Table has structures requiring upgrade |
HA_ADMIN_NEEDS_ALTER | Table has structures requiring ALTER TABLE |
HA_ADMIN_NOT_IMPLEMENTED |
bool handler::ha_check_and_repair | ( | THD * | thd | ) |
Check and repair table: public interface.
int handler::ha_close | ( | void | ) |
Close handler.
bool handler::ha_commit_inplace_alter_table | ( | TABLE * | altered_table, |
Alter_inplace_info * | ha_alter_info, | ||
bool | commit | ||
) |
Public function wrapping the actual handler call. Allows us to enforce asserts regardless of handler implementation.
int handler::ha_create | ( | const char * | name, |
TABLE * | form, | ||
HA_CREATE_INFO * | info | ||
) |
Create a table in the engine: public interface.
int handler::ha_create_handler_files | ( | const char * | name, |
const char * | old_name, | ||
int | action_flag, | ||
HA_CREATE_INFO * | info | ||
) |
Create handler files for CREATE TABLE: public interface.
int handler::ha_delete_all_rows | ( | ) |
Delete all rows: public interface.
int handler::ha_delete_table | ( | const char * | name | ) |
Delete table: public interface.
int handler::ha_disable_indexes | ( | uint | mode | ) |
Disable indexes: public interface.
int handler::ha_discard_or_import_tablespace | ( | my_bool | discard | ) |
Discard or import tablespace: public interface.
int handler::ha_drop_partitions | ( | const char * | path | ) |
Drop partitions: public interface.
void handler::ha_drop_table | ( | const char * | name | ) |
Drop table in the engine: public interface.
int handler::ha_enable_indexes | ( | uint | mode | ) |
Enable indexes: public interface.
int handler::ha_end_bulk_insert | ( | ) |
End bulk insert.
0 | Success |
!= | 0 Failure (error code returned) |
int handler::ha_external_lock | ( | THD * | thd, |
int | lock_type | ||
) |
These functions represent the public interface to *users* of the handler class, hence they are *not* virtual. For the inheritance interface, see the (private) functions write_row(), update_row(), and delete_row() below.
int handler::ha_index_end | ( | ) |
End use of index.
0 | Success |
!= | 0 Error (error code returned) |
int handler::ha_index_first | ( | uchar * | buf | ) |
Reads the first row via index.
[out] | buf | Row data |
0 | Success |
HA_ERR_END_OF_FILE | Row not found |
!= | 0 Error |
int handler::ha_index_init | ( | uint | idx, |
bool | sorted | ||
) |
Initialize use of index.
idx | Index to use |
sorted | Use sorted order |
0 | Success |
!= | 0 Error (error code returned) |
int handler::ha_index_last | ( | uchar * | buf | ) |
Reads the last row via index.
[out] | buf | Row data |
0 | Success |
HA_ERR_END_OF_FILE | Row not found |
!= | 0 Error |
int handler::ha_index_next | ( | uchar * | buf | ) |
Reads the next row via index.
[out] | buf | Row data |
0 | Success |
HA_ERR_END_OF_FILE | Row not found |
!= | 0 Error |
int handler::ha_index_next_same | ( | uchar * | buf, |
const uchar * | key, | ||
uint | keylen | ||
) |
Reads the next same row via index.
[out] | buf | Row data |
key | Key to search for | |
keylen | Length of key |
0 | Success |
HA_ERR_END_OF_FILE | Row not found |
!= | 0 Error |
int handler::ha_index_prev | ( | uchar * | buf | ) |
Reads the previous row via index.
[out] | buf | Row data |
0 | Success |
HA_ERR_END_OF_FILE | Row not found |
!= | 0 Error |
int handler::ha_index_read | ( | uchar * | buf, |
const uchar * | key, | ||
uint | key_len, | ||
enum ha_rkey_function | find_flag | ||
) |
Read one row via index.
[out] | buf | Row data |
key | Key to search for | |
keylen | Length of key | |
find_flag | Direction/condition on key usage |
0 | Success |
HA_ERR_END_OF_FILE | Row not found |
!= | 0 Error |
int handler::ha_index_read_idx_map | ( | uchar * | buf, |
uint | index, | ||
const uchar * | key, | ||
key_part_map | keypart_map, | ||
enum ha_rkey_function | find_flag | ||
) |
Initializes an index and read it.
int handler::ha_index_read_last | ( | uchar * | buf, |
const uchar * | key, | ||
uint | key_len | ||
) |
Reads the last row via index.
[out] | buf | Row data |
key | Key to search for | |
keylen | Length of key |
0 | Success |
HA_ERR_END_OF_FILE | Row not found |
!= | 0 Error |
int handler::ha_index_read_map | ( | uchar * | buf, |
const uchar * | key, | ||
key_part_map | keypart_map, | ||
enum ha_rkey_function | find_flag | ||
) |
Read [part of] row via [part of] index.
[out] | buf | buffer where store the data |
key | Key to search for | |
keypart_map | Which part of key to use | |
find_flag | Direction/condition on key usage |
0 | Success (found a record, and function has set table->status to 0) |
HA_ERR_END_OF_FILE | Row not found (function has set table->status to STATUS_NOT_FOUND) |
!= | 0 Error |
bool handler::ha_inplace_alter_table | ( | TABLE * | altered_table, |
Alter_inplace_info * | ha_alter_info | ||
) | [inline] |
Public function wrapping the actual handler call.
void handler::ha_notify_table_changed | ( | ) | [inline] |
Public function wrapping the actual handler call.
int handler::ha_open | ( | TABLE * | table_arg, |
const char * | name, | ||
int | mode, | ||
int | test_if_locked | ||
) |
Open database-handler.
IMPLEMENTATION Try O_RDONLY if cannot open as O_RDWR Don't wait for locks if not HA_OPEN_WAIT_IF_LOCKED is set
int handler::ha_optimize | ( | THD * | thd, |
HA_CHECK_OPT * | check_opt | ||
) |
Optimize table: public interface.
bool handler::ha_prepare_inplace_alter_table | ( | TABLE * | altered_table, |
Alter_inplace_info * | ha_alter_info | ||
) |
Public functions wrapping the actual handler call.
int handler::ha_rename_partitions | ( | const char * | path | ) |
Rename partitions: public interface.
int handler::ha_rename_table | ( | const char * | from, |
const char * | to | ||
) |
Rename table: public interface.
int handler::ha_repair | ( | THD * | thd, |
HA_CHECK_OPT * | check_opt | ||
) |
Repair table: public interface.
int handler::ha_reset | ( | ) |
Check handler usage and reset state of file to after 'open'.
int handler::ha_reset_auto_increment | ( | ulonglong | value | ) |
Reset auto increment: public interface.
int handler::ha_rnd_end | ( | ) |
End use of random access.
0 | Success |
!= | 0 Error (error code returned) |
int handler::ha_rnd_init | ( | bool | scan | ) |
Initialize table for random read or scan.
scan | if true: Initialize for random scans through rnd_next() if false: Initialize for random reads through rnd_pos() |
0 | Success |
!= | 0 Error (error code returned) |
int handler::ha_rnd_next | ( | uchar * | buf | ) |
Read next row via random scan.
buf | Buffer to read the row into |
0 | Success |
!= | 0 Error (error code returned) |
int handler::ha_rnd_pos | ( | uchar * | buf, |
uchar * | pos | ||
) |
Read row via random scan from position.
[out] | buf | Buffer to read the row into |
pos | Position from position() call |
0 | Success |
!= | 0 Error (error code returned) |
void handler::ha_start_bulk_insert | ( | ha_rows | rows | ) |
Start bulk insert.
Allow the handler to optimize for multiple row insert.
rows | Estimated rows to insert |
Table_flags handler::ha_table_flags | ( | ) | const [inline] |
The cached_table_flags is set at ha_open and ha_external_lock
PSI_table_share * handler::ha_table_share_psi | ( | const TABLE_SHARE * | share | ) | const [protected] |
Acquire the instrumented table information from a table share.
share | a table share |
int handler::ha_truncate | ( | ) |
Truncate table: public interface.
virtual Item* handler::idx_cond_push | ( | uint | keyno, |
Item * | idx_cond | ||
) | [inline, virtual] |
Push down an index condition to the handler.
The server will use this method to push down a condition it wants the handler to evaluate when retrieving records using a specified index. The pushed index condition will only refer to fields from this handler that is contained in the index (but it may also refer to fields in other handlers). Before the handler evaluates the condition it must read the content of the index entry into the record buffer.
The handler is free to decide if and how much of the condition it will take responsibility for evaluating. Based on this evaluation it should return the part of the condition it will not evaluate. If it decides to evaluate the entire condition it should return NULL. If it decides not to evaluate any part of the condition it should return a pointer to the same condition as given as argument.
keyno | the index number to evaluate the condition on |
idx_cond | the condition to be evaluated by the handler |
virtual int handler::index_first | ( | uchar * | buf | ) | [inline, protected, virtual] |
virtual int handler::index_last | ( | uchar * | buf | ) | [inline, protected, virtual] |
virtual int handler::index_next | ( | uchar * | buf | ) | [inline, protected, virtual] |
int handler::index_next_same | ( | uchar * | buf, |
const uchar * | key, | ||
uint | keylen | ||
) | [protected, virtual] |
double handler::index_only_read_time | ( | uint | keynr, |
double | records | ||
) | [virtual] |
Calculate cost of 'index only' scan for given index and number of records
keynr | Index number |
records | Estimated number of records to be retrieved |
virtual int handler::index_prev | ( | uchar * | buf | ) | [inline, protected, virtual] |
int handler::index_read_idx_map | ( | uchar * | buf, |
uint | index, | ||
const uchar * | key, | ||
key_part_map | keypart_map, | ||
enum ha_rkey_function | find_flag | ||
) | [protected, virtual] |
Positions an index cursor to the index specified in argument. Fetches the row if available. If the key value is null, begin at the first key of the index.
Reimplemented in ha_partition, and ha_ndbcluster.
virtual int handler::index_read_last_map | ( | uchar * | buf, |
const uchar * | key, | ||
key_part_map | keypart_map | ||
) | [inline, protected, virtual] |
The following functions works like index_read, but it find the last row with the current key value or prefix.
Reimplemented in ha_partition.
virtual int handler::index_read_map | ( | uchar * | buf, |
const uchar * | key, | ||
key_part_map | keypart_map, | ||
enum ha_rkey_function | find_flag | ||
) | [inline, protected, virtual] |
Positions an index cursor to the index specified in the handle ('active_index'). Fetches the row if available. If the key value is null, begin at the first key of the index.
Reimplemented in ha_partition.
void handler::init | ( | ) | [inline] |
This is called after create to allow us to set up cached variables
virtual bool handler::inplace_alter_table | ( | TABLE * | altered_table, |
Alter_inplace_info * | ha_alter_info | ||
) | [inline, protected, virtual] |
Alter the table structure in-place with operations specified using HA_ALTER_FLAGS and Alter_inplace_info. The level of concurrency allowed during this operation depends on the return value from check_if_supported_inplace_alter().
altered_table | TABLE object for new version of table. |
ha_alter_info | Structure describing changes to be done by ALTER TABLE and holding data used during in-place alter. |
true | Error |
false | Success |
Reimplemented in ha_partition.
virtual bool handler::is_fatal_error | ( | int | error, |
uint | flags | ||
) | [inline, virtual] |
This method is used to analyse the error to see whether the error is ignorable or not, certain handlers can have more error that are ignorable than others. E.g. the partition handler can get inserts into a range where there is no partition and this is an ignorable error. HA_ERR_FOUND_DUP_UNIQUE is a special case in MyISAM that means the same thing as HA_ERR_FOUND_DUP_KEY but can in some cases lead to a slightly different error message.
Reimplemented in ha_partition, and ha_ndbcluster.
virtual bool handler::is_fk_defined_on_table_or_index | ( | uint | index | ) | [inline, virtual] |
If index == MAX_KEY then a check for table is made and if index < MAX_KEY then a check is made if the table has foreign keys and if a foreign key uses this index (and thus the index cannot be dropped).
index | Index to check if foreign key uses it |
TRUE | Foreign key defined on table or index |
FALSE | No foreign key defined |
virtual uint handler::lock_count | ( | void | ) | const [inline, virtual] |
Reimplemented in ha_partition.
void handler::lock_shared_ha_data | ( | ) | [protected] |
Take a lock for protecting shared handler data.
ha_rows handler::multi_range_read_info | ( | uint | keyno, |
uint | n_ranges, | ||
uint | n_rows, | ||
uint * | bufsz, | ||
uint * | flags, | ||
Cost_estimate * | cost | ||
) | [virtual] |
Get cost and other information about MRR scan over some sequence of ranges
Calculate estimated cost and other information about an MRR scan for some sequence of ranges.
The ranges themselves will be known only at execution phase. When this function is called we only know number of ranges and a (rough) E(records) within those ranges.
Currently this function is only called for "n-keypart singlepoint" ranges, i.e. each range is "keypart1=someconst1 AND ... AND keypartN=someconstN"
The flags parameter is a combination of those flags: HA_MRR_SORTED, HA_MRR_INDEX_ONLY, HA_MRR_NO_ASSOCIATION, HA_MRR_LIMITS.
keyno | Index number |
n_ranges | Estimated number of ranges (i.e. intervals) in the range sequence. |
n_rows | Estimated total number of records contained within all of the ranges |
bufsz | INOUT IN: Size of the buffer available for use OUT: Size of the buffer that will be actually used, or 0 if buffer is not needed. |
flags | INOUT A combination of HA_MRR_* flags |
cost | OUT Estimated cost of MRR access |
0 | OK, *cost contains cost of the scan, *bufsz and *flags contain scan parameters. |
other | Error or can't perform the requested scan |
ha_rows handler::multi_range_read_info_const | ( | uint | keyno, |
RANGE_SEQ_IF * | seq, | ||
void * | seq_init_param, | ||
uint | n_ranges_arg, | ||
uint * | bufsz, | ||
uint * | flags, | ||
Cost_estimate * | cost | ||
) | [virtual] |
Get cost and other information about MRR scan over a known list of ranges
Calculate estimated cost and other information about an MRR scan for given sequence of ranges.
keyno | Index number |
seq | Range sequence to be traversed |
seq_init_param | First parameter for seq->init() |
n_ranges_arg | Number of ranges in the sequence, or 0 if the caller can't efficiently determine it |
bufsz | INOUT IN: Size of the buffer available for use OUT: Size of the buffer that is expected to be actually used, or 0 if buffer is not needed. |
flags | INOUT A combination of HA_MRR_* flags |
cost | OUT Estimated cost of MRR access |
HA_POS_ERROR | Error or the engine is unable to perform the requested scan. Values of OUT parameters are undefined. |
other | OK, *cost contains cost of the scan, *bufsz and *flags contain scan parameters. |
int handler::multi_range_read_init | ( | RANGE_SEQ_IF * | seq_funcs, |
void * | seq_init_param, | ||
uint | n_ranges, | ||
uint | mode, | ||
HANDLER_BUFFER * | buf | ||
) | [virtual] |
Initialize the MRR scan
Initialize the MRR scan. This function may do heavyweight scan initialization like row prefetching/sorting/etc (NOTE: but better not do it here as we may not need it, e.g. if we never satisfy WHERE clause on previous tables. For many implementations it would be natural to do such initializations in the first multi_read_range_next() call)
mode is a combination of the following flags: HA_MRR_SORTED, HA_MRR_INDEX_ONLY, HA_MRR_NO_ASSOCIATION
seq | Range sequence to be traversed |
seq_init_param | First parameter for seq->init() |
n_ranges | Number of ranges in the sequence |
mode | Flags, see the description section for the details |
buf | INOUT: memory buffer to be used |
Until WL#2623 is done (see its text, section 3.2), the following will also hold: The caller will guarantee that if "seq->init == mrr_ranges_array_init" then seq_init_param is an array of n_ranges KEY_MULTI_RANGE structures. This property will only be used by NDB handler until WL#2623 is done.
Buffer memory management is done according to the following scenario: The caller allocates the buffer and provides it to the callee by filling the members of HANDLER_BUFFER structure. The callee consumes all or some fraction of the provided buffer space, and sets the HANDLER_BUFFER members accordingly. The callee may use the buffer memory until the next multi_range_read_init() call is made, all records have been read, or until index_end() call is made, whichever comes first.
0 | OK |
1 | Error |
int handler::multi_range_read_next | ( | char ** | range_info | ) | [virtual] |
Get next record in MRR scan
Default MRR implementation: read the next record
range_info | OUT Undefined if HA_MRR_NO_ASSOCIATION flag is in effect Otherwise, the opaque value associated with the range that contains the returned record. |
0 | OK |
other | Error code |
void handler::notify_table_changed | ( | ) | [protected, virtual] |
Notify the storage engine that the table structure (.FRM) has been updated.
Reimplemented in ha_partition.
virtual uint handler::number_of_pushed_joins | ( | ) | const [inline, virtual] |
Reports #tables included in pushed join which this handler instance is part of. ==0 -> Not pushed
Reimplemented in ha_ndbcluster.
virtual const TABLE* handler::parent_of_pushed_join | ( | ) | const [inline, virtual] |
If this handler instance is a child in a pushed join sequence returned TABLE instance being my parent?
Reimplemented in ha_ndbcluster.
virtual bool handler::prepare_inplace_alter_table | ( | TABLE * | altered_table, |
Alter_inplace_info * | ha_alter_info | ||
) | [inline, protected, virtual] |
Allows the storage engine to update internal structures with concurrent writes blocked. If check_if_supported_inplace_alter() returns HA_ALTER_INPLACE_NO_LOCK_AFTER_PREPARE or HA_ALTER_INPLACE_SHARED_AFTER_PREPARE, this function is called with exclusive lock otherwise the same level of locking as for inplace_alter_table() will be used.
altered_table | TABLE object for new version of table. |
ha_alter_info | Structure describing changes to be done by ALTER TABLE and holding data used during in-place alter. |
true | Error |
false | Success |
Reimplemented in ha_partition.
void handler::print_error | ( | int | error, |
myf | errflag | ||
) | [virtual] |
Print error that we got from handler function.
Reimplemented in ha_partition, and ha_ndbcluster.
int handler::read_first_row | ( | uchar * | buf, |
uint | primary_key | ||
) | [virtual] |
Read first row (only) from a table.
This is never called for InnoDB tables, as these table types has the HA_STATS_RECORDS_IS_EXACT set.
Reimplemented in ha_ndbcluster.
int handler::read_range_first | ( | const key_range * | start_key, |
const key_range * | end_key, | ||
bool | eq_range_arg, | ||
bool | sorted | ||
) | [virtual] |
Read first row between two ranges. Store ranges for future calls to read_range_next.
start_key | Start key. Is 0 if no min range |
end_key | End key. Is 0 if no max range |
eq_range_arg | Set to 1 if start_key == end_key |
sorted | Set to 1 if result should be sorted per key |
0 | Found row |
HA_ERR_END_OF_FILE | No rows in range |
\:: | Error code |
Reimplemented in ha_partition, and ha_ndbcluster.
int handler::read_range_next | ( | ) | [virtual] |
Read next row between two endpoints.
0 | Found row |
HA_ERR_END_OF_FILE | No rows in range |
\:: | Error code |
Reimplemented in ha_partition, and ha_ndbcluster.
virtual double handler::read_time | ( | uint | index, |
uint | ranges, | ||
ha_rows | rows | ||
) | [inline, virtual] |
The cost of reading a set of ranges from the table using an index to access it.
index | The index number. |
ranges | The number of ranges to be read. |
rows | Total number of rows to be read. |
This method can be used to calculate the total cost of scanning a table using an index by calling it using read_time(index, 1, table_size).
Reimplemented in ha_partition.
virtual ha_rows handler::records | ( | ) | [inline, virtual] |
Number of rows in table. It will only be called if (table_flags() & (HA_HAS_RECORDS | HA_STATS_RECORDS_IS_EXACT)) != 0
Reimplemented in ha_partition, and ha_ndbcluster.
virtual my_bool handler::register_query_cache_table | ( | THD * | thd, |
char * | table_key, | ||
uint | key_length, | ||
qc_engine_callback * | engine_callback, | ||
ulonglong * | engine_data | ||
) | [inline, virtual] |
Register a named table with a call back function to the query cache.
thd | The thread handle | |
table_key | A pointer to the table name in the table cache | |
key_length | The length of the table name | |
[out] | engine_callback | The pointer to the storage engine call back function |
[out] | engine_data | Storage engine specific data which could be anything |
This method offers the storage engine, the possibility to store a reference to a table name which is going to be used with query cache. The method is called each time a statement is written to the cache and can be used to verify if a specific statement is cachable. It also offers the possibility to register a generic (but static) call back function which is called each time a statement is matched against the query cache.
TRUE | Success |
FALSE | The specified table or current statement should not be cached |
Reimplemented in ha_partition, and ha_ndbcluster.
int handler::rename_table | ( | const char * | from, |
const char * | to | ||
) | [protected, virtual] |
Default rename_table() and delete_table() rename/delete files with a given name and extensions from bas_ext().
These methods can be overridden, but their default implementation provide useful functionality.
Reimplemented in ha_ndbcluster, and ha_partition.
virtual int handler::reset_auto_increment | ( | ulonglong | value | ) | [inline, virtual] |
Reset the auto-increment counter to the given value, i.e. the next row inserted will get the given value. HA_ERR_WRONG_COMMAND is returned by storage engines that don't support this operation.
virtual int handler::restart_rnd_next | ( | uchar * | buf, |
uchar * | pos | ||
) | [inline, virtual] |
The following function is only needed for tables that may be temporary tables during joins.
virtual int handler::rnd_next | ( | uchar * | buf | ) | [protected, pure virtual] |
virtual int handler::rnd_pos | ( | uchar * | buf, |
uchar * | pos | ||
) | [protected, pure virtual] |
virtual int handler::rnd_pos_by_record | ( | uchar * | record | ) | [inline, virtual] |
This function only works for handlers having HA_PRIMARY_KEY_REQUIRED_FOR_POSITION set. It will return the row with the PK given in the record argument.
Reimplemented in ha_partition.
virtual const TABLE* handler::root_of_pushed_join | ( | ) | const [inline, virtual] |
If this handler instance is part of a pushed join sequence returned TABLE instance being root of the pushed query?
Reimplemented in ha_ndbcluster.
void handler::set_end_range | ( | const key_range * | range, |
enum_range_scan_direction | direction | ||
) |
Set the end position for a range scan. This is used for checking for when to end the range scan and by the ICP code to determine that the next record is within the current range.
range | The end value for the range scan |
direction | Direction of the range scan |
void handler::set_ha_share_ptr | ( | Handler_share * | arg_ha_share | ) | [protected] |
Set ha_share to be used by all instances of the same table/partition.
ha_share | Handler_share to be shared. |
virtual bool handler::start_bulk_delete | ( | ) | [inline, virtual] |
0 | Bulk delete used by handler |
1 | Bulk delete not used, normal operation used |
virtual bool handler::start_bulk_update | ( | ) | [inline, virtual] |
0 | Bulk update used by handler |
1 | Bulk update not used, normal operation used |
Reimplemented in ha_ndbcluster.
virtual bool handler::start_read_removal | ( | void | ) | [inline, virtual] |
Start read (before write) removal on the current table.
Reimplemented in ha_ndbcluster.
virtual THR_LOCK_DATA** handler::store_lock | ( | THD * | thd, |
THR_LOCK_DATA ** | to, | ||
enum thr_lock_type | lock_type | ||
) | [pure virtual] |
Is not invoked for non-transactional temporary tables.
Implemented in ha_partition, ha_ndbcluster, and ha_ndbinfo.
virtual uint8 handler::table_cache_type | ( | ) | [inline, virtual] |
Type of table for caching query
Reimplemented in ha_partition, ha_ndbcluster, and ha_ndbinfo.
virtual const char* handler::table_type | ( | ) | const [pure virtual] |
The following can be called without an open handler
Implemented in ha_partition, ha_ndbcluster, and ha_ndbinfo.
virtual int handler::truncate | ( | ) | [inline, virtual] |
Quickly remove all rows from a table.
Reimplemented in ha_partition.
virtual void handler::try_semi_consistent_read | ( | bool | ) | [inline, virtual] |
Tell the engine whether it should avoid unnecessary lock waits. If yes, in an UPDATE or DELETE, if the row under the cursor was locked by another transaction, the engine may try an optimistic read of the last committed row value under the cursor.
Reimplemented in ha_partition.
void handler::unlock_shared_ha_data | ( | ) | [protected] |
Release lock for protecting ha_share.
void handler::use_hidden_primary_key | ( | ) | [virtual] |
use_hidden_primary_key() is called in case of an update/delete when (table_flags() and HA_PRIMARY_KEY_REQUIRED_FOR_DELETE) is defined but we don't have a primary key
virtual bool handler::was_semi_consistent_read | ( | ) | [inline, virtual] |
In an UPDATE or DELETE, if the row under the cursor was locked by another transaction, and the engine used an optimistic read of the last committed row value under the cursor, then the engine returns 1 from this function. MySQL must NOT try to update this optimistic value. If the optimistic value does not match the WHERE condition, MySQL can decide to skip over this row. Currently only works for InnoDB. This can be used to avoid unnecessary lock waits.
If this method returns nonzero, it will also signal the storage engine that the next read will be a locking re-read of the row.
Reimplemented in ha_partition.
Interval returned by get_auto_increment() and being consumed by the inserter.
Number of reserved auto-increment intervals. Serves as a heuristic when we have no estimation of how many records the statement will insert: the more intervals we have reserved, the bigger the next one. Reset in handler::ha_release_auto_increment().
ulonglong handler::insert_id_for_cur_row |
insert id for the current row (*autogenerated*; if not autogenerated, it's 0). At first successful insertion, this variable is stored into THD::first_successful_insert_id_in_cur_stmt.
PSI_table* handler::m_psi |
Instrumented table associated with this handler. This member should be set to NULL when no instrumentation is in place, so that linking an instrumented/non instrumented server/plugin works. For example:
ulonglong handler::next_insert_id |
next_insert_id is the next value which should be inserted into the auto_increment column: in a inserting-multi-row statement (like INSERT SELECT), for the first row where the autoinc value is not specified by the statement, get_auto_increment() called and asked to generate a value, next_insert_id is set to the next value, then for all other rows next_insert_id is used (and increased each time) without calling get_auto_increment().
uint handler::ref_length |
Length of ref (1-8 or the clustered key length)