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

sqlk

package module

Go to main page

Versions in this module

v0

v0.2.2

Jan 13, 2026

v0.2.1

Jan 10, 2026

v0.2.0

Jan 10, 2026

Changes in this version

+ const DefaultMaxConnLifetime

+ const DefaultMaxIdleConn

+ const DefaultMaxOpenConn

+ const DriverMySQL

+ const DriverPostgreSQL

+ const Null

+ const Separator

+ var EmptyObjectJSON = json.RawMessage("{}")

+ var RowNotUpdatedError = new(rowNotUpdatedError)

+ func CommitOrRollback(txCtx *TxContext, err error) error

+ func ErrorIsPqCancelStatementByUser(err error) bool

+ func IsUpdated(result sql.Result) error

+ func NewInt(i int) *int

+ func ScanJSON(src interface{}, target interface{}) error

+ func ToNullString(str string) sql.NullString

+ func WithTransaction(ctx context.Context, db *sqlx.DB, opts *sql.TxOptions, fn TxFunc) (err error)

+ type AliasSetter interface

+ SetTableAs func(as string)

+ type ColumnGetter interface

+ GetColumn func() string

+ type ColumnWriter interface

+ ColumnQuery func() string

+ SetFormat func(format op.ColumnFormat)

+ type Config struct

+ Database string

+ Driver string

+ Host string

+ MaxConnLifetime *int

+ MaxIdleConn *int

+ MaxOpenConn *int

+ Password string

+ Port string

+ Username string

+ type Database struct

+ func NewDatabase(config Config) (*Database, error)

+ func (db *Database) Close() error

+ func (db *Database) GetConnection(ctx context.Context) (*sqlx.Conn, error)

+ func (db *Database) Init() error

+ func (db *Database) InitContext(ctx context.Context) error

+ func (db *Database) IsConnected() bool

+ func (db *Database) PingContext(ctx context.Context) error

+ func (db *Database) WithContext(ctx context.Context) *DatabaseContext

+ type DatabaseContext struct

+ func (s *DatabaseContext) MustPrepare(query string) *sqlx.Stmt

+ func (s *DatabaseContext) MustPrepareFmt(queryFmt string, args ...interface{}) *sqlx.Stmt

+ func (s *DatabaseContext) MustPrepareNamed(query string) *sqlx.NamedStmt

+ func (s *DatabaseContext) MustPrepareNamedFmt(queryFmt string, args ...interface{}) *sqlx.NamedStmt

+ func (s *DatabaseContext) MustPrepareRebind(query string) *sqlx.Stmt

+ func (s *DatabaseContext) MustPrepareReplace(q string, values map[string]string) *sqlx.Stmt

+ func (s *DatabaseContext) Rebind(query string) string

+ func (s *DatabaseContext) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ type Expander interface

+ Expand func(args ...interface{}) SelectWriter

+ type FilterParser = func(queryValue string) (WhereWriter, []interface{})

+ type FromWriter interface

+ FromQuery func() string

+ Join func(j JoinWriter)

+ type Int64 struct

+ func NewInt64(input int64) Int64

+ func (s *Int64) MarshalJSON() (raw []byte, err error)

+ func (s *Int64) UnmarshalJSON(b []byte) error

+ type JoinWriter interface

+ GetIndex func() int

+ GetTableName func() string

+ JoinQuery func() string

+ SetIndex func(s int)

+ type OrderByWriter interface

+ OrderByQuery func() string

+ type SchemaRefGetter interface

+ GetSchemaRef func() schema.Reference

+ type SchemaReference interface

+ SetSchema func(s *schema.Schema)

+ type SelectWriter interface

+ IsAllColumns func() bool

+ SelectQuery func() string

+ SetFormat func(format op.ColumnFormat)

+ type String struct

+ func NewString(str string) String

+ func (s *String) MarshalJSON() (raw []byte, err error)

+ func (s *String) UnmarshalJSON(b []byte) error

+ type TableGetter interface

+ GetTableName func() string

+ type TxContext struct

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

+ func (tc *TxContext) Commit() error

+ func (tc *TxContext) Ctx() context.Context

+ func (tc *TxContext) Rollback() error

+ func (tc *TxContext) Tx() *sqlx.Tx

+ type TxFunc func(*TxContext) error

+ type VariableWriter interface

+ VariableQuery func() string

+ type WhereCompareWriter interface

+ GetVariable func() VariableWriter

+ SetVariable func(v VariableWriter)

+ type WhereLogicWriter interface

+ GetConditions func() []WhereWriter

+ SetConditions func(conditions []WhereWriter)

+ type WhereWriter interface

+ WhereQuery func() string