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.2.2

Feb 8, 2026

Changes in this version

+ type Executor interface

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)

+ QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row

+ Select func(ctx context.Context, data any, query string, args ...any) error

type Tx

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

+ func (t *Tx) Select(ctx context.Context, data any, query string, args ...any) error

v0.2.1

Feb 8, 2026

v0.2.0

Feb 7, 2026

v0.1.1

Feb 5, 2026

v0.1.0

Feb 5, 2026

Changes in this version

+ func DeleteByQuery(dialect, tableName, field string) string

+ func InsertQuery(dialect, tableName string, fieldNames []string, values []any, ...) (string, error)

+ func IsSupabaseDialect(dialect string) bool

+ func NewSQLMocks(t *testing.T) (*DB, sqlmock.Sqlmock, *MockMetrics)

+ func NewSQLMocksWithConfig(t *testing.T, config *DBConfig) (*DB, sqlmock.Sqlmock, *MockMetrics)

+ func SelectByQuery(dialect, tableName, field string) string

+ func SelectQuery(dialect, tableName string) string

+ func ToSnakeCase(str string) string

+ func UpdateByQuery(dialect, tableName string, fieldNames []string, field string) string

+ type BindVarType uint

+ const DOLLAR

+ const QUESTION

+ const UNKNOWN

+ type DB struct

+ func NewSQL(configs config.Config, logger datasource.Logger, metrics Metrics) *DB

+ func NewSupabaseSQL(configs config.Config, logger datasource.Logger, metrics Metrics) *DB

+ func (d *DB) Begin() (*Tx, error)

+ func (d *DB) Close() error

+ func (d *DB) Dialect() string

+ func (d *DB) Exec(query string, args ...any) (sql.Result, error)

+ func (d *DB) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

+ func (d *DB) HealthCheck() *datasource.Health

+ func (d *DB) Prepare(query string) (*sql.Stmt, error)

+ func (d *DB) Query(query string, args ...any) (*sql.Rows, error)

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

+ func (d *DB) QueryRow(query string, args ...any) *sql.Row

+ func (d *DB) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

+ func (d *DB) Select(ctx context.Context, data any, query string, args ...any)

+ type DBConfig struct

+ Charset string

+ Database string

+ Dialect string

+ HostName string

+ MaxIdleConn int

+ MaxOpenConn int

+ Password string

+ Port string

+ SSLMode string

+ User string

+ type DBStats struct

+ Idle int

+ InUse int

+ MaxIdleClosed int64

+ MaxIdleTimeClosed int64

+ MaxLifetimeClosed int64

+ MaxOpenConnections int

+ OpenConnections int

+ WaitCount int64

+ WaitDuration time.Duration

+ type FieldConstraints struct

+ AutoIncrement bool

+ NotNull bool

+ type Log struct

+ Args []any

+ Duration int64

+ Query string

+ Type string

+ func (l *Log) PrettyPrint(writer io.Writer)

+ type Metrics interface

+ RecordHistogram func(ctx context.Context, name string, value float64, labels ...string)

+ SetGauge func(name string, value float64, labels ...string)

+ type MockMetrics struct

+ func NewMockMetrics(ctrl *gomock.Controller) *MockMetrics

+ func (m *MockMetrics) EXPECT() *MockMetricsMockRecorder

+ func (m *MockMetrics) RecordHistogram(ctx context.Context, name string, value float64, labels ...string)

+ func (m *MockMetrics) SetGauge(name string, value float64, labels ...string)

+ type MockMetricsMockRecorder struct

+ func (mr *MockMetricsMockRecorder) RecordHistogram(ctx, name, value any, labels ...any) *gomock.Call

+ func (mr *MockMetricsMockRecorder) SetGauge(name, value any, labels ...any) *gomock.Call

+ type SupabaseConfig struct

+ ConnectionType string

+ ProjectRef string

+ Region string

+ func GetSupabaseConfig(configs config.Config) *SupabaseConfig

+ type Tx struct

+ func (t *Tx) Commit() error

+ func (t *Tx) Exec(query string, args ...any) (sql.Result, error)

+ func (t *Tx) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

+ func (t *Tx) Prepare(query string) (*sql.Stmt, error)

+ func (t *Tx) Query(query string, args ...any) (*sql.Rows, error)

+ func (t *Tx) QueryRow(query string, args ...any) *sql.Row

+ func (t *Tx) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

+ func (t *Tx) Rollback() error