1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
/** 构建聚集索引记录某个版本 rec 的再前一个版本。
调用者必须持有聚集索引记录索引页的锁。*/
bool trx_undo_prev_version_build(const rec_t *index_rec, mtr_t *index_mtr,
const rec_t *rec, const dict_index_t *index,
ulint *offsets, mem_heap_t *heap,
rec_t **old_vers, mem_heap_t *v_heap,
const dtuple_t **vrow, ulint v_status,
lob::undo_vers_t *lob_undo) {
trx_undo_rec_t *undo_rec = nullptr;
dtuple_t *entry;
trx_id_t rec_trx_id;
ulint type;
undo_no_t undo_no;
table_id_t table_id;
trx_id_t trx_id;
roll_ptr_t roll_ptr;
upd_t *update = nullptr;
byte *ptr;
ulint info_bits;
ulint cmpl_info;
bool dummy_extern;
byte *buf;
roll_ptr = row_get_rec_roll_ptr(rec, index, offsets);
*old_vers = nullptr;
/* insert undo（说明是串上第一个记录）*/
if (trx_undo_roll_ptr_is_insert(roll_ptr)) { return true;}
rec_trx_id = row_get_rec_trx_id(rec, index, offsets);
bool is_temp = index->table->is_temporary();
// 获取 undo_rec 时会判断 rec_trx_id 是否被 purge_sys->view 可见
if (trx_undo_get_undo_rec(roll_ptr, rec_trx_id, heap, is_temp,
index->table->name, &undo_rec)) {
// 当前 rec_trx_id 在 purge_sys->view 可见，更老的（prev）undo 可能版本都被处理了
if (v_status & TRX_UNDO_PREV_IN_PURGE) {
/* 函数被 purge 流程中调用的特殊情况，用于 virtual row 处理 */
undo_rec = trx_undo_get_undo_rec_low(roll_ptr, heap, is_temp);
} else {
/* 正常情况，更老一个版本的 undo 不安全，到当前版本为止 */
return false;
}
}
// 解析获取到的对应上一版本的 undo rec
type_cmpl_t type_cmpl;
ptr = trx_undo_rec_get_pars(undo_rec, &type, &cmpl_info, &dummy_extern,
&undo_no, &table_id, type_cmpl);
if (table_id != index->table->id) return true; /*table 被重建，purge 遇到老 id 的 undo*/
ptr = trx_undo_update_rec_get_sys_cols(ptr, &trx_id, &roll_ptr, &info_bits);
ptr = trx_undo_rec_skip_row_ref(ptr, index);
// 通过 undo 构建 upd_t *update
ptr = trx_undo_update_rec_get_update(ptr, index, type, trx_id, roll_ptr,
info_bits, heap, &update, lob_undo,
type_cmpl);
ut_a(ptr);
if (row_upd_changes_field_size_or_external(index, offsets, update)) {
/* 如果前一个版本记录是被标记删除的，并且存在 disowned 的 blob，
则需要判断可见性这个版本记录的可见性，
如果 purge 可见，将其视为 missing history 处理，
这是因为上一版本记录 disowned 的 blob 可能已经被 purge 了。
可以省略 row_upd_changes_disowned_external(update) 调用，
但这样 purge_sys->latch 加锁更多，性能开销可更高。*/
if ((update->info_bits & REC_INFO_DELETED_FLAG) &&
row_upd_changes_disowned_external(update)) {
bool missing_ext;
rw_lock_s_lock(&purge_sys->latch, UT_LOCATION_HERE);
missing_ext = purge_sys->view.changes_visible(trx_id, index->table->name);
rw_lock_s_unlock(&purge_sys->latch);
if (missing_ext) {
/* treat as a fresh insert, not to cause assertion error at the caller. */
if (update != nullptr) {
update->reset();
}
return true;
}
}
// 通过 undo 还原
entry = row_rec_to_index_entry(rec, index, offsets, heap);
row_upd_index_replace_new_col_vals(entry, index, update, heap);
buf = static_cast<byte *>(mem_heap_alloc(heap, rec_get_converted_size(index, entry)));
*old_vers = rec_convert_dtuple_to_rec(buf, index, entry);
} else {
buf = static_cast<byte *>(mem_heap_alloc(heap, rec_offs_size(offsets)));
*old_vers = rec_copy(buf, rec, offsets);
// 通过 undo 还原
row_upd_rec_in_place(*old_vers, index, offsets, update, nullptr);
}
/* Set the old value (which is the after image of an update) in the
update vector to dtuple vrow */
if (v_status & TRX_UNDO_GET_OLD_V_VALUE)
row_upd_replace_vcol((dtuple_t *)*vrow, index->table, update, false, nullptr, nullptr);
if (vrow && !(cmpl_info & UPD_NODE_NO_ORD_CHANGE)) {
// 构建老版本的 virtual row
// ...
}
if (update != nullptr) {
update->reset();
}
return true;
}
|
