|
@@ -12,15 +12,16 @@ import (
|
|
|
)
|
|
|
|
|
|
var (
|
|
|
- DbConf *dbConf
|
|
|
- Mysql *mysql.Mysql
|
|
|
- BaseMysql *mysql.Mysql
|
|
|
- PushMysql *mysql.Mysql
|
|
|
- BaseService *mysql.Mysql
|
|
|
- MQFW m.MongodbSim
|
|
|
- Mgo_Ent m.MongodbSim
|
|
|
- Mgo_Log m.MongodbSim
|
|
|
- Mgo_Bidding m.MongodbSim
|
|
|
+ DbConf *dbConf
|
|
|
+ Mysql *mysql.Mysql
|
|
|
+ BaseMysql *mysql.Mysql
|
|
|
+ PushMysql *mysql.Mysql
|
|
|
+ BaseService *mysql.Mysql
|
|
|
+ GlobalCommonMysql *mysql.Mysql
|
|
|
+ MQFW m.MongodbSim
|
|
|
+ Mgo_Ent m.MongodbSim
|
|
|
+ Mgo_Log m.MongodbSim
|
|
|
+ Mgo_Bidding m.MongodbSim
|
|
|
//Mgo_Qyfw m.MongodbSim
|
|
|
)
|
|
|
|
|
@@ -42,9 +43,10 @@ type dbConf struct {
|
|
|
Login *redisConf
|
|
|
}
|
|
|
Mysql struct {
|
|
|
- Main *mysqlConf
|
|
|
- Push *mysqlConf
|
|
|
- Base *mysqlConf
|
|
|
+ Main *mysqlConf
|
|
|
+ Push *mysqlConf
|
|
|
+ Base *mysqlConf
|
|
|
+ GlobalCommon *mysqlConf
|
|
|
}
|
|
|
}
|
|
|
type mgoConf struct {
|
|
@@ -177,5 +179,17 @@ func init() {
|
|
|
}
|
|
|
BaseMysql.Init()
|
|
|
}
|
|
|
+ if DbConf.Mysql.GlobalCommon != nil {
|
|
|
+ log.Println("初始化 GlobalCommonMysql")
|
|
|
+ GlobalCommonMysql = &mysql.Mysql{
|
|
|
+ Address: DbConf.Mysql.GlobalCommon.Address,
|
|
|
+ UserName: DbConf.Mysql.GlobalCommon.UserName,
|
|
|
+ PassWord: DbConf.Mysql.GlobalCommon.PassWord,
|
|
|
+ DBName: DbConf.Mysql.GlobalCommon.DbName,
|
|
|
+ MaxOpenConns: DbConf.Mysql.GlobalCommon.MaxOpenConns,
|
|
|
+ MaxIdleConns: DbConf.Mysql.GlobalCommon.MaxIdleConns,
|
|
|
+ }
|
|
|
+ GlobalCommonMysql.Init()
|
|
|
+ }
|
|
|
}
|
|
|
}
|