mssqlx

package module

Go to main page

Versions in this module

v1

v1.1.8

Nov 12, 2022

v1.1.7

Jul 4, 2022

v1.1.6

May 17, 2022

v1.1.5

Sep 17, 2021

v1.1.4

Aug 6, 2021

v1.1.3

Jul 6, 2021

v1.1.2

Apr 7, 2021

Changes in this version

+ type Instantiate func(driverName, dsn string) (*sql.DB, error)

type Option

+ func WithDBInstantiate(f Instantiate) Option

v1.1.1

Oct 28, 2020

v1.1.0

Oct 17, 2020

Changes in this version

+ func IsDeadlock(err error) bool

+ func IsWsrepNotReady(err error) bool

+ type Stmt struct

+ func (s *Stmt) Exec(args ...interface{}) (sql.Result, error)

+ func (s *Stmt) ExecContext(ctx context.Context, args ...interface{}) (result sql.Result, err error)

+ func (s *Stmt) Query(args ...interface{}) (*sql.Rows, error)

+ func (s *Stmt) QueryContext(ctx context.Context, args ...interface{}) (result *sql.Rows, err error)

+ type Stmtx struct

+ func (s *Stmtx) Exec(args ...interface{}) (sql.Result, error)

+ func (s *Stmtx) ExecContext(ctx context.Context, args ...interface{}) (result sql.Result, err error)

+ func (s *Stmtx) Query(args ...interface{}) (*sql.Rows, error)

+ func (s *Stmtx) QueryContext(ctx context.Context, args ...interface{}) (result *sql.Rows, err error)

+ func (s *Stmtx) Queryx(args ...interface{}) (*sqlx.Rows, error)

+ func (s *Stmtx) QueryxContext(ctx context.Context, args ...interface{}) (result *sqlx.Rows, err error)

+ type Tx struct

+ func (t *Tx) Commit() (err error)

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

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

+ func (t *Tx) Prepare(query string) (*Stmt, error)

+ func (t *Tx) PrepareContext(ctx context.Context, query string) (result *Stmt, err error)

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

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

+ type Txx struct

+ func (t *Txx) Commit() (err error)

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

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

+ func (t *Txx) Prepare(query string) (*Stmt, error)

+ func (t *Txx) PrepareContext(ctx context.Context, query string) (result *Stmt, err error)

+ func (t *Txx) Preparex(query string) (*Stmtx, error)

+ func (t *Txx) PreparexContext(ctx context.Context, query string) (result *Stmtx, err error)

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

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

+ func (t *Txx) Queryx(query string, args ...interface{}) (*sqlx.Rows, error)

+ func (t *Txx) QueryxContext(ctx context.Context, query string, args ...interface{}) (result *sqlx.Rows, err error)

v1.0.8

May 27, 2020

Changes in this version

+ type Option func(*clusterOptions)

+ func WithReadQuerySource(source ReadQuerySource) Option

+ func WithWsrep() Option

+ type ReadQuerySource int

+ const ReadQuerySourceAll

+ const ReadQuerySourceSlaves

v1.0.7

Feb 14, 2020

v1.0.6

Nov 20, 2019

v1.0.5

Mar 26, 2019

v1.0.3

Mar 25, 2019

v1.0.2

Mar 4, 2019

v1.0.1

Sep 24, 2018

Changes in this version

+ const DefaultHealthCheckPeriodInMilli

+ var ErrNetwork = errors.New("Network error/Connection refused")

+ var ErrNoConnection = errors.New("No connection available")

+ var ErrNoConnectionOrWsrep = errors.New("No connection available or Wsrep is not ready")

+ type DBNode interface

+ GetDB func() *sqlxWrapper

+ type DBs struct

+ func ConnectMasterSlaves(driverName string, masterDSNs []string, slaveDSNs []string, ...) (*DBs, []error)

+ func (dbs *DBs) Begin() (*sql.Tx, error)

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

+ func (dbs *DBs) BeginTxx(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)

+ func (dbs *DBs) Beginx() (*sqlx.Tx, error)

+ func (dbs *DBs) BindNamed(query string, arg interface{}) (string, []interface{}, error)

+ func (dbs *DBs) Destroy() []error

+ func (dbs *DBs) DestroyMaster() []error

+ func (dbs *DBs) DestroySlave() []error

+ func (dbs *DBs) DriverName() string

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

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

+ func (dbs *DBs) ExecContextOnSlave(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (dbs *DBs) ExecOnSlave(query string, args ...interface{}) (sql.Result, error)

+ func (dbs *DBs) Get(dest interface{}, query string, args ...interface{}) (err error)

+ func (dbs *DBs) GetAllMasters() ([]*sqlx.DB, int)

+ func (dbs *DBs) GetAllSlaves() ([]*sqlx.DB, int)

+ func (dbs *DBs) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) (err error)

+ func (dbs *DBs) GetContextOnMaster(ctx context.Context, dest interface{}, query string, args ...interface{}) (err error)

+ func (dbs *DBs) GetOnMaster(dest interface{}, query string, args ...interface{}) (err error)

+ func (dbs *DBs) MapperFunc(mf func(string) string)

+ func (dbs *DBs) MapperFuncMaster(mf func(string) string)

+ func (dbs *DBs) MapperFuncSlave(mf func(string) string)

+ func (dbs *DBs) MustBegin() *sql.Tx

+ func (dbs *DBs) MustBeginTx(ctx context.Context, opts *sql.TxOptions) *sqlx.Tx

+ func (dbs *DBs) MustBeginx() *sqlx.Tx

+ func (dbs *DBs) MustExec(query string, args ...interface{}) sql.Result

+ func (dbs *DBs) MustExecContext(ctx context.Context, query string, args ...interface{}) sql.Result

+ func (dbs *DBs) MustExecContextOnSlave(ctx context.Context, query string, args ...interface{}) sql.Result

+ func (dbs *DBs) MustExecOnSlave(query string, args ...interface{}) sql.Result

+ func (dbs *DBs) NamedExec(query string, arg interface{}) (sql.Result, error)

+ func (dbs *DBs) NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)

+ func (dbs *DBs) NamedExecContextOnSlave(ctx context.Context, query string, arg interface{}) (sql.Result, error)

+ func (dbs *DBs) NamedExecOnSlave(query string, arg interface{}) (sql.Result, error)

+ func (dbs *DBs) NamedQuery(query string, arg interface{}) (*sqlx.Rows, error)

+ func (dbs *DBs) NamedQueryContext(ctx context.Context, query string, arg interface{}) (*sqlx.Rows, error)

+ func (dbs *DBs) NamedQueryContextOnMaster(ctx context.Context, query string, arg interface{}) (*sqlx.Rows, error)

+ func (dbs *DBs) NamedQueryOnMaster(query string, arg interface{}) (*sqlx.Rows, error)

+ func (dbs *DBs) Ping() []error

+ func (dbs *DBs) PingMaster() []error

+ func (dbs *DBs) PingSlave() []error

+ func (dbs *DBs) Prepare(query string) (db *sqlx.DB, stmt *sql.Stmt, err error)

+ func (dbs *DBs) PrepareContext(ctx context.Context, query string) (db *sqlx.DB, stmt *sql.Stmt, err error)

+ func (dbs *DBs) PrepareContextOnSlave(ctx context.Context, query string) (db *sqlx.DB, stmt *sql.Stmt, err error)

+ func (dbs *DBs) PrepareNamed(query string) (db *sqlx.DB, stmt *sqlx.NamedStmt, err error)

+ func (dbs *DBs) PrepareNamedContext(ctx context.Context, query string) (db *sqlx.DB, stmt *sqlx.NamedStmt, err error)

+ func (dbs *DBs) PrepareNamedContextOnSlave(ctx context.Context, query string) (db *sqlx.DB, stmt *sqlx.NamedStmt, err error)

+ func (dbs *DBs) PrepareNamedOnSlave(query string) (db *sqlx.DB, stmt *sqlx.NamedStmt, err error)

+ func (dbs *DBs) PrepareOnSlave(query string) (db *sqlx.DB, stmt *sql.Stmt, err error)

+ func (dbs *DBs) Preparex(query string) (db *sqlx.DB, stmt *sqlx.Stmt, err error)

+ func (dbs *DBs) PreparexContext(ctx context.Context, query string) (db *sqlx.DB, stmt *sqlx.Stmt, err error)

+ func (dbs *DBs) PreparexContextOnSlave(ctx context.Context, query string) (db *sqlx.DB, stmt *sqlx.Stmt, err error)

+ func (dbs *DBs) PreparexOnSlave(query string) (db *sqlx.DB, stmt *sqlx.Stmt, err error)

+ func (dbs *DBs) Query(query string, args ...interface{}) (r *sql.Rows, err error)

+ func (dbs *DBs) QueryContext(ctx context.Context, query string, args ...interface{}) (r *sql.Rows, err error)

+ func (dbs *DBs) QueryContextOnMaster(ctx context.Context, query string, args ...interface{}) (r *sql.Rows, err error)

+ func (dbs *DBs) QueryOnMaster(query string, args ...interface{}) (r *sql.Rows, err error)

+ func (dbs *DBs) QueryRow(query string, args ...interface{}) (r *sql.Row, err error)

+ func (dbs *DBs) QueryRowContext(ctx context.Context, query string, args ...interface{}) (r *sql.Row, err error)

+ func (dbs *DBs) QueryRowContextOnMaster(ctx context.Context, query string, args ...interface{}) (r *sql.Row, err error)

+ func (dbs *DBs) QueryRowOnMaster(query string, args ...interface{}) (r *sql.Row, err error)

+ func (dbs *DBs) QueryRowx(query string, args ...interface{}) (r *sqlx.Row, err error)

+ func (dbs *DBs) QueryRowxContext(ctx context.Context, query string, args ...interface{}) (r *sqlx.Row, err error)

+ func (dbs *DBs) QueryRowxContextOnMaster(ctx context.Context, query string, args ...interface{}) (r *sqlx.Row, err error)

+ func (dbs *DBs) QueryRowxOnMaster(query string, args ...interface{}) (r *sqlx.Row, err error)

+ func (dbs *DBs) Queryx(query string, args ...interface{}) (r *sqlx.Rows, err error)

+ func (dbs *DBs) QueryxContext(ctx context.Context, query string, args ...interface{}) (r *sqlx.Rows, err error)

+ func (dbs *DBs) QueryxContextOnMaster(ctx context.Context, query string, args ...interface{}) (r *sqlx.Rows, err error)

+ func (dbs *DBs) QueryxOnMaster(query string, args ...interface{}) (r *sqlx.Rows, err error)

+ func (dbs *DBs) Rebind(query string) string

+ func (dbs *DBs) Select(dest interface{}, query string, args ...interface{}) (err error)

+ func (dbs *DBs) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) (err error)

+ func (dbs *DBs) SelectContextOnMaster(ctx context.Context, dest interface{}, query string, args ...interface{}) (err error)

+ func (dbs *DBs) SelectOnMaster(dest interface{}, query string, args ...interface{}) (err error)

+ func (dbs *DBs) SetConnMaxLifetime(d time.Duration)

+ func (dbs *DBs) SetHealthCheckPeriod(period uint64)

+ func (dbs *DBs) SetMasterConnMaxLifetime(d time.Duration)

+ func (dbs *DBs) SetMasterHealthCheckPeriod(period uint64)

+ func (dbs *DBs) SetMasterMaxIdleConns(n int)

+ func (dbs *DBs) SetMasterMaxOpenConns(n int)

+ func (dbs *DBs) SetMaxIdleConns(n int)

+ func (dbs *DBs) SetMaxOpenConns(n int)

+ func (dbs *DBs) SetSlaveConnMaxLifetime(d time.Duration)

+ func (dbs *DBs) SetSlaveHealthCheckPeriod(period uint64)

+ func (dbs *DBs) SetSlaveMaxIdleConns(n int)

+ func (dbs *DBs) SetSlaveMaxOpenConns(n int)

+ func (dbs *DBs) Stats() (stats []sql.DBStats)

+ func (dbs *DBs) StatsMaster() (stats []sql.DBStats)

+ func (dbs *DBs) StatsSlave() (stats []sql.DBStats)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL