11
11
FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
13
13
You should have received a copy of the GNU General Public License along with
14
this program; if not, write to the Free Software Foundation, Inc., 59 Temple
15
Place, Suite 330, Boston, MA 02111-1307 USA
14
this program; if not, write to the Free Software Foundation, Inc., 51 Franklin
15
St, Fifth Floor, Boston, MA 02110-1301 USA
17
17
*****************************************************************************/
35
35
typedef struct st_innobase_share {
36
36
THR_LOCK lock; /*!< MySQL lock protecting
38
const char* table_name; /*!< InnoDB table name */
38
char table_name[FN_REFLEN]; /*!< InnoDB table name */
39
39
uint use_count; /*!< reference count,
40
40
incremented in get_share()
41
41
and decremented in free_share() */
42
42
void* table_name_hash;/*!< hash table chain node */
44
st_innobase_share(const char *arg) :
47
strncpy(table_name, arg, FN_REFLEN);
66
73
INNOBASE_SHARE* share; /*!< information for MySQL
69
unsigned char* upd_buff; /*!< buffer used in updates */
70
unsigned char* key_val_buff; /*!< buffer used in converting
71
search key values from MySQL format
76
std::vector<unsigned char> upd_buff; /*!< buffer used in updates */
77
std::vector<unsigned char> key_val_buff; /*!< buffer used in converting
78
search key values from MySQL format
73
80
ulong upd_and_key_val_buff_len;
74
81
/* the length of each of the previous
80
87
uint last_match_mode;/* match mode of the latest search:
81
88
ROW_SEL_EXACT, ROW_SEL_EXACT_PREFIX,
83
uint num_write_row; /*!< number of write_row() calls */
90
uint num_write_row; /*!< number of doInsertRecord() calls */
85
92
UNIV_INTERN uint store_key_val_for_row(uint keynr, char* buff,
86
93
uint buff_len, const unsigned char* record);
87
94
UNIV_INTERN void update_session(Session* session);
88
UNIV_INTERN void update_session();
89
95
UNIV_INTERN int change_active_index(uint32_t keynr);
90
96
UNIV_INTERN int general_fetch(unsigned char* buf, uint32_t direction, uint32_t match_mode);
91
97
UNIV_INTERN ulint innobase_lock_autoinc();
101
107
/* Init values for the class: */
103
109
UNIV_INTERN ha_innobase(plugin::StorageEngine &engine,
104
TableShare &table_arg);
105
111
UNIV_INTERN ~ha_innobase();
107
113
* Returns the plugin::TransactionStorageEngine pointer
114
120
UNIV_INTERN plugin::TransactionalStorageEngine *getTransactionalEngine()
116
return static_cast<plugin::TransactionalStorageEngine *>(engine);
122
return static_cast<plugin::TransactionalStorageEngine *>(getEngine());
120
Get the row type from the storage engine. If this method returns
121
ROW_TYPE_NOT_USED, the information in HA_CREATE_INFO should be used.
123
UNIV_INTERN enum row_type get_row_type() const;
125
125
UNIV_INTERN const char* index_type(uint key_number);
126
126
UNIV_INTERN const key_map* keys_to_use_for_scanning();
128
UNIV_INTERN int open(const char *name, int mode, uint test_if_locked);
128
UNIV_INTERN int doOpen(const drizzled::TableIdentifier &identifier, int mode, uint test_if_locked);
129
129
UNIV_INTERN int close(void);
130
130
UNIV_INTERN double scan_time();
131
131
UNIV_INTERN double read_time(uint index, uint ranges, ha_rows rows);
133
UNIV_INTERN int write_row(unsigned char * buf);
134
UNIV_INTERN int update_row(const unsigned char * old_data, unsigned char * new_data);
135
UNIV_INTERN int delete_row(const unsigned char * buf);
133
UNIV_INTERN int doInsertRecord(unsigned char * buf);
134
UNIV_INTERN int doUpdateRecord(const unsigned char * old_data, unsigned char * new_data);
135
UNIV_INTERN int doDeleteRecord(const unsigned char * buf);
136
136
UNIV_INTERN bool was_semi_consistent_read();
137
137
UNIV_INTERN void try_semi_consistent_read(bool yes);
138
138
UNIV_INTERN void unlock_row();
140
UNIV_INTERN int index_init(uint index, bool sorted);
141
UNIV_INTERN int index_end();
140
UNIV_INTERN int doStartIndexScan(uint index, bool sorted);
141
UNIV_INTERN int doEndIndexScan();
142
142
UNIV_INTERN int index_read(unsigned char * buf, const unsigned char * key,
143
143
uint key_len, enum ha_rkey_function find_flag);
144
144
UNIV_INTERN int index_read_idx(unsigned char * buf, uint index, const unsigned char * key,
150
150
UNIV_INTERN int index_first(unsigned char * buf);
151
151
UNIV_INTERN int index_last(unsigned char * buf);
153
UNIV_INTERN int rnd_init(bool scan);
154
UNIV_INTERN int rnd_end();
153
UNIV_INTERN int doStartTableScan(bool scan);
154
UNIV_INTERN int doEndTableScan();
155
155
UNIV_INTERN int rnd_next(unsigned char *buf);
156
156
UNIV_INTERN int rnd_pos(unsigned char * buf, unsigned char *pos);
171
171
UNIV_INTERN int check(Session* session);
172
172
UNIV_INTERN char* update_table_comment(const char* comment);
173
173
UNIV_INTERN char* get_foreign_key_create_info();
174
UNIV_INTERN int get_foreign_key_list(Session *session, List<FOREIGN_KEY_INFO> *f_key_list);
174
UNIV_INTERN int get_foreign_key_list(Session *session, List<ForeignKeyInfo> *f_key_list);
175
175
UNIV_INTERN bool can_switch_engines();
176
176
UNIV_INTERN uint referenced_by_foreign_key();
177
177
UNIV_INTERN void free_foreign_key_create_info(char* str);
187
187
UNIV_INTERN bool primary_key_is_clustered();
188
188
UNIV_INTERN int cmp_ref(const unsigned char *ref1, const unsigned char *ref2);
189
189
/** Fast index creation (smart ALTER TABLE) @see handler0alter.cc @{ */
190
UNIV_INTERN int add_index(TABLE *table_arg, KEY *key_info, uint num_of_keys);
191
UNIV_INTERN int prepare_drop_index(TABLE *table_arg, uint *key_num,
190
// Don't use these, I have just left them in here as reference for
191
// the future. -Brian
193
UNIV_INTERN int add_index(Session *session, TABLE *table_arg, KeyInfo *key_info, uint num_of_keys);
194
UNIV_INTERN int prepare_drop_index(Session *session,
192
197
uint num_of_keys);
193
UNIV_INTERN int final_drop_index(TABLE *table_arg);
198
UNIV_INTERN int final_drop_index(Session *session, TABLE *table_arg);
196
202
int read_range_first(const key_range *start_key, const key_range *end_key,
220
226
int session_slave_thread(const Session *session);
223
Check if a user thread is running a non-transactional update
224
@param session user thread
225
@retval 0 the user thread is not running a non-transactional update
226
@retval 1 the user thread is running a non-transactional update
228
int session_non_transactional_update(const Session *session);
231
Mark transaction to rollback and mark error as fatal to a sub-statement.
232
@param session Thread handle
233
@param all TRUE <=> rollback main transaction.
235
void session_mark_transaction_to_rollback(Session *session, bool all);
238
230
typedef struct trx_struct trx_t;
258
250
innobase_trx_allocate(
259
251
/*==================*/
260
252
Session *session); /*!< in: user thread handle */
254
/***********************************************************************
255
This function checks each index name for a table against reserved
256
system default primary index name 'GEN_CLUST_INDEX'. If a name matches,
257
this function pushes an error message to the client, and returns true. */
260
innobase_index_name_is_reserved(
261
/*============================*/
262
/* out: true if index name matches a
264
const trx_t* trx, /* in: InnoDB transaction handle */
265
const drizzled::KeyInfo* key_info,/* in: Indexes to be created */
266
ulint num_of_keys); /* in: Number of indexes to
261
269
#endif /* INNODB_HANDLER_HA_INNODB_H */