Struct Database 

pub struct Database { /* private fields */ }

A collection of tables and indexes over them.

A database also owns the memory pools used by its tables.

Implementations

impl Database

pub fn run_rule_set(&mut self, rule_set: &RuleSet) -> RuleSetReport

impl Database

pub fn new() -> Database

Create an empty Database.

Queries are executed using the current rayon thread pool, which defaults to the global thread pool.

pub fn new_rule_set(&mut self) -> RuleSetBuilder<'_>

Initialize a new rulse set to run against this database.

pub fn add_external_function( &mut self, f: impl ExternalFunction + 'static, ) -> ExternalFunctionId

Add a new external function to the database.

pub fn free_external_function(&mut self, id: ExternalFunctionId)

Free an existing external function. Make sure not to use id afterwards.

pub fn base_values(&self) -> &BaseValues

pub fn base_values_mut(&mut self) -> &mut BaseValues

pub fn container_values(&self) -> &ContainerValues

pub fn container_values_mut(&mut self) -> &mut ContainerValues

pub fn rebuild_containers(&mut self, table_id: TableId) -> bool

pub fn apply_rebuild( &mut self, func_id: TableId, to_rebuild: &[TableId], next_ts: Value, ) -> bool

Apply the value-level rebuild encoded by func_id to all the tables in to_rebuild.

The native Table::apply_rebuild method takes a next_ts argument for filling in new values in a table like crate::SortedWritesTable where values in a certain column need to be inserted in sorted order; the next_ts argument to this method is passed to apply_rebuild for this purpose.

pub fn with_execution_state<R>( &self, f: impl FnOnce(&mut ExecutionState<'_>) -> R, ) -> R

Run f with access to an ExecutionState mapped to this database.

pub fn estimate_size(&self, table: TableId, c: Option<Constraint>) -> usize

Estimate the size of the table. If a constraint is provided, return an estimate of the size of the subset of the table matching the constraint.

pub fn add_counter(&mut self) -> CounterId

Create a new counter for this database.

These counters can be used to generate unique ids as part of an action.

pub fn inc_counter(&self, counter: CounterId) -> usize

Increment the given counter and return its previous value.

pub fn read_counter(&self, counter: CounterId) -> usize

Get the current value of the given counter.

pub fn merge_all(&mut self) -> bool

A helper for merging all pending updates. Used to write to the database after updates have been staged. Returns true if any tuples were added.

Exposed for testing purposes.

Useful for out-of-band insertions into the database.

pub fn merge_table(&mut self, table: TableId)

A low-level helper for merging pending updates to a particular function.

Callers should prefer merge_all, as the process of merging the data for a particular table may cause other updates to be buffered elesewhere. The merge_all method runs merges to a fixed point to avoid surprises here.

pub fn next_table_id(&self) -> TableId

Get id of the next table to be added to the database.

This can be useful for “knot tying”, when tables need to reference their own id.

pub fn add_table<T: Table + Sized + 'static>( &mut self, table: T, read_deps: impl IntoIterator<Item = TableId>, write_deps: impl IntoIterator<Item = TableId>, ) -> TableId

Add a table with the given schema to the database.

The table must have a compatible spec with types (e.g. same number of columns).

pub fn get_table(&self, id: TableId) -> &WrappedTable

Get direct mutable access to the table.

This method is useful for out-of-band access to databse state.

pub fn get_table_mut(&mut self, id: TableId) -> &mut dyn Table

Get direct mutable access to the table.

This method is useful for out-of-band access to databse state.

Trait Implementations

impl Clone for Database

fn clone(&self) -> Database

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Database

fn default() -> Database

Returns the “default value” for a type.

impl Drop for Database

fn drop(&mut self)

Executes the destructor for this type.