Struct PreparedStatement

pub struct PreparedStatement<T> {
    flight_sql_client: FlightSqlServiceClient<T>,
    parameter_binding: Option<RecordBatch>,
    handle: Bytes,
    dataset_schema: Schema,
    parameter_schema: Schema,
}

A PreparedStatement

Fields

flight_sql_client: FlightSqlServiceClient<T>

parameter_binding: Option<RecordBatch>

handle: Bytes

dataset_schema: Schema

parameter_schema: Schema

Implementations

impl PreparedStatement<Channel>

pub(crate) fn new( flight_client: FlightSqlServiceClient<Channel>, handle: impl Into<Bytes>, dataset_schema: Schema, parameter_schema: Schema, ) -> Self

pub async fn execute(&mut self) -> Result<FlightInfo, ArrowError>

Executes the prepared statement query on the server.

pub async fn execute_update(&mut self) -> Result<i64, ArrowError>

Executes the prepared statement update query on the server.

pub fn parameter_schema(&self) -> Result<&Schema, ArrowError>

Retrieve the parameter schema from the query.

pub fn dataset_schema(&self) -> Result<&Schema, ArrowError>

Retrieve the ResultSet schema from the query.

pub fn set_parameters( &mut self, parameter_binding: RecordBatch, ) -> Result<(), ArrowError>

Set a RecordBatch that contains the parameters that will be bind.

async fn write_bind_params(&mut self) -> Result<(), ArrowError>

Submit parameters to the server, if any have been set on this prepared statement instance Updates our stored prepared statement handle with the handle given by the server response.

fn unpack_prepared_statement_handle( &self, put_result: &PutResult, ) -> Result<Option<Bytes>, ArrowError>

Decodes the app_metadata stored in a PutResult as a DoPutPreparedStatementResult and then returns the inner prepared statement handle as [Bytes]

pub async fn close(self) -> Result<(), ArrowError>

Close the prepared statement, so that this PreparedStatement can not used anymore and server can free up any resources.

Trait Implementations

impl<T: Clone> Clone for PreparedStatement<T>

fn clone(&self) -> PreparedStatement<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for PreparedStatement<T>

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

Formats the value using the given formatter.