Struct PostgresTransaction 

pub struct PostgresTransaction {
    pub writable: bool,
}

A transaction for reading and writing statements in PostgreSQL.

Fields

writable: bool

Implementations

impl PostgresTransaction

pub async fn begin( _store: &PostgresStore, writable: bool, ) -> Result<Self, PostgresError>

pub fn is_writable(&self) -> bool

Trait Implementations

impl Debug for PostgresTransaction

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

Formats the value using the given formatter.

impl ReadTransaction for PostgresTransaction

type Error = PostgresError

type Term = HeapTerm

type Statement = Quad<HeapTerm>

type StatementPattern = QuadPattern<HeapTerm>

fn match( &self, _pattern: impl Into<Self::StatementPattern>, ) -> impl Stream<Item = Result<Self::Statement, Self::Error>>

Returns a stream of all statements matching the given statement pattern.

fn is_empty(&self) -> impl Future<Output = Result<bool, Self::Error>> + Send

Returns true if the store is empty (contains no statements).

fn contexts(&self) -> impl Stream<Item = Result<Self::Term, Self::Error>> + Send

Returns a stream of all context terms (graph names) in the store.

fn contains( &self, pattern: impl Into<Self::StatementPattern> + Send, ) -> impl Future<Output = Result<bool, Self::Error>> + Send

Returns true if the store contains the given statement (pattern).

fn count( &self, pattern: impl Into<Self::StatementPattern> + Send, ) -> impl Future<Output = Result<u64, Self::Error>> + Send

Returns the number of statements matching the given statement pattern.

impl WriteTransaction for PostgresTransaction

type Error = PostgresError

type Term = HeapTerm

type Statement = Quad<HeapTerm>

type StatementPattern = QuadPattern<HeapTerm>

async fn rollback(self) -> Result<(), Self::Error>

Aborts the transaction, discarding any changes.

async fn commit(self) -> Result<(), Self::Error>

Commits the transaction, applying all changes.

async fn clear(&mut self) -> Result<(), Self::Error>

Clears all data from the store.

async fn insert( &mut self, _statement: impl Into<Self::Statement> + Send, ) -> Result<(), Self::Error>

Inserts a statement into the store.

async fn remove( &mut self, _statement: impl Into<Self::Statement> + Send, ) -> Result<(), Self::Error>

Removes a statement from the store.

async fn delete( &mut self, _pattern: impl Into<Self::StatementPattern> + Send, ) -> Result<(), Self::Error>

Deletes all statements matching the given statement pattern.