mysql

Documentation

Index

• Variables
• func Exec(query string, args ...interface{}) sql.Result
• func InitDB(username string, password string, port string, ip string, databaseName string)
• func Query(query string, args ...interface{}) ([]map[string]interface{}, *sql.Rows)
• func QueryWithConnection(con string, query string, args ...interface{}) ([]map[string]interface{}, *sql.Rows)
• func SetColVarType(colVar *[]interface{}, i int, typeName string)
• func SetResultValue(result *map[string]interface{}, index string, colVar interface{}, ...)
• func WithTransaction(fn TxFn) (err error, res map[string]interface{})
• type SqlTxStruct
  • func BeginTransactions() *SqlTxStruct
  • func BeginTransactionsByLevel() *SqlTxStruct
  • func (SqlTx *SqlTxStruct) Exec(query string, args ...interface{}) (sql.Result, error)
  • func (SqlTx *SqlTxStruct) Query(query string, args ...interface{}) ([]map[string]interface{}, error)
• type TxFn

Variables

var (
	SqlDB *sql.DB
)

Functions

func Exec

func Exec(query string, args ...interface{}) sql.Result

func InitDB

func InitDB(username string, password string, port string, ip string, databaseName string)

只会执行一次在执行程序启动的时候

func Query

func Query(query string, args ...interface{}) ([]map[string]interface{}, *sql.Rows)

func QueryWithConnection

func QueryWithConnection(con string, query string, args ...interface{}) ([]map[string]interface{}, *sql.Rows)

func SetColVarType

func SetColVarType(colVar *[]interface{}, i int, typeName string)

func SetResultValue

func SetResultValue(result *map[string]interface{}, index string, colVar interface{}, typeName string)

func WithTransaction

func WithTransaction(fn TxFn) (err error, res map[string]interface{})

Types

type SqlTxStruct

type SqlTxStruct struct {
	Tx *sql.Tx
}

func BeginTransactions

func BeginTransactions() *SqlTxStruct

func BeginTransactionsByLevel

func BeginTransactionsByLevel() *SqlTxStruct

func (*SqlTxStruct) Exec

func (SqlTx *SqlTxStruct) Exec(query string, args ...interface{}) (sql.Result, error)

func (*SqlTxStruct) Query

func (SqlTx *SqlTxStruct) Query(query string, args ...interface{}) ([]map[string]interface{}, error)

type TxFn

type TxFn func(*SqlTxStruct) (error, map[string]interface{})