golang如何使用链接池

新建一个dbtool,这个可以支持链接池
首先在/Users/code/gopath/src/study/gorm/db.go添加如下代码

package mysqltools
import (
    "fmt"
    "github.com/jinzhu/gorm"
    _ "github.com/jinzhu/gorm/dialects/mysql"
    "log"
    "sync"
)
/*
* MysqlConnectionPool
* 数据库连接操作库
* 基于gorm封装开发
 */
type MysqlConnectionPool struct {
}
var instance *MysqlConnectionPool
var once sync.Once
var db *gorm.DB
var errDB error
func GetInstance() *MysqlConnectionPool {
    once.Do(func() {
        instance = &MysqlConnectionPool{}
    })
    return instance
}
/*
* @fuc 初始化数据库连接(可在mail()适当位置调用)
*/
func (m *MysqlConnectionPool) InitDataPool() (isSuccess bool) {
    db, errDB = gorm.Open(
        "mysql",
        "root:root@tcp(localhost:3306)/default?charset=utf8&parseTime=True&loc=Local")
    fmt.Println(errDB)
    if errDB != nil {
        log.Fatal(errDB)
        return false
    }
    //关闭数据库，db会被多个goroutine共享，可以不调用
    // defer db.Close()
    return true
}
/*
* @fuc  对外获取数据库连接对象db
*/
func (m *MysqlConnectionPool) GetMysqlDB() (dbCon *gorm.DB) {
    return db
}

再/Users/code/gopath/src/study/test/abc.go 添加如下代码:

package main
import (
    "fmt"
    "log"
    "os"
    "study/gorm"
)
//这个就是对应的mysql表
type Student struct {
    //gorm.Model
    Id        int `gorm:"primary_key;auto_increment"`
    Telephone string
    FirstName string
    LastName  string
}
func main() {
    // init database pool
    isSuccess := mysqltools.GetInstance().InitDataPool()
    if !isSuccess {
        log.Println("init database pool failure...")
        os.Exit(1)
    }
    // do something...
    var users []Student
    db := mysqltools.GetInstance().GetMysqlDB()
    db.Find(&users)
    for k, u := range users {
        fmt.Println(k, u.FirstName)
    }
}

然后在/Users/easub/code/gopath/src/study/test运行go run abc.go:

<nil>
0 LejuRobot
1 LejuRobot
2 LejuRobot

golang如何使用链接池

微信号：腾讯云折扣返现

技术讨论QQ群： 863102326

作者: catherine

搜索

标签