Struct Database 

pub struct Database { /* private fields */ }

Sqlite 数据库连接封装

Implementations

impl Database

pub async fn connect(_db_type: DbType, path: &str) -> Result<Self>

连接到 Sqlite 数据库 (本地模式)

pub fn create_table<T: Model>(&self) -> CreateTableExecutor<'_, T>

创建表 - 返回执行器

pub async fn validate_table<T: Model>(&self) -> Result<()>

验证表结构是否与模型定义匹配

pub fn insert<I: Insertable>(&self, models: I) -> InsertExecutor<'_, I>

插入记录 - 返回执行器

pub fn insert_or_update<I: Insertable>( &self, models: I, ) -> InsertOrUpdateExecutor<'_, I>

插入或更新记录 - 返回执行器

pub fn insert_or_ignore<I: Insertable>( &self, models: I, ) -> InsertOrIgnoreExecutor<'_, I>

插入或忽略记录 - 返回执行器（存在重复主键时忽略）

pub async fn insert_or_update_batch<T: Model>( &self, models: &[&T], ) -> Result<()>

批量插入或更新记录（遇到重复键时更新） turso 不支持 ON CONFLICT，因此通过 DELETE + INSERT 实现 upsert 语义。

pub async fn insert_or_ignore_batch<T: Model>( &self, models: &[&T], ) -> Result<()>

批量插入或忽略记录（遇到重复键时忽略） turso 不支持 ON CONFLICT，因此通过捕获约束错误实现忽略语义。

pub fn select<T: Model>(&self) -> SelectExecutor<'_, T>

创建 Select 查询执行器

pub fn select_column<T: Model, V>(&self) -> GroupedSelectExecutor<'_, T, V>

创建分组聚合查询执行器

pub fn delete<T: Model>(&self) -> DeleteExecutor<T>

创建 Delete 执行器

pub fn update<T: Model>(&self) -> UpdateExecutor<T>

创建 Update 执行器

pub fn related<T: Model + 'static, R: Model>( &self, ) -> RelatedSelectExecutor<T, R>

创建 Related 查询执行器

pub async fn begin(&self) -> Result<Transaction>

开始事务

pub fn drop_table<T: Model>(&self) -> DropTableExecutor<'_, T>

删除表 - 返回执行器

pub async fn execute<T: Model>(&self, sql: &str) -> Result<Vec<T>>

执行原生 SQL 查询并返回模型列表 执行原生 SQL 查询并返回模型列表

pub async fn exec_table<T: Model>(&self, sql: &str) -> Result<Vec<T>>

👎Deprecated since 0.1.0:

请使用 execute 方法

执行原生 SQL 查询并返回模型列表（向后兼容）

pub async fn exec_non_query(&self, sql: &str) -> Result<u64>

执行原生非查询 SQL 并返回影响的行数

pub async fn is_valid(&self) -> bool

检查连接是否有效

Trait Implementations

impl Send for Database

impl Sync for Database