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

MySQL数据库

开发平台:

Visual C++

  1. /******************************************************
  2. General row routines
  3. (c) 1996 Innobase Oy
  4. Created 4/20/1996 Heikki Tuuri
  5. *******************************************************/
  6. #include "row0row.h"
  7. #ifdef UNIV_NONINL
  8. #include "row0row.ic"
  9. #endif
  10. #include "dict0dict.h"
  11. #include "btr0btr.h"
  12. #include "mach0data.h"
  13. #include "trx0rseg.h"
  14. #include "trx0trx.h"
  15. #include "trx0roll.h"
  16. #include "trx0undo.h"
  17. #include "trx0purge.h"
  18. #include "trx0rec.h"
  19. #include "que0que.h"
  20. #include "row0row.h"
  21. #include "row0upd.h"
  22. #include "rem0cmp.h"
  23. #include "read0read.h"
  24. /*************************************************************************
  25. Reads the trx id or roll ptr field from a clustered index record: this function
  26. is slower than the specialized inline functions. */
  27. dulint
  28. row_get_rec_sys_field(
  29. /*==================*/
  30. /* out: value of the field */
  31. ulint type, /* in: DATA_TRX_ID or DATA_ROLL_PTR */
  32. rec_t* rec, /* in: record */
  33. dict_index_t* index) /* in: clustered index */
  34. {
  35. ulint pos;
  36. byte* field;
  37. ulint len;
  38. ut_ad(index->type & DICT_CLUSTERED);
  39. pos = dict_index_get_sys_col_pos(index, type);
  40. field = rec_get_nth_field(rec, pos, &len);
  41. if (type == DATA_TRX_ID) {
  42. return(trx_read_trx_id(field));
  43. } else {
  44. ut_ad(type == DATA_ROLL_PTR);
  45. return(trx_read_roll_ptr(field));
  46. }
  47. }
  48. /*************************************************************************
  49. Sets the trx id or roll ptr field in a clustered index record: this function
  50. is slower than the specialized inline functions. */
  51. void
  52. row_set_rec_sys_field(
  53. /*==================*/
  54. /* out: value of the field */
  55. ulint type, /* in: DATA_TRX_ID or DATA_ROLL_PTR */
  56. rec_t* rec, /* in: record */
  57. dict_index_t* index, /* in: clustered index */
  58. dulint val) /* in: value to set */
  59. {
  60. ulint pos;
  61. byte* field;
  62. ulint len;
  63. ut_ad(index->type & DICT_CLUSTERED);
  64. pos = dict_index_get_sys_col_pos(index, type);
  65. field = rec_get_nth_field(rec, pos, &len);
  66. if (type == DATA_TRX_ID) {
  67. trx_write_trx_id(field, val);
  68. } else {
  69. ut_ad(type == DATA_ROLL_PTR);
  70. trx_write_roll_ptr(field, val);
  71. }
  72. }
  73. /*********************************************************************
  74. When an insert to a table is performed, this function builds the entry which
  75. has to be inserted to an index on the table. */
  76. dtuple_t*
  77. row_build_index_entry(
  78. /*==================*/
  79. /* out: index entry which should be inserted */
  80. dtuple_t* row,  /* in: row which should be inserted to the
  81. table */
  82. dict_index_t* index,  /* in: index on the table */
  83. mem_heap_t* heap) /* in: memory heap from which the memory for
  84. the index entry is allocated */
  85. {
  86. dtuple_t* entry;
  87. ulint entry_len;
  88. dict_field_t* ind_field;
  89. dfield_t* dfield;
  90. dfield_t* dfield2;
  91. dict_col_t* col;
  92. ulint i;
  93.         ulint           storage_len;
  94. dtype_t* cur_type;
  95. ut_ad(row && index && heap);
  96. ut_ad(dtuple_check_typed(row));
  97. entry_len = dict_index_get_n_fields(index);
  98. entry = dtuple_create(heap, entry_len);
  99. if (index->type & DICT_UNIVERSAL) {
  100. dtuple_set_n_fields_cmp(entry, entry_len);
  101. } else {
  102. dtuple_set_n_fields_cmp(entry,
  103. dict_index_get_n_unique_in_tree(index));
  104. }
  105. for (i = 0; i < entry_len; i++) {
  106. ind_field = dict_index_get_nth_field(index, i);
  107. col = ind_field->col;
  108. dfield = dtuple_get_nth_field(entry, i);
  109. dfield2 = dtuple_get_nth_field(row, dict_col_get_no(col));
  110. dfield_copy(dfield, dfield2);
  111. /* If a column prefix index, take only the prefix */
  112. if (ind_field->prefix_len > 0
  113.     && dfield_get_len(dfield2) != UNIV_SQL_NULL) {
  114. cur_type = dict_col_get_type(
  115. dict_field_get_col(ind_field));
  116. storage_len = dtype_get_at_most_n_mbchars(
  117. cur_type,
  118. ind_field->prefix_len,
  119. dfield_get_len(dfield2), dfield2->data);
  120. dfield_set_len(dfield, storage_len);
  121. }
  122. }
  123. ut_ad(dtuple_check_typed(entry));
  124. return(entry);
  125. }
  126. /***********************************************************************
  127. An inverse function to dict_row_build_index_entry. Builds a row from a
  128. record in a clustered index. */
  129. dtuple_t*
  130. row_build(
  131. /*======*/
  132. /* out, own: row built; see the NOTE below! */
  133. ulint type, /* in: ROW_COPY_POINTERS, ROW_COPY_DATA, or
  134. ROW_COPY_ALSO_EXTERNALS, 
  135. the two last copy also the data fields to
  136. heap as the first only places pointers to
  137. data fields on the index page, and thus is
  138. more efficient */
  139. dict_index_t* index, /* in: clustered index */
  140. rec_t* rec, /* in: record in the clustered index;
  141. NOTE: in the case ROW_COPY_POINTERS
  142. the data fields in the row will point
  143. directly into this record, therefore,
  144. the buffer page of this record must be
  145. at least s-latched and the latch held
  146. as long as the row dtuple is used! */
  147. mem_heap_t* heap) /* in: memory heap from which the memory
  148. needed is allocated */
  149. {
  150. dtuple_t* row;
  151. dict_table_t* table;
  152. dict_field_t* ind_field;
  153. dict_col_t* col;
  154. dfield_t* dfield;
  155. ulint n_fields;
  156. byte* field;
  157. ulint len;
  158. ulint row_len;
  159. byte* buf; 
  160. ulint i;
  161. ut_ad(index && rec && heap);
  162. ut_ad(index->type & DICT_CLUSTERED);
  163. if (type != ROW_COPY_POINTERS) {
  164. /* Take a copy of rec to heap */
  165. buf = mem_heap_alloc(heap, rec_get_size(rec));
  166. rec = rec_copy(buf, rec);
  167. }
  168. table = index->table;
  169. row_len = dict_table_get_n_cols(table);
  170. row = dtuple_create(heap, row_len);
  171. dtuple_set_info_bits(row, rec_get_info_bits(rec));
  172. n_fields = dict_index_get_n_fields(index);
  173. ut_ad(n_fields == rec_get_n_fields(rec));
  174. dict_table_copy_types(row, table);
  175. for (i = 0; i < n_fields; i++) {
  176.         ind_field = dict_index_get_nth_field(index, i);
  177. if (ind_field->prefix_len == 0) {
  178.         col = dict_field_get_col(ind_field);
  179. dfield = dtuple_get_nth_field(row,
  180. dict_col_get_no(col));
  181. field = rec_get_nth_field(rec, i, &len);
  182. if (type == ROW_COPY_ALSO_EXTERNALS
  183.     && rec_get_nth_field_extern_bit(rec, i)) {
  184.         field = btr_rec_copy_externally_stored_field(
  185. rec, i, &len, heap);
  186. }
  187. dfield_set_data(dfield, field, len);
  188. }
  189. }
  190. ut_ad(dtuple_check_typed(row));
  191. return(row);
  192. }
  193. /***********************************************************************
  194. Converts an index record to a typed data tuple. NOTE that externally
  195. stored (often big) fields are NOT copied to heap. */
  196. dtuple_t*
  197. row_rec_to_index_entry(
  198. /*===================*/
  199. /* out, own: index entry built; see the
  200. NOTE below! */
  201. ulint type, /* in: ROW_COPY_DATA, or ROW_COPY_POINTERS:
  202. the former copies also the data fields to
  203. heap as the latter only places pointers to
  204. data fields on the index page */
  205. dict_index_t* index, /* in: index */
  206. rec_t* rec, /* in: record in the index;
  207. NOTE: in the case ROW_COPY_POINTERS
  208. the data fields in the row will point
  209. directly into this record, therefore,
  210. the buffer page of this record must be
  211. at least s-latched and the latch held
  212. as long as the dtuple is used! */
  213. mem_heap_t* heap) /* in: memory heap from which the memory
  214. needed is allocated */
  215. {
  216. dtuple_t* entry;
  217. dfield_t* dfield;
  218. ulint i;
  219. byte* field;
  220. ulint len;
  221. ulint rec_len;
  222. byte* buf;
  223. ut_ad(rec && heap && index);
  224. if (type == ROW_COPY_DATA) {
  225. /* Take a copy of rec to heap */
  226. buf = mem_heap_alloc(heap, rec_get_size(rec));
  227. rec = rec_copy(buf, rec);
  228. }
  229. rec_len = rec_get_n_fields(rec);
  230. entry = dtuple_create(heap, rec_len);
  231. dtuple_set_n_fields_cmp(entry,
  232. dict_index_get_n_unique_in_tree(index));
  233. ut_ad(rec_len == dict_index_get_n_fields(index));
  234. dict_index_copy_types(entry, index, rec_len);
  235. dtuple_set_info_bits(entry, rec_get_info_bits(rec));
  236. for (i = 0; i < rec_len; i++) {
  237. dfield = dtuple_get_nth_field(entry, i);
  238. field = rec_get_nth_field(rec, i, &len);
  239. dfield_set_data(dfield, field, len);
  240. }
  241. ut_ad(dtuple_check_typed(entry));
  242. return(entry);
  243. }
  244. /***********************************************************************
  245. Builds from a secondary index record a row reference with which we can
  246. search the clustered index record. */
  247. dtuple_t*
  248. row_build_row_ref(
  249. /*==============*/
  250. /* out, own: row reference built; see the
  251. NOTE below! */
  252. ulint type, /* in: ROW_COPY_DATA, or ROW_COPY_POINTERS:
  253. the former copies also the data fields to
  254. heap, whereas the latter only places pointers
  255. to data fields on the index page */
  256. dict_index_t* index, /* in: index */
  257. rec_t* rec, /* in: record in the index;
  258. NOTE: in the case ROW_COPY_POINTERS
  259. the data fields in the row will point
  260. directly into this record, therefore,
  261. the buffer page of this record must be
  262. at least s-latched and the latch held
  263. as long as the row reference is used! */
  264. mem_heap_t* heap) /* in: memory heap from which the memory
  265. needed is allocated */
  266. {
  267. dict_table_t* table;
  268. dict_index_t* clust_index;
  269. dfield_t* dfield;
  270. dtuple_t* ref;
  271. byte* field;
  272. ulint len;
  273. ulint ref_len;
  274. ulint pos;
  275. byte* buf;
  276. ulint clust_col_prefix_len;
  277. ulint i;
  278. ut_ad(index && rec && heap);
  279. if (type == ROW_COPY_DATA) {
  280. /* Take a copy of rec to heap */
  281. buf = mem_heap_alloc(heap, rec_get_size(rec));
  282. rec = rec_copy(buf, rec);
  283. }
  284. table = index->table;
  285. clust_index = dict_table_get_first_index(table);
  286. ref_len = dict_index_get_n_unique(clust_index);
  287. ref = dtuple_create(heap, ref_len);
  288. dict_index_copy_types(ref, clust_index, ref_len);
  289. for (i = 0; i < ref_len; i++) {
  290. dfield = dtuple_get_nth_field(ref, i);
  291. pos = dict_index_get_nth_field_pos(index, clust_index, i);
  292. ut_a(pos != ULINT_UNDEFINED);
  293. field = rec_get_nth_field(rec, pos, &len);
  294. dfield_set_data(dfield, field, len);
  295. /* If the primary key contains a column prefix, then the
  296. secondary index may contain a longer prefix of the same
  297. column, or the full column, and we must adjust the length
  298. accordingly. */
  299. clust_col_prefix_len =
  300. dict_index_get_nth_field(clust_index, i)->prefix_len;
  301. if (clust_col_prefix_len > 0) {
  302.      if (len != UNIV_SQL_NULL) {
  303. dfield_set_len(dfield,
  304.   dtype_get_at_most_n_mbchars(
  305. dfield_get_type(dfield),
  306. clust_col_prefix_len, len, field));
  307. }
  308. }
  309. }
  310. ut_ad(dtuple_check_typed(ref));
  311. return(ref);
  312. }
  313. /***********************************************************************
  314. Builds from a secondary index record a row reference with which we can
  315. search the clustered index record. */
  316. void
  317. row_build_row_ref_in_tuple(
  318. /*=======================*/
  319. dtuple_t* ref, /* in/out: row reference built; see the
  320. NOTE below! */
  321. dict_index_t* index, /* in: index */
  322. rec_t* rec, /* in: record in the index;
  323. NOTE: the data fields in ref will point
  324. directly into this record, therefore,
  325. the buffer page of this record must be
  326. at least s-latched and the latch held
  327. as long as the row reference is used! */
  328. trx_t* trx) /* in: transaction */
  329. {
  330. dict_index_t* clust_index;
  331. dfield_t* dfield;
  332. byte* field;
  333. ulint len;
  334. ulint ref_len;
  335. ulint pos;
  336. ulint clust_col_prefix_len;
  337. ulint i;
  338. ut_a(ref && index && rec);
  339. if (!index->table) {
  340. fputs("InnoDB: table ", stderr);
  341. notfound:
  342. ut_print_name(stderr, trx, index->table_name);
  343. fputs(" for index ", stderr);
  344. ut_print_name(stderr, trx, index->name);
  345. fputs(" not foundn", stderr);
  346. ut_error;
  347. }
  348. clust_index = dict_table_get_first_index(index->table);
  349. if (!clust_index) {
  350. fputs("InnoDB: clust index for table ", stderr);
  351. goto notfound;
  352. }
  353. ref_len = dict_index_get_n_unique(clust_index);
  354. ut_ad(ref_len == dtuple_get_n_fields(ref));
  355. dict_index_copy_types(ref, clust_index, ref_len);
  356. for (i = 0; i < ref_len; i++) {
  357. dfield = dtuple_get_nth_field(ref, i);
  358. pos = dict_index_get_nth_field_pos(index, clust_index, i);
  359. ut_a(pos != ULINT_UNDEFINED);
  360. field = rec_get_nth_field(rec, pos, &len);
  361. dfield_set_data(dfield, field, len);
  362. /* If the primary key contains a column prefix, then the
  363. secondary index may contain a longer prefix of the same
  364. column, or the full column, and we must adjust the length
  365. accordingly. */
  366. clust_col_prefix_len =
  367. dict_index_get_nth_field(clust_index, i)->prefix_len;
  368. if (clust_col_prefix_len > 0) {
  369.      if (len != UNIV_SQL_NULL) {
  370. dfield_set_len(dfield,
  371.   dtype_get_at_most_n_mbchars(
  372. dfield_get_type(dfield),
  373. clust_col_prefix_len, len, field));
  374. }
  375. }
  376. }
  377. ut_ad(dtuple_check_typed(ref));
  378. }
  379. /***********************************************************************
  380. From a row build a row reference with which we can search the clustered
  381. index record. */
  382. void
  383. row_build_row_ref_from_row(
  384. /*=======================*/
  385. dtuple_t* ref, /* in/out: row reference built; see the
  386. NOTE below! ref must have the right number
  387. of fields! */
  388. dict_table_t* table, /* in: table */
  389. dtuple_t* row) /* in: row
  390. NOTE: the data fields in ref will point
  391. directly into data of this row */
  392. {
  393. dict_index_t* clust_index;
  394. dict_field_t* field;
  395. dfield_t* dfield;
  396. dfield_t* dfield2;
  397. dict_col_t* col;
  398. ulint ref_len;
  399. ulint i;
  400. dtype_t* cur_type;
  401. ut_ad(ref && table && row);
  402. clust_index = dict_table_get_first_index(table);
  403. ref_len = dict_index_get_n_unique(clust_index);
  404. ut_ad(ref_len == dtuple_get_n_fields(ref));
  405. for (i = 0; i < ref_len; i++) {
  406. dfield = dtuple_get_nth_field(ref, i);
  407. field = dict_index_get_nth_field(clust_index, i);
  408. col = dict_field_get_col(field);
  409. dfield2 = dtuple_get_nth_field(row, dict_col_get_no(col));
  410. dfield_copy(dfield, dfield2);
  411. if (field->prefix_len > 0
  412.     && dfield->len != UNIV_SQL_NULL) {
  413. cur_type = dict_col_get_type(
  414. dict_field_get_col(field));
  415. dfield->len = dtype_get_at_most_n_mbchars(
  416. cur_type,
  417. field->prefix_len,
  418. dfield->len, dfield->data);
  419. }
  420. }
  421. ut_ad(dtuple_check_typed(ref));
  422. }
  423. /*******************************************************************
  424. Searches the clustered index record for a row, if we have the row reference. */
  425. ibool
  426. row_search_on_row_ref(
  427. /*==================*/
  428. /* out: TRUE if found */
  429. btr_pcur_t* pcur, /* in/out: persistent cursor, which must
  430. be closed by the caller */
  431. ulint mode, /* in: BTR_MODIFY_LEAF, ... */
  432. dict_table_t* table, /* in: table */
  433. dtuple_t* ref, /* in: row reference */
  434. mtr_t* mtr) /* in: mtr */
  435. {
  436. ulint low_match;
  437. rec_t* rec;
  438. dict_index_t* index;
  439. page_t* page;
  440. ut_ad(dtuple_check_typed(ref));
  441. index = dict_table_get_first_index(table);
  442. ut_a(dtuple_get_n_fields(ref) == dict_index_get_n_unique(index));
  443. btr_pcur_open(index, ref, PAGE_CUR_LE, mode, pcur, mtr);
  444. low_match = btr_pcur_get_low_match(pcur);
  445. rec = btr_pcur_get_rec(pcur);
  446. page = buf_frame_align(rec);
  447. if (rec == page_get_infimum_rec(page)) {
  448. return(FALSE);
  449. }
  450. if (low_match != dtuple_get_n_fields(ref)) {
  451. return(FALSE);
  452. }
  453. return(TRUE);
  454. }
  455. /*************************************************************************
  456. Fetches the clustered index record for a secondary index record. The latches
  457. on the secondary index record are preserved. */
  458. rec_t*
  459. row_get_clust_rec(
  460. /*==============*/
  461. /* out: record or NULL, if no record found */
  462. ulint mode, /* in: BTR_MODIFY_LEAF, ... */
  463. rec_t* rec, /* in: record in a secondary index */
  464. dict_index_t* index, /* in: secondary index */
  465. dict_index_t** clust_index,/* out: clustered index */
  466. mtr_t* mtr) /* in: mtr */
  467. {
  468. mem_heap_t* heap;
  469. dtuple_t* ref;
  470. dict_table_t* table;
  471. btr_pcur_t pcur;
  472. ibool found;
  473. rec_t* clust_rec;
  474. ut_ad((index->type & DICT_CLUSTERED) == 0);
  475. table = index->table;
  476. heap = mem_heap_create(256);
  477. ref = row_build_row_ref(ROW_COPY_POINTERS, index, rec, heap);
  478. found = row_search_on_row_ref(&pcur, mode, table, ref, mtr);
  479. clust_rec = found ? btr_pcur_get_rec(&pcur) : NULL;
  480. mem_heap_free(heap);
  481. btr_pcur_close(&pcur);
  482. *clust_index = dict_table_get_first_index(table);
  483. return(clust_rec);
  484. }
  485. /*******************************************************************
  486. Searches an index record. */
  487. ibool
  488. row_search_index_entry(
  489. /*===================*/
  490. /* out: TRUE if found */
  491. dict_index_t* index, /* in: index */
  492. dtuple_t* entry, /* in: index entry */
  493. ulint mode, /* in: BTR_MODIFY_LEAF, ... */
  494. btr_pcur_t* pcur, /* in/out: persistent cursor, which must
  495. be closed by the caller */
  496. mtr_t* mtr) /* in: mtr */
  497. {
  498. ulint n_fields;
  499. ulint low_match;
  500. page_t* page;
  501. rec_t* rec;
  502. ut_ad(dtuple_check_typed(entry));
  503. btr_pcur_open(index, entry, PAGE_CUR_LE, mode, pcur, mtr);
  504. low_match = btr_pcur_get_low_match(pcur);
  505. rec = btr_pcur_get_rec(pcur);
  506. page = buf_frame_align(rec);
  507. n_fields = dtuple_get_n_fields(entry);
  508. if (rec == page_get_infimum_rec(page)) {
  509. return(FALSE);
  510. }
  511. if (low_match != n_fields) {
  512. /* Not found */
  513. return(FALSE);
  514. }
  515. return(TRUE);
  516. }