userCenter/rpc/internal/db/db.go

package db

import (
	"log"

	"app.yhyue.com/moapp/jybase/mongodb"
	"app.yhyue.com/moapp/jybase/mysql"
	"bp.jydev.jianyu360.cn/BaseService/userCenter/entity"
	"bp.jydev.jianyu360.cn/BaseService/userCenter/rpc/internal/config"
)

func init() {
	entity.Mysql = &mysql.Mysql{
		Address:      config.ConfigJson.Mysql.Address,
		UserName:     config.ConfigJson.Mysql.UserName,
		PassWord:     config.ConfigJson.Mysql.PassWord,
		DBName:       config.ConfigJson.Mysql.DbName,
		MaxOpenConns: config.ConfigJson.Mysql.MaxOpenConns,
		MaxIdleConns: config.ConfigJson.Mysql.MaxIdleConns,
	}
	entity.Mysql.Init()
	entity.BaseMysql = &mysql.Mysql{
		Address:      config.ConfigJson.BaseMysql.Address,
		UserName:     config.ConfigJson.BaseMysql.UserName,
		PassWord:     config.ConfigJson.BaseMysql.PassWord,
		DBName:       config.ConfigJson.BaseMysql.DbName,
		MaxOpenConns: config.ConfigJson.BaseMysql.MaxOpenConns,
		MaxIdleConns: config.ConfigJson.BaseMysql.MaxIdleConns,
	}
	entity.BaseMysql.Init()
	log.Println("初始化 mysql")

	entity.Mgo = mongodb.MongodbSim{
		MongodbAddr: config.ConfigJson.Mongo.Address,
		Size:        config.ConfigJson.Mongo.Size,
		DbName:      config.ConfigJson.Mongo.DbName,
	}
	entity.Mgo.InitPool()
	log.Println("初始化mongodb")
}