63
63
static TransactionServices transaction_services;
64
64
return transaction_services;
68
* Returns true if the transaction manager should construct
69
* Transaction and Statement messages, false otherwise.
71
bool shouldConstructMessages();
67
73
* Method which returns the active Transaction message
68
74
* for the supplied Session. If one is not found, a new Transaction
190
196
* @param Pointer to the Session committing the transaction
192
void commitTransactionMessage(Session *in_session);
198
int commitTransactionMessage(Session *in_session);
194
200
* Marks the current active transaction message as being rolled back and
195
201
* pushes the transaction message out to replicators.
294
300
void rawStatement(Session *in_session, const std::string &query);
295
301
/* transactions: interface to plugin::StorageEngine functions */
296
int ha_commit_one_phase(Session *session, bool all);
297
int ha_rollback_trans(Session *session, bool all);
302
int commitPhaseOne(Session *session, bool all);
303
int rollbackTransaction(Session *session, bool all);
299
305
/* transactions: these functions never call plugin::StorageEngine functions directly */
300
int ha_commit_trans(Session *session, bool all);
301
int ha_autocommit_or_rollback(Session *session, int error);
306
int commitTransaction(Session *session, bool all);
307
int autocommitOrRollback(Session *session, int error);
304
int ha_rollback_to_savepoint(Session *session, NamedSavepoint &sv);
305
int ha_savepoint(Session *session, NamedSavepoint &sv);
306
int ha_release_savepoint(Session *session, NamedSavepoint &sv);
307
bool mysql_xa_recover(Session *session);
310
int rollbackToSavepoint(Session *session, NamedSavepoint &sv);
311
int setSavepoint(Session *session, NamedSavepoint &sv);
312
int releaseSavepoint(Session *session, NamedSavepoint &sv);
310
315
* Marks a storage engine as participating in a statement