update

src/main.rs

@@ -39,7 +39,11 @@ async fn main() -> std::io::Result<()> {
     let db = match db::Database::new(&config).await {
         Ok(db) => {
             info!("数据库连接成功");
-            Arc::new(db)
+            let db = Arc::new(db);
+            // 启动时先合并上次未完成的 WAL，确保数据库干净
+            info!("正在合并数据库 WAL...");
+            db.wal_checkpoint().await;
+            db
         }
         Err(e) => {
             error!("数据库连接失败: {}", e);