package public import ( "log" util "app.yhyue.com/moapp/jybase/common" . "app.yhyue.com/moapp/jybase/mongodb" "app.yhyue.com/moapp/jybase/mysql" ) var ( DbConf *dbConf Mysql_Main *mysql.Mysql Mysql_From_Jianyu *mysql.Mysql Mysql_From_Jyactivities *mysql.Mysql Mysql_To *mysql.Mysql Mgo MongodbSim ) type dbConf struct { Mongodb struct { Main *mgoConf } Mysql struct { Main *mysqlConf From_jianyu *mysqlConf From_jyactivities *mysqlConf } } type mgoConf struct { Address string Size int DbName string ReplSet string UserName string Password string } type mysqlConf struct { DbName string Address string UserName string PassWord string MaxOpenConns int MaxIdleConns int } func init() { util.ReadConfig("./db.json", &DbConf) if DbConf != nil { if DbConf.Mongodb.Main != nil { log.Println("初始化 mongodb main") Mgo = MongodbSim{ MongodbAddr: DbConf.Mongodb.Main.Address, Size: DbConf.Mongodb.Main.Size, DbName: DbConf.Mongodb.Main.DbName, ReplSet: DbConf.Mongodb.Main.ReplSet, } Mgo.InitPool() } if DbConf.Mysql.Main != nil { log.Println("初始化 mysql main") Mysql_Main = &mysql.Mysql{ Address: DbConf.Mysql.Main.Address, UserName: DbConf.Mysql.Main.UserName, PassWord: DbConf.Mysql.Main.PassWord, DBName: DbConf.Mysql.Main.DbName, MaxOpenConns: DbConf.Mysql.Main.MaxOpenConns, MaxIdleConns: DbConf.Mysql.Main.MaxIdleConns, } Mysql_Main.Init() } if DbConf.Mysql.From_jianyu != nil { log.Println("初始化 mysql from jianyu") Mysql_From_Jianyu = &mysql.Mysql{ Address: DbConf.Mysql.From_jianyu.Address, UserName: DbConf.Mysql.From_jianyu.UserName, PassWord: DbConf.Mysql.From_jianyu.PassWord, DBName: DbConf.Mysql.From_jianyu.DbName, MaxOpenConns: DbConf.Mysql.From_jianyu.MaxOpenConns, MaxIdleConns: DbConf.Mysql.From_jianyu.MaxIdleConns, } Mysql_From_Jianyu.Init() } if DbConf.Mysql.From_jyactivities != nil { log.Println("初始化 mysql from jyactivities") Mysql_From_Jyactivities = &mysql.Mysql{ Address: DbConf.Mysql.From_jyactivities.Address, UserName: DbConf.Mysql.From_jyactivities.UserName, PassWord: DbConf.Mysql.From_jyactivities.PassWord, DBName: DbConf.Mysql.From_jyactivities.DbName, MaxOpenConns: DbConf.Mysql.From_jyactivities.MaxOpenConns, MaxIdleConns: DbConf.Mysql.From_jyactivities.MaxIdleConns, } Mysql_From_Jyactivities.Init() } } }