Something went wrong. Try again.
A privacy-first, self-hosted, fully open source personal knowledge management software, written in typescript and golang. (PERSONAL FORK)
Something went wrong. Try again.
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524// SiYuan - Refactor your thinking// Copyright (c) 2020-present, b3log.org//// This program is free software: you can redistribute it and/or modify// it under the terms of the GNU Affero General Public License as published by// the Free Software Foundation, either version 3 of the License, or// (at your option) any later version.//// This program is distributed in the hope that it will be useful,// but WITHOUT ANY WARRANTY; without even the implied warranty of// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the// GNU Affero General Public License for more details.//// You should have received a copy of the GNU Affero General Public License// along with this program. If not, see <https://www.gnu.org/licenses/>.
package sql
import ( "bytes" "crypto/sha256" "database/sql" "errors" "fmt" "os" "path/filepath" "regexp" "runtime" "runtime/debug" "strconv" "strings" "sync" "text/template" "time" "unicode/utf8"
"github.com/88250/gulu" "github.com/88250/lute/ast" "github.com/88250/lute/html" "github.com/88250/lute/parse" "github.com/mattn/go-sqlite3" _ "github.com/mattn/go-sqlite3" "github.com/siyuan-note/eventbus" "github.com/siyuan-note/logging" "github.com/siyuan-note/siyuan/kernel/treenode" "github.com/siyuan-note/siyuan/kernel/util")
var ( db *sql.DB historyDB *sql.DB assetContentDB *sql.DB)
func init() { regex := func(re, s string) (bool, error) { re = strings.ReplaceAll(re, "\\\\", "\\") return regexp.MatchString(re, s) }
sql.Register("sqlite3_extended", &sqlite3.SQLiteDriver{ ConnectHook: func(conn *sqlite3.SQLiteConn) error { return conn.RegisterFunc("regexp", regex, true) }, })}
var initDatabaseLock = sync.Mutex{}
func InitDatabase(forceRebuild bool) (err error) { initDatabaseLock.Lock() defer initDatabaseLock.Unlock()
ClearCache() disableCache() defer enableCache()
util.IncBootProgress(2, "Initializing database...")
if forceRebuild { ClearQueue() }
initDBConnection() treenode.InitBlockTree(forceRebuild)
if !forceRebuild { // 检查数据库结构版本，如果版本不一致的话说明改过表结构，需要重建 if util.DatabaseVer == getDatabaseVer() { return } logging.LogInfof("the database structure is changed, rebuilding database...") }
// 不存在库或者版本不一致都会走到这里
closeDatabase() if gulu.File.IsExist(util.DBPath) { if err = removeDatabaseFile(); err != nil { logging.LogErrorf("remove database file [%s] failed: %s", util.DBPath, err) util.PushClearProgress() err = nil } }
initDBConnection() initDBTables()
logging.LogInfof("reinitialized database [%s]", util.DBPath) return}
func initDBTables() { _, err := db.Exec("DROP TABLE IF EXISTS stat") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "drop table [stat] failed: %s", err) } _, err = db.Exec("CREATE TABLE stat (key, value)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create table [stat] failed: %s", err) } setDatabaseVer()
_, err = db.Exec("DROP TABLE IF EXISTS blocks") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "drop table [blocks] failed: %s", err) } _, err = db.Exec("CREATE TABLE blocks (id, parent_id, root_id, hash, box, path, hpath, name, alias, memo, tag, content, fcontent, markdown, length, type, subtype, ial, sort, created, updated)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create table [blocks] failed: %s", err) }
_, err = db.Exec("CREATE INDEX idx_blocks_id ON blocks(id)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create index [idx_blocks_id] failed: %s", err) }
_, err = db.Exec("CREATE INDEX idx_blocks_parent_id ON blocks(parent_id)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create index [idx_blocks_parent_id] failed: %s", err) }
_, err = db.Exec("CREATE INDEX idx_blocks_root_id ON blocks(root_id)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create index [idx_blocks_root_id] failed: %s", err) }
_, err = db.Exec("DROP TABLE IF EXISTS blocks_fts") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "drop table [blocks_fts] failed: %s", err) } _, err = db.Exec("CREATE VIRTUAL TABLE blocks_fts USING fts5(id UNINDEXED, parent_id UNINDEXED, root_id UNINDEXED, hash UNINDEXED, box UNINDEXED, path UNINDEXED, hpath, name, alias, memo, tag, content, fcontent, markdown UNINDEXED, length UNINDEXED, type UNINDEXED, subtype UNINDEXED, ial, sort UNINDEXED, created UNINDEXED, updated UNINDEXED, tokenize=\"siyuan\")") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create table [blocks_fts] failed: %s", err) }
_, err = db.Exec("DROP TABLE IF EXISTS blocks_fts_case_insensitive") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "drop table [blocks_fts_case_insensitive] failed: %s", err) } _, err = db.Exec("CREATE VIRTUAL TABLE blocks_fts_case_insensitive USING fts5(id UNINDEXED, parent_id UNINDEXED, root_id UNINDEXED, hash UNINDEXED, box UNINDEXED, path UNINDEXED, hpath, name, alias, memo, tag, content, fcontent, markdown UNINDEXED, length UNINDEXED, type UNINDEXED, subtype UNINDEXED, ial, sort UNINDEXED, created UNINDEXED, updated UNINDEXED, tokenize=\"siyuan case_insensitive\")") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create table [blocks_fts_case_insensitive] failed: %s", err) }
_, err = db.Exec("DROP TABLE IF EXISTS spans") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "drop table [spans] failed: %s", err) } _, err = db.Exec("CREATE TABLE spans (id, block_id, root_id, box, path, content, markdown, type, ial)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create table [spans] failed: %s", err) } _, err = db.Exec("CREATE INDEX idx_spans_root_id ON spans(root_id)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create index [idx_spans_root_id] failed: %s", err) }
_, err = db.Exec("DROP TABLE IF EXISTS assets") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "drop table [assets] failed: %s", err) } _, err = db.Exec("CREATE TABLE assets (id, block_id, root_id, box, docpath, path, name, title, hash)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create table [assets] failed: %s", err) } _, err = db.Exec("CREATE INDEX idx_assets_root_id ON assets(root_id)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create index [idx_assets_root_id] failed: %s", err) }
_, err = db.Exec("DROP TABLE IF EXISTS attributes") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "drop table [attributes] failed: %s", err) } _, err = db.Exec("CREATE TABLE attributes (id, name, value, type, block_id, root_id, box, path)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create table [attributes] failed: %s", err) } _, err = db.Exec("CREATE INDEX idx_attributes_block_id ON attributes(block_id)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create index [idx_attributes_block_id] failed: %s", err) } _, err = db.Exec("CREATE INDEX idx_attributes_root_id ON attributes(root_id)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create index [idx_attributes_root_id] failed: %s", err) }
_, err = db.Exec("DROP TABLE IF EXISTS refs") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "drop table [refs] failed: %s", err) } _, err = db.Exec("CREATE TABLE refs (id, def_block_id, def_block_parent_id, def_block_root_id, def_block_path, block_id, root_id, box, path, content, markdown, type)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create table [refs] failed: %s", err) }
_, err = db.Exec("DROP TABLE IF EXISTS file_annotation_refs") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "drop table [refs] failed: %s", err) } _, err = db.Exec("CREATE TABLE file_annotation_refs (id, file_path, annotation_id, block_id, root_id, box, path, content, type)") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create table [refs] failed: %s", err) }}
func initDBConnection() { if nil != db { closeDatabase() }
util.LogDatabaseSize(util.DBPath) dsn := util.DBPath + "?_journal_mode=WAL" + "&_synchronous=OFF" + "&_mmap_size=2684354560" + "&_secure_delete=OFF" + "&_cache_size=-20480" + "&_page_size=32768" + "&_busy_timeout=7000" + "&_ignore_check_constraints=ON" + "&_temp_store=MEMORY" + "&_case_sensitive_like=OFF" var err error db, err = sql.Open("sqlite3_extended", dsn) if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create database failed: %s", err) } db.SetMaxIdleConns(20) db.SetMaxOpenConns(20) db.SetConnMaxLifetime(365 * 24 * time.Hour)}
var initHistoryDatabaseLock = sync.Mutex{}
func InitHistoryDatabase(forceRebuild bool) { initHistoryDatabaseLock.Lock() defer initHistoryDatabaseLock.Unlock()
initHistoryDBConnection()
if !forceRebuild && gulu.File.IsExist(util.HistoryDBPath) { return }
historyDB.Close() if err := os.RemoveAll(util.HistoryDBPath); err != nil { logging.LogErrorf("remove history database file [%s] failed: %s", util.HistoryDBPath, err) return }
initHistoryDBConnection() initHistoryDBTables()}
func initHistoryDBConnection() { if nil != historyDB { historyDB.Close() }
util.LogDatabaseSize(util.HistoryDBPath) dsn := util.HistoryDBPath + "?_journal_mode=WAL" + "&_synchronous=OFF" + "&_mmap_size=2684354560" + "&_secure_delete=OFF" + "&_cache_size=-20480" + "&_page_size=32768" + "&_busy_timeout=7000" + "&_ignore_check_constraints=ON" + "&_temp_store=MEMORY" + "&_case_sensitive_like=OFF" var err error historyDB, err = sql.Open("sqlite3_extended", dsn) if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create history database failed: %s", err) } historyDB.SetMaxIdleConns(3) historyDB.SetMaxOpenConns(3) historyDB.SetConnMaxLifetime(365 * 24 * time.Hour)}
func initHistoryDBTables() { historyDB.Exec("DROP TABLE histories_fts_case_insensitive") _, err := historyDB.Exec("CREATE VIRTUAL TABLE histories_fts_case_insensitive USING fts5(id UNINDEXED, type UNINDEXED, op UNINDEXED, title, content, path UNINDEXED, created UNINDEXED, tokenize=\"siyuan case_insensitive\")") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create table [histories_fts_case_insensitive] failed: %s", err) }}
var initAssetContentDatabaseLock = sync.Mutex{}
func InitAssetContentDatabase(forceRebuild bool) { initAssetContentDatabaseLock.Lock() defer initAssetContentDatabaseLock.Unlock()
initAssetContentDBConnection()
if !forceRebuild && gulu.File.IsExist(util.AssetContentDBPath) { return }
assetContentDB.Close() if err := os.RemoveAll(util.AssetContentDBPath); err != nil { logging.LogErrorf("remove assets database file [%s] failed: %s", util.AssetContentDBPath, err) return }
initAssetContentDBConnection() initAssetContentDBTables()}
func initAssetContentDBConnection() { if nil != assetContentDB { assetContentDB.Close() }
util.LogDatabaseSize(util.AssetContentDBPath) dsn := util.AssetContentDBPath + "?_journal_mode=WAL" + "&_synchronous=OFF" + "&_mmap_size=2684354560" + "&_secure_delete=OFF" + "&_cache_size=-20480" + "&_page_size=32768" + "&_busy_timeout=7000" + "&_ignore_check_constraints=ON" + "&_temp_store=MEMORY" + "&_case_sensitive_like=OFF" var err error assetContentDB, err = sql.Open("sqlite3_extended", dsn) if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create assets database failed: %s", err) } assetContentDB.SetMaxIdleConns(3) assetContentDB.SetMaxOpenConns(3) assetContentDB.SetConnMaxLifetime(365 * 24 * time.Hour)}
func initAssetContentDBTables() { assetContentDB.Exec("DROP TABLE asset_contents_fts_case_insensitive") _, err := assetContentDB.Exec("CREATE VIRTUAL TABLE asset_contents_fts_case_insensitive USING fts5(id UNINDEXED, name, ext, path, size UNINDEXED, updated UNINDEXED, content, tokenize=\"siyuan case_insensitive\")") if err != nil { logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "create table [asset_contents_fts_case_insensitive] failed: %s", err) }}
var ( caseSensitive bool indexAssetPath bool)
func SetCaseSensitive(b bool) { caseSensitive = b if b { db.Exec("PRAGMA case_sensitive_like = ON;") } else { db.Exec("PRAGMA case_sensitive_like = OFF;") }}
func SetIndexAssetPath(b bool) { indexAssetPath = b}
func refsFromTree(tree *parse.Tree) (refs []*Ref, fileAnnotationRefs []*FileAnnotationRef) { ast.Walk(tree.Root, func(n *ast.Node, entering bool) ast.WalkStatus { if entering { return ast.WalkContinue }
if treenode.IsBlockRef(n) { ref := buildRef(tree, n) if !isRepeatedRef(refs, ref) { refs = append(refs, ref) } } else if treenode.IsFileAnnotationRef(n) { pathID := n.TextMarkFileAnnotationRefID idx := strings.LastIndex(pathID, "/") if -1 == idx { return ast.WalkContinue }
filePath := pathID[:idx] annotationID := pathID[idx+1:]
anchor := n.TextMarkTextContent text := filePath if "" != anchor { text = anchor } parentBlock := treenode.ParentBlock(n) ref := &FileAnnotationRef{ ID: ast.NewNodeID(), FilePath: filePath, AnnotationID: annotationID, BlockID: parentBlock.ID, RootID: tree.ID, Box: tree.Box, Path: tree.Path, Content: text, Type: treenode.TypeAbbr(n.Type.String()), } fileAnnotationRefs = append(fileAnnotationRefs, ref) } else if treenode.IsEmbedBlockRef(n) { ref := buildEmbedRef(tree, n) if !isRepeatedRef(refs, ref) { refs = append(refs, ref) } } return ast.WalkContinue }) return}
func isRepeatedRef(refs []*Ref, ref *Ref) bool { // Repeated references to the same block within a block only count as one reference https://github.com/siyuan-note/siyuan/issues/9670 for _, r := range refs { if r.DefBlockID == ref.DefBlockID && r.BlockID == ref.BlockID { return true } } return false}
func buildRef(tree *parse.Tree, refNode *ast.Node) *Ref { // 多个类型可能会导致渲染的 Markdown 不正确，所以这里只保留 block-ref 类型 tmpTyp := refNode.TextMarkType refNode.TextMarkType = "block-ref" markdown := treenode.ExportNodeStdMd(refNode, luteEngine) refNode.TextMarkType = tmpTyp
defBlockID, text, _ := treenode.GetBlockRef(refNode) var defBlockParentID, defBlockRootID, defBlockPath string defBlock := treenode.GetBlockTree(defBlockID) if nil != defBlock { defBlockParentID = defBlock.ParentID defBlockRootID = defBlock.RootID defBlockPath = defBlock.Path } parentBlock := treenode.ParentBlock(refNode) return &Ref{ ID: ast.NewNodeID(), DefBlockID: defBlockID, DefBlockParentID: defBlockParentID, DefBlockRootID: defBlockRootID, DefBlockPath: defBlockPath, BlockID: parentBlock.ID, RootID: tree.ID, Box: tree.Box, Path: tree.Path, Content: text, Markdown: markdown, Type: treenode.TypeAbbr(refNode.Type.String()), }}
func buildEmbedRef(tree *parse.Tree, embedNode *ast.Node) *Ref { defBlockID := getEmbedRef(embedNode) var defBlockParentID, defBlockRootID, defBlockPath string defBlock := treenode.GetBlockTree(defBlockID) if nil != defBlock { defBlockParentID = defBlock.ParentID defBlockRootID = defBlock.RootID defBlockPath = defBlock.Path }
return &Ref{ ID: ast.NewNodeID(), DefBlockID: defBlockID, DefBlockParentID: defBlockParentID, DefBlockRootID: defBlockRootID, DefBlockPath: defBlockPath, BlockID: embedNode.ID, RootID: tree.ID, Box: tree.Box, Path: tree.Path, Content: "", // 通过嵌入块构建引用时定义块可能还没有入库，所以这里统一不填充内容 Markdown: "", Type: treenode.TypeAbbr(embedNode.Type.String()), }}
func getEmbedRef(embedNode *ast.Node) (queryBlockID string) { queryBlockID = treenode.GetEmbedBlockRef(embedNode) return}
func fromTree(node *ast.Node, tree *parse.Tree) (blocks []*Block, spans []*Span, assets []*Asset, attributes []*Attribute) { rootID := tree.Root.ID boxID := tree.Box p := tree.Path ast.Walk(node, func(n *ast.Node, entering bool) ast.WalkStatus { if !entering { return ast.WalkContinue }
// 构造行级元素 spanBlocks, spanSpans, spanAssets, spanAttrs, walkStatus := buildSpanFromNode(n, tree, rootID, boxID, p) if 0 < len(spanBlocks) { blocks = append(blocks, spanBlocks...) } if 0 < len(spanSpans) { spans = append(spans, spanSpans...) } if 0 < len(spanAssets) { assets = append(assets, spanAssets...) } if 0 < len(spanAttrs) { attributes = append(attributes, spanAttrs...) }
// 构造属性 attrs := buildAttributeFromNode(n, rootID, boxID, p) if 0 < len(attrs) { attributes = append(attributes, attrs...) } if -1 != walkStatus { return walkStatus }
// 构造块级元素 if "" == n.ID || !n.IsBlock() { return ast.WalkContinue }
b, attrs := buildBlockFromNode(n, tree) blocks = append(blocks, b) if 0 < len(attrs) { attributes = append(attributes, attrs...) } return ast.WalkContinue }) return}
func buildAttributeFromNode(n *ast.Node, rootID, boxID, p string) (attributes []*Attribute) { switch n.Type { case ast.NodeKramdownSpanIAL: parentBlock := treenode.ParentBlock(n) attrs := parse.IALValMap(n) for name, val := range attrs { if !isAttr(name) { continue }
attr := &Attribute{ ID: ast.NewNodeID(), Name: name, Value: val, Type: "s", BlockID: parentBlock.ID, RootID: rootID, Box: boxID, Path: p, } attributes = append(attributes, attr) } case ast.NodeKramdownBlockIAL: attrs := parse.IALValMap(n) for name, val := range attrs { if !isAttr(name) { continue }
attr := &Attribute{ ID: ast.NewNodeID(), Name: name, Value: val, Type: "b", BlockID: n.ID, RootID: rootID, Box: boxID, Path: p, } attributes = append(attributes, attr) } } return}
func isAttr(name string) bool { return strings.HasPrefix(name, "custom-") || "name" == name || "alias" == name || "memo" == name || "bookmark" == name || "fold" == name || "heading-fold" == name || "style" == name}
func buildSpanFromNode(n *ast.Node, tree *parse.Tree, rootID, boxID, p string) (blocks []*Block, spans []*Span, assets []*Asset, attributes []*Attribute, walkStatus ast.WalkStatus) { boxLocalPath := filepath.Join(util.DataDir, boxID) docDirLocalPath := filepath.Join(boxLocalPath, p) switch n.Type { case ast.NodeImage: text := n.Text() markdown := treenode.ExportNodeStdMd(n, luteEngine) parentBlock := treenode.ParentBlock(n) span := &Span{ ID: ast.NewNodeID(), BlockID: parentBlock.ID, RootID: rootID, Box: boxID, Path: p, Content: text, Markdown: markdown, Type: treenode.TypeAbbr(n.Type.String()), IAL: treenode.IALStr(n), } spans = append(spans, span) walkStatus = ast.WalkSkipChildren
destNode := n.ChildByType(ast.NodeLinkDest) if nil == destNode { return }
// assetsLinkDestsInTree
if !util.IsAssetLinkDest(destNode.Tokens) { return }
dest := gulu.Str.FromBytes(destNode.Tokens) var title string if titleNode := n.ChildByType(ast.NodeLinkTitle); nil != titleNode { title = gulu.Str.FromBytes(titleNode.Tokens) }
var hash string var hashErr error if lp := assetLocalPath(dest, boxLocalPath, docDirLocalPath); "" != lp { if !gulu.File.IsDir(lp) { hash, hashErr = util.GetEtag(lp) if nil != hashErr { logging.LogErrorf("calc asset [%s] hash failed: %s", lp, hashErr) } } } name, _ := util.LastID(dest) asset := &Asset{ ID: ast.NewNodeID(), BlockID: parentBlock.ID, RootID: rootID, Box: boxID, DocPath: p, Path: dest, Name: name, Title: title, Hash: hash, } assets = append(assets, asset) return case ast.NodeTextMark: typ := treenode.TypeAbbr(n.Type.String()) + " " + n.TextMarkType text := n.Content() markdown := treenode.ExportNodeStdMd(n, luteEngine) parentBlock := treenode.ParentBlock(n) span := &Span{ ID: ast.NewNodeID(), BlockID: parentBlock.ID, RootID: rootID, Box: boxID, Path: p, Content: text, Markdown: markdown, Type: typ, IAL: treenode.IALStr(n), } spans = append(spans, span)
if n.IsTextMarkType("a") { dest := n.TextMarkAHref if util.IsAssetLinkDest([]byte(dest)) { var title string if titleNode := n.ChildByType(ast.NodeLinkTitle); nil != titleNode { title = gulu.Str.FromBytes(titleNode.Tokens) }
var hash string var hashErr error if lp := assetLocalPath(dest, boxLocalPath, docDirLocalPath); "" != lp { if !gulu.File.IsDir(lp) { hash, hashErr = util.GetEtag(lp) if nil != hashErr { logging.LogErrorf("calc asset [%s] hash failed: %s", lp, hashErr) } } } name, _ := util.LastID(dest) asset := &Asset{ ID: ast.NewNodeID(), BlockID: parentBlock.ID, RootID: rootID, Box: boxID, DocPath: p, Path: dest, Name: name, Title: title, Hash: hash, } assets = append(assets, asset) } } walkStatus = ast.WalkSkipChildren return case ast.NodeDocument: if asset := docTitleImgAsset(n, boxLocalPath, docDirLocalPath); nil != asset { assets = append(assets, asset) } if tags := docTagSpans(n); 0 < len(tags) { spans = append(spans, tags...) } case ast.NodeInlineHTML, ast.NodeHTMLBlock, ast.NodeIFrame, ast.NodeWidget, ast.NodeAudio, ast.NodeVideo: nodes, err := html.ParseFragment(bytes.NewReader(n.Tokens), &html.Node{Type: html.ElementNode}) if err != nil { logging.LogErrorf("parse HTML failed: %s", err) walkStatus = ast.WalkContinue return } if 1 > len(nodes) && ast.NodeHTMLBlock != n.Type { // HTML 块若内容为空时无法在数据库中查询到 https://github.com/siyuan-note/siyuan/issues/4691 walkStatus = ast.WalkContinue return }
if ast.NodeHTMLBlock == n.Type || ast.NodeIFrame == n.Type || ast.NodeWidget == n.Type || ast.NodeAudio == n.Type || ast.NodeVideo == n.Type { b, attrs := buildBlockFromNode(n, tree) blocks = append(blocks, b) attributes = append(attributes, attrs...) }
if ast.NodeInlineHTML == n.Type { // 没有行级 HTML，只有块级 HTML，这里转换为块 n.ID = ast.NewNodeID() n.SetIALAttr("id", n.ID) n.SetIALAttr("updated", n.ID[:14]) b, attrs := buildBlockFromNode(n, tree) b.Type = ast.NodeHTMLBlock.String() blocks = append(blocks, b) attributes = append(attributes, attrs...) walkStatus = ast.WalkContinue logging.LogWarnf("inline HTML [%s] is converted to HTML block ", n.Tokens) return }
if 1 > len(nodes) { walkStatus = ast.WalkContinue return }
var src []byte for _, attr := range nodes[0].Attr { if "src" == attr.Key || strings.HasPrefix(attr.Key, "data-assets") || strings.HasPrefix(attr.Key, "custom-data-assets") { src = gulu.Str.ToBytes(attr.Val) break } } if 1 > len(src) { walkStatus = ast.WalkContinue return }
if !util.IsAssetLinkDest(src) { walkStatus = ast.WalkContinue return }
dest := string(src) var hash string var hashErr error if lp := assetLocalPath(dest, boxLocalPath, docDirLocalPath); "" != lp { hash, hashErr = util.GetEtag(lp) if nil != hashErr { logging.LogErrorf("calc asset [%s] hash failed: %s", lp, hashErr) } }
parentBlock := treenode.ParentBlock(n) if ast.NodeInlineHTML != n.Type { parentBlock = n } name, _ := util.LastID(dest) asset := &Asset{ ID: ast.NewNodeID(), BlockID: parentBlock.ID, RootID: rootID, Box: boxID, DocPath: p, Path: dest, Name: name, Title: "", Hash: hash, } assets = append(assets, asset) walkStatus = ast.WalkSkipChildren return } walkStatus = -1 return}
func BuildBlockFromNode(n *ast.Node, tree *parse.Tree) (block *Block) { block, _ = buildBlockFromNode(n, tree) return}
func buildBlockFromNode(n *ast.Node, tree *parse.Tree) (block *Block, attributes []*Attribute) { boxID := tree.Box p := tree.Path rootID := tree.Root.ID name := html.UnescapeString(n.IALAttr("name")) alias := html.UnescapeString(n.IALAttr("alias")) memo := html.UnescapeString(n.IALAttr("memo")) tag := tagFromNode(n)
var content, fcontent, markdown, parentID string ialContent := treenode.IALStr(n) hash := treenode.NodeHash(n, tree, luteEngine) var length int if ast.NodeDocument == n.Type { content = n.IALAttr("title") fcontent = content length = utf8.RuneCountInString(fcontent) } else if n.IsContainerBlock() { markdown = treenode.ExportNodeStdMd(n, luteEngine) if !treenode.IsNodeOCRed(n) { util.PushNodeOCRQueue(n) } content = NodeStaticContent(n, nil, true, indexAssetPath, true)
fc := treenode.FirstLeafBlock(n) if !treenode.IsNodeOCRed(fc) { util.PushNodeOCRQueue(fc) } fcontent = NodeStaticContent(fc, nil, true, false, true)
parentID = n.Parent.ID if h := treenode.HeadingParent(n); nil != h { // 如果在标题块下方，则将标题块作为父节点 parentID = h.ID } length = utf8.RuneCountInString(fcontent) } else { markdown = treenode.ExportNodeStdMd(n, luteEngine) if !treenode.IsNodeOCRed(n) { util.PushNodeOCRQueue(n) } content = NodeStaticContent(n, nil, true, indexAssetPath, true)
parentID = n.Parent.ID if h := treenode.HeadingParent(n); nil != h { parentID = h.ID } length = utf8.RuneCountInString(content) }
block = &Block{ ID: n.ID, ParentID: parentID, RootID: rootID, Hash: hash, Box: boxID, Path: p, HPath: tree.HPath, Name: name, Alias: alias, Memo: memo, Tag: tag, Content: content, FContent: fcontent, Markdown: markdown, Length: length, Type: treenode.TypeAbbr(n.Type.String()), SubType: treenode.SubTypeAbbr(n), IAL: ialContent, Sort: nSort(n), Created: util.TimeFromID(n.ID), Updated: n.IALAttr("updated"), }
attrs := parse.IAL2Map(n.KramdownIAL) for attrName, attrVal := range attrs { if !isAttr(attrName) { continue }
attr := &Attribute{ ID: ast.NewNodeID(), Name: attrName, Value: attrVal, Type: "b", BlockID: n.ID, RootID: rootID, Box: boxID, Path: p, } attributes = append(attributes, attr) } return}
func tagFromNode(node *ast.Node) (ret string) { tagBuilder := bytes.Buffer{}
if ast.NodeDocument == node.Type { tagIAL := html.UnescapeString(node.IALAttr("tags")) tags := strings.Split(tagIAL, ",") for _, t := range tags { t = strings.TrimSpace(t) if "" == t { continue } tagBuilder.WriteString("#") tagBuilder.WriteString(t) tagBuilder.WriteString("# ") } return strings.TrimSpace(tagBuilder.String()) }
ast.Walk(node, func(n *ast.Node, entering bool) ast.WalkStatus { if !entering { return ast.WalkContinue }
if n.IsTextMarkType("tag") { tagBuilder.WriteString("#") tagBuilder.WriteString(n.Content()) tagBuilder.WriteString("# ") } return ast.WalkContinue }) return strings.TrimSpace(tagBuilder.String())}
func deleteByBoxTx(tx *sql.Tx, box string) (err error) { if err = deleteBlocksByBoxTx(tx, box); err != nil { return } if err = deleteSpansByBoxTx(tx, box); err != nil { return } if err = deleteAssetsByBoxTx(tx, box); err != nil { return } if err = deleteAttributesByBoxTx(tx, box); err != nil { return } if err = deleteBlockRefsByBoxTx(tx, box); err != nil { return } if err = deleteFileAnnotationRefsByBoxTx(tx, box); err != nil { return } return}
func deleteBlocksByIDs(tx *sql.Tx, ids []string) (err error) { if 1 > len(ids) { return }
var ftsIDs []string for _, id := range ids { removeBlockCache(id) ftsIDs = append(ftsIDs, "\""+id+"\"") }
var rowIDs []string stmt := "SELECT ROWID FROM blocks WHERE id IN (" + strings.Join(ftsIDs, ",") + ")" rows, err := tx.Query(stmt) if err != nil { logging.LogErrorf("query block rowIDs failed: %s", err) return } for rows.Next() { var rowID int64 if err = rows.Scan(&rowID); err != nil { logging.LogErrorf("scan block rowID failed: %s", err) rows.Close() return } rowIDs = append(rowIDs, strconv.FormatInt(rowID, 10)) } rows.Close()
if 1 > len(rowIDs) { return }
stmt = "DELETE FROM blocks WHERE ROWID IN (" + strings.Join(rowIDs, ",") + ")" if err = execStmtTx(tx, stmt); err != nil { return }
stmt = "DELETE FROM blocks_fts WHERE ROWID IN (" + strings.Join(rowIDs, ",") + ")" if err = execStmtTx(tx, stmt); err != nil { return }
if !caseSensitive { stmt = "DELETE FROM blocks_fts_case_insensitive WHERE ROWID IN (" + strings.Join(rowIDs, ",") + ")" if err = execStmtTx(tx, stmt); err != nil { return } } return}
func deleteBlocksByBoxTx(tx *sql.Tx, box string) (err error) { stmt := "DELETE FROM blocks WHERE box = ?" if err = execStmtTx(tx, stmt, box); err != nil { return } stmt = "DELETE FROM blocks_fts WHERE box = ?" if err = execStmtTx(tx, stmt, box); err != nil { return } if !caseSensitive { stmt = "DELETE FROM blocks_fts_case_insensitive WHERE box = ?" if err = execStmtTx(tx, stmt, box); err != nil { return } } ClearCache() return}
func deleteSpansByRootID(tx *sql.Tx, rootID string) (err error) { stmt := "DELETE FROM spans WHERE root_id =?" err = execStmtTx(tx, stmt, rootID) return}
func deleteSpansByBoxTx(tx *sql.Tx, box string) (err error) { stmt := "DELETE FROM spans WHERE box = ?" err = execStmtTx(tx, stmt, box) return}
func deleteAssetsByRootID(tx *sql.Tx, rootID string) (err error) { stmt := "DELETE FROM assets WHERE root_id = ?" err = execStmtTx(tx, stmt, rootID) return}
func deleteAssetsByBoxTx(tx *sql.Tx, box string) (err error) { stmt := "DELETE FROM assets WHERE box = ?" err = execStmtTx(tx, stmt, box) return}
func deleteAttributesByRootID(tx *sql.Tx, rootID string) (err error) { stmt := "DELETE FROM attributes WHERE root_id = ?" err = execStmtTx(tx, stmt, rootID) return
}
func deleteAttributesByBoxTx(tx *sql.Tx, box string) (err error) { stmt := "DELETE FROM attributes WHERE box = ?" err = execStmtTx(tx, stmt, box) return}
func deleteRefsByPath(tx *sql.Tx, box, path string) (err error) { stmt := "DELETE FROM refs WHERE box = ? AND path = ?" err = execStmtTx(tx, stmt, box, path) return}
func deleteRefsByPathTx(tx *sql.Tx, box, path string) (err error) { stmt := "DELETE FROM refs WHERE box = ? AND path = ?" err = execStmtTx(tx, stmt, box, path) return}
func deleteRefsByBoxTx(tx *sql.Tx, box string) (err error) { if err = deleteFileAnnotationRefsByBoxTx(tx, box); err != nil { return } return deleteBlockRefsByBoxTx(tx, box)}
func deleteBlockRefsByBoxTx(tx *sql.Tx, box string) (err error) { stmt := "DELETE FROM refs WHERE box = ?" err = execStmtTx(tx, stmt, box) return}
func deleteFileAnnotationRefsByPath(tx *sql.Tx, box, path string) (err error) { stmt := "DELETE FROM file_annotation_refs WHERE box = ? AND path = ?" err = execStmtTx(tx, stmt, box, path) return}
func deleteFileAnnotationRefsByPathTx(tx *sql.Tx, box, path string) (err error) { stmt := "DELETE FROM file_annotation_refs WHERE box = ? AND path = ?" err = execStmtTx(tx, stmt, box, path) return}
func deleteFileAnnotationRefsByBoxTx(tx *sql.Tx, box string) (err error) { stmt := "DELETE FROM file_annotation_refs WHERE box = ?" err = execStmtTx(tx, stmt, box) return}
func deleteByRootID(tx *sql.Tx, rootID string, context map[string]interface{}) (err error) { stmt := "DELETE FROM blocks WHERE root_id = ?" if err = execStmtTx(tx, stmt, rootID); err != nil { return } stmt = "DELETE FROM blocks_fts WHERE root_id = ?" if err = execStmtTx(tx, stmt, rootID); err != nil { return } if !caseSensitive { stmt = "DELETE FROM blocks_fts_case_insensitive WHERE root_id = ?" if err = execStmtTx(tx, stmt, rootID); err != nil { return } } stmt = "DELETE FROM spans WHERE root_id = ?" if err = execStmtTx(tx, stmt, rootID); err != nil { return } stmt = "DELETE FROM assets WHERE root_id = ?" if err = execStmtTx(tx, stmt, rootID); err != nil { return } stmt = "DELETE FROM refs WHERE root_id = ?" if err = execStmtTx(tx, stmt, rootID); err != nil { return } stmt = "DELETE FROM file_annotation_refs WHERE root_id = ?" if err = execStmtTx(tx, stmt, rootID); err != nil { return } stmt = "DELETE FROM attributes WHERE root_id = ?" if err = execStmtTx(tx, stmt, rootID); err != nil { return } ClearCache() eventbus.Publish(eventbus.EvtSQLDeleteBlocks, context, rootID) return}
func batchDeleteByRootIDs(tx *sql.Tx, rootIDs []string, context map[string]interface{}) (err error) { if 1 > len(rootIDs) { return }
ids := strings.Join(rootIDs, "','") ids = "('" + ids + "')" stmt := "DELETE FROM blocks WHERE root_id IN " + ids if err = execStmtTx(tx, stmt); err != nil { return } stmt = "DELETE FROM blocks_fts WHERE root_id IN " + ids if err = execStmtTx(tx, stmt); err != nil { return } if !caseSensitive { stmt = "DELETE FROM blocks_fts_case_insensitive WHERE root_id IN " + ids if err = execStmtTx(tx, stmt); err != nil { return } } stmt = "DELETE FROM spans WHERE root_id IN " + ids if err = execStmtTx(tx, stmt); err != nil { return } stmt = "DELETE FROM assets WHERE root_id IN " + ids if err = execStmtTx(tx, stmt); err != nil { return } stmt = "DELETE FROM refs WHERE root_id IN " + ids if err = execStmtTx(tx, stmt); err != nil { return } stmt = "DELETE FROM file_annotation_refs WHERE root_id IN " + ids if err = execStmtTx(tx, stmt); err != nil { return } stmt = "DELETE FROM attributes WHERE root_id IN " + ids if err = execStmtTx(tx, stmt); err != nil { return } ClearCache() eventbus.Publish(eventbus.EvtSQLDeleteBlocks, context, fmt.Sprintf("%d", len(rootIDs))) return}
func batchDeleteByPathPrefix(tx *sql.Tx, boxID, pathPrefix string) (err error) { stmt := "DELETE FROM blocks WHERE box = ? AND path LIKE ?" if err = execStmtTx(tx, stmt, boxID, pathPrefix+"%"); err != nil { return } stmt = "DELETE FROM blocks_fts WHERE box = ? AND path LIKE ?" if err = execStmtTx(tx, stmt, boxID, pathPrefix+"%"); err != nil { return } if !caseSensitive { stmt = "DELETE FROM blocks_fts_case_insensitive WHERE box = ? AND path LIKE ?" if err = execStmtTx(tx, stmt, boxID, pathPrefix+"%"); err != nil { return } } stmt = "DELETE FROM spans WHERE box = ? AND path LIKE ?" if err = execStmtTx(tx, stmt, boxID, pathPrefix+"%"); err != nil { return } stmt = "DELETE FROM assets WHERE box = ? AND docpath LIKE ?" if err = execStmtTx(tx, stmt, boxID, pathPrefix+"%"); err != nil { return } stmt = "DELETE FROM refs WHERE box = ? AND path LIKE ?" if err = execStmtTx(tx, stmt, boxID, pathPrefix+"%"); err != nil { return } stmt = "DELETE FROM file_annotation_refs WHERE box = ? AND path LIKE ?" if err = execStmtTx(tx, stmt, boxID, pathPrefix+"%"); err != nil { return } stmt = "DELETE FROM attributes WHERE box = ? AND path LIKE ?" if err = execStmtTx(tx, stmt, boxID, pathPrefix+"%"); err != nil { return } ClearCache() return}
func batchUpdatePath(tx *sql.Tx, tree *parse.Tree, context map[string]interface{}) (err error) { stmt := "UPDATE blocks SET box = ?, path = ?, hpath = ? WHERE root_id = ?" if err = execStmtTx(tx, stmt, tree.Box, tree.Path, tree.HPath, tree.ID); err != nil { return } stmt = "UPDATE blocks_fts SET box = ?, path = ?, hpath = ? WHERE root_id = ?" if err = execStmtTx(tx, stmt, tree.Box, tree.Path, tree.HPath, tree.ID); err != nil { return } if !caseSensitive { stmt = "UPDATE blocks_fts_case_insensitive SET box = ?, path = ?, hpath = ? WHERE root_id = ?" if err = execStmtTx(tx, stmt, tree.Box, tree.Path, tree.HPath, tree.ID); err != nil { return } } ClearCache() evtHash := fmt.Sprintf("%x", sha256.Sum256([]byte(tree.ID)))[:7] eventbus.Publish(eventbus.EvtSQLUpdateBlocksHPaths, context, 1, evtHash) return}
func batchUpdateHPath(tx *sql.Tx, tree *parse.Tree, context map[string]interface{}) (err error) { stmt := "UPDATE blocks SET hpath = ? WHERE root_id = ?" if err = execStmtTx(tx, stmt, tree.HPath, tree.ID); err != nil { return } stmt = "UPDATE blocks_fts SET hpath = ? WHERE root_id = ?" if err = execStmtTx(tx, stmt, tree.HPath, tree.ID); err != nil { return } if !caseSensitive { stmt = "UPDATE blocks_fts_case_insensitive SET hpath = ? WHERE root_id = ?" if err = execStmtTx(tx, stmt, tree.HPath, tree.ID); err != nil { return } } ClearCache() evtHash := fmt.Sprintf("%x", sha256.Sum256([]byte(tree.ID)))[:7] eventbus.Publish(eventbus.EvtSQLUpdateBlocksHPaths, context, 1, evtHash) return}
func CloseDatabase() { if err := closeDatabase(); err != nil { logging.LogErrorf("close database failed: %s", err) return } if err := historyDB.Close(); err != nil { logging.LogErrorf("close history database failed: %s", err) return } if err := assetContentDB.Close(); err != nil { logging.LogErrorf("close asset content database failed: %s", err) return } treenode.CloseDatabase() logging.LogInfof("closed database")}
func queryRow(query string, args ...interface{}) *sql.Row { query = strings.TrimSpace(query) if "" == query { logging.LogErrorf("statement is empty") return nil } if nil == db { return nil } return db.QueryRow(query, args...)}
func query(query string, args ...interface{}) (*sql.Rows, error) { query = strings.TrimSpace(query) if "" == query { return nil, errors.New("statement is empty") } if nil == db { return nil, errors.New("database is nil") } return db.Query(query, args...)}
func beginTx() (tx *sql.Tx, err error) { if tx, err = db.Begin(); err != nil { logging.LogErrorf("begin tx failed: %s\n %s", err, logging.ShortStack()) if strings.Contains(err.Error(), "database is locked") { os.Exit(logging.ExitCodeReadOnlyDatabase) } } return}
func commitTx(tx *sql.Tx) (err error) { if nil == tx { logging.LogErrorf("tx is nil") return errors.New("tx is nil") }
if err = tx.Commit(); err != nil { logging.LogErrorf("commit tx failed: %s\n %s", err, logging.ShortStack()) } return}
func beginHistoryTx() (tx *sql.Tx, err error) { if tx, err = historyDB.Begin(); err != nil { logging.LogErrorf("begin history tx failed: %s\n %s", err, logging.ShortStack()) if strings.Contains(err.Error(), "database is locked") { os.Exit(logging.ExitCodeReadOnlyDatabase) } } return}
func commitHistoryTx(tx *sql.Tx) (err error) { if nil == tx { logging.LogErrorf("tx is nil") return errors.New("tx is nil") }
if err = tx.Commit(); err != nil { logging.LogErrorf("commit tx failed: %s\n %s", err, logging.ShortStack()) } return}
func beginAssetContentTx() (tx *sql.Tx, err error) { if tx, err = assetContentDB.Begin(); err != nil { logging.LogErrorf("begin asset content tx failed: %s\n %s", err, logging.ShortStack()) if strings.Contains(err.Error(), "database is locked") { os.Exit(logging.ExitCodeReadOnlyDatabase) } } return}
func commitAssetContentTx(tx *sql.Tx) (err error) { if nil == tx { logging.LogErrorf("tx is nil") return errors.New("tx is nil") }
if err = tx.Commit(); err != nil { logging.LogErrorf("commit tx failed: %s\n %s", err, logging.ShortStack()) } return}
func prepareExecInsertTx(tx *sql.Tx, stmtSQL string, args []interface{}) (err error) { stmt, err := tx.Prepare(stmtSQL) if err != nil { return } if _, err = stmt.Exec(args...); err != nil { logging.LogErrorf("exec database stmt [%s] failed: %s", stmtSQL, err) return } return}
func execStmtTx(tx *sql.Tx, stmt string, args ...interface{}) (err error) { if _, err = tx.Exec(stmt, args...); err != nil { if strings.Contains(err.Error(), "database disk image is malformed") { tx.Rollback() closeDatabase() removeDatabaseFile() logging.LogFatalf(logging.ExitCodeReadOnlyDatabase, "database disk image [%s] is malformed, please restart SiYuan kernel to rebuild it", util.DBPath) } logging.LogErrorf("exec database stmt [%s] failed: %s\n %s", stmt, err, logging.ShortStack()) return } return}
func nSort(n *ast.Node) int { switch n.Type { // 以下为块级元素 case ast.NodeHeading: return 5 case ast.NodeParagraph: return 10 case ast.NodeCodeBlock: return 10 case ast.NodeMathBlock: return 10 case ast.NodeTable: return 10 case ast.NodeHTMLBlock: return 10 case ast.NodeList: return 20 case ast.NodeListItem: return 20 case ast.NodeBlockquote: return 20 case ast.NodeSuperBlock: return 30 case ast.NodeAttributeView: return 30 case ast.NodeDocument: return 0 case ast.NodeText, ast.NodeTextMark: if n.IsTextMarkType("tag") { return 205 } return 200 } return 100}
func ialAttr(ial, name string) (ret string) { idx := strings.Index(ial, name) if 0 > idx { return "" } ret = ial[idx+len(name)+2:] ret = ret[:strings.Index(ret, "\"")] return}
func removeDatabaseFile() (err error) { err = os.RemoveAll(util.DBPath) if err != nil { return } err = os.RemoveAll(util.DBPath + "-shm") if err != nil { return } err = os.RemoveAll(util.DBPath + "-wal") if err != nil { return } return}
func closeDatabase() (err error) { if nil == db { return }
err = db.Close() debug.FreeOSMemory() runtime.GC() // 没有这句的话文件句柄不会释放，后面就无法删除文件 return}
func SQLTemplateFuncs(templateFuncMap *template.FuncMap) { (*templateFuncMap)["queryBlocks"] = func(stmt string, args ...string) (retBlocks []*Block) { for _, arg := range args { stmt = strings.Replace(stmt, "?", arg, 1) } retBlocks = SelectBlocksRawStmt(stmt, 1, 512) return } (*templateFuncMap)["getBlock"] = func(arg any) (retBlock *Block) { switch v := arg.(type) { case string: retBlock = GetBlock(v) case map[string]interface{}: if id, ok := v["id"]; ok { retBlock = GetBlock(id.(string)) } } return } (*templateFuncMap)["querySpans"] = func(stmt string, args ...string) (retSpans []*Span) { for _, arg := range args { stmt = strings.Replace(stmt, "?", arg, 1) } retSpans = SelectSpansRawStmt(stmt, 512) return } (*templateFuncMap)["querySQL"] = func(stmt string) (ret []map[string]interface{}) { ret, _ = Query(stmt, 1024) return }}