trx0roll.h
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:10k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /******************************************************
  2. Transaction rollback
  3. (c) 1996 Innobase Oy
  4. Created 3/26/1996 Heikki Tuuri
  5. *******************************************************/
  6. #ifndef trx0roll_h
  7. #define trx0roll_h
  8. #include "univ.i"
  9. #include "trx0trx.h"
  10. #include "trx0types.h"
  11. #include "mtr0mtr.h"
  12. #include "trx0sys.h"
  13. /***********************************************************************
  14. Returns a transaction savepoint taken at this point in time. */
  15. trx_savept_t
  16. trx_savept_take(
  17. /*============*/
  18. /* out: savepoint */
  19. trx_t* trx); /* in: transaction */
  20. /***********************************************************************
  21. Creates an undo number array. */
  22. trx_undo_arr_t*
  23. trx_undo_arr_create(void);
  24. /*=====================*/
  25. /***********************************************************************
  26. Frees an undo number array. */
  27. void
  28. trx_undo_arr_free(
  29. /*==============*/
  30. trx_undo_arr_t* arr); /* in: undo number array */
  31. /***********************************************************************
  32. Returns pointer to nth element in an undo number array. */
  33. UNIV_INLINE
  34. trx_undo_inf_t*
  35. trx_undo_arr_get_nth_info(
  36. /*======================*/
  37. /* out: pointer to the nth element */
  38. trx_undo_arr_t* arr, /* in: undo number array */
  39. ulint n); /* in: position */
  40. /***************************************************************************
  41. Tries truncate the undo logs. */
  42. void
  43. trx_roll_try_truncate(
  44. /*==================*/
  45. trx_t* trx); /* in: transaction */
  46. /************************************************************************
  47. Pops the topmost record when the two undo logs of a transaction are seen
  48. as a single stack of records ordered by their undo numbers. Inserts the
  49. undo number of the popped undo record to the array of currently processed
  50. undo numbers in the transaction. When the query thread finishes processing
  51. of this undo record, it must be released with trx_undo_rec_release. */
  52. trx_undo_rec_t*
  53. trx_roll_pop_top_rec_of_trx(
  54. /*========================*/
  55. /* out: undo log record copied to heap, NULL
  56. if none left, or if the undo number of the
  57. top record would be less than the limit */
  58. trx_t* trx, /* in: transaction */
  59. dulint limit, /* in: least undo number we need */
  60. dulint* roll_ptr,/* out: roll pointer to undo record */
  61. mem_heap_t* heap); /* in: memory heap where copied */
  62. /************************************************************************
  63. Reserves an undo log record for a query thread to undo. This should be
  64. called if the query thread gets the undo log record not using the pop
  65. function above. */
  66. ibool
  67. trx_undo_rec_reserve(
  68. /*=================*/
  69. /* out: TRUE if succeeded */
  70. trx_t* trx, /* in: transaction */
  71. dulint undo_no);/* in: undo number of the record */
  72. /***********************************************************************
  73. Releases a reserved undo record. */
  74. void
  75. trx_undo_rec_release(
  76. /*=================*/
  77. trx_t* trx, /* in: transaction */
  78. dulint undo_no);/* in: undo number */
  79. /*************************************************************************
  80. Starts a rollback operation. */
  81. void
  82. trx_rollback(
  83. /*=========*/
  84. trx_t* trx, /* in: transaction */
  85. trx_sig_t* sig, /* in: signal starting the rollback */
  86. que_thr_t** next_thr);/* in/out: next query thread to run;
  87. if the value which is passed in is
  88. a pointer to a NULL pointer, then the
  89. calling function can start running
  90. a new query thread */
  91. /***********************************************************************
  92. Rollback or clean up transactions which have no user session. If the
  93. transaction already was committed, then we clean up a possible insert
  94. undo log. If the transaction was not yet committed, then we roll it back. */
  95. void
  96. trx_rollback_or_clean_all_without_sess(void);
  97. /*========================================*/
  98. /********************************************************************
  99. Finishes a transaction rollback. */
  100. void
  101. trx_finish_rollback_off_kernel(
  102. /*===========================*/
  103. que_t* graph, /* in: undo graph which can now be freed */
  104. trx_t* trx, /* in: transaction */
  105. que_thr_t** next_thr);/* in/out: next query thread to run;
  106. if the value which is passed in is
  107. a pointer to a NULL pointer, then the
  108.     calling function can start running
  109. a new query thread; if this parameter is
  110. NULL, it is ignored */
  111. /********************************************************************
  112. Builds an undo 'query' graph for a transaction. The actual rollback is
  113. performed by executing this query graph like a query subprocedure call.
  114. The reply about the completion of the rollback will be sent by this
  115. graph. */
  116. que_t*
  117. trx_roll_graph_build(
  118. /*=================*/
  119. /* out, own: the query graph */
  120. trx_t* trx); /* in: trx handle */
  121. /*************************************************************************
  122. Creates a rollback command node struct. */
  123. roll_node_t*
  124. roll_node_create(
  125. /*=============*/
  126. /* out, own: rollback node struct */
  127. mem_heap_t* heap); /* in: mem heap where created */
  128. /***************************************************************
  129. Performs an execution step for a rollback command node in a query graph. */
  130. que_thr_t*
  131. trx_rollback_step(
  132. /*==============*/
  133. /* out: query thread to run next, or NULL */
  134. que_thr_t* thr); /* in: query thread */
  135. /***********************************************************************
  136. Rollback a transaction used in MySQL. */
  137. int
  138. trx_rollback_for_mysql(
  139. /*===================*/
  140. /* out: error code or DB_SUCCESS */
  141. trx_t* trx); /* in: transaction handle */
  142. /***********************************************************************
  143. Rollback the latest SQL statement for MySQL. */
  144. int
  145. trx_rollback_last_sql_stat_for_mysql(
  146. /*=================================*/
  147. /* out: error code or DB_SUCCESS */
  148. trx_t* trx); /* in: transaction handle */
  149. /***********************************************************************
  150. Rollback a transaction used in MySQL. */
  151. int
  152. trx_general_rollback_for_mysql(
  153. /*===========================*/
  154. /* out: error code or DB_SUCCESS */
  155. trx_t* trx, /* in: transaction handle */
  156. ibool partial,/* in: TRUE if partial rollback requested */
  157. trx_savept_t* savept);/* in: pointer to savepoint undo number, if
  158. partial rollback requested */
  159. /***********************************************************************
  160. Rolls back a transaction back to a named savepoint. Modifications after the
  161. savepoint are undone but InnoDB does NOT release the corresponding locks
  162. which are stored in memory. If a lock is 'implicit', that is, a new inserted
  163. row holds a lock where the lock information is carried by the trx id stored in 
  164. the row, these locks are naturally released in the rollback. Savepoints which
  165. were set after this savepoint are deleted. */
  166. ulint
  167. trx_rollback_to_savepoint_for_mysql(
  168. /*================================*/
  169. /* out: if no savepoint
  170. of the name found then
  171. DB_NO_SAVEPOINT,
  172. otherwise DB_SUCCESS */
  173. trx_t* trx, /* in: transaction handle */
  174. const char* savepoint_name, /* in: savepoint name */
  175. ib_longlong* mysql_binlog_cache_pos);/* out: the MySQL binlog cache
  176. position corresponding to this
  177. savepoint; MySQL needs this
  178. information to remove the
  179. binlog entries of the queries
  180. executed after the savepoint */
  181. /***********************************************************************
  182. Creates a named savepoint. If the transaction is not yet started, starts it.
  183. If there is already a savepoint of the same name, this call erases that old
  184. savepoint and replaces it with a new. Savepoints are deleted in a transaction
  185. commit or rollback. */
  186. ulint
  187. trx_savepoint_for_mysql(
  188. /*====================*/
  189. /* out: always DB_SUCCESS */
  190. trx_t* trx, /* in: transaction handle */
  191. const char* savepoint_name, /* in: savepoint name */
  192. ib_longlong binlog_cache_pos); /* in: MySQL binlog cache
  193. position corresponding to this
  194. connection at the time of the
  195. savepoint */
  196. /***********************************************************************
  197. Frees savepoint structs. */
  198. void
  199. trx_roll_savepoints_free(
  200. /*=====================*/
  201. trx_t* trx, /* in: transaction handle */
  202. trx_named_savept_t* savep); /* in: free all savepoints > this one;
  203. if this is NULL, free all savepoints
  204. of trx */
  205. extern sess_t* trx_dummy_sess;
  206. /* A cell in the array used during a rollback and a purge */
  207. struct trx_undo_inf_struct{
  208. dulint trx_no; /* transaction number: not defined during
  209. a rollback */
  210. dulint undo_no; /* undo number of an undo record */
  211. ibool in_use; /* TRUE if the cell is in use */
  212. };
  213. /* During a rollback and a purge, undo numbers of undo records currently being
  214. processed are stored in this array */
  215. struct trx_undo_arr_struct{
  216. ulint n_cells; /* number of cells in the array */
  217. ulint n_used; /* number of cells currently in use */
  218. trx_undo_inf_t* infos; /* the array of undo infos */
  219. mem_heap_t* heap; /* memory heap from which allocated */
  220. };
  221. /* Rollback command node in a query graph */
  222. struct roll_node_struct{
  223. que_common_t common; /* node type: QUE_NODE_ROLLBACK */
  224. ulint state; /* node execution state */
  225. ibool partial;/* TRUE if we want a partial rollback */
  226. trx_savept_t savept; /* savepoint to which to roll back, in the
  227. case of a partial rollback */
  228. };
  229. /* A savepoint set with SQL's "SAVEPOINT savepoint_id" command */
  230. struct trx_named_savept_struct{
  231. char* name; /* savepoint name */
  232. trx_savept_t savept; /* the undo number corresponding to
  233. the savepoint */
  234. ib_longlong mysql_binlog_cache_pos;
  235. /* the MySQL binlog cache position
  236. corresponding to this savepoint, not
  237. defined if the MySQL binlogging is not
  238. enabled */
  239. UT_LIST_NODE_T(trx_named_savept_t)
  240. trx_savepoints; /* the list of savepoints of a
  241. transaction */
  242. };
  243. /* Rollback node states */
  244. #define ROLL_NODE_SEND 1
  245. #define ROLL_NODE_WAIT 2
  246. #ifndef UNIV_NONINL
  247. #include "trx0roll.ic"
  248. #endif
  249. #endif