Skip to main content

Database

ic_dbms_api::dbms::database

Trait Database 

Source 
pub trait Database {
    // Required methods
    fn select<T>(
        &self,
        query: Query,
    ) -> Result<Vec<<T as TableSchema>::Record>, DbmsError>
       where T: TableSchema;
    fn select_raw(
        &self,
        table: &str,
        query: Query,
    ) -> Result<Vec<Vec<(ColumnDef, Value)>>, DbmsError>;
    fn insert<T>(
        &self,
        record: <T as TableSchema>::Insert,
    ) -> Result<(), DbmsError>
       where T: TableSchema,
             <T as TableSchema>::Insert: InsertRecord<Schema = T>;
    fn update<T>(
        &self,
        patch: <T as TableSchema>::Update,
    ) -> Result<u64, DbmsError>
       where T: TableSchema,
             <T as TableSchema>::Update: UpdateRecord<Schema = T>;
    fn delete<T>(
        &self,
        behaviour: DeleteBehavior,
        filter: Option<Filter>,
    ) -> Result<u64, DbmsError>
       where T: TableSchema;
    fn commit(&mut self) -> Result<(), DbmsError>;
    fn rollback(&mut self) -> Result<(), DbmsError>;
}
Expand description

This module defines the Database trait and related database functionalities.

Required Methods§

Source

fn select<T>( &self, query: Query, ) -> Result<Vec<<T as TableSchema>::Record>, DbmsError>
where T: TableSchema,

Executes a SELECT query and returns the results.

§Arguments
  • query - The SELECT Query to be executed.
§Returns

The returned results are a vector of [table::TableRecord] matching the query.

Source

fn select_raw( &self, table: &str, query: Query, ) -> Result<Vec<Vec<(ColumnDef, Value)>>, DbmsError>

Executes a generic SELECT and returns raw column-value pairs.

Unlike Database::select, this method does not require a concrete table type. It takes a table name and dispatches internally.

Source

fn insert<T>(&self, record: <T as TableSchema>::Insert) -> Result<(), DbmsError>
where T: TableSchema, <T as TableSchema>::Insert: InsertRecord<Schema = T>,

Executes an INSERT query.

§Arguments
  • record - The INSERT record to be executed.
Source

fn update<T>(&self, patch: <T as TableSchema>::Update) -> Result<u64, DbmsError>
where T: TableSchema, <T as TableSchema>::Update: UpdateRecord<Schema = T>,

Executes an UPDATE query.

§Arguments
  • patch - The UPDATE patch to be applied.
  • filter - An optional Filter to specify which records to update.
§Returns

The number of rows updated.

Source

fn delete<T>( &self, behaviour: DeleteBehavior, filter: Option<Filter>, ) -> Result<u64, DbmsError>
where T: TableSchema,

Executes a DELETE query.

§Arguments
  • behaviour - The DeleteBehavior to apply for foreign key constraints.
  • filter - An optional Filter to specify which records to delete.
§Returns

The number of rows deleted.

Source

fn commit(&mut self) -> Result<(), DbmsError>

Commits the current transaction.

The transaction is consumed.

Any error during commit will panic to ensure consistency.

Source

fn rollback(&mut self) -> Result<(), DbmsError>

Rolls back the current transaction.

The transaction is consumed.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§