mysql

README

可参照uploader服务

import (
    "github.com/joshqu1985/fireman/pkg/mysql"
)

// 全局初始化调用一次
func init() {
    if err := mysql.Init(Conf.Mysql); err != nil {
        panic(err)
    }
}

// 使用示例
func DemoGetMysqlData(state int) ([]TmpData, error) {
    items := []TmpData{}
    handle := func(orm *gorm.DB) error {
        return orm.Where("state=?", state).Find(&items).Error
    }
    //下面的语句没有指定表名, test是库名，可以在TmpData处指定表名， 参见GORM
    return items, mysql.Master("test").Doit(handle)
}

Documentation

Index

• type Client
  • func (c *Client) Doit(ctx context.Context, h func(*gorm.DB) error) error
• type Config
• type ConfigNode
• type Pool
  • func NewPool(confs []Config) *Pool
  • func (p *Pool) Master(dbname string) *Client
  • func (p *Pool) Slave(dbname string) *Client

Types

type Client

type Client struct {
	*gorm.DB
}

func (*Client) Doit

func (c *Client) Doit(ctx context.Context, h func(*gorm.DB) error) error

type Config

type Config struct {
	Name   string
	Opts   string
	Master ConfigNode
	Slaves []ConfigNode
}

type ConfigNode

type ConfigNode struct {
	Host    string
	Auth    string
	MaxIdle int `toml:"max_idle"`
	MaxOpen int `toml:"max_open"`
	MaxLife int `toml:"max_life"`
}

type Pool

type Pool struct {
	Instances map[string]dbInstance
}

func NewPool

func NewPool(confs []Config) *Pool

func (*Pool) Master

func (p *Pool) Master(dbname string) *Client

func (*Pool) Slave

func (p *Pool) Slave(dbname string) *Client