diff options
Diffstat (limited to 'storage/mroonga/mrn_table.hpp')
| -rw-r--r-- | storage/mroonga/mrn_table.hpp | 179 |
1 files changed, 179 insertions, 0 deletions
diff --git a/storage/mroonga/mrn_table.hpp b/storage/mroonga/mrn_table.hpp new file mode 100644 index 00000000..5ef7bc71 --- /dev/null +++ b/storage/mroonga/mrn_table.hpp @@ -0,0 +1,179 @@ +/* -*- c-basic-offset: 2 -*- */ +/* + Copyright(C) 2011-2013 Kentoku SHIBA + Copyright(C) 2011-2015 Kouhei Sutou <kou@clear-code.com> + + This library is free software; you can redistribute it and/or + modify it under the terms of the GNU Lesser General Public + License as published by the Free Software Foundation; either + version 2.1 of the License, or (at your option) any later version. + + This library 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 + Lesser General Public License for more details. + + You should have received a copy of the GNU Lesser General Public + License along with this library; if not, write to the Free Software + Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA +*/ + +#ifndef MRN_TABLE_HPP_ +#define MRN_TABLE_HPP_ + +#ifdef __cplusplus +extern "C" { +#endif + +#include <groonga.h> + +typedef struct st_mroonga_long_term_share +{ + char *table_name; + uint table_name_length; + + // for auto_increment (storage mode only) + mysql_mutex_t auto_inc_mutex; + bool auto_inc_inited; + ulonglong auto_inc_value; +} MRN_LONG_TERM_SHARE; + +typedef struct st_mroonga_share +{ + char *table_name; + uint table_name_length; + uint use_count; + mysql_mutex_t record_mutex; + THR_LOCK lock; + TABLE_SHARE *table_share; + TABLE_SHARE *wrap_table_share; + MRN_LONG_TERM_SHARE *long_term_share; + + char *engine; + int engine_length; + char *default_tokenizer; + int default_tokenizer_length; + char *normalizer; + int normalizer_length; + char *token_filters; + int token_filters_length; + plugin_ref plugin; + handlerton *hton; + char **index_table; + char **key_tokenizer; + char **col_flags; + char **col_type; + uint *index_table_length; + uint *key_tokenizer_length; + uint *col_flags_length; + uint *col_type_length; + uint *wrap_key_nr; + uint wrap_keys; + uint base_keys; + KEY *wrap_key_info; + KEY *base_key_info; + uint wrap_primary_key; + uint base_primary_key; + bool wrapper_mode; + bool disable_keys; +} MRN_SHARE; + +struct st_mrn_wrap_hton +{ + char path[FN_REFLEN + 1]; + handlerton *hton; + st_mrn_wrap_hton *next; +}; + +struct st_mrn_slot_data +{ + grn_id last_insert_record_id; + st_mrn_wrap_hton *first_wrap_hton; + HA_CREATE_INFO *alter_create_info; + HA_CREATE_INFO *disable_keys_create_info; + char *alter_connect_string; + char *alter_comment; +}; + +#define MRN_SET_WRAP_ALTER_KEY(file, ha_alter_info) \ + alter_table_operations base_handler_flags = ha_alter_info->handler_flags; \ + ha_table_option_struct* base_option_struct = ha_alter_info->create_info->option_struct; \ + KEY *base_key_info_buffer = ha_alter_info->key_info_buffer; \ + uint base_key_count = ha_alter_info->key_count; \ + uint base_index_drop_count = ha_alter_info->index_drop_count; \ + KEY **base_index_drop_buffer = ha_alter_info->index_drop_buffer; \ + uint base_index_add_count = ha_alter_info->index_add_count; \ + uint *base_index_add_buffer = ha_alter_info->index_add_buffer; \ + ha_alter_info->handler_flags = file->alter_handler_flags; \ + ha_alter_info->create_info->option_struct = wrap_altered_table->s->option_struct; \ + ha_alter_info->key_info_buffer = file->alter_key_info_buffer; \ + ha_alter_info->key_count = file->alter_key_count; \ + ha_alter_info->index_drop_count = file->alter_index_drop_count; \ + ha_alter_info->index_drop_buffer = &file->alter_index_drop_buffer; \ + ha_alter_info->index_add_count = file->alter_index_add_count; \ + ha_alter_info->index_add_buffer = file->alter_index_add_buffer; + +#define MRN_SET_BASE_ALTER_KEY(share, table_share) \ + ha_alter_info->handler_flags = base_handler_flags; \ + ha_alter_info->create_info->option_struct = base_option_struct; \ + ha_alter_info->key_info_buffer = base_key_info_buffer; \ + ha_alter_info->key_count = base_key_count; \ + ha_alter_info->index_drop_count = base_index_drop_count; \ + ha_alter_info->index_drop_buffer = base_index_drop_buffer; \ + ha_alter_info->index_add_count = base_index_add_count; \ + ha_alter_info->index_add_buffer = base_index_add_buffer; + +#define MRN_SET_WRAP_SHARE_KEY(share, table_share) +/* + table_share->keys = share->wrap_keys; \ + table_share->key_info = share->wrap_key_info; \ + table_share->primary_key = share->wrap_primary_key; +*/ + +#define MRN_SET_BASE_SHARE_KEY(share, table_share) +/* + table_share->keys = share->base_keys; \ + table_share->key_info = share->base_key_info; \ + table_share->primary_key = share->base_primary_key; +*/ + +#define MRN_SET_WRAP_TABLE_KEY(file, table) \ + table->key_info = file->wrap_key_info; \ + table->s = share->wrap_table_share; + +#define MRN_SET_BASE_TABLE_KEY(file, table) \ + table->key_info = file->base_key_info; \ + table->s = share->table_share; + +#ifdef WITH_PARTITION_STORAGE_ENGINE +void mrn_get_partition_info(const char *table_name, uint table_name_length, + const TABLE *table, partition_element **part_elem, + partition_element **sub_elem); +#endif +int mrn_parse_table_param(MRN_SHARE *share, TABLE *table); +bool mrn_is_geo_key(const KEY *key_info); +int mrn_add_index_param(MRN_SHARE *share, KEY *key_info, int i); +int mrn_parse_index_param(MRN_SHARE *share, TABLE *table); +int mrn_add_column_param(MRN_SHARE *share, Field *field, int i); +int mrn_parse_column_param(MRN_SHARE *share, TABLE *table); +MRN_SHARE *mrn_get_share(const char *table_name, TABLE *table, int *error); +int mrn_free_share_alloc(MRN_SHARE *share); +int mrn_free_share(MRN_SHARE *share); +MRN_LONG_TERM_SHARE *mrn_get_long_term_share(const char *table_name, + uint table_name_length, + int *error); +void mrn_free_long_term_share(MRN_LONG_TERM_SHARE *long_term_share); +TABLE_SHARE *mrn_get_table_share(TABLE_LIST *table_list, int *error); +TABLE_SHARE *mrn_create_tmp_table_share(TABLE_LIST *table_list, const char *path, + int *error); +void mrn_free_tmp_table_share(TABLE_SHARE *table_share); +KEY *mrn_create_key_info_for_table(MRN_SHARE *share, TABLE *table, int *error); +void mrn_set_bitmap_by_key(MY_BITMAP *map, KEY *key_info); +st_mrn_slot_data *mrn_get_slot_data(THD *thd, bool can_create); +void mrn_clear_slot_data(THD *thd); + +#ifdef __cplusplus +} +#endif + +#endif /* MRN_TABLE_HPP_ */ |