Struct ConstraintService 

pub struct ConstraintService<P>
where
    P: Pager<Blob = EntryHandle> + Send + Sync,
{ /* private fields */ }

High-level constraint service API intended for runtime consumers.

Implementations

impl<P> ConstraintService<P>

where P: Pager<Blob = EntryHandle> + Send + Sync,

pub fn new( metadata: Arc<MetadataManager<P>>, catalog: Arc<TableCatalog>, ) -> Self

Create a new constraint validation service.

pub fn validate_insert_foreign_keys<F>( &self, referencing_table_id: TableId, schema_field_ids: &[FieldId], column_order: &[usize], rows: &[Vec<PlanValue>], fetch_parent_rows: F, ) -> LlkvResult<()>

where F: FnMut(ForeignKeyRowFetch<'_>) -> LlkvResult<Vec<Vec<PlanValue>>>,

Validate that incoming INSERT rows satisfy the table’s foreign key constraints.

pub fn validate_insert_constraints<FSingle, FMulti>( &self, schema_field_ids: &[FieldId], column_constraints: &[InsertColumnConstraint], unique_columns: &[InsertUniqueColumn], multi_column_uniques: &[InsertMultiColumnUnique], primary_key: Option<&InsertMultiColumnUnique>, column_order: &[usize], rows: &[Vec<PlanValue>], fetch_column_values: FSingle, fetch_multi_column_rows: FMulti, ) -> LlkvResult<()>

where FSingle: FnMut(FieldId) -> LlkvResult<Vec<PlanValue>>, FMulti: FnMut(&[FieldId]) -> LlkvResult<Vec<Vec<PlanValue>>>,

Validate INSERT rows against all table constraints including primary keys, unique constraints, and CHECK expressions. This is a comprehensive validation that combines uniqueness checks (both single-column and multi-column) with row-level CHECK constraint evaluation.

pub fn validate_row_level_constraints( &self, schema_field_ids: &[FieldId], column_constraints: &[InsertColumnConstraint], column_order: &[usize], rows: &[Vec<PlanValue>], ) -> LlkvResult<()>

Validate rows against CHECK constraints. This method evaluates CHECK expressions for each row, ensuring they satisfy the table’s row-level constraint rules.

pub fn validate_primary_key_rows<F>( &self, schema_field_ids: &[FieldId], primary_key: &InsertMultiColumnUnique, column_order: &[usize], rows: &[Vec<PlanValue>], fetch_multi_column_rows: F, ) -> LlkvResult<()>

where F: FnMut(&[FieldId]) -> LlkvResult<Vec<Vec<PlanValue>>>,

Validate that INSERT rows satisfy the primary key constraint by checking for duplicates against both existing rows in the table and within the new batch.

pub fn validate_update_primary_keys<F>( &self, schema_field_ids: &[FieldId], primary_key: &InsertMultiColumnUnique, column_order: &[usize], rows: &[Vec<PlanValue>], original_keys: &[Option<UniqueKey>], fetch_multi_column_rows: F, ) -> LlkvResult<()>

where F: FnMut(&[FieldId]) -> LlkvResult<Vec<Vec<PlanValue>>>,

Validate UPDATE operations that modify primary key columns. Ensures that updated primary key values don’t conflict with existing rows (excluding the original row being updated).

pub fn validate_delete_foreign_keys<FParents, FChildren>( &self, referenced_table_id: TableId, referenced_row_ids: &[RowId], fetch_parent_rows: FParents, fetch_child_rows: FChildren, ) -> LlkvResult<()>

where FParents: FnMut(ForeignKeyParentRowsFetch<'_>) -> LlkvResult<Vec<Vec<PlanValue>>>, FChildren: FnMut(ForeignKeyChildRowsFetch<'_>) -> LlkvResult<Vec<(RowId, Vec<PlanValue>)>>,

Validate that deleting the given rows will not violate foreign key constraints.

pub fn validate_update_foreign_keys<FParents, FChildren>( &self, referenced_table_id: TableId, referenced_row_ids: &[RowId], updated_field_ids: &[FieldId], fetch_parent_rows: FParents, fetch_child_rows: FChildren, ) -> LlkvResult<()>

where FParents: FnMut(ForeignKeyParentRowsFetch<'_>) -> LlkvResult<Vec<Vec<PlanValue>>>, FChildren: FnMut(ForeignKeyChildRowsFetch<'_>) -> LlkvResult<Vec<(RowId, Vec<PlanValue>)>>,

Validate that updating the given rows will not violate foreign key constraints.

This checks if any columns being updated are referenced by foreign keys, and whether the OLD values are still being referenced by child tables.

pub fn referencing_foreign_keys( &self, referenced_table_id: TableId, ) -> LlkvResult<Vec<ForeignKeyView>>

Return the set of foreign keys referencing the provided table.

Trait Implementations

impl<P> Clone for ConstraintService<P>

where P: Pager<Blob = EntryHandle> + Send + Sync + Clone,

fn clone(&self) -> ConstraintService<P>

Returns a duplicate of the value.

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

Performs copy-assignment from source.