mdb

Documentation

Index

• Constants
• Variables
• func ConnectionMysql(dataSource *msystem.Mysql) *sqlx.DB
• func GetId(dest any) (string, any)
• func GetTableName(dest any) string
• func InSql(param []any) string
• func InitMysql()
• func NewInsert(entity Table, ignore ...string) (string, []any)
• func NewInsertMap(tableName string, dataMap map[string]any) (string, []any)
• func NewSelect(tableName string) *query
• func NewSelectF(tableName string) *query
• func NewUpdate(tableName string) *update
• type Counter
  • func (domain Counter) Nil() bool
  • func (domain Counter) OK() bool
• type D
• type SQLExecute
  • func (domain *SQLExecute) Commit() *SQLExecute
  • func (domain *SQLExecute) Count(tableName string, where map[string]any) (count Counter)
  • func (domain *SQLExecute) CountQuery(query *query) (count Counter)
  • func (domain *SQLExecute) CountSql(sql string, param ...any) (count Counter)
  • func (domain *SQLExecute) Delete(tableName string, where map[string]any) (rowsAffect int64)
  • func (domain *SQLExecute) DeleteByField(entity any, fieldName string, fieldVal any) (rowsAffect int64)
  • func (domain *SQLExecute) DeleteById(entity any) (rowsAffect int64)
  • func (domain *SQLExecute) Exec(execSql string, params ...any) (rowsAffect int64, err error)
  • func (domain *SQLExecute) Exists(tableName string, where map[string]any) (exists bool)
  • func (domain *SQLExecute) Insert(insertSql string, params ...any) (rowsAffect int64, lastId int64)
  • func (domain *SQLExecute) InsertMap(entity Table, ignore ...string) (rowsAffect int64, lastId int64)
  • func (domain *SQLExecute) NotFound(tableName string, where map[string]any) (notFound bool)
  • func (domain *SQLExecute) OpenTransactional() *SQLExecute
  • func (domain *SQLExecute) Rollback() *SQLExecute
  • func (domain *SQLExecute) SelectByField(entity any, fieldName string, fieldValue any)
  • func (domain *SQLExecute) SelectById(entity any)
  • func (domain *SQLExecute) SelectList(entity any, sql string, params ...any)
  • func (domain *SQLExecute) SelectPage(entity any, query *query, searchPage mmodel.CmdPage) *mmodel.Pageable
  • func (domain *SQLExecute) SelectRow(entity any, sql string, params ...any)
  • func (domain *SQLExecute) Update(updateSql string, params ...any) (rowsAffect int64)
  • func (domain *SQLExecute) UpdateMap(tableName string, update map[string]any, where map[string]any) (rowsAffect int64)
• type Table
• type TableId

Constants

const ShowSql = false

Variables

var Scan = &scan{}

var Update update

Functions

func ConnectionMysql

func ConnectionMysql(dataSource *msystem.Mysql) *sqlx.DB

func GetId

func GetId(dest any) (string, any)

func GetTableName

func GetTableName(dest any) string

func InSql

func InSql(param []any) string

func InitMysql

func InitMysql()

func NewInsert

func NewInsert(entity Table, ignore ...string) (string, []any)

func NewInsertMap

func NewInsertMap(tableName string, dataMap map[string]any) (string, []any)

func NewSelect

func NewSelect(tableName string) *query

func NewSelectF

func NewSelectF(tableName string) *query

func NewUpdate

func NewUpdate(tableName string) *update

Types

type Counter

type Counter struct {
	Count int64 `db:"count"`
}

func (Counter) Nil

func (domain Counter) Nil() bool

func (Counter) OK

func (domain Counter) OK() bool

type D

type D = map[string]any

type SQLExecute

type SQLExecute struct {
	DB              *sqlx.DB
	TransactionalId string
	ShowSql         bool
	Transactional   *sqlx.Tx
}

var MySql *SQLExecute

var SqlIte3 *SQLExecute

func (*SQLExecute) Commit

func (domain *SQLExecute) Commit() *SQLExecute

func (*SQLExecute) Count

func (domain *SQLExecute) Count(tableName string, where map[string]any) (count Counter)

func (*SQLExecute) CountQuery

func (domain *SQLExecute) CountQuery(query *query) (count Counter)

func (*SQLExecute) CountSql

func (domain *SQLExecute) CountSql(sql string, param ...any) (count Counter)

func (*SQLExecute) Delete

func (domain *SQLExecute) Delete(tableName string, where map[string]any) (rowsAffect int64)

func (*SQLExecute) DeleteByField

func (domain *SQLExecute) DeleteByField(entity any, fieldName string, fieldVal any) (rowsAffect int64)

func (*SQLExecute) DeleteById

func (domain *SQLExecute) DeleteById(entity any) (rowsAffect int64)

func (*SQLExecute) Exec

func (domain *SQLExecute) Exec(execSql string, params ...any) (rowsAffect int64, err error)

func (*SQLExecute) Exists

func (domain *SQLExecute) Exists(tableName string, where map[string]any) (exists bool)

func (*SQLExecute) Insert

func (domain *SQLExecute) Insert(insertSql string, params ...any) (rowsAffect int64, lastId int64)

func (*SQLExecute) InsertMap

func (domain *SQLExecute) InsertMap(entity Table, ignore ...string) (rowsAffect int64, lastId int64)

func (*SQLExecute) NotFound

func (domain *SQLExecute) NotFound(tableName string, where map[string]any) (notFound bool)

func (*SQLExecute) OpenTransactional

func (domain *SQLExecute) OpenTransactional() *SQLExecute

func (*SQLExecute) Rollback

func (domain *SQLExecute) Rollback() *SQLExecute

func (*SQLExecute) SelectByField

func (domain *SQLExecute) SelectByField(entity any, fieldName string, fieldValue any)

func (*SQLExecute) SelectById

func (domain *SQLExecute) SelectById(entity any)

func (*SQLExecute) SelectList

func (domain *SQLExecute) SelectList(entity any, sql string, params ...any)

func (*SQLExecute) SelectPage

func (domain *SQLExecute) SelectPage(entity any, query *query, searchPage mmodel.CmdPage) *mmodel.Pageable

func (*SQLExecute) SelectRow

func (domain *SQLExecute) SelectRow(entity any, sql string, params ...any)

func (*SQLExecute) Update

func (domain *SQLExecute) Update(updateSql string, params ...any) (rowsAffect int64)

func (*SQLExecute) UpdateMap

func (domain *SQLExecute) UpdateMap(tableName string, update map[string]any, where map[string]any) (rowsAffect int64)

type Table

type Table interface {
	TableName() string
}

type TableId

type TableId interface {
	IdName() string
	IdVal() any
}