我正在尝试创建一个非常简单的 Bolt 数据库,名为“ledger.db”,其中包含一个名为“Users”的 Bucket,其中包含 Usernames 作为 Key 和 Balances 作为允许用户相互转移余额的值。我正在使用 Bolter 在命令行中查看数据库
有两个问题,都包含在这个传递函数中,问题在于传递函数。
第一个:传递函数内部是一个 if/else。如果条件为真,则按应有的方式执行。如果它是假的,什么都不会发生。没有语法错误,程序运行起来好像没有任何问题,只是不执行 else 语句。
第二:即使条件为真,当它执行时,它也不会更新数据库中各自的余额值。它会更新接收者的余额,但不会对发送者做同样的事情。数学运算完成,值被编组为与 JSON 兼容的格式。
问题是发件人余额未在数据库中更新。
一切都来自第二个“成功!” fmt.Println() 函数未处理
我尝试将“db.Update()”更改为“db.Batch()”。我试过改变 Put() 函数的顺序。我试过弄乱goroutines和defer,但我不知道如何使用它们,因为我对golang相当陌生。
func (from *User) transfer(to User, amount int) error{
var fbalance int = 0
var tbalance int = 0
db, err := bolt.Open("ledger.db", 0600, nil)
if err != nil {
log.Fatal(err)
}
defer db.Close()
return db.Update(func(tx *bolt.Tx) error {
uBuck := tx.Bucket([]byte("Users"))
json.Unmarshal(uBuck.Get([]byte(from.username)), &fbalance)
json.Unmarshal(uBuck.Get([]byte(to.username)), &tbalance)
if (amount <= fbalance) {
fbalance = fbalance - amount
encoded, err := json.Marshal(fbalance)
if err != nil {
return err
}
tbalance = tbalance + amount
encoded2, err := json.Marshal(tbalance)
if err != nil {
return err
}
fmt.Println("Success!")
c := uBuck
err = c.Put([]byte(to.username), encoded2)
return err
fmt.Println("Success!")
err = c.Put([]byte(from.username), encoded)
return err
fmt.Println("Success!")
} else {
return fmt.Errorf("Not enough in balance!", amount)
}
return nil
})
return nil
}
func main() {
/*
db, err := bolt.Open("ledger.db", 0600, nil)
if err != nil {
log.Fatal(err)
}
defer db.Close()
*/
var b User = User{"Big", "jig", 50000, 0}
var t User = User{"Trig", "pig", 40000, 0}
// These two functions add each User to the database, they aren't
// the problem
b.createUser()
t.createUser()
/*
db.View(func(tx *bolt.Tx) error {
c := tx.Bucket([]byte("Users"))
get := c.Get([]byte(b.username))
fmt.Printf("The return value %v",get)
return nil
})
*/
t.transfer(b, 40000)
}
我希望数据库从 Big:50000 Trig:40000 的初始值开始显示 Big:90000 Trig:0
相反,程序输出 Big:90000 Trig:40000