Transaction

Queryx also supported type-safe database transactions, making it easy to execute database transactions safely.

Creating a transaction:

c, err := db.NewClient()
tx := c.Tx()

c, err := db.NewClient()
tx := c.Tx()

The queryx transaction object works similarly to the queryx client methods with the exception that it requires an additional commit call to make changes to the database.

post, err := tx.QueryPost().Create(tx.ChangPost().SetTitle("post title"))
err := post.Update(tx.ChangePost().SetTitle("new post title"))
if err := tx.Commit() {
  tx.Rollback()
}

post, err := tx.QueryPost().Create(tx.ChangPost().SetTitle("post title"))
err := post.Update(tx.ChangePost().SetTitle("new post title"))
if err := tx.Commit() {
  tx.Rollback()
}

Queryx also supports wrapping transactions within a function block to avoid manual commit and rollback operations. Queryx automatically performs the rollback operation in case of an error returned from the function block.

err := c.Transaction(func (tx *db.Tx) error {
  post, err := tx.QueryPost().Create(tx.ChangPost().SetTitle("post title"))
  if err != nil {
    return err
  }
  err := post.Update(tx.ChangePost().SetTitle("new post title"))
  if err != nil {
    return err
  }
  return nil
})

err := c.Transaction(func (tx *db.Tx) error {
  post, err := tx.QueryPost().Create(tx.ChangPost().SetTitle("post title"))
  if err != nil {
    return err
  }
  err := post.Update(tx.ChangePost().SetTitle("new post title"))
  if err != nil {
    return err
  }
  return nil
})

Transaction ​

Transaction