Struct Conn 

pub struct Conn { /* private fields */ }

Implementations

impl Conn

pub fn new<O: TryInto<Opts>>(opts: O) -> Result<Self>

where Error: From<O::Error>,

Create a new MySQL connection from connection options

pub fn new_with_stream(stream: Stream, opts: &Opts) -> Result<Self>

Create a new MySQL connection with an existing stream

pub fn server_version(&self) -> &[u8]

Example: "11.4.8-MariaDB"

pub fn capability_flags(&self) -> CapabilityFlags

Get the negotiated capability flags

pub fn is_mysql(&self) -> bool

Check if the server is MySQL (as opposed to MariaDB)

pub fn is_mariadb(&self) -> bool

Check if the server is MariaDB (as opposed to MySQL)

pub fn connection_id(&self) -> u64

Get the connection ID assigned by the server

pub fn status_flags(&self) -> ServerStatusFlags

Get the server status flags from the initial handshake

pub fn is_broken(&self) -> bool

Indicates if the connection is broken by errors

This state is used by Pool to decide if this Conn can be reset and reused or dropped.

pub fn prepare(&mut self, sql: &str) -> Result<PreparedStatement>

Returns Ok(statement_id) on success

pub fn exec<'conn, P, H>( &'conn mut self, stmt: &'conn mut PreparedStatement, params: P, handler: &mut H, ) -> Result<()>

where P: Params, H: BinaryResultSetHandler,

Executes a prepared statement with parameters.

This is the most general version of exec_*() methods.

pub fn exec_bulk_insert_or_update<P, I, H>( &mut self, stmt: &mut PreparedStatement, params: P, flags: BulkFlags, handler: &mut H, ) -> Result<()>

where P: BulkParamsSet + IntoIterator<Item = I>, I: Params, H: BinaryResultSetHandler,

Execute a bulk prepared statement with a result set handler.

On MariaDB, this sends all parameters in a single packet using the bulk command extension. On Oracle MySQL, this falls back to multiple exec() calls.

pub fn exec_first<Row, P>( &mut self, stmt: &mut PreparedStatement, params: P, ) -> Result<Option<Row>>

where Row: for<'buf> FromRawRow<'buf>, P: Params,

Execute a prepared statement and return only the first row, dropping the rest.

pub fn exec_drop<P>( &mut self, stmt: &mut PreparedStatement, params: P, ) -> Result<()>

where P: Params,

Execute a prepared statement and discard all results

pub fn exec_collect<Row, P>( &mut self, stmt: &mut PreparedStatement, params: P, ) -> Result<Vec<Row>>

where Row: for<'buf> FromRawRow<'buf>, P: Params,

Execute a prepared statement and collect all rows into a Vec.

pub fn exec_foreach<Row, P, F>( &mut self, stmt: &mut PreparedStatement, params: P, f: F, ) -> Result<()>

where Row: for<'buf> FromRawRow<'buf>, P: Params, F: FnMut(Row) -> Result<()>,

Execute a prepared statement and call a closure for each row.

The closure can return an error to stop iteration early.

pub fn query<H>(&mut self, sql: &str, handler: &mut H) -> Result<()>

where H: TextResultSetHandler,

Execute a text protocol SQL query

pub fn query_drop(&mut self, sql: &str) -> Result<()>

Execute a text protocol SQL query and discard the result

pub fn ping(&mut self) -> Result<()>

Send a ping to the server to check if the connection is alive

This sends a COM_PING command to the MySQL server and waits for an OK response.

pub fn reset(&mut self) -> Result<()>

Reset the connection to its initial state

pub fn run_transaction<F, R>(&mut self, f: F) -> Result<R>

where F: FnOnce(&mut Conn, Transaction) -> Result<R>,

Execute a closure within a transaction

Errors

Returns Error::NestedTransaction if called while already in a transaction