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
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
|
/*****************************************************************************
Copyright (c) 2016, 2025, Oracle and/or its affiliates.
This program is free software; you can redistribute it and/or modify it under
the terms of the GNU General Public License, version 2.0, as published by the
Free Software Foundation.
This program is designed to work with certain software (including
but not limited to OpenSSL) that is licensed under separate terms,
as designated in a particular file or component or in included license
documentation. The authors of MySQL hereby grant you an additional
permission to link the program and your derivative works with the
separately licensed software that they have either included with
the program or referenced in the documentation.
This program is distributed in the hope that it will be useful, but WITHOUT
ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
FOR A PARTICULAR PURPOSE. See the GNU General Public License, version 2.0,
for more details.
You should have received a copy of the GNU General Public License along with
this program; if not, write to the Free Software Foundation, Inc.,
51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*****************************************************************************/
#include <list>
#include "btr0btr.h"
#include "buf0buf.h"
#include "dict0dict.h"
#include "lob0first.h"
#include "lob0index.h"
#include "lob0lob.h"
#include "table.h"
#include "trx0trx.h"
namespace lob {
/** Allocate one LOB page.
@param[in] index Index in which LOB exists.
@param[in] lob_mtr Mini-transaction context.
@param[in] hint Hint page number for allocation.
@param[in] bulk true if operation is OPCODE_INSERT_BULK,
false otherwise.
@return the allocated block of the BLOB page or nullptr. */
buf_block_t *alloc_lob_page(dict_index_t *index, mtr_t *lob_mtr, page_no_t hint,
bool bulk) {
ulint r_extents;
mtr_t mtr_bulk;
mtr_t *alloc_mtr;
buf_block_t *block = nullptr;
space_id_t space_id = dict_index_get_space(index);
ut_ad(fsp_check_tablespace_size(space_id));
if (bulk) {
mtr_start(&mtr_bulk);
alloc_mtr = &mtr_bulk;
} else {
alloc_mtr = lob_mtr;
}
bool success =
fsp_reserve_free_extents(&r_extents, space_id, 1, FSP_BLOB, alloc_mtr, 1);
DBUG_EXECUTE_IF("innodb_alloc_lob_page_failed", success = false;);
if (!success) {
if (bulk) {
ut_ad(alloc_mtr == &mtr_bulk);
alloc_mtr->commit();
}
return (nullptr);
}
block = btr_page_alloc(index, hint, FSP_NO_DIR, 0, alloc_mtr, lob_mtr);
fil_space_release_free_extents(space_id, r_extents);
if (bulk) {
ut_ad(alloc_mtr == &mtr_bulk);
alloc_mtr->commit();
}
return (block);
}
dberr_t get_affected_index_entries(const ref_t &ref, dict_index_t *index,
const Binary_diff &bdiff,
List_iem_t &entries, mtr_t *mtr) {
page_no_t first_page_no = ref.page_no();
space_id_t space_id = ref.space_id();
const page_size_t page_size = dict_table_page_size(index->table);
const page_id_t first_page_id(space_id, first_page_no);
size_t offset = bdiff.offset();
ulint data_len = 0;
if (!dict_table_has_atomic_blobs(index->table)) {
/* For compact and redundant row format, remove the local
prefix length from the offset. */
ut_ad(offset >= DICT_ANTELOPE_MAX_INDEX_COL_LEN);
offset -= DICT_ANTELOPE_MAX_INDEX_COL_LEN;
}
/* Currently only working with uncompressed LOB */
ut_ad(!page_size.is_compressed());
first_page_t first_page(mtr, index);
first_page.load_x(first_page_id, page_size);
#ifdef UNIV_DEBUG
{
page_type_t page_type = first_page.get_page_type();
ut_ad(page_type == FIL_PAGE_TYPE_LOB_FIRST);
}
#endif /* UNIV_DEBUG */
/* Obtain the first index entry. */
flst_base_node_t *base_node = first_page.index_list();
fil_addr_t node_loc = flst_get_first(base_node, mtr);
buf_block_t *block = nullptr;
index_entry_t entry(mtr, index);
while (!fil_addr_is_null(node_loc)) {
if (block == nullptr) {
block = entry.load_x(node_loc);
} else if (block->page.id.page_no() != node_loc.page) {
block = entry.load_x(node_loc);
} else {
/* Next entry in the same page. */
ut_ad(block == entry.get_block());
entry.reset(node_loc);
}
/* Get the amount of data */
data_len = entry.get_data_len();
if (offset < data_len) {
index_entry_mem_t entry_mem;
entry.read(entry_mem);
entries.push_back(entry_mem);
size_t remain = data_len - offset;
if (bdiff.length() > remain) {
block = entry.next();
if (block != nullptr) {
entry.read(entry_mem);
entries.push_back(entry_mem);
}
}
break;
}
offset -= data_len;
/* The next node should not be the same as the current node. */
ut_ad(!node_loc.is_equal(entry.get_next()));
node_loc = entry.get_next();
}
ut_ad(entries.size() == 1 || entries.size() == 2);
return (DB_SUCCESS);
}
/** Get information about the given LOB.
@param[in] ref LOB reference.
@param[in] index Clustered index to which LOB belongs.
@param[out] lob_version LOB version number.
@param[out] last_trx_id trx_id that modified the lob last.
@param[out] last_undo_no Trx undo no that modified the lob last.
@param[out] page_type the Page type of first lob page.
@param[in] mtr Mini-transaction context.
@return always returns DB_SUCCESS. */
dberr_t get_info(ref_t &ref, dict_index_t *index, ulint &lob_version,
trx_id_t &last_trx_id, undo_no_t &last_undo_no,
page_type_t &page_type, mtr_t *mtr) {
page_no_t first_page_no = ref.page_no();
space_id_t space_id = ref.space_id();
const page_size_t page_size = dict_table_page_size(index->table);
const page_id_t first_page_id(space_id, first_page_no);
/* Currently only working with uncompressed LOB */
ut_ad(!page_size.is_compressed());
first_page_t first_page(mtr, index);
first_page.load_x(first_page_id, page_size);
page_type = first_page.get_page_type();
lob_version = first_page.get_lob_version();
last_trx_id = first_page.get_last_trx_id();
last_undo_no = first_page.get_last_trx_undo_no();
return (DB_SUCCESS);
}
} /* namespace lob */
|
