transaction.go

func Transaction(driver Driver, handler func(driver Driver) error) error {
	if driver == nil {
		return errors.Wrap(ErrInvalidDriver, "sqlxx: cannot create a transaction")
	}

	tx, err := driver.Beginx()
	if err != nil {
		return errors.Wrap(err, "sqlxx: cannot create a transaction")
	}

	client := &Client{Node: tx}
	err = handler(client)
	if err != nil {

		thr := tx.Rollback()
		if thr != nil {
			// TODO: Add an observer to collect this error.
			thr = errors.Wrap(thr, "sqlxx: cannot rollback transaction")
			_ = thr
		}

		return err
	}

	err = tx.Commit()
	if err != nil {
		return errors.Wrap(err, "sqlxx: cannot commit transaction")
	}

	return nil
}