Struct EmbeddedDb 

pub struct EmbeddedDb { /* private fields */ }

嵌入式数据库

提供简化的数据库操作 API

Implementations

impl EmbeddedDb

pub fn open(name: &str) -> Result<Self, SqliteError>

打开或创建数据库

Arguments

• name - 数据库名称（用于生成文件路径）

Example

let db = EmbeddedDb::open("my_app")?;

pub fn open_path(path: impl Into<PathBuf>) -> Result<Self, SqliteError>

打开指定路径的数据库

pub fn open_with_config( name: &str, config: SqliteConfig, ) -> Result<Self, SqliteError>

打开带配置的数据库

pub fn memory() -> Result<Self, SqliteError>

创建内存数据库

pub fn name(&self) -> &str

获取数据库名称

pub fn connection(&self) -> &Connection

获取底层连接

pub fn migrate<F>(&self, f: F) -> Result<MigrationReport, SqliteError>

where F: FnOnce(&mut MigrationBuilder),

执行迁移

pub fn schema_version(&self) -> Result<u32, SqliteError>

获取当前 schema 版本

pub fn select(&self, table: &str) -> SelectBuilder<'_>

创建 SELECT 查询

pub fn insert(&self, table: &str) -> InsertBuilder<'_>

创建 INSERT 查询

pub fn update(&self, table: &str) -> UpdateBuilder<'_>

创建 UPDATE 查询

pub fn delete(&self, table: &str) -> DeleteBuilder<'_>

创建 DELETE 查询

pub fn execute(&self, sql: &str, params: &[Param]) -> Result<usize, SqliteError>

执行原始 SQL

pub fn execute_batch(&self, sql: &str) -> Result<(), SqliteError>

执行批量 SQL

pub fn query_row( &self, sql: &str, params: &[Param], ) -> Result<Option<Row>, SqliteError>

查询单行

pub fn query(&self, sql: &str, params: &[Param]) -> Result<Rows, SqliteError>

查询多行

pub fn last_insert_id(&self) -> Result<i64, SqliteError>

获取最后插入的行 ID

pub fn begin_transaction(&self) -> Result<Transaction<'_>, SqliteError>

开始事务

pub fn with_transaction<F, T>(&self, f: F) -> Result<T, SqliteError>

where F: FnOnce(&Transaction<'_>) -> Result<T, SqliteError>,

在事务中执行操作

pub fn table_exists(&self, table: &str) -> Result<bool, SqliteError>

检查表是否存在

pub fn table_columns(&self, table: &str) -> Result<Vec<ColumnInfo>, SqliteError>

获取表的列信息

pub fn database_size(&self) -> Result<i64, SqliteError>

获取数据库大小（字节）

pub fn vacuum(&self) -> Result<(), SqliteError>

执行 VACUUM 优化

pub fn close(self) -> Result<(), SqliteError>

关闭数据库