Struct DbPool 

pub struct DbPool { /* private fields */ }

数据库连接池包装器

提供了对 SQLx 连接池的高级封装，支持连接管理、查询执行和事务操作。

示例

use baichun_framework_db::{DatabaseConfig, DbPool};

async fn example() -> Result<()> {
    // 创建连接池
    let config = DatabaseConfig::new()
        .url("mysql://user:pass@localhost/db_name")
        .max_connections(10);
    let pool = DbPool::new(&config).await?;

    // 执行查询
    pool.execute("CREATE TABLE users (id INT PRIMARY KEY)").await?;

    // 开始事务
    let tx = pool.begin().await?;
    // ... 执行事务操作 ...

    Ok(())
}

Implementations

impl DbPool

pub async fn new(config: &DatabaseConfig) -> Result<Self>

创建新的数据库连接池

根据提供的配置创建一个新的连接池实例。

pub fn pool(&self) -> &Pool<MySql>

获取底层的 SQLx 连接池

用于需要直接访问 SQLx 功能的场景。

pub async fn begin(&self) -> Result<Transaction<'_, MySql>>

开始新的事务

返回一个事务对象，可以用于执行事务操作。

pub async fn execute(&self, query: &str) -> Result<MySqlQueryResult>

执行不返回结果的查询

适用于 DDL 语句或不需要返回结果的 DML 语句。

pub fn metrics(&self) -> DbMetrics

获取数据库连接池指标

返回当前连接池的状态信息，包括总连接数、活动连接数等。

Trait Implementations

impl Clone for DbPool

fn clone(&self) -> DbPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.