From 97c2c208baee2a4107258f20901486940f90f8be Mon Sep 17 00:00:00 2001
From: lychang <lychang@genesysinfo.net>
Date: Mon, 20 Jul 2026 01:43:33 +0800
Subject: [PATCH] update

---
 src/main.rs | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/main.rs b/src/main.rs
index ba45df2..d6fb1ac 100644
--- a/src/main.rs
+++ b/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);