sql

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