Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

sql

package

Go to main page

Versions in this module

v0

v0.3.1

Aug 25, 2022

v0.3.0

Aug 24, 2022

v0.2.1

Apr 30, 2022

v0.2.0

Apr 30, 2022

Changes in this version

+ type ConnBeginTx invocation[Conn, ConnHook, func(ctx context.Context, txOptions *sql.TxOptions) (*Tx, error)]

+ func NewConnBeginTx(recv *Conn, ...) *ConnBeginTx

+ func (invocation *ConnBeginTx) Proceed(ctx context.Context, txOptions *sql.TxOptions) (*Tx, error)

+ type ConnClose invocation[Conn, ConnHook, func() error]

+ func NewConnClose(recv *Conn, original func() error) *ConnClose

+ func (invocation *ConnClose) Proceed() error

+ type ConnExec invocation[Conn, ConnHook, func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)]

+ func (invocation *ConnExec) Proceed(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func NewConnExec(recv *Conn, ...) *ConnExec

+ type ConnFind invocation[Conn, ConnHook, func(ctx context.Context, dest interface{}, query string, args ...interface{}) error]

+ func (invocation *ConnFind) Proceed(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func NewConnFind(recv *Conn, ...) *ConnFind

+ type ConnFindAll invocation[Conn, ConnHook, func(ctx context.Context, dest interface{}, query string, args ...interface{}) error]

+ func (invocation *ConnFindAll) Proceed(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func NewConnFindAll(recv *Conn, ...) *ConnFindAll

+ type ConnHook struct

+ BeginTx func(invocation *ConnBeginTx, ctx context.Context, txOptions *sql.TxOptions) (*Tx, error)

+ Close func(invocation *ConnClose) error

+ Exec func(invocation *ConnExec, ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ Find func(invocation *ConnFind, ctx context.Context, dest interface{}, query string, ...) error

+ FindAll func(invocation *ConnFindAll, ctx context.Context, dest interface{}, query string, ...) error

+ Ping func(invocation *ConnPing, ctx context.Context) error

+ Prepare func(invocation *ConnPrepare, ctx context.Context, query string, ...) (*Stmt, error)

+ Query func(invocation *ConnQuery, ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ type ConnPing invocation[Conn, ConnHook, func(ctx context.Context) error]

+ func NewConnPing(recv *Conn, original func(ctx context.Context) error) *ConnPing

+ func (invocation *ConnPing) Proceed(ctx context.Context) error

+ type ConnPrepare invocation[Conn, ConnHook, func(ctx context.Context, query string, examples ...interface{}) (*Stmt, error)]

+ func (invocation *ConnPrepare) Proceed(ctx context.Context, query string, examples ...interface{}) (*Stmt, error)

+ func NewConnPrepare(recv *Conn, ...) *ConnPrepare

+ type ConnQuery invocation[Conn, ConnHook, func(ctx context.Context, query string, args ...interface{}) (*Rows, error)]

+ func (invocation *ConnQuery) Proceed(ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ func NewConnQuery(recv *Conn, ...) *ConnQuery

+ type Core struct

+ func NewCore(db kra.DB, hooks ...interface{}) *Core

type DB

+ func (db *DB) Conn(ctx context.Context) (*Conn, error)

+ type DBBeginTx invocation[DB, DBHook, func(ctx context.Context, txOptions *sql.TxOptions) (*Tx, error)]

+ func NewDBBeginTx(recv *DB, ...) *DBBeginTx

+ func (invocation *DBBeginTx) Proceed(ctx context.Context, txOptions *sql.TxOptions) (*Tx, error)

+ type DBClose invocation[DB, DBHook, func() error]

+ func NewDBClose(recv *DB, original func() error) *DBClose

+ func (invocation *DBClose) Proceed() error

+ type DBExec invocation[DB, DBHook, func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)]

+ func (invocation *DBExec) Proceed(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func NewDBExec(recv *DB, ...) *DBExec

+ type DBFind invocation[DB, DBHook, func(ctx context.Context, dest interface{}, query string, args ...interface{}) error]

+ func (invocation *DBFind) Proceed(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func NewDBFind(recv *DB, ...) *DBFind

+ type DBFindAll invocation[DB, DBHook, func(ctx context.Context, dest interface{}, query string, args ...interface{}) error]

+ func (invocation *DBFindAll) Proceed(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func NewDBFindAll(recv *DB, ...) *DBFindAll

+ type DBHook struct

+ BeginTx func(invocation *DBBeginTx, ctx context.Context, txOptions *sql.TxOptions) (*Tx, error)

+ Close func(invocation *DBClose) error

+ Exec func(invocation *DBExec, ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ Find func(invocation *DBFind, ctx context.Context, dest interface{}, query string, ...) error

+ FindAll func(invocation *DBFindAll, ctx context.Context, dest interface{}, query string, ...) error

+ Ping func(invocation *DBPing, ctx context.Context) error

+ Prepare func(invocation *DBPrepare, ctx context.Context, query string, ...) (*Stmt, error)

+ Query func(invocation *DBQuery, ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ type DBPing invocation[DB, DBHook, func(ctx context.Context) error]

+ func NewDBPing(recv *DB, original func(ctx context.Context) error) *DBPing

+ func (invocation *DBPing) Proceed(ctx context.Context) error

+ type DBPrepare invocation[DB, DBHook, func(ctx context.Context, query string, examples ...interface{}) (*Stmt, error)]

+ func (invocation *DBPrepare) Proceed(ctx context.Context, query string, examples ...interface{}) (*Stmt, error)

+ func NewDBPrepare(recv *DB, ...) *DBPrepare

+ type DBQuery invocation[DB, DBHook, func(ctx context.Context, query string, args ...interface{}) (*Rows, error)]

+ func (invocation *DBQuery) Proceed(ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ func NewDBQuery(recv *DB, ...) *DBQuery

+ type HookHolster struct

+ Conn []*ConnHook

+ Core []*kra.CoreHook

+ DB []*DBHook

+ Rows []*RowsHook

+ Stmt []*StmtHook

+ Tx []*TxHook

+ func NewHookHolster(hooks ...interface{}) *HookHolster

type Rows

+ func NewRows(core *Core, rows *sql.Rows) *Rows

+ type RowsClose invocation[Rows, RowsHook, func() error]

+ func NewRowsClose(recv *Rows, original func() error) *RowsClose

+ func (invocation *RowsClose) Proceed() error

+ type RowsErr invocation[Rows, RowsHook, func() error]

+ func NewRowsErr(recv *Rows, original func() error) *RowsErr

+ func (invocation *RowsErr) Proceed() error

+ type RowsHook struct

+ Close func(invocation *RowsClose) error

+ Err func(invocation *RowsErr) error

+ Next func(invocation *RowsNext) bool

+ Scan func(invocation *RowsScan, dest interface{}) error

+ type RowsNext invocation[Rows, RowsHook, func() bool]

+ func NewRowsNext(recv *Rows, original func() bool) *RowsNext

+ func (invocation *RowsNext) Proceed() bool

+ type RowsScan invocation[Rows, RowsHook, func(dest interface{}) error]

+ func (invocation *RowsScan) Proceed(dest interface{}) error

+ func NewRowsScan(recv *Rows, original func(dest interface{}) error) *RowsScan

+ type StmtClose invocation[Stmt, StmtHook, func() error]

+ func NewStmtClose(recv *Stmt, original func() error) *StmtClose

+ func (invocation *StmtClose) Proceed() error

+ type StmtExec invocation[Stmt, StmtHook, func(ctx context.Context, args ...interface{}) (sql.Result, error)]

+ func (invocation *StmtExec) Proceed(ctx context.Context, args ...interface{}) (sql.Result, error)

+ func NewStmtExec(recv *Stmt, ...) *StmtExec

+ type StmtHook struct

+ Close func(invocation *StmtClose) error

+ Exec func(invocation *StmtExec, ctx context.Context, args ...interface{}) (sql.Result, error)

+ Query func(invocation *StmtQuery, ctx context.Context, args ...interface{}) (*Rows, error)

+ type StmtQuery invocation[Stmt, StmtHook, func(ctx context.Context, args ...interface{}) (*Rows, error)]

+ func (invocation *StmtQuery) Proceed(ctx context.Context, args ...interface{}) (*Rows, error)

+ func NewStmtQuery(recv *Stmt, ...) *StmtQuery

+ type TxBeginTx invocation[Tx, TxHook, func(ctx context.Context, txOptions *sql.TxOptions) (*Tx, error)]

+ func NewTxBeginTx(recv *Tx, ...) *TxBeginTx

+ func (invocation *TxBeginTx) Proceed(ctx context.Context, txOptions *sql.TxOptions) (*Tx, error)

+ type TxClose invocation[Tx, TxHook, func() error]

+ func NewTxClose(recv *Tx, original func() error) *TxClose

+ func (invocation *TxClose) Proceed() error

+ type TxCommit invocation[Tx, TxHook, func() error]

+ func NewTxCommit(recv *Tx, original func() error) *TxCommit

+ func (invocation *TxCommit) Proceed() error

+ type TxExec invocation[Tx, TxHook, func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)]

+ func (invocation *TxExec) Proceed(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func NewTxExec(recv *Tx, ...) *TxExec

+ type TxFind invocation[Tx, TxHook, func(ctx context.Context, dest interface{}, query string, args ...interface{}) error]

+ func (invocation *TxFind) Proceed(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func NewTxFind(recv *Tx, ...) *TxFind

+ type TxFindAll invocation[Tx, TxHook, func(ctx context.Context, dest interface{}, query string, args ...interface{}) error]

+ func (invocation *TxFindAll) Proceed(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func NewTxFindAll(recv *Tx, ...) *TxFindAll

+ type TxHook struct

+ BeginTx func(invocation *TxBeginTx, ctx context.Context, txOptions *sql.TxOptions) (*Tx, error)

+ Close func(invocation *TxClose) error

+ Commit func(invocation *TxCommit) error

+ Exec func(invocation *TxExec, ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ Find func(invocation *TxFind, ctx context.Context, dest interface{}, query string, ...) error

+ FindAll func(invocation *TxFindAll, ctx context.Context, dest interface{}, query string, ...) error

+ Ping func(invocation *TxPing, ctx context.Context) error

+ Prepare func(invocation *TxPrepare, ctx context.Context, query string, ...) (*Stmt, error)

+ Query func(invocation *TxQuery, ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ Rollback func(invocation *TxRollback) error

+ type TxPing invocation[Tx, TxHook, func(ctx context.Context) error]

+ func NewTxPing(recv *Tx, original func(ctx context.Context) error) *TxPing

+ func (invocation *TxPing) Proceed(ctx context.Context) error

+ type TxPrepare invocation[Tx, TxHook, func(ctx context.Context, query string, examples ...interface{}) (*Stmt, error)]

+ func (invocation *TxPrepare) Proceed(ctx context.Context, query string, examples ...interface{}) (*Stmt, error)

+ func NewTxPrepare(recv *Tx, ...) *TxPrepare

+ type TxQuery invocation[Tx, TxHook, func(ctx context.Context, query string, args ...interface{}) (*Rows, error)]

+ func (invocation *TxQuery) Proceed(ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ func NewTxQuery(recv *Tx, ...) *TxQuery

+ type TxRollback invocation[Tx, TxHook, func() error]

+ func NewTxRollback(recv *Tx, original func() error) *TxRollback

+ func (invocation *TxRollback) Proceed() error

v0.1.7

Apr 17, 2022

v0.1.6

Apr 16, 2022

v0.1.5

Jan 4, 2022

v0.1.4

Nov 24, 2021

v0.1.3

Jun 18, 2021

v0.1.1

Jun 16, 2021

v0.1.0

May 9, 2021

Changes in this version

+ type Conn struct

+ func NewConn(conn *sql.Conn, core *kra.Core) *Conn

+ func (conn *Conn) Begin(ctx context.Context) (*Tx, error)

+ func (conn *Conn) BeginTx(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

+ func (conn *Conn) Close() error

+ func (conn *Conn) Conn() *sql.Conn

+ func (conn *Conn) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (conn *Conn) Find(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (conn *Conn) FindAll(ctx context.Context, dest []interface{}, query string, args ...interface{}) error

+ func (conn *Conn) Ping(ctx context.Context) error

+ func (conn *Conn) Prepare(ctx context.Context, query string, examples ...interface{}) (*Stmt, error)

+ func (conn *Conn) Query(ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ type DB struct

+ func NewDB(db *sql.DB, core *kra.Core) *DB

+ func Open(core *kra.Core, driverName, dataSourceName string) (*DB, error)

+ func (db *DB) Begin(ctx context.Context) (*Tx, error)

+ func (db *DB) BeginTx(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

+ func (db *DB) Close() error

+ func (db *DB) DB() *sql.DB

+ func (db *DB) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (db *DB) Find(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (db *DB) FindAll(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (db *DB) Ping(ctx context.Context) error

+ func (db *DB) Prepare(ctx context.Context, query string, examples ...interface{}) (*Stmt, error)

+ func (db *DB) Query(ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ type ExecFn func(context.Context, string, ...interface{}) (sql.Result, error)

+ type PrepareFn func(context.Context, string) (*sql.Stmt, error)

+ type QueryFn func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ type Rows struct

+ func (rows *Rows) Close() error

+ func (rows *Rows) Rows() *sql.Rows

+ func (rows *Rows) Scan(dest interface{}) error

+ type Stmt struct

+ func (stmt *Stmt) Close() error

+ func (stmt *Stmt) Exec(ctx context.Context, args ...interface{}) (sql.Result, error)

+ func (stmt *Stmt) Query(ctx context.Context, args ...interface{}) (*Rows, error)

+ func (stmt *Stmt) Stmt() *sql.Stmt

+ type Tx struct

+ func (tx *Tx) Commit() error

+ func (tx *Tx) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (tx *Tx) Find(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (tx *Tx) FindAll(ctx context.Context, dest []interface{}, query string, args ...interface{}) error

+ func (tx *Tx) Prepare(ctx context.Context, query string, examples ...interface{}) (*Stmt, error)

+ func (tx *Tx) Query(ctx context.Context, query string, args ...interface{}) (*Rows, error)

+ func (tx *Tx) Rollback() error

+ func (tx *Tx) Tx() *sql.Tx