123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125 |
- 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_Main_Bxt *mysql.Mysql
- Mysql_From_Jianyu *mysql.Mysql
- Mysql_From_Jypoints *mysql.Mysql
- Mysql_From_Jyactivities *mysql.Mysql
- Mgo MongodbSim
- )
- type dbConf struct {
- Mongodb struct {
- Main *mgoConf
- }
- Mysql struct {
- Main *mysqlConf
- Main_bxt *mysqlConf
- From_jianyu *mysqlConf
- From_jyactivities *mysqlConf
- From_jypoints *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 jianyu")
- 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.Main_bxt != nil {
- log.Println("初始化 mysql main bxt")
- Mysql_Main_Bxt = &mysql.Mysql{
- Address: DbConf.Mysql.Main_bxt.Address,
- UserName: DbConf.Mysql.Main_bxt.UserName,
- PassWord: DbConf.Mysql.Main_bxt.PassWord,
- DBName: DbConf.Mysql.Main_bxt.DbName,
- MaxOpenConns: DbConf.Mysql.Main_bxt.MaxOpenConns,
- MaxIdleConns: DbConf.Mysql.Main_bxt.MaxIdleConns,
- }
- Mysql_Main_Bxt.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()
- }
- if DbConf.Mysql.From_jypoints != nil {
- log.Println("初始化 mysql from jypoints")
- Mysql_From_Jypoints = &mysql.Mysql{
- Address: DbConf.Mysql.From_jypoints.Address,
- UserName: DbConf.Mysql.From_jypoints.UserName,
- PassWord: DbConf.Mysql.From_jypoints.PassWord,
- DBName: DbConf.Mysql.From_jypoints.DbName,
- MaxOpenConns: DbConf.Mysql.From_jypoints.MaxOpenConns,
- MaxIdleConns: DbConf.Mysql.From_jypoints.MaxIdleConns,
- }
- Mysql_From_Jypoints.Init()
- }
- }
- }
|