implement

Documentation

Index

• func GetError(err error, query string, args ...interface{}) error
• func ResolveFirstDataResult(rows *sql.Rows, result any) (err error)
• func ResolveFirstRow(rows *sql.Rows) (dataRows xdb.Row, err error)
• func ResolveMultiRows(rows *sql.Rows) (datasetRows []xdb.Rows, err error)
• func ResolveParams(input any) (params xtypes.XMap, err error)
• func ResolveRows(rows *sql.Rows) (dataRows xdb.Rows, err error)
• func ResolveRowsDataResult(rows *sql.Rows, result any) (err error)
• func ResolveScalar(rows *sql.Rows) (val any, err error)
• func Unwrap(args ...interface{}) []interface{}
• type DbResolveMapValCallback
• type DbResolveResultCallback
• type ISysDB
  • func NewSysDB(proto string, conn string, opts ...Option) (ISysDB, error)
• type ISysTrans
• type Option
  • func WithConnName(connName string) Option
  • func WithMaxIdle(maxIdle int) Option
  • func WithMaxLifeTime(maxLifeTime int) Option
  • func WithMaxOpen(maxOpen int) Option
• type WrapArgs
  • func (a WrapArgs) MarshalJSON() (result []byte, err error)
  • func (a WrapArgs) String() string

Functions

func GetError

func GetError(err error, query string, args ...interface{}) error

func ResolveFirstDataResult

func ResolveFirstDataResult(rows *sql.Rows, result any) (err error)

解析数据结果

func ResolveFirstRow

func ResolveFirstRow(rows *sql.Rows) (dataRows xdb.Row, err error)

func ResolveMultiRows

func ResolveMultiRows(rows *sql.Rows) (datasetRows []xdb.Rows, err error)

func ResolveParams

func ResolveParams(input any) (params xtypes.XMap, err error)

func ResolveRows

func ResolveRows(rows *sql.Rows) (dataRows xdb.Rows, err error)

func ResolveRowsDataResult

func ResolveRowsDataResult(rows *sql.Rows, result any) (err error)

解析数据结果

func ResolveScalar

func ResolveScalar(rows *sql.Rows) (val any, err error)

func Unwrap

func Unwrap(args ...interface{}) []interface{}

Types

type DbResolveMapValCallback

type DbResolveMapValCallback func(*sql.Rows) (result any, err error)

type DbResolveResultCallback

type DbResolveResultCallback func(*sql.Rows, any) error

type ISysDB

type ISysDB interface {
	Query(string, ...interface{}) (*sql.Rows, error)
	Exec(string, ...interface{}) (sql.Result, error)
	Begin() (ISysTrans, error)
	Close() error
}

func NewSysDB

func NewSysDB(proto string, conn string, opts ...Option) (ISysDB, error)

NewSysDB 创建DB实例

type ISysTrans

type ISysTrans interface {
	Query(string, ...interface{}) (*sql.Rows, error)
	Execute(string, ...interface{}) (sql.Result, error)
	Rollback() error
	Commit() error
}

ISysTrans 数据库事务接口

type Option

type Option func(*sysDB)

func WithConnName

func WithConnName(connName string) Option

func WithMaxIdle

func WithMaxIdle(maxIdle int) Option

func WithMaxLifeTime

func WithMaxLifeTime(maxLifeTime int) Option

func WithMaxOpen

func WithMaxOpen(maxOpen int) Option

type WrapArgs

type WrapArgs struct {
	Name  string
	Value any
	Out   bool
}

func (WrapArgs) MarshalJSON

func (a WrapArgs) MarshalJSON() (result []byte, err error)

func (WrapArgs) String

func (a WrapArgs) String() string