diff --git a/kernel/treenode/blocktree.go b/kernel/treenode/blocktree.go index ab699aaa9..229d833e2 100644 --- a/kernel/treenode/blocktree.go +++ b/kernel/treenode/blocktree.go @@ -569,6 +569,10 @@ func IndexBlockTree(tree *parse.Tree) { } execInsertBlocktrees(tx, tree, changedNodes) + + if err = tx.Commit(); err != nil { + logging.LogErrorf("commit transaction failed: %s", err) + } } func UpsertBlockTree(tree *parse.Tree) { @@ -628,6 +632,10 @@ func UpsertBlockTree(tree *parse.Tree) { } execInsertBlocktrees(tx, tree, changedNodes) + + if err = tx.Commit(); err != nil { + logging.LogErrorf("commit transaction failed: %s", err) + } } func execInsertBlocktrees(tx *sql.Tx, tree *parse.Tree, changedNodes []*ast.Node) { @@ -651,9 +659,6 @@ func execInsertBlocktrees(tx *sql.Tx, tree *parse.Tree, changedNodes []*ast.Node return } } - if err = tx.Commit(); err != nil { - logging.LogErrorf("commit transaction failed: %s", err) - } } func InitBlockTree(force bool) {