Struct DuckDbConnection 

pub struct DuckDbConnection { /* private fields */ }

DuckDB 连接包装器

v0.3.0 性能优化：使用连接池（Vec<duckdb::Connection>）替代单 Mutex<Connection>。

通过 Connection::try_clone() 创建多个连接共享同一个 DatabaseHandle， 每个 spawn_blocking 任务从池中获取一个连接，执行后归还。 Semaphore 限制并发数 = 连接池大小，实现真正的并行查询。

Implementations

impl DuckDbConnection

pub fn new(url: &str) -> Result<Self, DbError>

创建新的 DuckDB 连接（默认连接池大小 4）

参数

• url - DuckDB 连接字符串，支持：
  • :memory: 或 duckdb::memory: — 内存数据库
  • duckdb:path/to/file.db — 文件数据库
  • duckdb://path/to/file.db — 文件数据库（URL 格式）

错误

连接创建失败时返回 DbError::Connection

示例

use dbnexus::database::pool::DuckDbConnection;

let conn = DuckDbConnection::new("duckdb::memory:")?;

pub fn with_pool_size(url: &str, pool_size: usize) -> Result<Self, DbError>

创建指定连接池大小的 DuckDB 连接

参数

• url - DuckDB 连接字符串
• pool_size - 连接池大小（并发查询数）

pub async fn execute(&self, sql: &str) -> DbResult<DuckDbExecResult>

执行 SQL（DDL/DML），返回受影响行数

v0.3.0 连接池模式：从池中取出连接 → spawn_blocking 执行 → 归还连接

pub async fn query(&self, sql: &str) -> DbResult<Vec<DuckDbRow>>

执行查询，返回结果行集合

v0.3.0 连接池模式：从池中取出连接 → spawn_blocking 执行 → 归还连接

pub async fn health_check(&self) -> DbResult<()>

健康检查（执行 SELECT 1）

错误

连接不可用时返回 DbError::Connection

pub fn pool_size(&self) -> usize

获取连接池大小

Trait Implementations

impl Clone for DuckDbConnection

fn clone(&self) -> DuckDbConnection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DuckDbConnection

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

Formats the value using the given formatter.