Struct TransactionStatementHook 

pub struct TransactionStatementHook;

Hook for processing transaction related statements

Note that this hook doesn’t create actual transactions. It just responds with reasonable return values.

Trait Implementations

impl Debug for TransactionStatementHook

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

Formats the value using the given formatter.

impl QueryHook for TransactionStatementHook

fn handle_simple_query<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, statement: &'life1 Statement, _session_context: &'life2 SessionContext, client: &'life3 mut (dyn ClientInfo + Send + Sync), ) -> Pin<Box<dyn Future<Output = Option<PgWireResult<Response>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

called in simple query handler to return response directly

fn handle_extended_parse_query<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, stmt: &'life1 Statement, _session_context: &'life2 SessionContext, _client: &'life3 (dyn ClientInfo + Send + Sync), ) -> Pin<Box<dyn Future<Output = Option<PgWireResult<LogicalPlan>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

called at extended query parse phase, for generating LogicalPlanfrom statement

fn handle_extended_query<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, statement: &'life1 Statement, _logical_plan: &'life2 LogicalPlan, _params: &'life3 ParamValues, session_context: &'life4 SessionContext, client: &'life5 mut (dyn ClientInfo + Send + Sync), ) -> Pin<Box<dyn Future<Output = Option<PgWireResult<Response>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

called at extended query execute phase, for query execution