sqldb

package

v0.2.0 Latest Latest Go to latest Published: Apr 7, 2024 License: MIT Imports: 9 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/celer-network/goutils

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ChkExec(res sql.Result, err error, want int64, info string) error
func ChkExecDiffError(res sql.Result, err, diffErr error, want int64) error
func ChkQueryRow(err error) (bool, error)
func InClause(column string, num, start int) string
type Db
- func NewDb(driver, info string, poolSize int) (*Db, error)
type DbTx
type SqlStorage
type TxFunc

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrTxConflict = errors.New("Transaction conflict")
	ErrNoRows     = errors.New("No matching rows in the database")
)

Functions ¶

func ChkExec ¶

func ChkExec(res sql.Result, err error, want int64, info string) error

func ChkExecDiffError ¶

func ChkExecDiffError(res sql.Result, err, diffErr error, want int64) error

Similar to ChkExec() but returns the given "diff error" when the number of rows affected is different from the desired number. This allows the caller to distinguish between the error cases.

func ChkQueryRow ¶

func ChkQueryRow(err error) (bool, error)

func InClause ¶

func InClause(column string, num, start int) string

Return the IN-clause of a SQL query based on the column name, the number of its values and their starting position, e.g. "status IN ($3, $4, $5)"

Types ¶

type Db ¶

type Db struct {
	// contains filtered or unexported fields
}

func NewDb ¶

func NewDb(driver, info string, poolSize int) (*Db, error)

func (*Db) Close ¶

func (d *Db) Close()

func (*Db) Exec ¶

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

func (*Db) OpenTransaction ¶

func (d *Db) OpenTransaction() (*DbTx, error)

func (*Db) Query ¶

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

func (*Db) QueryRow ¶

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

func (*Db) Transactional ¶

func (d *Db) Transactional(callback TxFunc, args ...interface{}) error

type DbTx ¶

type DbTx struct {
	// contains filtered or unexported fields
}

func (*DbTx) Commit ¶

func (t *DbTx) Commit() error

func (*DbTx) ConvertError ¶

func (t *DbTx) ConvertError(err error) error

func (*DbTx) Discard ¶

func (t *DbTx) Discard()

func (*DbTx) Exec ¶

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

func (*DbTx) Query ¶

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

func (*DbTx) QueryRow ¶

func (t *DbTx) QueryRow(query string, args ...interface{}) *sql.Row

type SqlStorage ¶

type SqlStorage interface {
	Exec(query string, args ...interface{}) (sql.Result, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
}

type TxFunc ¶

type TxFunc func(tx *DbTx, args ...interface{}) error

Source Files ¶

View all Source files

sqldb.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL