database

Documentation

Index

• func MaskSecret(dsn string) string
• type DB
  • func NewDatabase(dsn string) (DB, error)
• type Database
  • func (d *Database) BeginTransaction(ctx context.Context) (Transaction, error)
  • func (d *Database) ExecContext(ctx context.Context, query string, args ...interface{}) (int64, error)
  • func (d *Database) QueryRowsContext(ctx context.Context, query string, args ...interface{}) ([]map[string]interface{}, error)
• type Transaction
• type Tx
  • func (t *Tx) Commit() error
  • func (t *Tx) ExecContext(ctx context.Context, query string, args ...interface{}) (int64, error)
  • func (t *Tx) QueryRowsContext(ctx context.Context, query string, args ...interface{}) ([]map[string]interface{}, error)
  • func (t *Tx) Rollback() error

Functions

func MaskSecret

func MaskSecret(dsn string) string

Types

type DB

type DB interface {
	QueryRowsContext(ctx context.Context, query string, args ...interface{}) ([]map[string]interface{}, error)
	ExecContext(ctx context.Context, query string, args ...interface{}) (int64, error)
	BeginTransaction(ctx context.Context) (Transaction, error)
	Close() error
}

func NewDatabase

func NewDatabase(dsn string) (DB, error)

type Database

type Database struct {
	*sqlx.DB
	// contains filtered or unexported fields
}

func (*Database) BeginTransaction

func (d *Database) BeginTransaction(ctx context.Context) (Transaction, error)

func (*Database) ExecContext

func (d *Database) ExecContext(ctx context.Context, query string, args ...interface{}) (int64, error)

func (*Database) QueryRowsContext

func (d *Database) QueryRowsContext(ctx context.Context, query string, args ...interface{}) ([]map[string]interface{}, error)

type Transaction

type Transaction interface {
	QueryRowsContext(ctx context.Context, query string, args ...interface{}) ([]map[string]interface{}, error)
	ExecContext(ctx context.Context, query string, args ...interface{}) (int64, error)
	Rollback() error
	Commit() error
}

type Tx

type Tx struct {
	*sqlx.Tx
	// contains filtered or unexported fields
}

func (*Tx) Commit

func (t *Tx) Commit() error

func (*Tx) ExecContext

func (t *Tx) ExecContext(ctx context.Context, query string, args ...interface{}) (int64, error)

func (*Tx) QueryRowsContext

func (t *Tx) QueryRowsContext(ctx context.Context, query string, args ...interface{}) ([]map[string]interface{}, error)

func (*Tx) Rollback

func (t *Tx) Rollback() error