mysql

Sep 25, 2020

Changes in this version

type MysqlRows

+ func (row *MysqlRows) ReadResultMsg(mysql *Mysql_Conn) (err error)

Sep 24, 2020

Changes in this version

+ func ReadLength_Coded_Slice(data []byte, pos *int) (l int, err error)

+ type MysqlColumn struct

Aug 26, 2020

Changes in this version

+ func Writelenmsg(write *MsgBuffer, msg []byte)

type Database_mysql_stmt

+ func (stmt Database_mysql_stmt) Execute(args []driver.Value) error

Aug 18, 2020

Changes in this version

+ const CLIENT_COMPRESS

+ const CLIENT_CONNECT_WITH_DB

+ const CLIENT_LOCAL_FILES

+ const CLIENT_LONG_FLAG

+ const CLIENT_LONG_PASSWORD

+ const CLIENT_MULTI_RESULTS

+ const CLIENT_PLUGIN_AUTH

+ const CLIENT_PROTOCOL_41

+ const CLIENT_SECURE_CONNECTION

+ const CLIENT_SSL

+ const CLIENT_TRANSACTIONS

+ const Default_MaxIdleConns

+ const Default_MaxOpenConns

+ const ISDEBUG

+ var Mysql_ssl_ca string

+ var Mysql_ssl_cert string

+ var Mysql_ssl_key string

+ func Bytes2str(b []byte) string

+ func DEBUG(v ...interface{})

+ func JsonMarshalString(i interface{}) string

+ func Log(format string, v ...interface{})

+ func Preg_match(regtext string, text string) bool

+ func Preg_match_result(regtext string, text string, n int) ([][]string, error)

+ func Preg_replace(regtext string, text string, src string) (string, error)

+ func ReadLengthCodedStringFromBuffer(msg *MsgBuffer, return_str bool) (string, error)

+ func ReadLength_Coded_Binary(buf *MsgBuffer) (int, error)

+ func ReadLength_Coded_Byte(msg *MsgBuffer) ([]byte, error)

+ func ReadNullTerminatedString(msg *MsgBuffer) (string, error)

+ func Str2bytes(s string) []byte

+ func Write1lenmsg(write *MsgBuffer, msg []byte)

+ func WriteNullTerminatedString(write *MsgBuffer, msg string)

+ func WriteNullmsg(write *MsgBuffer, msg []byte)

+ type Database_mysql_conn struct

+ func (conn *Database_mysql_conn) Begin() (driver.Tx, error)

+ func (conn *Database_mysql_conn) Prepare(query string) (driver.Stmt, error)

+ type Database_mysql_stmt struct

+ func (stmt Database_mysql_stmt) Close() (err error)

+ func (stmt Database_mysql_stmt) Exec(values []driver.Value) (driver.Result, error)

+ func (stmt Database_mysql_stmt) LastInsertId() (int64, error)

+ func (stmt Database_mysql_stmt) NumInput() int

+ func (stmt Database_mysql_stmt) Query(values []driver.Value) (driver.Rows, error)

+ func (stmt Database_mysql_stmt) RowsAffected() (int64, error)

+ type Database_mysql_tx struct

+ func (tx Database_mysql_tx) Commit() error

+ func (tx Database_mysql_tx) Rollback() error

+ type Database_rows struct

+ func (row *Database_rows) Close() error

+ func (row *Database_rows) Columns() []string

+ func (row *Database_rows) Next(dest []driver.Value) (err error)

+ type Field_struct struct

+ Field_t reflect.Type

+ Kind reflect.Kind

+ Offset uintptr

+ type MsgBuffer struct

+ func New(size int) *MsgBuffer

+ func NewBuffer(n int) *MsgBuffer

+ func (r *MsgBuffer) Close() error

+ func (r *MsgBuffer) Read(p []byte) (n int, err error)

+ func (r *MsgBuffer) ReadByte() (b byte, err error)

+ func (r *MsgBuffer) Shift(len int)

+ func (w *MsgBuffer) Bytes() []byte

+ func (w *MsgBuffer) Len() int

+ func (w *MsgBuffer) Make(l int) []byte

+ func (w *MsgBuffer) Next(l int) []byte

+ func (w *MsgBuffer) PreBytes(n int) []byte

+ func (w *MsgBuffer) Reset()

+ func (w *MsgBuffer) ResetBuf(b []byte)

+ func (w *MsgBuffer) String() string

+ func (w *MsgBuffer) Truncate(i int)

+ func (w *MsgBuffer) Write(b []byte) (int, error)

+ func (w *MsgBuffer) WriteByte(s byte)

+ func (w *MsgBuffer) WriteString(s string)

+ type MySQLDriver struct

+ func (d MySQLDriver) Open(dsn string) (driver.Conn, error)

+ type MysqlDB struct

+ ConnMaxLifetime int64

+ Conn_chan chan *Mysql_Conn

+ Conn_chan2 chan *Mysql_Conn

+ Conn_m sync.Map

+ Conn_num int32

+ Lock sync.Mutex

+ MaxIdleConns int32

+ MaxOpenConns int32

+ TimeZone string

+ func (mysqldb *MysqlDB) BeginTransaction() (*Mysql_Conn, error)

+ func (mysqldb *MysqlDB) EndTransaction(conn *Mysql_Conn)

+ func (mysqldb *MysqlDB) Exec(sql []byte) (int64, int64, error)

+ func (mysqldb *MysqlDB) GET() (conn *Mysql_Conn, err error)

+ func (mysqldb *MysqlDB) Ping() error

+ func (mysqldb *MysqlDB) Put(conn *Mysql_Conn)

+ func (mysqldb *MysqlDB) Query(sql []byte, row *MysqlRows) (columns [][]byte, err error)

+ type MysqlRows struct

+ Buffer *MsgBuffer

+ Buffer2 *MsgBuffer

+ func (row *MysqlRows) Columns(mysql *Mysql_Conn) (columns [][]byte, err error)

+ func (row *MysqlRows) Scan(a ...*[]byte) error

+ type Mysql_Conn struct

+ Capabilities uint32

+ Lock sync.Mutex

+ Status bool

+ Thread_id uint32

+ TimeZone string

+ func (mysql *Mysql_Conn) Close() error

+ func (mysql *Mysql_Conn) Exec(sql []byte) (lastInsertId int64, rowsAffected int64, err error)

+ func (mysql *Mysql_Conn) Query(sql []byte, rows *MysqlRows) (columns [][]byte, err error)