sql

package module
v1.0.0-alpha-cf931a640... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 18, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

README

gosql

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AtP

func AtP(index int) string

func Colon

func Colon(index int) string

func Configure

func Configure(f func(Config) Config)

func Dollar

func Dollar(index int) string

func PanicOnLogicalError

func PanicOnLogicalError(err error)

func PrintLogicalError

func PrintLogicalError(err error)

func Question

func Question(index int) string

Types

type Config

type Config struct {
	Placeholder         Placeholder
	LogicalErrorHandler func(err error)
}

type DB

type DB sql.DB

func Open

func Open(driverName string, dataSource string) (db *DB, err error)

func (*DB) Begin

func (d *DB) Begin(ctx context.Context, options *TxOptions) (txCtx context.Context, err error)

func (*DB) Commit

func (d *DB) Commit(ctx context.Context) (err error)

func (*DB) End

func (d *DB) End(ctx context.Context, txErr error) (commitErr error, rollbackErr error)

func (*DB) Exec

func (d *DB) Exec(query string, arg ...any) (result Result, err error)

func (*DB) ExecContext

func (d *DB) ExecContext(ctx context.Context, query string, arg ...any) (result Result, err error)

func (*DB) Executor

func (d *DB) Executor(ctx context.Context) (executor Executor)

func (*DB) NamedExec

func (d *DB) NamedExec(query string, args map[string]any) (result Result, err error)

func (*DB) NamedExecContext

func (d *DB) NamedExecContext(ctx context.Context, query string, args map[string]any) (result Result, err error)

func (*DB) NamedQuery

func (d *DB) NamedQuery(query string, args map[string]any) (rows *Rows, err error)

func (*DB) NamedQueryContext

func (d *DB) NamedQueryContext(ctx context.Context, query string, args map[string]any) (rows *Rows, err error)

func (*DB) Query

func (d *DB) Query(query string, args ...any) (rows *Rows, err error)

func (*DB) QueryContext

func (d *DB) QueryContext(ctx context.Context, query string, args ...any) (rows *Rows, err error)

func (*DB) Rollback

func (d *DB) Rollback(ctx context.Context) (err error)

func (*DB) Transactional

func (d *DB) Transactional(
	ctx context.Context,
	f func(ctx context.Context) error,
	options *TxOptions,
) (beginErr error, err error, commitErr error, rollbackErr error)

type Executor

type Executor interface {
	Exec(query string, args ...any) (result Result, err error)
	NamedExec(query string, args map[string]any) (result Result, err error)

	ExecContext(ctx context.Context, query string, args ...any) (result Result, err error)
	NamedExecContext(ctx context.Context, query string, args map[string]any) (result Result, err error)

	Query(query string, args ...any) (rows *Rows, err error)
	NamedQuery(query string, args map[string]any) (rows *Rows, err error)

	QueryContext(ctx context.Context, query string, args ...any) (rows *Rows, err error)
	NamedQueryContext(ctx context.Context, query string, args map[string]any) (rows *Rows, err error)
}

type Frame

type Frame uintptr

func (Frame) File

func (f Frame) File() string

func (Frame) Func

func (f Frame) Func() string

func (Frame) Line

func (f Frame) Line() int

type Placeholder

type Placeholder = func(index int) string

type Result

type Result = sql.Result

type Rows

type Rows = sql.Rows

type StackTrace

type StackTrace []Frame

type Tx

type Tx sql.Tx

func (*Tx) Commit

func (t *Tx) Commit() (err error)

func (*Tx) Exec

func (t *Tx) Exec(query string, arg ...any) (result Result, err error)

func (*Tx) ExecContext

func (t *Tx) ExecContext(ctx context.Context, query string, arg ...any) (result Result, err error)

func (*Tx) NamedExec

func (t *Tx) NamedExec(query string, args map[string]any) (result Result, err error)

func (*Tx) NamedExecContext

func (t *Tx) NamedExecContext(ctx context.Context, query string, args map[string]any) (result Result, err error)

func (*Tx) NamedQuery

func (t *Tx) NamedQuery(query string, args map[string]any) (rows *Rows, err error)

func (*Tx) NamedQueryContext

func (t *Tx) NamedQueryContext(ctx context.Context, query string, args map[string]any) (rows *Rows, err error)

func (*Tx) Query

func (t *Tx) Query(query string, args ...any) (rows *Rows, err error)

func (*Tx) QueryContext

func (t *Tx) QueryContext(ctx context.Context, query string, args ...any) (rows *Rows, err error)

func (*Tx) Rollback

func (t *Tx) Rollback() (err error)

type TxController

type TxController interface {
	Transactional(
		ctx context.Context,
		f func(ctx context.Context) error,
		options *TxOptions,
	) (beginErr error, err error, commitErr error, rollbackErr error)
	Begin(ctx context.Context, options *TxOptions) (txCtx context.Context, err error)
	End(ctx context.Context, txErr error) (rollbackErr error, commitErr error)
	Commit(ctx context.Context) (err error)
	Rollback(ctx context.Context) (err error)
}

type TxOptions

type TxOptions = sql.TxOptions

Jump to

Keyboard shortcuts

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