btr0cur.h
上传用户:tsgydb
上传日期:2007-04-14
资源大小:10674k
文件大小:19k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /******************************************************
  2. The index tree cursor
  3. (c) 1994-1996 Innobase Oy
  4. Created 10/16/1994 Heikki Tuuri
  5. *******************************************************/
  6. #ifndef btr0cur_h
  7. #define btr0cur_h
  8. #include "univ.i"
  9. #include "dict0dict.h"
  10. #include "data0data.h"
  11. #include "page0cur.h"
  12. #include "btr0types.h"
  13. #include "que0types.h"
  14. #include "row0types.h"
  15. #include "ha0ha.h"
  16. /* Mode flags for btr_cur operations; these can be ORed */
  17. #define BTR_NO_UNDO_LOG_FLAG 1 /* do no undo logging */
  18. #define BTR_NO_LOCKING_FLAG 2 /* do no record lock checking */
  19. #define BTR_KEEP_SYS_FLAG 4 /* sys fields will be found from the
  20. update vector or inserted entry */
  21. #define BTR_CUR_ADAPT
  22. #define BTR_CUR_HASH_ADAPT
  23. /*************************************************************
  24. Returns the page cursor component of a tree cursor. */
  25. UNIV_INLINE
  26. page_cur_t*
  27. btr_cur_get_page_cur(
  28. /*=================*/
  29. /* out: pointer to page cursor component */
  30. btr_cur_t* cursor); /* in: tree cursor */
  31. /*************************************************************
  32. Returns the record pointer of a tree cursor. */
  33. UNIV_INLINE
  34. rec_t*
  35. btr_cur_get_rec(
  36. /*============*/
  37. /* out: pointer to record */
  38. btr_cur_t* cursor); /* in: tree cursor */
  39. /*************************************************************
  40. Invalidates a tree cursor by setting record pointer to NULL. */
  41. UNIV_INLINE
  42. void
  43. btr_cur_invalidate(
  44. /*===============*/
  45. btr_cur_t* cursor); /* in: tree cursor */
  46. /*************************************************************
  47. Returns the page of a tree cursor. */
  48. UNIV_INLINE
  49. page_t*
  50. btr_cur_get_page(
  51. /*=============*/
  52. /* out: pointer to page */
  53. btr_cur_t* cursor); /* in: tree cursor */
  54. /*************************************************************
  55. Returns the tree of a cursor. */
  56. UNIV_INLINE
  57. dict_tree_t*
  58. btr_cur_get_tree(
  59. /*=============*/
  60. /* out: tree */
  61. btr_cur_t* cursor); /* in: tree cursor */
  62. /*************************************************************
  63. Positions a tree cursor at a given record. */
  64. UNIV_INLINE
  65. void
  66. btr_cur_position(
  67. /*=============*/
  68. dict_index_t* index,  /* in: index */
  69. rec_t* rec, /* in: record in tree */
  70. btr_cur_t* cursor);/* in: cursor */
  71. /************************************************************************
  72. Searches an index tree and positions a tree cursor on a given level.
  73. NOTE: n_fields_cmp in tuple must be set so that it cannot be compared
  74. to node pointer page number fields on the upper levels of the tree!
  75. Note that if mode is PAGE_CUR_LE, which is used in inserts, then
  76. cursor->up_match and cursor->low_match both will have sensible values.
  77. If mode is PAGE_CUR_GE, then up_match will a have a sensible value. */
  78. void
  79. btr_cur_search_to_nth_level(
  80. /*========================*/
  81. dict_index_t* index, /* in: index */
  82. ulint level, /* in: the tree level of search */
  83. dtuple_t* tuple, /* in: data tuple; NOTE: n_fields_cmp in
  84. tuple must be set so that it cannot get
  85. compared to the node ptr page number field! */
  86. ulint mode, /* in: PAGE_CUR_L, ...;
  87. NOTE that if the search is made using a unique
  88. prefix of a record, mode should be PAGE_CUR_LE,
  89. not PAGE_CUR_GE, as the latter may end up on
  90. the previous page of the record! Inserts
  91. should always be made using PAGE_CUR_LE to
  92. search the position! */
  93. ulint latch_mode, /* in: BTR_SEARCH_LEAF, ...;
  94. cursor->left_page is used to store a pointer
  95. to the left neighbor page, in the cases
  96. BTR_SEARCH_PREV and BTR_MODIFY_PREV */
  97. btr_cur_t* cursor, /* out: tree cursor; the cursor page is s- or
  98. x-latched */
  99. ulint has_search_latch,/* in: latch mode the caller
  100. currently has on btr_search_latch:
  101. RW_S_LATCH, or 0 */
  102. mtr_t* mtr); /* in: mtr */
  103. /*********************************************************************
  104. Opens a cursor at either end of an index. */
  105. void
  106. btr_cur_open_at_index_side(
  107. /*=======================*/
  108. ibool from_left, /* in: TRUE if open to the low end,
  109. FALSE if to the high end */
  110. dict_index_t* index, /* in: index */
  111. ulint latch_mode, /* in: latch mode */
  112. btr_cur_t* cursor, /* in: cursor */
  113. mtr_t* mtr); /* in: mtr */
  114. /**************************************************************************
  115. Positions a cursor at a randomly chosen position within a B-tree. */
  116. void
  117. btr_cur_open_at_rnd_pos(
  118. /*====================*/
  119. dict_index_t* index, /* in: index */
  120. ulint latch_mode, /* in: BTR_SEARCH_LEAF, ... */
  121. btr_cur_t* cursor, /* in/out: B-tree cursor */
  122. mtr_t* mtr); /* in: mtr */
  123. /*****************************************************************
  124. Tries to perform an insert to a page in an index tree, next to cursor.
  125. It is assumed that mtr holds an x-latch on the page. The operation does
  126. not succeed if there is too little space on the page. If there is just
  127. one record on the page, the insert will always succeed; this is to
  128. prevent trying to split a page with just one record. */
  129. ulint
  130. btr_cur_optimistic_insert(
  131. /*======================*/
  132. /* out: DB_SUCCESS, DB_WAIT_LOCK,
  133. DB_FAIL, or error number */
  134. ulint flags, /* in: undo logging and locking flags: if not
  135. zero, the parameters index and thr should be
  136. specified */
  137. btr_cur_t* cursor, /* in: cursor on page after which
  138. to insert; cursor stays valid */
  139. dtuple_t* entry, /* in: entry to insert */
  140. rec_t** rec, /* out: pointer to inserted record if
  141. succeed */
  142. que_thr_t* thr, /* in: query thread or NULL */
  143. mtr_t* mtr); /* in: mtr */
  144. /*****************************************************************
  145. Performs an insert on a page of an index tree. It is assumed that mtr
  146. holds an x-latch on the tree and on the cursor page. If the insert is
  147. made on the leaf level, to avoid deadlocks, mtr must also own x-latches
  148. to brothers of page, if those brothers exist. */
  149. ulint
  150. btr_cur_pessimistic_insert(
  151. /*=======================*/
  152. /* out: DB_SUCCESS or error number */
  153. ulint flags, /* in: undo logging and locking flags: if not
  154. zero, the parameters index and thr should be
  155. specified */
  156. btr_cur_t* cursor, /* in: cursor after which to insert;
  157. cursor does not stay valid */
  158. dtuple_t* entry, /* in: entry to insert */
  159. rec_t** rec, /* out: pointer to inserted record if
  160. succeed */
  161. que_thr_t* thr, /* in: query thread or NULL */
  162. mtr_t* mtr); /* in: mtr */
  163. /*****************************************************************
  164. Updates a record when the update causes no size changes in its fields. */
  165. ulint
  166. btr_cur_update_in_place(
  167. /*====================*/
  168. /* out: DB_SUCCESS or error number */
  169. ulint flags, /* in: undo logging and locking flags */
  170. btr_cur_t* cursor, /* in: cursor on the record to update;
  171. cursor stays valid and positioned on the
  172. same record */
  173. upd_t* update, /* in: update vector */
  174. ulint cmpl_info,/* in: compiler info on secondary index
  175. updates */
  176. que_thr_t* thr, /* in: query thread */
  177. mtr_t* mtr); /* in: mtr */
  178. /*****************************************************************
  179. Tries to update a record on a page in an index tree. It is assumed that mtr
  180. holds an x-latch on the page. The operation does not succeed if there is too
  181. little space on the page or if the update would result in too empty a page,
  182. so that tree compression is recommended. */
  183. ulint
  184. btr_cur_optimistic_update(
  185. /*======================*/
  186. /* out: DB_SUCCESS, or DB_OVERFLOW if the
  187. updated record does not fit, DB_UNDERFLOW
  188. if the page would become too empty */
  189. ulint flags, /* in: undo logging and locking flags */
  190. btr_cur_t* cursor, /* in: cursor on the record to update;
  191. cursor stays valid and positioned on the
  192. same record */
  193. upd_t* update, /* in: update vector; this must also
  194. contain trx id and roll ptr fields */
  195. ulint cmpl_info,/* in: compiler info on secondary index
  196. updates */
  197. que_thr_t* thr, /* in: query thread */
  198. mtr_t* mtr); /* in: mtr */
  199. /*****************************************************************
  200. Performs an update of a record on a page of a tree. It is assumed
  201. that mtr holds an x-latch on the tree and on the cursor page. If the
  202. update is made on the leaf level, to avoid deadlocks, mtr must also
  203. own x-latches to brothers of page, if those brothers exist. */
  204. ulint
  205. btr_cur_pessimistic_update(
  206. /*=======================*/
  207. /* out: DB_SUCCESS or error code */
  208. ulint flags, /* in: undo logging, locking, and rollback
  209. flags */
  210. btr_cur_t* cursor, /* in: cursor on the record to update;
  211. cursor does not stay valid */
  212. upd_t* update, /* in: update vector; this is allowed also
  213. contain trx id and roll ptr fields, but
  214. the values in update vector have no effect */
  215. ulint cmpl_info,/* in: compiler info on secondary index
  216. updates */
  217. que_thr_t* thr, /* in: query thread */
  218. mtr_t* mtr); /* in: mtr */
  219. /***************************************************************
  220. Marks a clustered index record deleted. Writes an undo log record to
  221. undo log on this delete marking. Writes in the trx id field the id
  222. of the deleting transaction, and in the roll ptr field pointer to the
  223. undo log record created. */
  224. ulint
  225. btr_cur_del_mark_set_clust_rec(
  226. /*===========================*/
  227. /* out: DB_SUCCESS, DB_LOCK_WAIT, or error
  228. number */
  229. ulint flags, /* in: undo logging and locking flags */
  230. btr_cur_t* cursor, /* in: cursor */
  231. ibool val, /* in: value to set */
  232. que_thr_t* thr, /* in: query thread */
  233. mtr_t* mtr); /* in: mtr */
  234. /***************************************************************
  235. Sets a secondary index record delete mark to TRUE or FALSE. */
  236. ulint
  237. btr_cur_del_mark_set_sec_rec(
  238. /*=========================*/
  239. /* out: DB_SUCCESS, DB_LOCK_WAIT, or error
  240. number */
  241. ulint flags, /* in: locking flag */
  242. btr_cur_t* cursor, /* in: cursor */
  243. ibool val, /* in: value to set */
  244. que_thr_t* thr, /* in: query thread */
  245. mtr_t* mtr); /* in: mtr */
  246. /***************************************************************
  247. Sets a secondary index record delete mark to FALSE. This function is
  248. only used by the insert buffer insert merge mechanism. */
  249. void
  250. btr_cur_del_unmark_for_ibuf(
  251. /*========================*/
  252. rec_t* rec, /* in: record to delete unmark */
  253. mtr_t* mtr); /* in: mtr */
  254. /*****************************************************************
  255. Tries to compress a page of the tree on the leaf level. It is assumed
  256. that mtr holds an x-latch on the tree and on the cursor page. To avoid
  257. deadlocks, mtr must also own x-latches to brothers of page, if those
  258. brothers exist. NOTE: it is assumed that the caller has reserved enough
  259. free extents so that the compression will always succeed if done! */
  260. void
  261. btr_cur_compress(
  262. /*=============*/
  263. btr_cur_t* cursor, /* in: cursor on the page to compress;
  264. cursor does not stay valid */
  265. mtr_t* mtr); /* in: mtr */
  266. /*****************************************************************
  267. Tries to compress a page of the tree if it seems useful. It is assumed
  268. that mtr holds an x-latch on the tree and on the cursor page. To avoid
  269. deadlocks, mtr must also own x-latches to brothers of page, if those
  270. brothers exist. NOTE: it is assumed that the caller has reserved enough
  271. free extents so that the compression will always succeed if done! */
  272. ibool
  273. btr_cur_compress_if_useful(
  274. /*=======================*/
  275. /* out: TRUE if compression occurred */
  276. btr_cur_t* cursor, /* in: cursor on the page to compress;
  277. cursor does not stay valid if compression
  278. occurs */
  279. mtr_t* mtr); /* in: mtr */
  280. /***********************************************************
  281. Removes the record on which the tree cursor is positioned. It is assumed
  282. that the mtr has an x-latch on the page where the cursor is positioned,
  283. but no latch on the whole tree. */
  284. ibool
  285. btr_cur_optimistic_delete(
  286. /*======================*/
  287. /* out: TRUE if success, i.e., the page
  288. did not become too empty */
  289. btr_cur_t* cursor, /* in: cursor on the record to delete;
  290. cursor stays valid: if deletion succeeds,
  291. on function exit it points to the successor
  292. of the deleted record */
  293. mtr_t* mtr); /* in: mtr */
  294. /*****************************************************************
  295. Removes the record on which the tree cursor is positioned. Tries
  296. to compress the page if its fillfactor drops below a threshold
  297. or if it is the only page on the level. It is assumed that mtr holds
  298. an x-latch on the tree and on the cursor page. To avoid deadlocks,
  299. mtr must also own x-latches to brothers of page, if those brothers
  300. exist. */
  301. ibool
  302. btr_cur_pessimistic_delete(
  303. /*=======================*/
  304. /* out: TRUE if compression occurred */
  305. ulint* err, /* out: DB_SUCCESS or DB_OUT_OF_FILE_SPACE;
  306. the latter may occur because we may have
  307. to update node pointers on upper levels,
  308. and in the case of variable length keys
  309. these may actually grow in size */
  310. ibool has_reserved_extents, /* in: TRUE if the
  311. caller has already reserved enough free
  312. extents so that he knows that the operation
  313. will succeed */
  314. btr_cur_t* cursor, /* in: cursor on the record to delete;
  315. if compression does not occur, the cursor
  316. stays valid: it points to successor of
  317. deleted record on function exit */
  318. mtr_t* mtr); /* in: mtr */
  319. /***************************************************************
  320. Parses a redo log record of updating a record in-place. */
  321. byte*
  322. btr_cur_parse_update_in_place(
  323. /*==========================*/
  324. /* out: end of log record or NULL */
  325. byte* ptr, /* in: buffer */
  326. byte* end_ptr,/* in: buffer end */
  327. page_t* page); /* in: page or NULL */
  328. /***************************************************************
  329. Parses a redo log record of updating a record, but not in-place. */
  330. byte*
  331. btr_cur_parse_opt_update(
  332. /*=====================*/
  333. /* out: end of log record or NULL */
  334. byte* ptr, /* in: buffer */
  335. byte* end_ptr,/* in: buffer end */
  336. page_t* page, /* in: page or NULL */
  337. mtr_t* mtr); /* in: mtr or NULL */
  338. /********************************************************************
  339. Parses the redo log record for delete marking or unmarking of a clustered
  340. index record. */
  341. byte*
  342. btr_cur_parse_del_mark_set_clust_rec(
  343. /*=================================*/
  344. /* out: end of log record or NULL */
  345. byte* ptr, /* in: buffer */
  346. byte* end_ptr,/* in: buffer end */
  347. page_t* page); /* in: page or NULL */
  348. /********************************************************************
  349. Parses the redo log record for delete marking or unmarking of a secondary
  350. index record. */
  351. byte*
  352. btr_cur_parse_del_mark_set_sec_rec(
  353. /*===============================*/
  354. /* out: end of log record or NULL */
  355. byte* ptr, /* in: buffer */
  356. byte* end_ptr,/* in: buffer end */
  357. page_t* page); /* in: page or NULL */
  358. /***********************************************************************
  359. Estimates the number of rows in a given index range. */
  360. ulint
  361. btr_estimate_n_rows_in_range(
  362. /*=========================*/
  363. /* out: estimated number of rows */
  364. dict_index_t* index, /* in: index */
  365. dtuple_t* tuple1, /* in: range start, may also be empty tuple */
  366. ulint mode1, /* in: search mode for range start */
  367. dtuple_t* tuple2, /* in: range end, may also be empty tuple */
  368. ulint mode2); /* in: search mode for range end */
  369. /***********************************************************************
  370. Estimates the number of different key values in a given index. */
  371. ulint
  372. btr_estimate_number_of_different_key_vals(
  373. /*======================================*/
  374. /* out: estimated number of key values */
  375. dict_index_t* index); /* in: index */
  376. /*######################################################################*/
  377. /* In the pessimistic delete, if the page data size drops below this
  378. limit, merging it to a neighbor is tried */
  379. #define BTR_CUR_PAGE_COMPRESS_LIMIT (UNIV_PAGE_SIZE / 2)
  380. /* A slot in the path array. We store here info on a search path down the
  381. tree. Each slot contains data on a single level of the tree. */
  382. typedef struct btr_path_struct btr_path_t;
  383. struct btr_path_struct{
  384. ulint nth_rec; /* index of the record
  385. where the page cursor stopped on
  386. this level (index in alphabetical
  387. order); value ULINT_UNDEFINED
  388. denotes array end */
  389. ulint n_recs; /* number of records on the page */
  390. };
  391. #define BTR_PATH_ARRAY_N_SLOTS 250 /* size of path array (in slots) */
  392. /* The tree cursor: the definition appears here only for the compiler
  393. to know struct size! */
  394. struct btr_cur_struct {
  395. dict_index_t* index; /* index where positioned */
  396. page_cur_t page_cur; /* page cursor */
  397. page_t* left_page; /* this field is used to store a pointer
  398. to the left neighbor page, in the cases
  399. BTR_SEARCH_PREV and BTR_MODIFY_PREV */
  400. /*------------------------------*/
  401. que_thr_t* thr; /* this field is only used when
  402. btr_cur_search_... is called for an
  403. index entry insertion: the calling
  404. query thread is passed here to be
  405. used in the insert buffer */
  406. /*------------------------------*/
  407. /* The following fields are used in btr_cur_search... to pass
  408. information: */
  409. ulint flag; /* BTR_CUR_HASH, BTR_CUR_HASH_FAIL,
  410. BTR_CUR_BINARY, or
  411. BTR_CUR_INSERT_TO_IBUF */
  412. ulint tree_height; /* Tree height if the search is done
  413. for a pessimistic insert or update
  414. operation */
  415. ulint up_match; /* If the search mode was PAGE_CUR_LE,
  416. the number of matched fields to the
  417. the first user record to the right of
  418. the cursor record after
  419. btr_cur_search_...;
  420. for the mode PAGE_CUR_GE, the matched
  421. fields to the first user record AT THE
  422. CURSOR or to the right of it;
  423. NOTE that the up_match and low_match
  424. values may exceed the correct values
  425. for comparison to the adjacent user
  426. record if that record is on a
  427. different leaf page! (See the note in
  428. row_ins_duplicate_key.) */
  429. ulint up_bytes; /* number of matched bytes to the
  430. right at the time cursor positioned;
  431. only used internally in searches: not
  432. defined after the search */
  433. ulint low_match; /* if search mode was PAGE_CUR_LE,
  434. the number of matched fields to the
  435. first user record AT THE CURSOR or
  436. to the left of it after
  437. btr_cur_search_...;
  438. NOT defined for PAGE_CUR_GE or any
  439. other search modes; see also the NOTE
  440. in up_match! */
  441. ulint low_bytes; /* number of matched bytes to the
  442. right at the time cursor positioned;
  443. only used internally in searches: not
  444. defined after the search */
  445. ulint n_fields; /* prefix length used in a hash
  446. search if hash_node != NULL */
  447. ulint n_bytes; /* hash prefix bytes if hash_node !=
  448. NULL */
  449. ulint fold; /* fold value used in the search if
  450. flag is BTR_CUR_HASH */
  451. /*------------------------------*/
  452. btr_path_t* path_arr; /* in estimating the number of
  453. rows in range, we store in this array
  454. information of the path through
  455. the tree */
  456. };
  457. /* Values for the flag documenting the used search method */
  458. #define BTR_CUR_HASH 1 /* successful shortcut using the hash
  459. index */
  460. #define BTR_CUR_HASH_FAIL 2 /* failure using hash, success using
  461. binary search: the misleading hash
  462. reference is stored in the field
  463. hash_node, and might be necessary to
  464. update */
  465. #define BTR_CUR_BINARY 3 /* success using the binary search */
  466. #define BTR_CUR_INSERT_TO_IBUF 4 /* performed the intended insert to
  467. the insert buffer */
  468. /* If pessimistic delete fails because of lack of file space,
  469. there is still a good change of success a little later: try this many times,
  470. and sleep this many microseconds in between */
  471. #define BTR_CUR_RETRY_DELETE_N_TIMES 100
  472. #define BTR_CUR_RETRY_SLEEP_TIME 50000
  473. extern ulint btr_cur_n_non_sea;
  474. #ifndef UNIV_NONINL
  475. #include "btr0cur.ic"
  476. #endif
  477. #endif