mysqlbuilder

Documentation

Index

• func BuildDBDriver(opts *Options) string
• type Count
• type DBConnect
  • func New(opts ...Option) (*DBConnect, error)
  • func (db *DBConnect) Exec(ctx context.Context, query string, args ...any) (lastInsertId, rowsAffected int64, err error)
  • func (db *DBConnect) Query(ctx context.Context, query string, args ...any) (results []map[string]any, count int64, err error)
  • func (db *DBConnect) Select(ctx context.Context, dest any, query string, args ...any) (count int64, err error)
  • func (db *DBConnect) SelectOne(ctx context.Context, dest any, query string, args ...any) (err error)
• type Map
  • func (m *Map) Scan(src any) error
• type Option
  • func WithCharset(charset string) Option
  • func WithDBName(dbName string) Option
  • func WithHost(host string) Option
  • func WithLoc(loc string) Option
  • func WithPass(pass string) Option
  • func WithPoolSize(size int) Option
  • func WithPort(port int) Option
  • func WithUser(user string) Option
• type Options

Functions

func BuildDBDriver

func BuildDBDriver(opts *Options) string

BuildDBDriver return a driver like "user:pass@tcp(host:port)/dbName?charset=utf8&loc=Asia%%2FShanghai"

Types

type Count

type Count struct {
	Count int64 `db:"count"`
}

type DBConnect

type DBConnect struct {
	*sql.DB
	Options   *Options
	ContextTx contextKey
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) (*DBConnect, error)

New return a new mysql client, and try ping.

func (*DBConnect) Exec

func (db *DBConnect) Exec(ctx context.Context, query string, args ...any) (lastInsertId, rowsAffected int64, err error)

Exec exec query by prepare sql, eg: INSERT, UPDATE, DELETE

func (*DBConnect) Query

func (db *DBConnect) Query(ctx context.Context, query string, args ...any) (results []map[string]any, count int64, err error)

Query query by prepare sql, eg: SELECT

func (*DBConnect) Select

func (db *DBConnect) Select(ctx context.Context, dest any, query string, args ...any) (count int64, err error)

func (*DBConnect) SelectOne

func (db *DBConnect) SelectOne(ctx context.Context, dest any, query string, args ...any) (err error)

type Map

type Map map[string]any

func (*Map) Scan

func (m *Map) Scan(src any) error

Scan 实现 Scan 接口，用来自动赋值

type Option

type Option func(opts *Options)

func WithCharset

func WithCharset(charset string) Option

func WithDBName

func WithDBName(dbName string) Option

func WithHost

func WithHost(host string) Option

func WithLoc

func WithLoc(loc string) Option

func WithPass

func WithPass(pass string) Option

func WithPoolSize

func WithPoolSize(size int) Option

func WithPort

func WithPort(port int) Option

func WithUser

func WithUser(user string) Option

type Options

type Options struct {
	User     string
	Pass     string
	Host     string
	Port     int
	PoolSize int

	DBName  string
	Charset string
	Loc     string
}