# rusqlite + SQLite 开发指南 ## 设置 [依赖项] rusqlite = { 版本 = "0.32", 功能 = ["捆绑"] } dirs = "5.0" # 操作系统数据目录 ## 连接使用 rusqlite::{连接，结果}；让 conn = Connection::open("app.db")?; // 基于文件让 conn = Connection::open_in_memory()?; // 内存中（测试） // 操作系统特定的数据目录 fn get_db_path() -> PathBuf { dirs::data_local_dir().unwrap_or_else(|| PathBuf::from(".")) .join("myapp").join("app.db") } // Linux: ~/.local/share/myapp/app.db // Windows: C:\Users\<用户>\AppData\Local\myapp\app.db // 初始化让 conn = Connection::open(&db_path)?; conn.execute_batch("PRAGMAforeign_keys = ON;")?; run_migrations(&conn)?; ## 增删改查使用 rusqlite::params； // 插入 conn.execute("INSERT INTO 条目（标题）值 (?1)", params![title])?; 让 id = conn.last_insert_rowid(); // 选择（单个） conn.query_row("从 id = ?1 的条目中选择 *", params![id], |row| { 好的(条目{ id: row.get(0)?, 标题: row.get(1)? }) }）？ // 选择（多个） let mut stmt = conn.prepare("SELECT * FROM items LIMIT ?1")?; 让条目 = stmt.query_map(params![limit], |row| { 好的(条目{ id: row.get(0)?, 标题: row.get(1)? }) })?.collect::<结果>>()?; // 更新 conn.execute("更新条目 SET title = ?1 WHERE id = ?2", params![title, id])?; // 删除 conn.execute("从 id = ?1 的条目中删除", params![id])?; ## 交易让 tx = conn.transaction()?; tx.execute("插入条目(标题)值(?1)", params![标题])?; 让entry_id = tx.last_insert_rowid(); tx.execute("插入标签(名称)值(?1)", params![标签])?; tx.commit()?; // 提交前出错 → 删除时自动回滚 ## 命名参数使用 rusqlite::named_params; conn. 执行( “插入条目（标题、版本）值（：标题、：版本）”，命名参数！ { ":title": 标题, ":versioned": 版本为 i32 }, ）？； ## 迁移（PRAGMA user_version） fn run_migrations(conn: &Connection) -> 结果 <()> { 让版本： i32 = conn.query_row("PRAGMA user_version", [], |r| r.get(0))?; 如果版本 < 1 { conn.execute_batch(include_str!("../../migrations/001_initial.sql"))?; conn.execute("PRAGMA user_version = 1", [])?; } 如果版本 < 2 { conn.execute_batch(include_str!("../../migrations/002_add_field.sql"))?; conn.execute("PRAGMA user_version = 2", [])?; } 好的（（）） } ## FTS5 全文搜索 -- 虚拟表使用 fts5 创建虚拟表条目_fts（标题，代码，备忘录，内容='entry_versions'，content_rowid='id'）; -- 同步触发器在插入entry_versions开始后创建触发器entry_versions_ai INSERT INTO Entry_fts(rowid, title, code, memo) SELECT ev.id, e.title, ev.code, ev.memo FROM Entry_versions ev JOIN 条目 e ON e.id = ev.entry_id WHERE ev.id = NEW.id; 结尾; fn search(conn: &Connection, 查询: &str, limit: i64) -> Result> { 让 fts_query = query.split_whitespace() .map(|w| format!("{}*", w)).collect::>().join(" "); 让 mut stmt = conn.prepare( “选择ev.entry_id，e.title， snippet(entries_fts, 1, '', '', '...', 32) as code_snippet 来自条目_fts JOIN Entry_versions ev ON Entry_fts.rowid = ev.id JOIN 条目 e ON ev.entry_id = e.id WHERE Entry_fts MATCH ?1 ORDER BY 等级限制 ?2" ）？； stmt.query_map(params![fts_query, limit], |row| { 好的（SearchResult {entry_id：row.get（0）？，标题：row.get（1）？，片段：row.get（2）？}） })?.collect() } ### FTS5 查询语法语法 |示例|含义 ---|---|--- 词| `阿克苏姆` |包含“阿苏姆” 多个| `axum 处理程序` |包含两者 (AND) 前缀| `手*` |从“手”开始短语| `“错误处理”` |准确的短语或 | `阿克苏姆或勒浦托` |任一不 | `axum 不是 leptos` |有axum，没有leptos ## 错误处理使用 rusqlite::Error 作为 SqliteError； pub 枚举 DbError { SQLite（Sqlite错误），未找到（i64）， } impl From for DbError { fn from(e: SqliteError) -> Self { DbError::Sqlite(e) } } // 将 QueryReturnedNoRows 转换为 NotFound conn.query_row(...).map_err(|e| 匹配 e { SqliteError::QueryReturnedNoRows => DbError::NotFound(id), _ => DbError::Sqlite(e), }) ## SQLx (PostgreSQL) 与 rusqlite 项目 | rusqlite | SQLx ---|---|--- 编译时检查 |没有 | `查询！`宏连接|同步（文件）|异步（网络）移民|手册（PRAGMA）| sqlx-cli 枚举 |否（使用整数）|本地人全文检索 | FTS5 | ts向量使用案例 |单用户应用程序 |多用户SaaS

Rusqlite 指南

包含技能