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 (
	PACKET_DB_MAX_SIZE           = 4 * 1024  // max size of sql
	PACKET_SQL_MAX_SIZE          = 32 * 1024 // max size of sql
	PACKET_HTTPC_MAX_SIZE        = 32 * 1024 // max size of sql
	PACKET_MESSAGE_MAX_SIZE      = 32 * 1024 // max size of message
	PACKET_METHOD_STACK_MAX_SIZE = 32 * 1024 // max size of message

	COMPILE_FILE_MAX_SIZE = 2 * 1024 // max size of filename

	HTTP_HOST_MAX_SIZE   = 2 * 1024 // max size of host
	HTTP_URI_MAX_SIZE    = 2 * 1024 // max size of uri
	HTTP_METHOD_MAX_SIZE = 256      // max size of method
	HTTP_IP_MAX_SIZE     = 256      // max size of ip(request_addr)
	HTTP_UA_MAX_SIZE     = 2 * 1024 // max size of user agent
	HTTP_REF_MAX_SIZE    = 2 * 1024 // max size of referer
	HTTP_USERID_MAX_SIZE = 2 * 1024 // max size of userid

	HTTP_PARAM_MAX_COUNT      = 20
	HTTP_PARAM_KEY_MAX_SIZE   = 255 // = 을 빼고 255 byte
	HTTP_PARAM_VALUE_MAX_SIZE = 256

	HTTP_HEADER_MAX_COUNT      = 20
	HTTP_HEADER_KEY_MAX_SIZE   = 255 // = 을 빼고 255 byte
	HTTP_HEADER_VALUE_MAX_SIZE = 256

	SQL_PARAM_MAX_COUNT      = 20
	SQL_PARAM_VALUE_MAX_SIZE = 256

	STEP_ERROR_MESSAGE_MAX_SIZE = 4 * 1024
)

const (
	SQL_TYPE_DBC       = 1
	SQL_TYPE_SQL       = 2
	SQL_TYPE_SQL_PARAM = 3
)

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()