Versions in this module Expand all Collapse all v1 v1.1.2 Dec 6, 2022 v1.1.1 Dec 5, 2022 Changes in this version + func Version() string + type DB interface + Begin func() (*sql.Tx, error) + BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) + Close func() error + Driver func() driver.Driver + Exec func(query string, args ...interface{}) (sql.Result, error) + ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error) + Ping func() error + PingContext func(ctx context.Context) error + Prepare func(query string) (Stmt, error) + PrepareContext func(ctx context.Context, query string) (Stmt, error) + Query func(query string, args ...interface{}) (*sql.Rows, error) + QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) + QueryRow func(query string, args ...interface{}) *sql.Row + QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row + SetConnMaxIdleTime func(d time.Duration) + SetConnMaxLifetime func(d time.Duration) + SetMaxIdleConns func(n int) + SetMaxOpenConns func(n int) + func WrapDBs(dbs ...*sql.DB) DB + type DBImpl struct + func Open(driverName, dataSourceNames string) (db *DBImpl, err error) + func (dbImpl *DBImpl) Begin() (*sql.Tx, error) + func (dbImpl *DBImpl) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) + func (dbImpl *DBImpl) Close() error + func (dbImpl *DBImpl) Driver() driver.Driver + func (dbImpl *DBImpl) Exec(query string, args ...interface{}) (sql.Result, error) + func (dbImpl *DBImpl) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error) + func (dbImpl *DBImpl) Ping() error + func (dbImpl *DBImpl) PingContext(ctx context.Context) error + func (dbImpl *DBImpl) Prepare(query string) (Stmt, error) + func (dbImpl *DBImpl) PrepareContext(ctx context.Context, query string) (Stmt, error) + func (dbImpl *DBImpl) Query(query string, args ...interface{}) (*sql.Rows, error) + func (dbImpl *DBImpl) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) + func (dbImpl *DBImpl) QueryRow(query string, args ...interface{}) *sql.Row + func (dbImpl *DBImpl) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row + func (dbImpl *DBImpl) ReadOnly() *sql.DB + func (dbImpl *DBImpl) ReadWrite() *sql.DB + func (dbImpl *DBImpl) SetConnMaxIdleTime(d time.Duration) + func (dbImpl *DBImpl) SetConnMaxLifetime(d time.Duration) + func (dbImpl *DBImpl) SetMaxIdleConns(n int) + func (dbImpl *DBImpl) SetMaxOpenConns(n int) + type Stmt interface + Close func() error + Exec func(...interface{}) (sql.Result, error) + ExecContext func(ctx context.Context, args ...interface{}) (sql.Result, error) + Query func(...interface{}) (*sql.Rows, error) + QueryContext func(ctx context.Context, args ...interface{}) (*sql.Rows, error) + QueryRow func(args ...interface{}) *sql.Row + QueryRowContext func(ctx context.Context, args ...interface{}) *sql.Row