Struct TableHeap 

pub struct TableHeap {
    pub schema: SchemaRef,
    pub buffer_pool: Arc<BufferManager>,
    pub first_page_id: AtomicPageId,
    pub last_page_id: AtomicPageId,
}

Fields

schema: SchemaRef

buffer_pool: Arc<BufferManager>

first_page_id: AtomicPageId

last_page_id: AtomicPageId

Implementations

impl TableHeap

pub fn try_new( schema: SchemaRef, buffer_pool: Arc<BufferManager>, ) -> QuillSQLResult<Self>

Creates a new table heap. This involves allocating an initial page.

pub fn insert_tuple( &self, meta: &TupleMeta, tuple: &Tuple, ) -> QuillSQLResult<RecordId>

Inserts a tuple into the table.

This function inserts the given tuple into the table. If the last page in the table has enough space for the tuple, it is inserted there. Otherwise, a new page is allocated and the tuple is inserted there.

Parameters:

• meta: The metadata associated with the tuple.
• tuple: The tuple to be inserted.

Returns: An Option containing the Rid of the inserted tuple if successful, otherwise None. Inserts a tuple into the table.

pub fn mvcc_insert_version( &self, tuple: &Tuple, txn_id: TransactionId, cid: CommandId, prev_version: Option<RecordId>, ) -> QuillSQLResult<(RecordId, TupleMeta)>

MVCC helper: insert a new tuple version with optional link to a previous version.

pub fn mvcc_update( &self, current_rid: RecordId, new_tuple: Tuple, txn_id: TransactionId, cid: CommandId, ) -> QuillSQLResult<(RecordId, TupleMeta)>

Create a new tuple version for UPDATE while marking the source version deleted. Returns the RecordId of the new version and the original metadata (pre-change) for undo.

pub fn mvcc_mark_deleted( &self, rid: RecordId, txn_id: TransactionId, cid: CommandId, ) -> QuillSQLResult<TupleMeta>

Mark a tuple version as deleted for MVCC-aware DELETE operations. Returns the previous metadata prior to marking deleted (for undo purposes).

pub fn mvcc_remove_version(&self, rid: RecordId) -> QuillSQLResult<()>

Remove a heap version created by an aborted operation. For safety this currently expects the version to live at the tail of the page; otherwise it simply marks the slot deleted and leaves full reclamation to vacuum.

pub fn update_tuple(&self, rid: RecordId, tuple: Tuple) -> QuillSQLResult<()>

pub fn update_tuple_meta( &self, meta: TupleMeta, rid: RecordId, ) -> QuillSQLResult<()>

pub fn full_tuple(&self, rid: RecordId) -> QuillSQLResult<(TupleMeta, Tuple)>

pub fn tuple(&self, rid: RecordId) -> QuillSQLResult<Tuple>

pub fn tuple_meta(&self, rid: RecordId) -> QuillSQLResult<TupleMeta>

pub fn get_first_rid(&self) -> QuillSQLResult<Option<RecordId>>

pub fn get_next_rid(&self, rid: RecordId) -> QuillSQLResult<Option<RecordId>>

pub fn recovery_view(buffer_pool: Arc<BufferManager>) -> Self

Construct a lightweight TableHeap view for recovery operations. This instance uses an empty schema and does not rely on first/last page ids.

pub fn recover_set_tuple_meta( &self, rid: RecordId, meta: TupleMeta, ) -> QuillSQLResult<()>

Recovery-only API: set tuple meta without emitting WAL. Only used by RecoveryManager during UNDO.

pub fn recover_set_tuple_bytes( &self, rid: RecordId, new_bytes: &[u8], ) -> QuillSQLResult<()>

Recovery-only API: set tuple raw bytes without emitting WAL. If size mismatches, repack tuple area and update offsets.

pub fn recover_restore_tuple( &self, rid: RecordId, meta: TupleMeta, tuple: &Tuple, ) -> QuillSQLResult<()>

pub fn recover_delete_tuple( &self, rid: RecordId, txn_id: TransactionId, cid: CommandId, ) -> QuillSQLResult<()>

pub fn delete_tuple( &self, rid: RecordId, txn_id: TransactionId, cid: CommandId, ) -> QuillSQLResult<()>

pub fn vacuum_slot_if<F>( &self, rid: RecordId, predicate: F, ) -> QuillSQLResult<bool>

where F: FnOnce(&TupleMeta) -> bool,

Attempt to reclaim the tuple at rid if predicate returns true for the current metadata. Returns true when the tuple was removed.

Trait Implementations

impl Debug for TableHeap

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.