Struct MySqlAsyncConnection 

pub struct MySqlAsyncConnection { /* private fields */ }

Async MySQL connection.

This connection uses asupersync’s TCP stream for non-blocking I/O and implements the Connection trait from sqlmodel-core.

Implementations

impl MySqlAsyncConnection

pub async fn connect(_cx: &Cx, config: MySqlConfig) -> Outcome<Self, Error>

Establish a new async connection to the MySQL server.

This performs the complete connection handshake asynchronously:

1. TCP connection
2. Receive server handshake
3. Send handshake response with authentication
4. Handle auth result (possibly auth switch)

pub fn state(&self) -> ConnectionState

Get the current connection state.

pub fn is_ready(&self) -> bool

Check if the connection is ready for queries.

pub fn connection_id(&self) -> u32

Get the connection ID.

pub fn server_version(&self) -> Option<&str>

Get the server version.

pub fn affected_rows(&self) -> u64

Get the number of affected rows from the last statement.

pub fn last_insert_id(&self) -> u64

Get the last insert ID.

pub async fn query_async( &mut self, _cx: &Cx, sql: &str, params: &[Value], ) -> Outcome<Vec<Row>, Error>

Execute a text protocol query asynchronously.

pub async fn execute_async( &mut self, cx: &Cx, sql: &str, params: &[Value], ) -> Outcome<u64, Error>

Execute a statement asynchronously and return affected rows.

This is similar to query_async but returns the number of affected rows instead of the result set. Useful for INSERT, UPDATE, DELETE statements.

pub async fn prepare_async( &mut self, _cx: &Cx, sql: &str, ) -> Outcome<PreparedStatement, Error>

Prepare a statement for later execution using the binary protocol.

This sends COM_STMT_PREPARE to the server and stores the metadata needed for later execution via query_prepared_async or execute_prepared_async.

pub async fn query_prepared_async( &mut self, _cx: &Cx, stmt: &PreparedStatement, params: &[Value], ) -> Outcome<Vec<Row>, Error>

Execute a prepared statement and return result rows (binary protocol).

pub async fn execute_prepared_async( &mut self, cx: &Cx, stmt: &PreparedStatement, params: &[Value], ) -> Outcome<u64, Error>

Execute a prepared statement and return affected row count.

pub async fn close_prepared_async(&mut self, stmt: &PreparedStatement)

Close a prepared statement.

pub async fn ping_async(&mut self, _cx: &Cx) -> Outcome<(), Error>

Ping the server asynchronously.

pub async fn close_async(self, _cx: &Cx) -> Result<(), Error>

Close the connection asynchronously.

Trait Implementations

impl Debug for MySqlAsyncConnection

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

Formats the value using the given formatter.