Struct Conn 

pub struct Conn { /* private fields */ }

Implementations

impl Conn

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

where Error: From<O::Error>,

Create a new MySQL connection from connection options (async)

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

Create a new MySQL connection with an existing stream (async)

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

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

Check if the connection is broken due to a previous I/O error

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

Prepare a statement and return the PreparedStatement (async)

Returns Ok(PreparedStatement) on success.

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

where P: Params, H: BinaryResultSetHandler,

Execute a prepared statement with a result set handler (async)

pub async 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 (async)

pub async fn exec_first<P, H>( &mut self, stmt: &mut PreparedStatement, params: P, handler: &mut H, ) -> Result<bool>

where P: Params, H: BinaryResultSetHandler,

Execute a prepared statement and return only the first row, dropping the rest (async)

Returns

• Ok(true) - First row was found and processed
• Ok(false) - No rows in result set
• Err(Error) - Query execution or handler callback failed

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

where P: Params,

Execute a prepared statement and discard all results (async)

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

where H: TextResultSetHandler,

Execute a text protocol SQL query (async)

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

Execute a text protocol SQL query and discard all results (async)

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

Send a ping to the server to check if the connection is alive (async)

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

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

Reset the connection to its initial state (async)

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

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

Execute a closure within a transaction (async)

Errors

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