userCenter/rpc/internal/db/db.go

package db

import (
	"log"
	"strings"

	"app.yhyue.com/moapp/jybase/mongodb"
	"app.yhyue.com/moapp/jybase/redis"

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

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

	log.Println("初始化 redis")
	redis.InitRedisBySize(strings.Join(entity.ConfigJson.RedisAddrees, ","), 100, 30, 300)

	//初始化 mongodb
	if entity.ConfigJson.Mongo.Main.Address != "" {
		log.Println("初始化 mongo main")
		entity.Mgo = mongodb.MongodbSim{
			MongodbAddr: entity.ConfigJson.Mongo.Main.Address,
			Size:        entity.ConfigJson.Mongo.Main.Size,
			DbName:      entity.ConfigJson.Mongo.Main.DbName,
		}
		entity.Mgo.InitPool()
	}
	//初始化 mongodb
	if entity.ConfigJson.Mongo.Log.Address != "" {
		log.Println("初始化 mongo log")
		entity.MgoLog = mongodb.MongodbSim{
			MongodbAddr: entity.ConfigJson.Mongo.Log.Address,
			Size:        entity.ConfigJson.Mongo.Log.Size,
			DbName:      entity.ConfigJson.Mongo.Log.DbName,
			UserName:    entity.ConfigJson.Mongo.Log.UserName,
			Password:    entity.ConfigJson.Mongo.Log.Password,
		}
		entity.MgoLog.InitPool()
	}
	//用户角色功能初始化
	entity.UserRolePowerInit(entity.ConfigJson.UserRolePower)
	log.Println("初始化 mysql")

}