sql

Oct 22, 2025

Changes in this version

type DefaultHandler

+ func (d *DefaultHandler) IsConnected() bool

type DefaultService

+ func (d *DefaultService) ExecWithCtx(ctx context.Context, query *string, params ...any) (sql.Result, error)

+ func (d *DefaultService) QueryRowWithCtx(ctx context.Context, query *string, params ...any) *sql.Row

type Handler

+ IsConnected func() bool

type Service

+ ExecWithCtx func(ctx any, query *string, params ...any) (sql.Result, error)

+ QueryRowWithCtx func(ctx any, query *string, params ...any) *sql.Row

Oct 14, 2025

Changes in this version

+ type DefaultHandler struct

+ func NewDefaultHandler(config *Config) (*DefaultHandler, error)

+ func (d *DefaultHandler) Connect() (*sql.DB, error)

+ func (d *DefaultHandler) DB() (*sql.DB, error)

+ func (d *DefaultHandler) Disconnect() error

+ type Handler interface

+ Connect func() (*sql.DB, error)

+ DB func() (*sql.DB, error)

+ Disconnect func()

Oct 14, 2025

Changes in this version

type DefaultConnHandler

+ func (d *DefaultConnHandler) Disconnect() error

Oct 4, 2025

Changes in this version

type DefaultService

+ func (d *DefaultService) Disconnect() error

+ type TransactionFn func(tx *sql.Tx) error

Jan 28, 2025

Changes in this version

+ var ErrNilService = errors.New("service cannot be nil")

+ func Disconnect(db *sql.DB) error

type Config

+ DataSourceName func() string

+ DriverName func() string

+ type ConnConfig struct

+ func NewConnConfig(driverName, dataSourceName string, maxOpenConnections, maxIdleConnections int, ...) (*ConnConfig, error)

+ func (c *ConnConfig) ConnectionMaxIdleTime() time.Duration

+ func (c *ConnConfig) ConnectionMaxLifetime() time.Duration

+ func (c *ConnConfig) DataSourceName() string

+ func (c *ConnConfig) DriverName() string

+ func (c *ConnConfig) MaxIdleConnections() int

+ func (c *ConnConfig) MaxOpenConnections() int

+ type ConnHandler interface

+ Connect func() (*sql.DB, error)

+ DB func() (*sql.DB, error)

+ Disconnect func()

+ type DefaultConnHandler struct

+ func NewDefaultConnHandler(driverName, dataSourceName string, config Config) (*DefaultConnHandler, error)

+ func (d *DefaultConnHandler) Connect() (*sql.DB, error)

+ func (d *DefaultConnHandler) DB() (*sql.DB, error)

+ type DefaultService struct

+ func NewDefaultService(db *sql.DB) (instance *DefaultService, err error)

+ func (d *DefaultService) CreateTransaction(fn func(tx *sql.Tx) error) error

+ func (d *DefaultService) DB() *sql.DB

+ func (d *DefaultService) Exec(query *string, params ...interface{}) (sql.Result, error)

+ func (d *DefaultService) Migrate(queries ...string) error

+ func (d *DefaultService) QueryRow(query *string, params ...interface{}) *sql.Row

+ func (d *DefaultService) ScanRow(row *sql.Row, destinations ...interface{}) error

+ type Service interface

+ CreateTransaction func(fn func(tx *sql.Tx) error) error

+ DB func() *sql.DB

+ Exec func(query *string, params ...interface{}) (sql.Result, error)

+ Migrate func(queries ...string) error

+ QueryRow func(query *string, params ...interface{}) *sql.Row

+ ScanRow func(row *sql.Row, destinations ...interface{}) error

Jan 27, 2025

Changes in this version

type Config

+ ConnectionMaxIdleTime time.Duration

Jan 16, 2025

Changes in this version

+ func RunQueriesConcurrentlyWithCancel(db *sql.DB, queries ...func(db *sql.DB, ctx context.Context) error) *[]error

Jan 16, 2025

Changes in this version

+ func RunQueriesConcurrently(db *sql.DB, queries ...func(db *sql.DB, ctx context.Context) error) *[]error

Jan 9, 2025

Changes in this version

+ func Close(db *sql.DB) error

+ func Connect(driverName, dataSourceName string, config *Config) (*sql.DB, error)

+ type Config struct

+ ConnectionMaxLifetime *time.Duration

+ DB *sql.DB

+ MaxIdleConnections *int

+ MaxOpenConnections *int

+ func NewConfig(maxOpenConnections *int, maxIdleConnections *int, ...) *Config

+ func (c *Config) Close(db *sql.DB) error

+ func (c *Config) Connect(driverName, dataSourceName string) (*sql.DB, error)

Jan 9, 2025

Changes in this version

+ const UniqueViolationCode

+ func IsUniqueViolationError(err error) (bool, string)

Jan 9, 2025

Changes in this version

+ var ErrNilQuery = errors.New("sql query cannot be nil")

+ var ErrNilRow = errors.New("sql row cannot be nil")

Jan 9, 2025

Changes in this version

+ func CreateTransaction(db *sql.DB, fn func(tx *sql.Tx) error) error