internal/index/migrations.go
@@ -35,7 +35,10 @@
   return nil
}
// backupDB 迁移前备份 .db 文件(已有备份则跳过)
// backupDB 迁移前备份 .db 文件(已有备份则跳过)。
// 用 VACUUM INTO 而非 os.ReadFile:WAL 模式下未 checkpoint 的数据在
// -wal 文件里,直读主文件会漏掉这部分,导致备份不一致;VACUUM INTO
// 会合并 WAL 生成一份完整的独立库文件(SQLite 3.27+)。
func (s *Store) backupDB() error {
   if s.dbPath == "" {
      return nil // 无路径信息时跳过备份(测试场景)
@@ -44,23 +47,19 @@
   if _, err := os.Stat(dst); err == nil {
      return nil // 已有备份
   }
   data, err := os.ReadFile(s.dbPath)
   if err != nil {
      return err
   }
   return os.WriteFile(dst, data, 0644)
   _, err := s.db.Exec(`VACUUM INTO ?`, dst)
   return err
}
// migrateV1toV2 执行 v1 → v2 的全部变更
// migrateV1toV2 执行 v1 → v2 的全部变更。
// 注意:版本号(schema_versions)必须在最后一步(FTS 重建)成功后才写入,
// 否则中途失败时后续 Open 会读到 version=2 直接早退,半迁移状态无法重试。
func (s *Store) migrateV1toV2() error {
   // 1. schema_versions 表
   // 1. schema_versions 表(只建表,版本号推迟到最后写入)
   if _, err := s.db.Exec(`CREATE TABLE IF NOT EXISTS schema_versions (
      key TEXT PRIMARY KEY, value TEXT NOT NULL)`); err != nil {
      return err
   }
   if _, err := s.db.Exec(`INSERT OR REPLACE INTO schema_versions VALUES ('version', '2')`); err != nil {
      return err
   }
   // 2. nodes 加列(逐列检查,幂等)
   for _, col := range []struct{ name, def string }{
@@ -107,7 +106,17 @@
   if err := s.CreateFTS(); err != nil {
      return err
   }
   return s.PopulateFTS()
   if err := s.PopulateFTS(); err != nil {
      return err
   }
   // 6. 最后一步:全部成功后才写入版本号(参数化,引用常量 currentSchemaVersion)。
   // 提前写入会导致中途失败时后续 Open 读到 version=2 直接早退,半迁移状态无法重试。
   if _, err := s.db.Exec(`INSERT OR REPLACE INTO schema_versions VALUES ('version', ?)`,
      currentSchemaVersion); err != nil {
      return err
   }
   return nil
}
// nodeColumnExists 检查 nodes 表是否已有指定列