msql

package

v0.0.2-alpha Latest Latest Go to latest Published: Jan 26, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/quietking0312/component

Documentation ¶

Index ¶

func DefaultTxOptions() *sql.TxOptions
func NewGormDB(opts ...Option)
type DB
- func NewDB(opts ...Option) (*DB, error)
- func (db *DB) Ping() error
type DBCfg
- func DefaultDBOption() *DBCfg
type Option
type SqlxDB
- func NewSqlxDB(opts ...Option) (*SqlxDB, error)
type TxOption

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DefaultTxOptions ¶

func DefaultTxOptions() *sql.TxOptions

func NewGormDB ¶

func NewGormDB(opts ...Option)

Types ¶

type DB ¶

type DB struct {
	DB    *sql.DB
	DBCfg *DBCfg
}

func NewDB ¶

func NewDB(opts ...Option) (*DB, error)

func (*DB) Ping ¶

func (db *DB) Ping() error

type DBCfg ¶

type DBCfg struct {
	DriveName         string
	DataSourceName    string
	MaxIdleConnection int
	MaxOpenConnection int
	MaxQueryTime      time.Duration
}

func DefaultDBOption ¶

func DefaultDBOption() *DBCfg

type Option ¶

type Option func(cfg *DBCfg)

func DataSourceName ¶

func DataSourceName(dsn string) Option

func DriveName ¶

func DriveName(drivename string) Option

func MaxIdleConnection ¶

func MaxIdleConnection(idle int) Option

func MaxOpenConnection ¶

func MaxOpenConnection(open int) Option

func MaxQueryTime ¶

func MaxQueryTime(query time.Duration) Option

type SqlxDB ¶

type SqlxDB struct {
	SqlxDB *sqlx.DB
	DBCfg  *DBCfg
}

func NewSqlxDB ¶

func NewSqlxDB(opts ...Option) (*SqlxDB, error)

func (*SqlxDB) In ¶

func (_sqlxDB *SqlxDB) In(format string, args ...interface{}) (string, []interface{}, error)

func (*SqlxDB) SqlxBeginTx ¶

func (_sqlxDB *SqlxDB) SqlxBeginTx(opts TxOption, cbs ...func(tx *sqlx.Tx, ctx context.Context) error) error

func (*SqlxDB) SqlxExec ¶

func (_sqlxDB *SqlxDB) SqlxExec(format string, args ...interface{}) (sql.Result, error)

func (*SqlxDB) SqlxGet ¶

func (_sqlxDB *SqlxDB) SqlxGet(dest interface{}, format string, args ...interface{}) error

func (*SqlxDB) SqlxNameExec ¶

func (_sqlxDB *SqlxDB) SqlxNameExec(format string, arg interface{}) (sql.Result, error)

func (*SqlxDB) SqlxNameQuery ¶

func (_sqlxDB *SqlxDB) SqlxNameQuery(format string, args interface{}, cb func(rows *sqlx.Rows) error) error

func (*SqlxDB) SqlxQuery ¶

func (_sqlxDB *SqlxDB) SqlxQuery(format string, args []interface{}, cb func(rows *sqlx.Rows) error) error

func (*SqlxDB) SqlxQueryRow ¶

func (_sqlxDB *SqlxDB) SqlxQueryRow(format string, args []interface{}, cb func(row *sqlx.Row) error) error

func (*SqlxDB) SqlxSelect ¶

func (_sqlxDB *SqlxDB) SqlxSelect(dest interface{}, format string, args ...interface{}) error

type TxOption ¶

type TxOption func(options *sql.TxOptions)

func LevelReadCommitted ¶

func LevelReadCommitted() TxOption

LevelReadCommitted 读取完成立刻释放共享锁模式

func LevelRepeatableRead ¶

func LevelRepeatableRead() TxOption

LevelRepeatableRead 事务完成释放共享锁模式

func LevelSerializable ¶

func LevelSerializable() TxOption

LevelSerializable 事务序列操作

Source Files ¶

View all Source files

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