buryingPoint/online_datasync/db/db.go

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_Jypoints     *mysql.Mysql
	Mysql_From_Jyactivities *mysql.Mysql
	Mgo                     MongodbSim
)

type dbConf struct {
	Mongodb struct {
		Main *mgoConf
	}
	Mysql struct {
		Main              *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")
			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()
		}
		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()
		}
	}
}