Versions in this module Expand all Collapse all v0 v0.0.5 Apr 8, 2026 v0.0.4 Sep 1, 2025 v0.0.3 Feb 7, 2025 v0.0.2 Jun 10, 2024 v0.0.1 Jun 10, 2024 Changes in this version + var ErrNotFound = sql.ErrNoRows + type Command interface + BeginTx func(ctx context.Context, name string, opts TxOptions) (CommandTx, error) + Close func() error + Exec func(ctx context.Context, name string, query string, args ...interface{}) (sql.Result, error) + Get func(ctx context.Context, name string, query string, dest interface{}, ...) error + In func(query string, args ...interface{}) (string, []interface{}, error) + NamedExec func(ctx context.Context, name string, query string, args interface{}) (sql.Result, error) + NamedQuery func(ctx context.Context, name string, query string, arg interface{}) (*sqlx.Rows, error) + Ping func(ctx context.Context) error + Prepare func(ctx context.Context, name string, query string) (CommandStmt, error) + Query func(ctx context.Context, name string, query string, args ...interface{}) (*sqlx.Rows, error) + QueryIn func(ctx context.Context, name string, query string, args ...interface{}) (*sqlx.Rows, error) + QueryRow func(ctx context.Context, name string, query string, args ...interface{}) (*sqlx.Row, error) + Rebind func(query string) string + type CommandStmt interface + Close func() error + Exec func(name string, args ...interface{}) (sql.Result, error) + Get func(name string, dest interface{}, args ...interface{}) error + Query func(name string, args ...interface{}) (*sqlx.Rows, error) + QueryRow func(name string, args ...interface{}) (*sqlx.Row, error) + Select func(name string, dest interface{}, args ...interface{}) error + type CommandTx interface + Commit func() error + Exec func(name string, query string, args ...interface{}) (sql.Result, error) + Get func(name string, query string, dest interface{}, args ...interface{}) error + NamedExec func(name string, query string, args interface{}) (sql.Result, error) + Prepare func(name string, query string) (CommandStmt, error) + Query func(name string, query string, args ...interface{}) (*sqlx.Rows, error) + QueryRow func(name string, query string, args ...interface{}) (*sqlx.Row, error) + Rebind func(query string) string + Rollback func() + Select func(name string, query string, dest interface{}, args ...interface{}) error + Stmt func(name string, stmt *sqlx.Stmt) CommandStmt + type Config struct + Driver string + Follower ConnConfig + Leader ConnConfig + LogQuery bool + Name string + UseInstrument bool + type ConnConfig struct + DB string + Host string + MockDB *sql.DB + Options ConnOptions + Password string + Port int + SSL bool + Schema string + User string + type ConnOptions struct + MaxIdle int + MaxLifeTime time.Duration + MaxOpen int + type Interface interface + Follower func() Command + Leader func() Command + Stop func() + func Init(cfg Config, log logger.Interface, instr instrument.Interface) Interface + type TxOptions struct + Isolation sql.IsolationLevel + ReadOnly bool
Go to main page