Struct PgMutationExecutor 

pub struct PgMutationExecutor { /* private fields */ }

Implementations

impl PgMutationExecutor

pub fn new(pool: Pool) -> Self

pub fn pool(&self) -> Pool

pub async fn ensure_schema( &self, dialect: &PostgresDialect, entities: &[&EntityDescriptor], ) -> Result<(), MutationExecutorError>

pub async fn ensure_id_space_table( &self, table_name: &str, ) -> Result<(), MutationExecutorError>

pub async fn execute( &self, query: &CompiledQuery, ) -> Result<u64, MutationExecutorError>

pub async fn fetch_all( &self, query: &CompiledQuery, ) -> Result<Vec<Record>, MutationExecutorError>

Trait Implementations

impl Clone for PgMutationExecutor

fn clone(&self) -> PgMutationExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl SqlTransaction for PgMutationExecutor

type Error = MutationExecutorError

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

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

impl SqlTransactionTransport for PgMutationExecutor

type Tx<'a> = PgMutationExecutor where Self: 'a

async fn begin_sql(&self) -> Result<Self::Tx<'_>, Self::Error>

impl SqlTransport for PgMutationExecutor

type Error = MutationExecutorError

async fn fetch_all_sql( &self, query: &CompiledQuery, ) -> Result<Vec<Record>, Self::Error>

async fn execute_sql(&self, query: &CompiledQuery) -> Result<u64, Self::Error>