data_field_dispose/mgo_tidb_update/config/config.go

package config

import (
	"log"

	qu "app.yhyue.com/moapp/jybase/common"
	"app.yhyue.com/moapp/jybase/mongodb"
	"app.yhyue.com/moapp/jybase/mysql"
)

var (
	Config      *config
	Tidb        *mysql.Mysql
	Mgo_Bidding *mongodb.MongodbSim
)

type config struct {
	Mongodb struct {
		Bidding *mongo `json:"bidding"`
	} `json:"mongodb"`
	Tidb *mysqlConf `json:"tidb"`
}

type mysqlConf struct {
	DbName       string
	Address      string
	UserName     string
	PassWord     string
	MaxOpenConns int
	MaxIdleConns int
}

type mongo struct {
	Address  string
	Size     int
	DbName   string
	ReplSet  string
	UserName string
	Password string
}

//
func init() {

	//程序配置文件
	qu.ReadConfig(&Config)
	InitTidb(Config.Tidb.Address, Config.Tidb.PassWord, Config.Tidb.DbName, Config.Tidb.UserName)
	InitMongoBidding(Config.Mongodb.Bidding.Address, Config.Mongodb.Bidding.DbName, Config.Mongodb.Bidding.UserName, Config.Mongodb.Bidding.Password)

	log.Println("init end")
}

//初始化Tidb
func InitTidb(mysql_addr, mysql_pwd, dbname, username string) {
	Tidb = &mysql.Mysql{
		Address:      mysql_addr,
		UserName:     username,
		PassWord:     mysql_pwd,
		DBName:       dbname,
		MaxOpenConns: 50,
		MaxIdleConns: 20,
	}
	Tidb.Init()
	log.Println("初始化 tidb1")
}

//初始化mongodb
func InitMongoBidding(addr, dbname, username, password string) {
	Mgo_Bidding = &mongodb.MongodbSim{
		MongodbAddr: addr,
		Size:        15,
		DbName:      dbname,
		UserName:    username,
		Password:    password,
	}
	Mgo_Bidding.InitPool()
}