Struct NativeMySqlBackend 

pub struct NativeMySqlBackend { /* private fields */ }

MySQL ORM adapter using retained clean mysql_async sessions.

Implementations

impl NativeMySqlBackend

pub async fn connect(url: &str) -> Result<Self, BackendError>

Connect with the default bounded admission settings.

Args: url: MySQL connection URL, including the database name.

Returns: A connected native backend, or a configuration/connection error.

pub async fn connect_with( url: &str, options: NativeMySqlOptions, ) -> Result<Self, BackendError>

Connect with explicit admission and checkout limits.

Args: url: Native-driver MySQL connection URL. options: Connection count, waiting count and checkout deadline.

Returns: A connected backend, or an invalid configuration/connection error.

pub async fn connect_options( connection: Opts, options: NativeMySqlOptions, ) -> Result<Self, BackendError>

Connect with native options, including verified TLS and custom roots.

Args: connection: Driver options; TLS roots and identity policy retained. options: Connection count, admission and checkout deadline.

Returns: Warm backend, or configuration/session/connection failure.

Native pool bounds, session setup, found-rows and statement cache override corresponding driver settings to preserve adapter contracts. Custom initialization must leave no transaction or lock open.

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

Disconnect the pool after all held connections have been released.

Returns: Success after disconnect, or the native driver error.

pub async fn warm(&self) -> Result<(), BackendError>

Initialize all configured pool slots within one checkout deadline.

Returns: Success after every slot is configured, or a checkout/setup error.

Trait Implementations

impl Backend for NativeMySqlBackend

fn read_parameter_count( &self, plan: &QueryPlan, ) -> Result<Option<usize>, OrmError>

Count compiled read parameters without database I/O.

fn begin<'life0, 'async_trait>( &'life0 self, isolation: Option<IsolationLevel>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Transaction>, OrmError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Begin a transaction on a dedicated connection.

fn begin_schema<'life0, 'async_trait>( &'life0 self, transactional: bool, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Transaction>, OrmError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connection for a schema migration.

impl Clone for NativeMySqlBackend

fn clone(&self) -> NativeMySqlBackend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NativeMySqlBackend

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

Formats the value using the given formatter.

impl Executor for NativeMySqlBackend

fn capabilities(&self) -> BackendCapabilities

Declared capabilities.

fn fetch<'life0, 'life1, 'async_trait>( &'life0 self, plan: &'life1 QueryPlan, ) -> Pin<Box<dyn Future<Output = Result<QueryResult, OrmError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute a read plan.

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, plan: &'life1 WritePlan, ) -> Pin<Box<dyn Future<Output = Result<ExecResult, OrmError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute a write plan.

fn fetch_raw<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, params: Vec<Value>, ) -> Pin<Box<dyn Future<Output = Result<QueryResult, OrmError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Run raw SQL returning rows. params are bound, never interpolated.

fn execute_raw<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, args: Vec<Value>, ) -> Pin<Box<dyn Future<Output = Result<u64, OrmError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Run raw SQL returning the affected-row count. params are bound.

fn execute_script<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), OrmError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Run a multi-statement script without parameters (DDL, migrations).