aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-19 16:14:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

core/storage: Fix BTreeCursor::rowid() with MVCC

Browse Source
This commit is contained in:
Pekka Enberg
2025-07-17 16:23:16 +03:00
parent cef0195b42
commit aa84daabf1
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
core/storage/btree.rs
View File

@@ -4065,10 +4065,14 @@ impl BTreeCursor {
#[instrument(skip(self), level = Level::INFO)]
pub fn rowid(&mut self) -> Result<IOResult<Option<i64>>> {
if let Some(mv_cursor) = &self.mv_cursor {
let mv_cursor = mv_cursor.borrow();
return Ok(IOResult::Done(
mv_cursor.current_row_id().map(|rowid| rowid.row_id),
));
if self.has_record.get() {
let mv_cursor = mv_cursor.borrow();
return Ok(IOResult::Done(
mv_cursor.current_row_id().map(|rowid| rowid.row_id),
));
} else {
return Ok(IOResult::Done(None));
}
}
if self.has_record.get() {
let page = self.stack.top();