database

Sep 17, 2024

Changes in this version

type Manager

+ func NewManager() Manager

Sep 11, 2024

Changes in this version

+ const StringConnClosed

+ const StringDeadlock

+ const StringLostConn

+ var ErrLostConn error = errors.Base("lost connection during query")

+ var ErrServerConnClosed error = errors.Base("server connection closed")

+ var ErrTxnDeadlock error = errors.Base("deadlock found when trying to get lock")

type Database

+ GetError func(error) error

Sep 10, 2024

Changes in this version

+ const KeyTransaction

+ var ErrNoDatabase error = errors.Base("no database name provided")

+ var ErrNoDriver error = errors.Base("no driver provided")

+ var ErrNoHostname error = errors.Base("no hostname provided")

+ var ErrNoPassword error = errors.Base("no password provided")

+ var ErrNoUsername error = errors.Base("no username provided")

+ var ErrTxnContext error = errors.Base("could not create transaction context")

+ var ErrTxnKeyNotFound error = errors.Base("transaction key not found")

+ var ErrTxnKeyNotTxn error = errors.Base("key value is not a transaction")

+ var ErrTxnStart error = errors.Base("could not start transaction")

type Database

+ func FromDB(db *sql.DB, driver string) Database

+ Commit func(context.Context) error

+ Rollback func(context.Context) error

+ Tx func(context.Context) (*sqlx.Tx, error)

+ type Manager interface

+ CheckDB func(Database) error

+ Open func(string, string) (Database, error)

+ OpenConfig func(*Config) (Database, error)

Jul 30, 2023

Changes in this version

type Config

+ PasswordSecret string

+ UsernameSecret string

+ func (c *Config) Validate() error

+ type Cursor struct

+ Limit int64

+ Offset int64

+ var EmptyCursor *Cursor = &Cursor{ ... }

+ func NewCursor(offset, limit int64) *Cursor

+ func (c Cursor) Valid() bool

+ type NullBool struct

+ func (x NullBool) MarshalJSON() ([]byte, error)

+ type NullByte struct

+ func (x NullByte) MarshalJSON() ([]byte, error)

+ type NullFloat64 struct

+ func (x NullFloat64) MarshalJSON() ([]byte, error)

+ type NullInt16 struct

+ func (x NullInt16) MarshalJSON() ([]byte, error)

+ type NullInt32 struct

+ func (x NullInt32) MarshalJSON() ([]byte, error)

+ type NullInt64 struct

+ func (x NullInt64) MarshalJSON() ([]byte, error)

+ type NullString struct

+ func (x NullString) MarshalJSON() ([]byte, error)

+ type NullTime struct

+ func (x NullTime) MarshalJSON() ([]byte, error)

Mar 24, 2022

Changes in this version

+ type Config struct

+ BatchSize int

+ Database string

+ Driver string

+ Hostname string

+ MaxIdleConns int

+ MaxOpenConns int

+ Password string

+ Port int

+ SetPoolLimits bool

+ Username string

+ func NewConfig() *Config

+ func (c *Config) ToDSN() string

+ type Database struct

+ func (db *Database) Begin() (*sql.Tx, error)

+ func (db *Database) Beginx() (*sqlx.Tx, error)

+ func (db *Database) Close() error

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

+ func (db *Database) Get(what interface{}, query string, args ...interface{}) error

+ func (db *Database) MustBegin() *sqlx.Tx

+ func (db *Database) NamedExec(query string, args interface{}) (sql.Result, error)

+ func (db *Database) Ping() error

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

+ func (db *Database) Query(query string, args ...interface{}) (IRows, error)

+ func (db *Database) QueryRowx(query string, args ...interface{}) IRow

+ func (db *Database) Queryx(query string, args ...interface{}) (IRowsx, error)

+ func (db *Database) Select(what interface{}, query string, args ...interface{}) error

+ func (db *Database) SetMaxIdleConns(limit int)

+ func (db *Database) SetMaxOpenConns(limit int)

+ type DatabaseMgr struct

+ func (dbm *DatabaseMgr) CheckDB(db IDatabase) error

+ func (dbm *DatabaseMgr) Open(driver string, dsn string) (IDatabase, error)

+ func (dbm *DatabaseMgr) OpenConfig(conf *Config) (IDatabase, error)

+ type IDatabase interface

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

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

+ Close func() error

+ Exec func(string, ...interface{}) (sql.Result, error)

+ Get func(interface{}, string, ...interface{}) error

+ MustBegin func() *sqlx.Tx

+ NamedExec func(string, interface{}) (sql.Result, error)

+ Ping func() error

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

+ Query func(string, ...interface{}) (IRows, error)

+ QueryRowx func(string, ...interface{}) IRow

+ Queryx func(string, ...interface{}) (IRowsx, error)

+ Select func(interface{}, string, ...interface{}) error

+ SetMaxIdleConns func(int)

+ SetMaxOpenConns func(int)

+ func Open(driver string, dsn string) (IDatabase, error)

+ type IDatabaseMgr interface

+ CheckDB func(IDatabase) error

+ Open func(string, string) (IDatabase, error)

+ OpenConfig func(*Config) (IDatabase, error)

+ type IRow interface

+ Err func() error

+ Scan func(dest ...interface{}) error

+ type IRows interface

+ Close func() error

+ ColumnTypes func() ([]*sql.ColumnType, error)

+ Columns func() ([]string, error)

+ Err func() error

+ Next func() bool

+ NextResultSet func() bool

+ Scan func(...interface{}) error

+ type IRowsx interface

+ Close func() error

+ ColumnTypes func() ([]*sql.ColumnType, error)

+ Columns func() ([]string, error)

+ Err func() error

+ Next func() bool

+ NextResultSet func() bool

+ Scan func(...interface{}) error

+ StructScan func(interface{}) error

+ type ITx interface

+ Commit func()

+ NamedExec func(string, interface{}) (sql.Result, error)

+ type Tx struct

+ func (tx *Tx) Commit()

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