Struct Pool 

pub struct Pool { /* private fields */ }

连接池核心实现

Implementations

impl Pool

pub fn new( config: PoolConfig, factory: Arc<dyn ConnectionFactory>, ) -> Result<Self, PoolError>

创建连接池

L-5 修复：补充示例文档

示例

use sz_orm_core::pool::{Pool, PoolConfig, PoolConfigBuilder, ConnectionFactory};
use std::sync::Arc;

struct MyFactory;
impl ConnectionFactory for MyFactory {
    // ...
}

let config = PoolConfigBuilder::new()
    .max_size(10)
    .acquire_timeout(std::time::Duration::from_secs(30))
    .build();
let pool = Pool::new(config, Arc::new(MyFactory))?;

pub fn config(&self) -> &PoolConfig

获取配置

pub async fn acquire(&self) -> Result<PooledConnection, PoolError>

从池中获取连接（带超时）

L-5 修复：补充示例文档

超时时间由 PoolConfig::acquire_timeout 控制，默认 30 秒。 若超时则返回 PoolError::AcquireTimeout。

示例

// 从池中获取连接
let conn = pool.acquire().await?;
// 使用连接执行查询...
// conn.query("SELECT 1").await?;

pub async fn release(&self, pooled: PooledConnection)

释放连接回池中 如果池已关闭或连接已断开，则直接关闭连接而不是放回池中。

接收 PooledConnection 以保留原始 created_at，避免 max_lifetime 在每次归还后被重置（Critical bug fix）。

pub async fn status(&self) -> PoolStatus

获取池状态

pub async fn reap_idle(&self)

回收空闲过久的连接

pub async fn close_all(&self)

关闭所有空闲连接，并标记池为已关闭 注意：已借出未归还的连接不受影响，但归还时会被直接关闭； 同时 close_all 后的新 acquire 也会被拒绝。

pub async fn health_check(&self) -> u32

M-7 修复：连接池健康检查（heartbeat）

对所有空闲连接执行 ping()，移除已断开或 ping 失败的连接。 调用方应定期调用此方法（如每 60 秒），以清理失效连接。

返回值

返回被移除的连接数。

注意

• 此方法会持锁等待所有 ping 完成，可能阻塞 acquire/release
• 仅检查空闲连接，不影响已借出的连接
• 对于大量空闲连接，可能产生较多并发 ping，建议在低峰期执行