internal

Documentation

Index

• func GetError(err error, query string, args ...interface{}) error
• func ResolveMultiRows(rows *sql.Rows) (datasetRows []xdb.Rows, err error)
• func ResolveRows(rows *sql.Rows) (dataRows xdb.Rows, err error)
• func Unwrap(args ...interface{}) []interface{}
• type ISysDB
  • func NewSysDB(proto string, conn string, maxOpen int, maxIdle int, maxLifeTime time.Duration) (ISysDB, error)
• type ISysTrans
• 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 ResolveMultiRows

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

func ResolveRows

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

func Unwrap

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

Types

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, maxOpen int, maxIdle int, maxLifeTime time.Duration) (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 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