Struct Transaction 

pub struct Transaction { /* private fields */ }

Implementations

impl Transaction

pub fn new() -> Self

创建一个无 backing 连接的空事务。

只能作为占位符用于「不执行任何语句」的场景；在其中执行 SQL 会返回错误。 需要真正执行语句时用 Transaction::with_inner 或后端的 transaction()。

pub fn with_inner(inner: Box<dyn TransactionInner>) -> Self

pub async fn commit(self) -> Result<(), RdbmsError>

pub async fn rollback(self) -> Result<(), RdbmsError>

Trait Implementations

impl Default for Transaction

fn default() -> Self

Returns the “default value” for a type.

impl Drop for Transaction

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl SqlExecutor for Transaction

fn execute_then_query<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, first: &'life1 str, first_params: &'life2 [Value], second: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>, RdbmsError>> + Send + 'async_trait>>

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

在调用方已有的事务里跑两条语句：不另开事务，也不提交 —— 原子边界归调用方，insert(&tx, …) 的语义就是「用我这个事务发这两条」。

全程持锁：若在两条语句之间放开，并发的 tx.execute(…)（同一条连接上的 另一个 INSERT）会把 LAST_INSERT_ID() 的值换成它插的那条 —— 正是本方法要挡的静默错值。

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

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

执行一条 SQL 语句，返回受影响行数。 用户提供的值请走 SqlExecutor::execute_with。

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

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

查询多行。用户提供的值请走 SqlExecutor::query_with。

fn execute_with<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Result<u64, RdbmsError>> + Send + 'async_trait>>

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

参数化执行，防注入。无法绑定参数的后端返回错误。

fn query_with<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>, RdbmsError>> + Send + 'async_trait>>

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

参数化查询，防注入。无法绑定参数的后端返回错误。

fn dialect(&self) -> Dialect

本执行器背后的数据库方言。

fn query_write<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>, RdbmsError>> + Send + 'async_trait>>

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

写路径且需要返回结果（INSERT ... RETURNING / OUTPUT INSERTED）。 默认委托给 SqlExecutor::query_with；只有读写分离路由需要覆写， 否则写语句会被路由到从库。