udcdb

go get gitee.com/common_go/dbdao

[MysqlConfig]
; 是否打开执行sql记录
showSql=true
; 是否记录sql执行时间，前提需打开showSql
showExecTime=true
; 慢执行日志，前提打开showExecTime，单位500s，默认为0，打全部执行耗时日志
slowslowDuration=500
; 最大连接数，默认100
maxConn=50
; 最大空闲连接数，默认30
maxIdle=30

[MysqlCluster]
; group = 主库 从库1 从库2 ... 从库n
udc = udc_rw:123456@tcp(localhost:3306)/udc_test udc_ro:123456@tcp(localhost:3306)/udc_test
blog = blog_rw:123456@tcp(localhost:3306)/blog_test blog_ro:123456@tcp(localhost:3306)/blog_test

// 获取 udc 实例组
db := dbdao.GetDbInstance("udc")

// 返回 Master 数据库引擎
masterEngine := db.Engine.Master()

// 依据给定的负载策略返回一个 Slave 数据库引擎
slaveEngine := db.Engine.Slave()

type User struct {
    Id int64
    Name string
    Salt string
    Age int
    Passwd string `xorm:"varchar(200)"`
    Created time.Time `xorm:"created"`
    Updated time.Time `xorm:"updated"`
}

// 主库插入
affected, err := masterEngine.Insert(&user)
// INSERT INTO struct () values ()

affected, err := masterEngine.Insert(&user1, &user2)
// INSERT INTO struct1 () values ()
// INSERT INTO struct2 () values ()

affected, err := masterEngine.Insert(&users)
// INSERT INTO struct () values (),(),()

affected, err := masterEngine.Insert(&user1, &users)
// INSERT INTO struct1 () values ()
// INSERT INTO struct2 () values (),(),()

// 从库查询
has, err := slaveEngine.Get(&user)
// SELECT * FROM user LIMIT 1

has, err := slaveEngine.Where("name = ?", name).Desc("id").Get(&user)
// SELECT * FROM user WHERE name = ? ORDER BY id DESC LIMIT 1