Struct TableRegistry 

pub struct TableRegistry { /* private fields */ }

The table registry takes care of storing the records for each table, using the [FreeSegmentsLedger] and [PageLedger] to derive exactly where to read/write.

A registry is generic over a record, which must implement Encode.

The CRUD operations provided by the table registry do NOT perform any logical checks, but just allow to read/write records from/to memory. So CRUD checks must be performed by a higher layer, prior to calling these methods.

Implementations

impl TableRegistry

pub fn load( table_pages: TableRegistryPage, mm: &mut impl MemoryAccess, ) -> MemoryResult<Self>

Loads the table registry from memory.

pub fn insert<E>( &mut self, record: E, mm: &mut impl MemoryAccess, ) -> MemoryResult<RecordAddress>

where E: Encode,

Inserts a new record into the table registry.

Returns the address where the record was inserted, which can be used to read it back or to update/delete it.

NOTE: this function does NOT make any logical checks on the record being inserted.

pub fn read<'a, E, MA>(&'a self, mm: &'a mut MA) -> TableReader<'a, E, MA>

where E: Encode, MA: MemoryAccess,

Creates a TableReader to read records from the table registry.

Use TableReader::try_next to read records one by one.

pub fn read_at<E, MA>( &self, address: RecordAddress, mm: &mut MA, ) -> MemoryResult<E>

where E: Encode, MA: MemoryAccess,

Reads a single record at the given address.

pub fn delete( &mut self, record: impl Encode, address: RecordAddress, mm: &mut impl MemoryAccess, ) -> MemoryResult<()>

Deletes a record at the given page and offset.

The space occupied by the record is marked as free and zeroed.

pub fn update( &mut self, new_record: impl Encode, old_record: impl Encode, old_address: RecordAddress, mm: &mut impl MemoryAccess, ) -> MemoryResult<RecordAddress>

Updates a record at the given page and offset.

The RecordAddress of the new record is returned, which can be different from the old one if the record was reallocated.

The logic is the following:

1. If the new record has exactly the same size of the old record, overwrite it in place.
2. If the new record does not fit, delete the old record and insert the new record.

pub fn index_ledger(&self) -> &IndexLedger

Get a reference to the index ledger, allowing to read the indexes.

pub fn index_ledger_mut(&mut self) -> &mut IndexLedger

Get a mutable reference to the index ledger, allowing to modify the indexes.

pub fn next_autoincrement( &mut self, column_name: &str, mm: &mut impl MemoryAccess, ) -> MemoryResult<Option<Value>>

Get next value for an autoincrement column of the given type, and increment it in the ledger.