98
98
session->ha_data[xxx_engine.slot]
100
100
slot number is initialized by MySQL after xxx_init() is called.
103
std::bitset<HTON_BIT_SIZE> flags; /* global handler flags */
105
to store per-savepoint data storage engine is provided with an area
106
of a requested size (0 is ok here).
107
savepoint_offset must be initialized statically to the size of
108
the needed memory to store per-savepoint information.
109
After xxx_init it is changed to be an offset to savepoint storage
110
area and need not be used by storage engine.
111
see binlog_engine and binlog_savepoint_set/rollback for an example.
113
uint32_t savepoint_offset;
114
uint32_t license; /* Flag for Engine License */
103
std::bitset<HTON_BIT_SIZE> flags; /* global handler flags */
105
to store per-savepoint data storage engine is provided with an area
106
of a requested size (0 is ok here).
107
savepoint_offset must be initialized statically to the size of
108
the needed memory to store per-savepoint information.
109
After xxx_init it is changed to be an offset to savepoint storage
110
area and need not be used by storage engine.
111
see binlog_engine and binlog_savepoint_set/rollback for an example.
113
uint32_t savepoint_offset;
114
uint32_t license; /* Flag for Engine License */
116
116
StorageEngine(const std::string &name_arg, bool support_2pc= false)
117
117
: name(name_arg), two_phase_commit(support_2pc), savepoint_offset(0) {}
127
bool is_enabled() const
129
return (state == SHOW_OPTION_YES);
132
std::string get_name() { return name; }
135
StorageEngine methods:
137
close_connection is only called if
138
session->ha_data[xxx_engine.slot] is non-zero, so even if you don't need
139
this storage area - set it to something, so that MySQL would know
140
this storage engine was accessed in this connection
142
virtual int close_connection(Session *)
147
The void * points to an uninitialized storage area of requested size
148
(see savepoint_offset description)
150
virtual int savepoint_set(Session *, void *)
156
The void * points to a storage area, that was earlier passed
157
to the savepoint_set call
159
virtual int savepoint_rollback(Session *, void *)
164
virtual int savepoint_release(Session *, void *)
170
'all' is true if it's a real commit, that makes persistent changes
171
'all' is false if it's not in fact a commit but an end of the
172
statement that is part of the transaction.
173
NOTE 'all' is also false in auto-commit mode where 'end of statement'
174
and 'real commit' mean the same event.
176
virtual int commit(Session *, bool)
181
virtual int rollback(Session *, bool)
186
virtual int prepare(Session *, bool) { return 0; }
187
virtual int recover(XID *, uint32_t) { return 0; }
188
virtual int commit_by_xid(XID *) { return 0; }
189
virtual int rollback_by_xid(XID *) { return 0; }
190
virtual handler *create(TABLE_SHARE *, MEM_ROOT *)= 0;
192
virtual void drop_database(char*) { }
193
virtual int start_consistent_snapshot(Session *) { return 0; }
194
virtual bool flush_logs() { return false; }
195
virtual bool show_status(Session *, stat_print_fn *, enum ha_stat_type)
200
/* args: current_session, tables, cond */
201
virtual int fill_files_table(Session *, TableList *,
202
Item *) { return 0; }
203
virtual int release_temporary_latches(Session *) { return false; }
205
/* args: current_session, db, name */
206
virtual int table_exists_in_engine(Session*, const char *, const char *);
126
bool is_enabled() const
128
return (state == SHOW_OPTION_YES);
131
std::string get_name() { return name; }
134
StorageEngine methods:
136
close_connection is only called if
137
session->ha_data[xxx_engine.slot] is non-zero, so even if you don't need
138
this storage area - set it to something, so that MySQL would know
139
this storage engine was accessed in this connection
141
virtual int close_connection(Session *)
146
The void * points to an uninitialized storage area of requested size
147
(see savepoint_offset description)
149
virtual int savepoint_set(Session *, void *)
155
The void * points to a storage area, that was earlier passed
156
to the savepoint_set call
158
virtual int savepoint_rollback(Session *, void *)
163
virtual int savepoint_release(Session *, void *)
169
'all' is true if it's a real commit, that makes persistent changes
170
'all' is false if it's not in fact a commit but an end of the
171
statement that is part of the transaction.
172
NOTE 'all' is also false in auto-commit mode where 'end of statement'
173
and 'real commit' mean the same event.
175
virtual int commit(Session *, bool)
180
virtual int rollback(Session *, bool)
185
virtual int prepare(Session *, bool) { return 0; }
186
virtual int recover(XID *, uint32_t) { return 0; }
187
virtual int commit_by_xid(XID *) { return 0; }
188
virtual int rollback_by_xid(XID *) { return 0; }
189
virtual handler *create(TABLE_SHARE *, MEM_ROOT *)= 0;
191
virtual void drop_database(char*) { }
192
virtual int start_consistent_snapshot(Session *) { return 0; }
193
virtual bool flush_logs() { return false; }
194
virtual bool show_status(Session *, stat_print_fn *, enum ha_stat_type)
199
/* args: current_session, tables, cond */
200
virtual int fill_files_table(Session *, TableList *,
201
Item *) { return 0; }
202
virtual int release_temporary_latches(Session *) { return false; }
204
/* args: current_session, db, name */
205
virtual int table_exists_in_engine(Session*, const char *, const char *);