sql

Documentation

Overview

github.com/whatap/go-api/sql

github.com/whatap/go-api/sql

Index

• Constants
• func CloseSqlContext(ctx *SqlCtx)
• func End(sqlCtx *SqlCtx, err error) error
• func Trace(ctx context.Context, dbhost, sql string, param []interface{}, elapsed int, ...) error
• type SqlCtx
  • func NewSqlCtx() *SqlCtx
  • func PoolSqlContext() *SqlCtx
  • func Start(ctx context.Context, dbhost, sql string) (*SqlCtx, error)
  • func StartOpen(ctx context.Context, dbhost string) (*SqlCtx, error)
  • func StartWithParam(ctx context.Context, dbhost, sql string, param ...interface{}) (*SqlCtx, error)
  • func StartWithParamArray(ctx context.Context, dbhost, sql string, param []interface{}) (*SqlCtx, error)
  • func (this *SqlCtx) Clear()

Constants

const (
	SQL_TYPE_DBC       = 1
	SQL_TYPE_SQL       = 2
	SQL_TYPE_SQL_PARAM = 3

	SQL_PARAM_MAX_COUNT      = 20
	SQL_PARAM_VALUE_MAX_SIZE = 256
)

Functions

func CloseSqlContext

func CloseSqlContext(ctx *SqlCtx)

func End

func End(sqlCtx *SqlCtx, err error) error

func Trace

func Trace(ctx context.Context, dbhost, sql string, param []interface{}, elapsed int, err error) error

Types

type SqlCtx

type SqlCtx struct {
	Txid        int64
	ServiceName string
	StartTime   int64
	Dbc         string
	Sql         string
	Param       string
	Type        uint8
	Cpu         int64
	Mem         int64
	// contains filtered or unexported fields
}

func NewSqlCtx

func NewSqlCtx() *SqlCtx

func PoolSqlContext

func PoolSqlContext() *SqlCtx

func Start

func Start(ctx context.Context, dbhost, sql string) (*SqlCtx, error)

func StartOpen

func StartOpen(ctx context.Context, dbhost string) (*SqlCtx, error)

func StartWithParam

func StartWithParam(ctx context.Context, dbhost, sql string, param ...interface{}) (*SqlCtx, error)

func StartWithParamArray

func StartWithParamArray(ctx context.Context, dbhost, sql string, param []interface{}) (*SqlCtx, error)

func (*SqlCtx) Clear

func (this *SqlCtx) Clear()