Struct Database 

pub struct Database { /* private fields */ }

数据库管理器 - DuckDB适配器

Implementations

impl Database

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

连接到数据库

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

连接到内存数据库 (主要用于测试，生产环境建议使用connect()以确保数据持久化)

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

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

pub async fn is_database_initialized(&self) -> Result<bool>

检查数据库是否已经初始化

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

运行数据库迁移 (DuckDB版本中此方法为空操作，因为表在初始化时自动创建)

pub async fn get_or_create_client_uuid(&self) -> Result<Uuid>

获取或创建客户端 UUID

pub async fn get_client_uuid(&self) -> Result<Option<Uuid>>

从数据库获取客户端UUID

pub async fn set_client_uuid(&self, uuid: &Uuid) -> Result<()>

设置客户端UUID

pub async fn update_client_id(&self, client_id: &str) -> Result<()>

更新客户端ID（服务端返回的ID）

pub async fn get_client_id(&self) -> Result<Option<String>>

获取客户端ID（服务端返回的ID）

pub async fn get_api_client_id(&self) -> Result<Option<String>>

获取用于API请求的客户端标识（只使用服务端返回的client_id）

pub async fn get_config(&self, key: &str) -> Result<Option<String>>

通用配置项获取

pub async fn set_config(&self, key: &str, value: &str) -> Result<()>

通用配置项设置

pub async fn get_client_identity(&self) -> Result<Option<ClientIdentity>>

获取客户端身份信息 (兼容性方法，DuckDB版本中简化实现)

pub async fn create_backup_record( &self, file_path: String, service_version: String, backup_type: BackupType, status: BackupStatus, ) -> Result<i64>

创建备份记录

pub async fn get_all_backups(&self) -> Result<Vec<BackupRecord>>

获取所有备份记录

pub async fn get_backup_by_id(&self, id: i64) -> Result<Option<BackupRecord>>

根据 ID 获取备份记录

pub async fn create_scheduled_task( &self, task_type: TaskType, target_version: String, scheduled_at: DateTime<Utc>, ) -> Result<i64>

创建计划任务

pub async fn get_pending_tasks(&self) -> Result<Vec<ScheduledTask>>

获取待执行的任务

pub async fn update_task_status( &self, task_id: i64, status: TaskStatus, details: Option<String>, ) -> Result<()>

更新任务状态

pub async fn delete_backup_record(&self, backup_id: i64) -> Result<()>

删除备份记录

pub async fn update_backup_file_path( &self, backup_id: i64, new_path: String, ) -> Result<()>

更新备份文件路径

pub async fn update_all_backup_paths( &self, old_prefix: &str, new_prefix: &str, ) -> Result<()>

批量更新备份文件路径（用于存储目录迁移）

Trait Implementations

impl Clone for Database

fn clone(&self) -> Database

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Database

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

Formats the value using the given formatter.