Могу ли я иметь вложенное ведро под вложенным ведром в boltdb?

Question

Это то, что я должен создавать вложенные корзины. Он не возвращает никакой ошибки, но не может создать вложенное ведро под другим вложенным ведром.

func CreateNestedBuckets(buckets []string) error {
err := db.Update(func(tx *bolt.Tx) error {
    var bkt *bolt.Bucket
    var err error
    first := true
    for _, bucket := range buckets {
        log.Error(bucket)
        if first == true {
            bkt, err = tx.CreateBucketIfNotExists([]byte(bucket))
            first = false
        } else {
            bkt, err = bkt.CreateBucketIfNotExists([]byte(bucket))
        }
        if err != nil {
            log.Error("error creating nested bucket")
            return err
        }
    }
    return nil
})
if err != nil {
    log.Error("error creating nested bucket!!!")
    return err
}
return nil
}

Answer 1

Краткий ответ: да! Вы можете иметь вложенные корзины: https://twitter.com/boltdb/status/454730212010254336

Длинный ответ: ваш код работает нормально! Вот некоторые вещи, чтобы проверить, хотя:

• Вы проверяете правильный файл базы данных болтов? Файл botlt db будет создан в каталоге, из которого вы запускаете код, если только вы не указали абсолютный путь.
• Содержит ли ваш вклад достаточно элементов для создания вложенной структуры?

Я запустил ваш код со следующей настройкой (пара небольших изменений, но ничего особенного), и он отлично работает:

package main

import (
    "log"
    "os"
    "time"

    "github.com/boltdb/bolt"
)

var dbname = "test.bdb"
var dbperms os.FileMode = 0770
var options = &bolt.Options{Timeout: 1 * time.Second}

func main() {
    var names []string
    names = append(names, "bucketOne")
    names = append(names, "bucketTwo")
    names = append(names, "bucketThree")

    if err := CreateNestedBuckets(names); err != nil {
        log.Fatal(err)
    }
}

// CreateNestedBuckets - Function to create
// nested buckets from an array of Strings
func CreateNestedBuckets(buckets []string) error {
    db, dberr := bolt.Open(dbname, dbperms, options)
    if dberr != nil {
        log.Fatal(dberr)
    }
    defer db.Close()

    err := db.Update(func(tx *bolt.Tx) error {
        var bkt *bolt.Bucket
        var err error
        first := true
        for _, bucket := range buckets {
            log.Println(bucket)
            if first == true {
                bkt, err = tx.CreateBucketIfNotExists([]byte(bucket))
                first = false
            } else {
                bkt, err = bkt.CreateBucketIfNotExists([]byte(bucket))
            }
            if err != nil {
                log.Println("error creating nested bucket")
                return err
            }
        }
        return nil
    })
    if err != nil {
        log.Println("error creating nested bucket!!!")
        return err
    }
    return nil
}

Для проверки вы можете просмотреть файл с помощью команды strings:

cat test.bdb | strings
bucketThree
bucketTwo
bucketOne

Если вы работаете в Windows, я не уверен, что такое эквивалентная команда, но вы можете открыть файл с помощью Блокнота и проверить его вручную. Это не будет красиво, но вы все равно должны увидеть название ваших ведер там.

С другой стороны, обработка ошибок приведет к тому, что очень похожие сообщения будут напечатаны последовательно. Вот немного более чистое решение, которое вы можете использовать:

// CreateNestedBucketsNew - function to create
// nested buckets from an array of Strings - my implementation
func CreateNestedBucketsNew(buckets []string) (err error) {
    err = db.Update(func(tx *bolt.Tx) (err error) {
        var bkt *bolt.Bucket

        for index, bucket := range buckets {
            if index == 0 {
                bkt, err = tx.CreateBucketIfNotExists([]byte(bucket))
            } else {
                bkt, err = bkt.CreateBucketIfNotExists([]byte(bucket))
            }

            if err != nil {
                return fmt.Errorf("Error creating nested bucket [%s]: %v", bucket, err)
            }
        }
        return err
    })
    return err
}

Answer 2

В демонстрации fste89 есть некоторые отладки; это право:

package main

import (
    "fmt"
    "time"

    "github.com/boltdb/bolt"
)

func CreateNestedBuckets(fatherTable string, sonTabls []string) error {
    db, dberr := bolt.Open("your file path", 0600, &bolt.Options{Timeout: 1 * time.Second})
    if dberr != nil {
        fmt.Println(dberr)
    }
    defer db.Close()

    err := db.Update(func(tx *bolt.Tx) error {
        var bkt *bolt.Bucket
        var err error
        bkFather, err = tx.CreateBucketIfNotExists([]byte(fatherTable))

        for _, ta := range sonTabls {
            fmt.Println(ta)

            _, err = bkFather.CreateBucketIfNotExists([]byte(ta))

            if err != nil {
                fmt.Println("error creating nested bucket")
                return err
            }
        }
        return nil
    })
    if err != nil {
        fmt.Println("error creating nested bucket!!!")
        return err
    }
    return nil
}

func main() {
    t := []string{"cc", "1", "2", "3"}
    fmt.Println(CreateNestedBuckets("sb", t))
}

эхо:

cc
1
2
3
<nil>

Видно введите описание изображения здесь

Answer 3

func CreateNestedBuckets(fatherTable string, sonTables []string) error {
    db, dberr := bolt.Open("E:\\OneDrive\\code\\go\\project\\transmission\\static\\localstorage.db", 0600, &bolt.Options{Timeout: 1 * time.Second})
    if dberr != nil {
        fmt.Println(dberr)
    }
    defer db.Close()

    err := db.Update(func(tx *bolt.Tx) error {
        var err error
        bkFather, err := tx.CreateBucketIfNotExists([]byte(fatherTable))

        for _, ta := range sonTables {
            fmt.Println(ta)

            _, err = bkFather.CreateBucketIfNotExists([]byte(ta))

            if err != nil {
                fmt.Println("error creating nested bucket")
                return err
            }
        }
        return nil
    })
    if err != nil {
        fmt.Println("error creating nested bucket!!!")
        return err
    }
    return nil
}