Struct ExtendedQueryStateMachine 

pub struct ExtendedQueryStateMachine<'a, H> { /* private fields */ }

Extended query protocol state machine.

Implementations

impl<'a, H: ExtendedHandler> ExtendedQueryStateMachine<'a, H>

pub fn take_prepared_statement(&mut self) -> Option<PreparedStatement>

Take the prepared statement (after prepare completes).

pub fn prepare( handler: &'a mut H, buffer_set: &mut BufferSet, idx: u64, query: &str, param_oids: &[Oid], ) -> Self

Prepare a statement.

Writes Parse + DescribeStatement + Sync to buffer_set.write_buffer.

pub fn execute<P: ToParams>( handler: &'a mut H, buffer_set: &mut BufferSet, statement_name: &str, param_oids: &[Oid], params: &P, ) -> Result<Self>

Execute a prepared statement.

Writes Bind + DescribePortal + Execute + Sync to buffer_set.write_buffer.

Uses the server-provided parameter OIDs to encode parameters, which allows flexible type conversion (e.g., i64 encoded as INT4 if server expects INT4).

pub fn execute_sql<P: ToParams>( handler: &'a mut H, buffer_set: &mut BufferSet, sql: &str, params: &P, ) -> Result<Self>

Execute raw SQL (unnamed statement).

Writes Parse + Bind + DescribePortal + Execute + Sync to buffer_set.write_buffer.

Uses the natural OIDs from the parameters to inform the server about parameter types, which prevents “incorrect binary data format” errors when the server would otherwise infer a different type (e.g., INT4 vs INT8).

pub fn close_statement( handler: &'a mut H, buffer_set: &mut BufferSet, name: &str, ) -> Self

Close a prepared statement.

Writes Close + Sync to buffer_set.write_buffer.

Trait Implementations

impl<H: ExtendedHandler> StateMachine for ExtendedQueryStateMachine<'_, H>

fn step(&mut self, buffer_set: &mut BufferSet) -> Result<Action>

Process input and return the next action to perform.

fn transaction_status(&self) -> TransactionStatus

Get the transaction status from the final ReadyForQuery.