mysql

Documentation

Index

• func AboveOpr(name string, val interface{}) string
• func BelowOpr(name string, val interface{}) string
• func EqualOpr(name string, val interface{}) string
• func InOpr(name string, val interface{}) string
• func IsKeyWord(str string) bool
• func LikeOpr(name string, val interface{}) string
• func NotEqualOpr(name string, val interface{}) string
• func NotInOpr(name string, val interface{}) string
• func SortOpr(name string, ascSort bool) string
• type Builder
  • func New(vModel model.Model, modelProvider provider.Provider, prefix string) *Builder
  • func (s *Builder) BuildCount(filter model.Filter) (ret string, err error)
  • func (s *Builder) BuildCreateRelationSchema(relationSchema string) (string, error)
  • func (s *Builder) BuildCreateSchema() (ret string, err error)
  • func (s *Builder) BuildDelete() (ret string, err error)
  • func (s *Builder) BuildDeleteRelation(vField model.Field, rModel model.Model) (delRight, delRelation string, err error)
  • func (s *Builder) BuildDropRelationSchema(relationSchema string) (string, error)
  • func (s *Builder) BuildDropSchema() (string, error)
  • func (s *Builder) BuildInsert() (ret string, err error)
  • func (s *Builder) BuildInsertRelation(vField model.Field, rModel model.Model) (ret string, err error)
  • func (s *Builder) BuildQuery(filter model.Filter) (ret string, err error)
  • func (s *Builder) BuildQueryRelation(vField model.Field, rModel model.Model) (ret string, err error)
  • func (s *Builder) BuildUpdate() (ret string, err error)
• type Config
  • func NewConfig(dbServer, dbName, username, password, charSet string) *Config
  • func (s *Config) CharSet() string
  • func (s *Config) Database() string
  • func (s *Config) Password() string
  • func (s *Config) Same(cfg *Config) bool
  • func (s *Config) Server() string
  • func (s *Config) Username() string
• type Executor
  • func NewExecutor(config *Config) (ret *Executor, err error)
  • func (s *Executor) BeginTransaction() (err error)
  • func (s *Executor) CheckTableExist(tableName string) (ret bool, err error)
  • func (s *Executor) CommitTransaction() (err error)
  • func (s *Executor) Connect() (err error)
  • func (s *Executor) Execute(sql string) (rowsAffected int64, lastInsertID int64, err error)
  • func (s *Executor) Finish()
  • func (s *Executor) GetField(value ...interface{}) (err error)
  • func (s *Executor) Next() bool
  • func (s *Executor) Ping() (err error)
  • func (s *Executor) Query(sql string) (err error)
  • func (s *Executor) Release()
  • func (s *Executor) RollbackTransaction() (err error)
• type OprFunc
• type Pool
  • func NewPool() *Pool
  • func (s *Pool) CheckConfig(cfgPtr *Config) error
  • func (s *Pool) FetchOut() (ret *Executor, err error)
  • func (s *Pool) GetExecutor() (ret *Executor, err error)
  • func (s *Pool) Initialize(maxConnNum int, configPtr *Config) (err error)
  • func (s *Pool) PutIn(val *Executor)
  • func (s *Pool) Uninitialized()

Functions

func AboveOpr

func AboveOpr(name string, val interface{}) string

AboveOpr Above Opr

func BelowOpr

func BelowOpr(name string, val interface{}) string

BelowOpr Below Opr

func EqualOpr

func EqualOpr(name string, val interface{}) string

EqualOpr Equal Opr

func InOpr

func InOpr(name string, val interface{}) string

InOpr In Opr

func IsKeyWord

func IsKeyWord(str string) bool

IsKeyWord check if a keyword

func LikeOpr

func LikeOpr(name string, val interface{}) string

LikeOpr Like Opr

func NotEqualOpr

func NotEqualOpr(name string, val interface{}) string

NotEqualOpr NotEqual Opr

func NotInOpr

func NotInOpr(name string, val interface{}) string

NotInOpr NotIn Opr

func SortOpr

func SortOpr(name string, ascSort bool) string

SortOpr sort opr

Types

type Builder

type Builder struct {
	common.Common
}

Builder Builder

func New

func New(vModel model.Model, modelProvider provider.Provider, prefix string) *Builder

New create builder

func (*Builder) BuildCount

func (s *Builder) BuildCount(filter model.Filter) (ret string, err error)

BuildCount build count

func (*Builder) BuildCreateRelationSchema

func (s *Builder) BuildCreateRelationSchema(relationSchema string) (string, error)

BuildCreateRelationSchema Build CreateRelation Schema

func (*Builder) BuildCreateSchema

func (s *Builder) BuildCreateSchema() (ret string, err error)

BuildCreateSchema BuildCreateSchema

func (*Builder) BuildDelete

func (s *Builder) BuildDelete() (ret string, err error)

BuildDelete BuildDelete

func (*Builder) BuildDeleteRelation

func (s *Builder) BuildDeleteRelation(vField model.Field, rModel model.Model) (delRight, delRelation string, err error)

BuildDeleteRelation BuildDeleteRelation

func (*Builder) BuildDropRelationSchema

func (s *Builder) BuildDropRelationSchema(relationSchema string) (string, error)

BuildDropRelationSchema Build DropRelation Schema

func (*Builder) BuildDropSchema

func (s *Builder) BuildDropSchema() (string, error)

BuildDropSchema BuildDropSchema

func (*Builder) BuildInsert

func (s *Builder) BuildInsert() (ret string, err error)

BuildInsert Build Insert

func (*Builder) BuildInsertRelation

func (s *Builder) BuildInsertRelation(vField model.Field, rModel model.Model) (ret string, err error)

BuildInsertRelation Build Insert Relation

func (*Builder) BuildQuery

func (s *Builder) BuildQuery(filter model.Filter) (ret string, err error)

BuildQuery build query sql

func (*Builder) BuildQueryRelation

func (s *Builder) BuildQueryRelation(vField model.Field, rModel model.Model) (ret string, err error)

BuildQueryRelation build query relation sql

func (*Builder) BuildUpdate

func (s *Builder) BuildUpdate() (ret string, err error)

BuildUpdate Build Update

type Config

type Config struct {
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(dbServer, dbName, username, password, charSet string) *Config

func (*Config) CharSet

func (s *Config) CharSet() string

func (*Config) Database

func (s *Config) Database() string

func (*Config) Password

func (s *Config) Password() string

func (*Config) Same

func (s *Config) Same(cfg *Config) bool

func (*Config) Server

func (s *Config) Server() string

func (*Config) Username

func (s *Config) Username() string

type Executor

type Executor struct {
	// contains filtered or unexported fields
}

Executor Executor

func NewExecutor

func NewExecutor(config *Config) (ret *Executor, err error)

NewExecutor 新建一个数据访问对象

func (*Executor) BeginTransaction

func (s *Executor) BeginTransaction() (err error)

func (*Executor) CheckTableExist

func (s *Executor) CheckTableExist(tableName string) (ret bool, err error)

CheckTableExist Check Table Exist

func (*Executor) CommitTransaction

func (s *Executor) CommitTransaction() (err error)

func (*Executor) Connect

func (s *Executor) Connect() (err error)

func (*Executor) Execute

func (s *Executor) Execute(sql string) (rowsAffected int64, lastInsertID int64, err error)

func (*Executor) Finish

func (s *Executor) Finish()

func (*Executor) GetField

func (s *Executor) GetField(value ...interface{}) (err error)

func (*Executor) Next

func (s *Executor) Next() bool

func (*Executor) Ping

func (s *Executor) Ping() (err error)

func (*Executor) Query

func (s *Executor) Query(sql string) (err error)

func (*Executor) Release

func (s *Executor) Release()

func (*Executor) RollbackTransaction

func (s *Executor) RollbackTransaction() (err error)

type OprFunc

type OprFunc func(string, interface{}) string

type Pool

type Pool struct {
	// contains filtered or unexported fields
}

Pool executorPool

func NewPool

func NewPool() *Pool

NewPool new pool

func (*Pool) CheckConfig

func (s *Pool) CheckConfig(cfgPtr *Config) error

func (*Pool) FetchOut

func (s *Pool) FetchOut() (ret *Executor, err error)

FetchOut FetchOut Executor

func (*Pool) GetExecutor

func (s *Pool) GetExecutor() (ret *Executor, err error)

func (*Pool) Initialize

func (s *Pool) Initialize(maxConnNum int, configPtr *Config) (err error)

Initialize initialize executor pool

func (*Pool) PutIn

func (s *Pool) PutIn(val *Executor)

PutIn PutIn Executor

func (*Pool) Uninitialized

func (s *Pool) Uninitialized()

Uninitialized uninitialized executor pool