Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

db

package

Go to main page

Versions in this module

v1

v1.3.1

Dec 1, 2022

v1.3.0

Dec 1, 2022

Changes in this version

type Adapter

+ func (a *Adapter) Eject() *sql.DB

type DB

+ Eject func() *sql.DB

v1.2.0

Sep 4, 2022

Changes in this version

+ func CloseAll() []exception.Exception

+ func GetInstance(instanceName string) (*sql.DB, exception.Exception)

+ type Adapter struct

+ func (a *Adapter) ExecContext(ktx kontext.Context, queryKey, query string, args ...interface{}) (Result, exception.Exception)

+ func (a *Adapter) Ping(ktx kontext.Context) exception.Exception

+ func (a *Adapter) QueryContext(ktx kontext.Context, queryKey, query string, args ...interface{}) (Rows, exception.Exception)

+ func (a *Adapter) QueryRowContext(ktx kontext.Context, queryKey, query string, args ...interface{}) Row

+ func (a *Adapter) Transaction(ktx kontext.Context, transactionKey string, f func(tx TX) exception.Exception) exception.Exception

+ type Config struct

+ Host string

+ Name string

+ Password string

+ Port string

+ Username string

+ type DB interface

+ Ping func(ktx kontext.Context) exception.Exception

+ func Adapt(db *sql.DB) DB

+ func FabricateMySQL(instanceName string, config Config, opts ...Option) (DB, exception.Exception)

+ type Option func(*Config)

+ func WithConnMaxLifetime(connMaxLifetime time.Duration) Option

+ func WithMaxIdleConn(maxIdleConn int) Option

+ func WithMaxOpenConn(maxOpenConn int) Option

+ type Result interface

+ LastInsertId func() (int64, exception.Exception)

+ RowsAffected func() (int64, exception.Exception)

+ func AdaptResult(result sql.Result) Result

+ type ResultAdapter struct

+ func (r *ResultAdapter) LastInsertId() (int64, exception.Exception)

+ func (r *ResultAdapter) RowsAffected() (int64, exception.Exception)

+ type Row interface

+ Scan func(dest ...interface{}) exception.Exception

+ func AdaptRow(sqlrow *sql.Row) Row

+ type RowAdapter struct

+ func (r *RowAdapter) Scan(dest ...interface{}) exception.Exception

+ type Rows interface

+ Close func() exception.Exception

+ Columns func() ([]string, exception.Exception)

+ Err func() exception.Exception

+ Next func() bool

+ NextResultSet func() bool

+ Scan func(dest ...interface{}) exception.Exception

+ func AdaptRows(rows *sql.Rows) Rows

+ type RowsAdapter struct

+ func (r *RowsAdapter) Close() exception.Exception

+ func (r *RowsAdapter) Columns() ([]string, exception.Exception)

+ func (r *RowsAdapter) Err() exception.Exception

+ func (r *RowsAdapter) Scan(dest ...interface{}) exception.Exception

+ type TX interface

+ ExecContext func(ctx kontext.Context, queryKey, query string, args ...interface{}) (Result, exception.Exception)

+ QueryContext func(ctx kontext.Context, queryKey, query string, args ...interface{}) (Rows, exception.Exception)

+ QueryRowContext func(ctx kontext.Context, queryKey, query string, args ...interface{}) Row

+ type TXAdapter struct

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

+ func (t *TXAdapter) ExecContext(ctx kontext.Context, queryKey, query string, args ...interface{}) (Result, exception.Exception)

+ func (t *TXAdapter) QueryContext(ctx kontext.Context, queryKey, query string, args ...interface{}) (Rows, exception.Exception)

+ func (t *TXAdapter) QueryRowContext(ctx kontext.Context, queryKey, query string, args ...interface{}) Row

+ type Transactionable interface

+ Transaction func(ctx kontext.Context, transactionKey string, f func(tx TX) exception.Exception) exception.Exception