Как я могу гарантировать, что все мои функции транзакции записи будут разрешены по порядку? Кроме того, почему функция else не выполняется? - PullRequest
0 голосов
/ 14 января 2019

Я пытаюсь создать очень простую базу данных Bolt с именем ledger.db, которая включает в себя одно Bucket, называемое «Users», которое содержит имена пользователей в качестве ключа и Balances в качестве значения, которое позволяет пользователям переводить свой баланс в один другой. Я использую Bolter для просмотра базы данных в командной строке

Существует две проблемы, обе из которых содержатся в этой проблеме передаточной функции, которая находится в передаточной функции.

Первое: внутри передаточной функции есть if / else. Если условие истинно, оно выполняется так, как должно. Если это неверно, ничего не происходит. Синтаксических ошибок нет, и программа работает так, как будто ничего плохого, она просто не выполняет оператор else.

Второе: даже если условие истинно, при выполнении оно не обновляет ОБА соответствующие значения баланса в базе данных. Он обновляет баланс получателя, но не делает то же самое для отправителя. Математические операции завершены, и значения упорядочены в JSON-совместимый формат.

Проблема в том, что баланс отправителя не обновляется в базе данных.

Все со второго "Удачи!" Функция fmt.Println () и далее не обрабатывается

Я попытался изменить "db.Update ()" на "db.Batch ()". Я попытался изменить порядок функций Put (). Я пробовал возиться с горутинами и откладывать, но понятия не имею, как их использовать, так как я довольно новичок в 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: 90000 Trig: 0 от начальных значений Big: 50000 Trig: 40000

Вместо этого программа выводит Big: 90000 Trig: 40000

1 Ответ

0 голосов
/ 14 января 2019

Вы возвращаетесь безоговорочно:

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!")

Вы не возвращаете и не проверяете ошибки.

json.Unmarshal(uBuck.Get([]byte(from.username)), &fbalance)
json.Unmarshal(uBuck.Get([]byte(to.username)), &tbalance)

t.transfer(b, 40000)

и т. Д.


Отладка вашего утверждения кода по утверждению.

...