db

Documentation

Index

• Variables
• func Init(dsnRO, dsnRW string, debug bool) error
• func WithTx(exec boil.Executor, currentTx boil.Transactor, f TxFunc) (err error)
• type QueryLogger
  • func (d *QueryLogger) Begin() (boil.Transactor, error)
  • func (d *QueryLogger) Close() error
  • func (d *QueryLogger) Exec(query string, args ...interface{}) (sql.Result, error)
  • func (d *QueryLogger) Query(query string, args ...interface{}) (*sql.Rows, error)
  • func (d *QueryLogger) QueryRow(query string, args ...interface{}) *sql.Row
• type TxFunc

Variables

var RO boil.Executor

RO this db can only be used for read-only calls. Calls made that trigger a RW will break replication if successful but also should actually produce an error from mysql.

var RW boil.Executor

RW this db is used for read-write calls, it can be used for RO calls too but to load balance use the RO please.

Functions

func Init

func Init(dsnRO, dsnRW string, debug bool) error

Init initializes a database connection based on the dsn provided. It also sets it as the global db connection.

func WithTx

func WithTx(exec boil.Executor, currentTx boil.Transactor, f TxFunc) (err error)

WithTx wraps a function in an sql transaction. the transaction is committed if there's no error, or rolled back if there is one. if `currentTx` is nil, a new transaction is started. otherwise currentTx is used as the transaction

Types

type QueryLogger

type QueryLogger struct {
	DB      *sqlx.DB
	Logger  *log.Logger
	Enabled bool
	Name    string
}

QueryLogger is used to add extended logging for db queries in debug mode.

func (*QueryLogger) Begin

func (d *QueryLogger) Begin() (boil.Transactor, error)

Begin implementation of Executor

func (*QueryLogger) Close

func (d *QueryLogger) Close() error

Close implementation of Executor

func (*QueryLogger) Exec

func (d *QueryLogger) Exec(query string, args ...interface{}) (sql.Result, error)

Exec implementation of Executor

func (*QueryLogger) Query

func (d *QueryLogger) Query(query string, args ...interface{}) (*sql.Rows, error)

Query implementation of Executor

func (*QueryLogger) QueryRow

func (d *QueryLogger) QueryRow(query string, args ...interface{}) *sql.Row

QueryRow implementation of Executor

type TxFunc

type TxFunc func(tx boil.Transactor) error

TxFunc is a function that can be wrapped in a transaction