mysql.go

package db

import (
	"database/sql"

	"client/bulletin/common"

	_ "github.com/go-sql-driver/mysql"
)

// Mysql 全局的MySQL连接池
var Mysql *sql.DB

// InitMysql 根据配置信息连接MySQL并设置参数
func InitMysql(config *common.MysqlConfig) {
	pool, err := sql.Open("mysql", config.Dsn)
	if err != nil {
		panic(err)
	}

	if config.MaxIdle > 0 {
		pool.SetMaxIdleConns(config.MaxIdle)
	}
	if config.MaxOpen > 0 {
		pool.SetMaxOpenConns(config.MaxOpen)
	}

	Mysql = pool
}