From c8c0e6c1d0dced5309fce174221ba454755e7e08 Mon Sep 17 00:00:00 2001
From: HAL <328961630@qq.com>
Date: Fri, 10 Jan 2025 22:40:16 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=87=BA=E7=8E=B0=E7=A9=BA?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=BA=93=E6=97=B6=E4=B8=8D=E6=98=BE=E7=A4=BA?=
 =?UTF-8?q?=EF=BC=8C=E8=81=8A=E5=A4=A9=E6=98=BE=E7=A4=BA=E4=B8=8D=E5=85=A8?=
 =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pkg/wechat/wechatDataProvider.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/pkg/wechat/wechatDataProvider.go b/pkg/wechat/wechatDataProvider.go
index 4428201..19c3bff 100644
--- a/pkg/wechat/wechatDataProvider.go
+++ b/pkg/wechat/wechatDataProvider.go
@@ -260,7 +260,8 @@ func CreateWechatDataProvider(resPath string, prefixRes string) (*WechatDataProv
 		msgDB, err := wechatOpenMsgDB(msgDBPath)
 		if err != nil {
 			log.Printf("open db %s error: %v", msgDBPath, err)
-			break
+			index += 1
+			continue
 		}
 		provider.msgDBs = append(provider.msgDBs, msgDB)
 		log.Printf("MSG%d.db start %d - %d end\n", index, msgDB.startTime, msgDB.endTime)
@@ -1080,6 +1081,7 @@ func wechatOpenMsgDB(path string) (*wechatMsgDB, error) {
 	err = msgDB.db.QueryRow(querySql).Scan(&msgDB.startTime)
 	if err != nil {
 		log.Println("select DB startTime failed:", path, ":", err)
+		msgDB.db.Close()
 		return nil, err
 	}
 
@@ -1087,6 +1089,7 @@ func wechatOpenMsgDB(path string) (*wechatMsgDB, error) {
 	err = msgDB.db.QueryRow(querySql).Scan(&msgDB.endTime)
 	if err != nil {
 		log.Println("select DB endTime failed:", path, ":", err)
+		msgDB.db.Close()
 		return nil, err
 	}