Commit 61b53bee by zhengqiuyun86

mysql加入连接配置

parent 1f5329a9
...@@ -80,11 +80,13 @@ var Es = EsConf{} ...@@ -80,11 +80,13 @@ var Es = EsConf{}
//Mysql conf //Mysql conf
type MysqlConf struct { type MysqlConf struct {
Host string Host string
Port int Port int
User string User string
Password string Password string
NameSpace string NameSpace string
MaxIdleConns int
MaxOpenConns int
} }
var MySql = MysqlConf{} var MySql = MysqlConf{}
...@@ -111,6 +111,17 @@ func Init() { ...@@ -111,6 +111,17 @@ func Init() {
conf.MySql.User, conf.MySql.Password, conf.MySql.Host, conf.MySql.Port, conf.MySql.NameSpace)), &gorm.Config{ conf.MySql.User, conf.MySql.Password, conf.MySql.Host, conf.MySql.Port, conf.MySql.NameSpace)), &gorm.Config{
Logger: newLogger, Logger: newLogger,
}) })
sqlDB, err := customerDb.DB()
if conf.MySql.MaxIdleConns == 0 {
sqlDB.SetMaxIdleConns(10)
} else {
sqlDB.SetMaxIdleConns(conf.MySql.MaxIdleConns)
}
if conf.MySql.MaxOpenConns == 0 {
sqlDB.SetMaxOpenConns(10)
} else {
sqlDB.SetMaxOpenConns(conf.MySql.MaxOpenConns)
}
if err != nil { if err != nil {
log.Error(fmt.Sprintf("%s connect error:%s", "Mysql server", err.Error())) log.Error(fmt.Sprintf("%s connect error:%s", "Mysql server", err.Error()))
} else { } else {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment