From c88268fbfd2927a634eda82cb7247b102fedf78d Mon Sep 17 00:00:00 2001 From: Liang Ding Date: Tue, 21 Feb 2023 12:39:29 +0800 Subject: [PATCH] =?UTF-8?q?:art:=20=E7=A7=BB=E5=8A=A8=E6=96=87=E6=A1=A3?= =?UTF-8?q?=E6=9B=B4=E6=96=B0=E7=B4=A2=E5=BC=95=E6=97=B6=E5=8C=BA=E5=88=86?= =?UTF-8?q?=E5=A4=A7=E5=B0=8F=E5=86=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- kernel/sql/database.go | 40 +++++++++++++++++++++++++--------------- 1 file changed, 25 insertions(+), 15 deletions(-) diff --git a/kernel/sql/database.go b/kernel/sql/database.go index f5f17f948..e152f790c 100644 --- a/kernel/sql/database.go +++ b/kernel/sql/database.go @@ -869,9 +869,11 @@ func deleteBlocksByIDs(tx *sql.Tx, ids []string) (err error) { if err = execStmtTx(tx, stmt); nil != err { return } - stmt = "DELETE FROM blocks_fts_case_insensitive WHERE id IN " + in.String() - if err = execStmtTx(tx, stmt); nil != err { - return + if !caseSensitive { + stmt = "DELETE FROM blocks_fts_case_insensitive WHERE id IN " + in.String() + if err = execStmtTx(tx, stmt); nil != err { + return + } } return } @@ -885,9 +887,11 @@ func deleteBlocksByBoxTx(tx *sql.Tx, box string) (err error) { if err = execStmtTx(tx, stmt, box); nil != err { return } - stmt = "DELETE FROM blocks_fts_case_insensitive WHERE box = ?" - if err = execStmtTx(tx, stmt, box); nil != err { - return + if !caseSensitive { + stmt = "DELETE FROM blocks_fts_case_insensitive WHERE box = ?" + if err = execStmtTx(tx, stmt, box); nil != err { + return + } } ClearCache() return @@ -993,9 +997,11 @@ func deleteByRootID(tx *sql.Tx, rootID string, context map[string]interface{}) ( if err = execStmtTx(tx, stmt, rootID); nil != err { return } - stmt = "DELETE FROM blocks_fts_case_insensitive WHERE root_id = ?" - if err = execStmtTx(tx, stmt, rootID); nil != err { - return + if !caseSensitive { + stmt = "DELETE FROM blocks_fts_case_insensitive WHERE root_id = ?" + if err = execStmtTx(tx, stmt, rootID); nil != err { + return + } } stmt = "DELETE FROM spans WHERE root_id = ?" if err = execStmtTx(tx, stmt, rootID); nil != err { @@ -1029,9 +1035,11 @@ func batchDeleteByRootIDs(tx *sql.Tx, rootIDs []string, context map[string]inter if err = execStmtTx(tx, stmt); nil != err { return } - stmt = "DELETE FROM blocks_fts_case_insensitive WHERE root_id IN " + ids - if err = execStmtTx(tx, stmt); nil != err { - return + if !caseSensitive { + stmt = "DELETE FROM blocks_fts_case_insensitive WHERE root_id IN " + ids + if err = execStmtTx(tx, stmt); nil != err { + return + } } stmt = "DELETE FROM spans WHERE root_id IN " + ids if err = execStmtTx(tx, stmt); nil != err { @@ -1063,9 +1071,11 @@ func batchDeleteByPathPrefix(tx *sql.Tx, boxID, pathPrefix string) (err error) { if err = execStmtTx(tx, stmt, boxID, pathPrefix+"%"); nil != err { return } - stmt = "DELETE FROM blocks_fts_case_insensitive WHERE box = ? AND path LIKE ?" - if err = execStmtTx(tx, stmt, boxID, pathPrefix+"%"); nil != err { - return + if !caseSensitive { + stmt = "DELETE FROM blocks_fts_case_insensitive WHERE box = ? AND path LIKE ?" + if err = execStmtTx(tx, stmt, boxID, pathPrefix+"%"); nil != err { + return + } } stmt = "DELETE FROM spans WHERE box = ? AND path LIKE ?" if err = execStmtTx(tx, stmt, boxID, pathPrefix+"%"); nil != err {