source

Documentation

Index

• type Mysql
  • func NewMysql(title string, gap int) *Mysql
  • func (m *Mysql) Connect(scheme string) (err error)
  • func (m *Mysql) Get(query string) (interface{}, error)
  • func (m *Mysql) GetScheme() string
  • func (m *Mysql) GetTitle() string
  • func (m *Mysql) Ping() (err error)
  • func (m *Mysql) ReConnect() (err error)
  • func (m *Mysql) Set(query string) (interface{}, error)
• type Source

Types

type Mysql

type Mysql struct {
	// contains filtered or unexported fields
}

func NewMysql

func NewMysql(title string, gap int) *Mysql

func (*Mysql) Connect

func (m *Mysql) Connect(scheme string) (err error)

Sqlx惰性连接，open并不会实际建立连接。该方法会立即使用Ping测试连接可用性。

func (*Mysql) Get

func (m *Mysql) Get(query string) (interface{}, error)

暂时只支持传统意义的select，结果为[]map[string]string todo：验证其他类型语句的正确性。

func (*Mysql) GetScheme

func (m *Mysql) GetScheme() string

func (*Mysql) GetTitle

func (m *Mysql) GetTitle() string

func (*Mysql) Ping

func (m *Mysql) Ping() (err error)

使用mysql_ping进行连接状态的探测。

func (*Mysql) ReConnect

func (m *Mysql) ReConnect() (err error)

重连，更新结构体下的db，使用一个新的sqlx结构体替换原db，并自动ping

func (*Mysql) Set

func (m *Mysql) Set(query string) (interface{}, error)

返回[]int，第一个值为lastId，第二值为effectedRow

type Source

type Source interface {
	Connect(string) error                  //连接
	ReConnect() error                      //重新连接
	Ping() error                           //判活
	Get(query string) (interface{}, error) //返回原始数据
	Set(query string) (interface{}, error) //设置格式化后的数据
}