sqldb

Aug 31, 2024

Changes in this version

type DB

+ WithHook func(h Hook)

+ type Hook interface

+ AfterBegin func(context context.Context, sid string, start_time, end_time time.Time, err error)

+ AfterCommit func(context context.Context, sid string, start_time, end_time time.Time, err error)

+ AfterQuery func(context context.Context, sid string, method string, query string, ...)

+ AfterRollback func(context context.Context, start_time, end_time time.Time, err error)

type Options

+ Hook Hook

Jul 16, 2023

Changes in this version

type Options

+ Name string

Jul 15, 2023

Changes in this version

type DB

+ func New(Driver string, DSN string) DB

+ func NewWithOptions(Driver string, DSN string, opts *Options) DB

+ WithTrx func(t Trx) DB

type Options

+ PanicablePings bool

+ type Trx interface

+ TraceDependency func(ctx context.Context, spanId string, dependencyType string, serviceName string, ...)

+ TraceException func(ctx context.Context, err interface{}, skip int, fields map[string]string)

Apr 7, 2023

Changes in this version

type DB

+ func TracedNativeDBWrapperWithOptions(Driver string, DSN string, t *tracer.AppInsightsCore, name string, ...) DB

+ SetMaxIdleConns func(n int)

+ SetMaxOpenConns func(n int)

+ type Options struct

+ MaxIdleConns int

+ MaxOpenConns int

Feb 8, 2023

Changes in this version

type DB

+ func DBWarpper(db *sql.DB, t *tracer.AppInsightsCore, name string, logger *zap.Logger) DB

Jan 5, 2023

Changes in this version

+ type DB interface

+ Begin func() (*Tx, error)

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

+ Close func() error

+ Conn func(ctx context.Context) (*sql.Conn, error)

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

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

+ Ping func() error

+ PingContext func(ctx context.Context) error

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

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

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

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

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

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

+ SetConnMaxIdleTime func(d time.Duration)

+ SetConnMaxLifetime func(d time.Duration)

+ Stats func() sql.DBStats

+ WithLogger func(l *zap.Logger) DB

+ func DBProvider(Driver string, DSN string) DB

+ func TracedNativeDBWrapper(Driver string, DSN string, t *tracer.AppInsightsCore, name string) DB

+ type Tx struct

+ func (t *Tx) Commit() error

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

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

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

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

+ func (t *Tx) QueryRow(query string, args ...interface{}) *sql.Row

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

+ func (t *Tx) Rollback() error