Struct DatabaseManager 

pub struct DatabaseManager { /* private fields */ }

DuckDB 数据库管理器 - 针对并发特性优化

设计原则：

• 文件数据库：每个操作创建新连接，天然支持并发读
• 内存数据库：使用单一连接+Mutex，确保数据一致性
• 写操作：串行执行，避免write-write conflict
• 重试机制：检测冲突并实现指数退避重试

Implementations

impl DatabaseManager

pub async fn new<P: AsRef<Path>>(db_path: P) -> Result<Self>

创建新的数据库管理器（文件数据库）

pub async fn new_memory() -> Result<Self>

创建内存数据库管理器（主要用于测试）

pub async fn init_database(&self) -> Result<()>

显式初始化数据库（只应在 nuwax-cli init 时调用）

pub async fn read_with_retry<F, R>(&self, operation: F) -> Result<R>

where F: Fn(&Connection) -> DuckResult<R> + Send + Sync, R: Send,

并发读操作（文件数据库支持真正的并发）

pub async fn write_with_retry<F, R>(&self, operation: F) -> Result<R>

where F: Fn(&Connection) -> DuckResult<R> + Send + Sync, R: Send,

并发写操作（确保写入一致性）

pub async fn batch_write_with_retry<F, R>(&self, operations: F) -> Result<R>

where F: Fn(&Connection) -> DuckResult<R> + Send + Sync, R: Send,

批量写操作（事务中执行多个写操作） 注意：这个方法接受一个闭包，该闭包会在事务上下文中执行

pub async fn initialize_schema(&self) -> Result<()>

初始化数据库表结构

pub fn get_connection_stats(&self) -> ConnectionStats

获取连接统计信息

pub async fn health_check(&self) -> Result<HealthStatus>

健康检查

Trait Implementations

impl Clone for DatabaseManager

fn clone(&self) -> DatabaseManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.