mysql

package
v0.0.0-...-752a2b9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 8, 2021 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	USERNAME = ""
	PASSWORD = ""
	NETWORK  = "tcp"
	SERVER   = "localhost"
	PORT     = 3306
	DATABASE = ""
	PREFIX   = "t_"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Db

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

func (*Db) Db

func (db *Db) Db(table ...string) *DbQuery

type DbConnection

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

创建连接器

func (*DbConnection) Connt

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

构建连接

type DbQuery

type DbQuery struct {
	Wher        string //[]map[string]string
	Joinn       string
	Wherestring string

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

构建查询器

func (*DbQuery) Alias

func (sqlstruct *DbQuery) Alias(alias string) *DbQuery

func (*DbQuery) Builder

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

func (*DbQuery) Clearquery

func (sqlstruct *DbQuery) Clearquery()

func (*DbQuery) Count

func (sqlstruct *DbQuery) Count(args ...interface{}) int64

func (*DbQuery) CreateDBTx

func (sqlstruct *DbQuery) CreateDBTx() (context.Context, *sql.Tx, error)

创建事务

func (*DbQuery) Del

func (sqlstruct *DbQuery) Del(where ...interface{}) sql.Result

func (*DbQuery) Field

func (sqlstruct *DbQuery) Field(field string) *DbQuery

func (*DbQuery) Find

func (sqlstruct *DbQuery) Find(args ...interface{}) map[string]interface{}

func (*DbQuery) FindNew

func (sqlstruct *DbQuery) FindNew(args ...interface{}) (map[string]interface{}, error)

func (*DbQuery) GetField

func (sqlstruct *DbQuery) GetField() string

func (*DbQuery) GetGroup

func (sqlstruct *DbQuery) GetGroup() string

func (*DbQuery) GetLimit

func (sqlstruct *DbQuery) GetLimit() string

func (*DbQuery) GetOrder

func (sqlstruct *DbQuery) GetOrder() string

func (*DbQuery) GetRow

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

func (*DbQuery) GetRows

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

func (*DbQuery) GetSave

func (sqlstruct *DbQuery) GetSave() string

func (*DbQuery) Getjoin

func (sqlstruct *DbQuery) Getjoin() string

func (*DbQuery) Getwhere

func (sqlstruct *DbQuery) Getwhere() string

func (*DbQuery) Group

func (sqlstruct *DbQuery) Group(group string)

func (*DbQuery) Join

func (sqlstruct *DbQuery) Join(jType string, table string, on string) *DbQuery

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

func (*DbQuery) Limit

func (sqlstruct *DbQuery) Limit(limit string)

func (*DbQuery) Order

func (sqlstruct *DbQuery) Order(order string) *DbQuery

func (*DbQuery) Save

func (sqlstruct *DbQuery) Save(save map[string]interface{}) sql.Result

func (*DbQuery) SaveNew

func (sqlstruct *DbQuery) SaveNew(save map[string]interface{}) (sql.Result, error)

func (*DbQuery) Select

func (sqlstruct *DbQuery) Select(args ...interface{}) []map[string]interface{}

func (*DbQuery) SelectNew

func (sqlstruct *DbQuery) SelectNew(args ...interface{}) ([]map[string]interface{}, error)

func (*DbQuery) SelectSql

func (sqlstruct *DbQuery) SelectSql() string

func (*DbQuery) Size

func (sqlstruct *DbQuery) Size(page int, size int) *DbQuery

func (*DbQuery) Table

func (sqlstruct *DbQuery) Table(table string) *DbQuery

func (*DbQuery) TxSave

func (sqlstruct *DbQuery) TxSave(ctx context.Context, tx *sql.Tx, save map[string]interface{}) (sql.Result, error)

事务写入

func (*DbQuery) TxUpdate

func (sqlstruct *DbQuery) TxUpdate(ctx context.Context, tx *sql.Tx, update map[string]interface{}, where ...interface{}) (sql.Result, error)

事务更新

func (*DbQuery) Update

func (sqlstruct *DbQuery) Update(update map[string]interface{}, where ...interface{}) sql.Result

func (*DbQuery) UpdateNew

func (sqlstruct *DbQuery) UpdateNew(update map[string]interface{}, where ...interface{}) (sql.Result, error)

func (*DbQuery) Where

func (sqlstruct *DbQuery) Where(wher string) *DbQuery

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL