moneygo/internal/handlers/tx.go

package handlers

import (
	"database/sql"
	"github.com/aclindsa/gorp"
	"strings"
)

type Tx struct {
	Dialect gorp.Dialect
	Tx      *gorp.Transaction
}

func (tx *Tx) Rebind(query string) string {
	chunks := strings.Split(query, "?")
	str := chunks[0]
	for i := 1; i < len(chunks); i++ {
		str += tx.Dialect.BindVar(i-1) + chunks[i]
	}
	return str
}

func (tx *Tx) Select(i interface{}, query string, args ...interface{}) ([]interface{}, error) {
	return tx.Tx.Select(i, tx.Rebind(query), args...)
}

func (tx *Tx) Exec(query string, args ...interface{}) (sql.Result, error) {
	return tx.Tx.Exec(tx.Rebind(query), args...)
}

func (tx *Tx) SelectInt(query string, args ...interface{}) (int64, error) {
	return tx.Tx.SelectInt(tx.Rebind(query), args...)
}

func (tx *Tx) SelectOne(holder interface{}, query string, args ...interface{}) error {
	return tx.Tx.SelectOne(holder, tx.Rebind(query), args...)
}

func (tx *Tx) Insert(list ...interface{}) error {
	return tx.Tx.Insert(list...)
}

func (tx *Tx) Update(list ...interface{}) (int64, error) {
	return tx.Tx.Update(list...)
}

func (tx *Tx) Delete(list ...interface{}) (int64, error) {
	return tx.Tx.Delete(list...)
}

func (tx *Tx) Commit() error {
	return tx.Tx.Commit()
}

func (tx *Tx) Rollback() error {
	return tx.Tx.Rollback()
}

func GetTx(db *gorp.DbMap) (*Tx, error) {
	tx, err := db.Begin()
	if err != nil {
		return nil, err
	}
	return &Tx{db.Dialect, tx}, nil
}