mysql

Documentation

Index

• type Db
  • func (db *Db) Db(table string) *ExQuery
• type DbConnection
  • func (DbConnection *DbConnection) Connt(cnt *map[string]string) error
• type DbQuery
  • func (q *DbQuery) Builder(dbConnection *DbConnection)
• type ExQuery
  • func (q *ExQuery) Alias(alias string) *ExQuery
  • func (sqlstruct *ExQuery) Clearquery()
  • func (q *ExQuery) Count() (int, error)
  • func (q *ExQuery) CreateDBTx() (*ExQuery, error)
  • func (q *ExQuery) Del() (sql.Result, error)
  • func (q *ExQuery) Exec(sql string, args ...interface{}) (sql.Result, error)
  • func (q *ExQuery) Field(field string) *ExQuery
  • func (q *ExQuery) Find() (map[string]interface{}, error)
  • func (q *ExQuery) Fun(f func(query *ExQuery) *ExQuery) *ExQuery
  • func (q *ExQuery) GetRow(query *sql.Rows) map[string]interface{}
  • func (q *ExQuery) GetRows(query *sql.Rows) []map[string]interface{}
  • func (q *ExQuery) Group(group string) *ExQuery
  • func (q *ExQuery) Having(h string, v interface{}) *ExQuery
  • func (q *ExQuery) In(in string, v []interface{}) *ExQuery
  • func (q *ExQuery) Join(jType string, table string, on string) *ExQuery
  • func (q *ExQuery) Limit(limit string) *ExQuery
  • func (q *ExQuery) Or(or string, v ...interface{}) *ExQuery
  • func (q *ExQuery) OrIn(in string, v []interface{}) *ExQuery
  • func (q *ExQuery) Order(order string) *ExQuery
  • func (q *ExQuery) Query(sql string, args ...interface{}) ([]map[string]interface{}, error)
  • func (q *ExQuery) Save(save map[string]interface{}) (sql.Result, error)
  • func (q *ExQuery) Select() ([]map[string]interface{}, error)
  • func (q *ExQuery) SelectSql() string
  • func (q *ExQuery) Size(page int, size int) *ExQuery
  • func (q *ExQuery) Table(table string) *ExQuery
  • func (q *ExQuery) TxCommit() error
  • func (q *ExQuery) TxRollback() error
  • func (q *ExQuery) TxSave(save map[string]interface{}) (sql.Result, error)
  • func (q *ExQuery) TxUpdate(update map[string]interface{}, where ...interface{}) (sql.Result, error)
  • func (q *ExQuery) Update(update map[string]interface{}) (sql.Result, error)
  • func (q *ExQuery) Value(key string) (interface{}, error)
  • func (q *ExQuery) Where(wher string, v ...interface{}) *ExQuery
  • func (q *ExQuery) WhereOr(f func(query *ExQuery) *ExQuery) *ExQuery

Types

type Db

type Db struct {
	DbConn *DbConnection
	// DbQuery  DbQuery
	Dbconfig *map[string]interface{}
}

func (*Db) Db

func (db *Db) Db(table string) *ExQuery

type DbConnection

type DbConnection struct {
	DB       *sql.DB
	DbPrefix string
	DbName   string
	DbConf   map[string]string
}

创建连接器

func (*DbConnection) Connt

func (DbConnection *DbConnection) Connt(cnt *map[string]string) error

构建连接

type DbQuery

type DbQuery struct {
	DB       *sql.DB
	Prefix   string
	Executor *ExQuery
	sync.RWMutex
}

构建查询器

func (*DbQuery) Builder

func (q *DbQuery) Builder(dbConnection *DbConnection)

dbConnection.DB.PingContext(ctx) 防止ping阻塞

type ExQuery

type ExQuery struct {
	Wher string

	Joinn string

	Rows   interface{}
	Row    interface{}
	Prefix string
	DB     *sql.DB
	Ctx    context.Context
	Tx     *sql.Tx
	sync.RWMutex
	// contains filtered or unexported fields
}

执行器

func (*ExQuery) Alias

func (q *ExQuery) Alias(alias string) *ExQuery

func (*ExQuery) Clearquery

func (sqlstruct *ExQuery) Clearquery()

func (*ExQuery) Count

func (q *ExQuery) Count() (int, error)

func (*ExQuery) CreateDBTx

func (q *ExQuery) CreateDBTx() (*ExQuery, error)

创建事务 注意，不能用q.DB.Conn(ctx) 否则会创建 新的连接并不会释放

func (*ExQuery) Del

func (q *ExQuery) Del() (sql.Result, error)

func (*ExQuery) Exec

func (q *ExQuery) Exec(sql string, args ...interface{}) (sql.Result, error)

func (*ExQuery) Field

func (q *ExQuery) Field(field string) *ExQuery

func (*ExQuery) Find

func (q *ExQuery) Find() (map[string]interface{}, error)

func (*ExQuery) Fun

func (q *ExQuery) Fun(f func(query *ExQuery) *ExQuery) *ExQuery

闭包查询

func (*ExQuery) GetRow

func (q *ExQuery) GetRow(query *sql.Rows) map[string]interface{}

func (*ExQuery) GetRows

func (q *ExQuery) GetRows(query *sql.Rows) []map[string]interface{}

func (*ExQuery) Group

func (q *ExQuery) Group(group string) *ExQuery

func (*ExQuery) Having

func (q *ExQuery) Having(h string, v interface{}) *ExQuery

func (*ExQuery) In

func (q *ExQuery) In(in string, v []interface{}) *ExQuery

func (*ExQuery) Join

func (q *ExQuery) Join(jType string, table string, on string) *ExQuery

涉及线程安全，改用字符串

func (*ExQuery) Limit

func (q *ExQuery) Limit(limit string) *ExQuery

func (*ExQuery) Or

func (q *ExQuery) Or(or string, v ...interface{}) *ExQuery

func (*ExQuery) OrIn

func (q *ExQuery) OrIn(in string, v []interface{}) *ExQuery

func (*ExQuery) Order

func (q *ExQuery) Order(order string) *ExQuery

func (*ExQuery) Query

func (q *ExQuery) Query(sql string, args ...interface{}) ([]map[string]interface{}, error)

func (*ExQuery) Save

func (q *ExQuery) Save(save map[string]interface{}) (sql.Result, error)

func (*ExQuery) Select

func (q *ExQuery) Select() ([]map[string]interface{}, error)

func (*ExQuery) SelectSql

func (q *ExQuery) SelectSql() string

func (*ExQuery) Size

func (q *ExQuery) Size(page int, size int) *ExQuery

func (*ExQuery) Table

func (q *ExQuery) Table(table string) *ExQuery

func (*ExQuery) TxCommit

func (q *ExQuery) TxCommit() error

事务提交

func (*ExQuery) TxRollback

func (q *ExQuery) TxRollback() error

事务回滚

func (*ExQuery) TxSave

func (q *ExQuery) TxSave(save map[string]interface{}) (sql.Result, error)

事务写入

func (*ExQuery) TxUpdate

func (q *ExQuery) TxUpdate(update map[string]interface{}, where ...interface{}) (sql.Result, error)

事务更新

func (*ExQuery) Update

func (q *ExQuery) Update(update map[string]interface{}) (sql.Result, error)

func (*ExQuery) Value

func (q *ExQuery) Value(key string) (interface{}, error)

func (*ExQuery) Where

func (q *ExQuery) Where(wher string, v ...interface{}) *ExQuery

func (*ExQuery) WhereOr

func (q *ExQuery) WhereOr(f func(query *ExQuery) *ExQuery) *ExQuery

使用此方法时 请优先于任何where条件执行