userCenter/rpc/internal/db/db.go

package db

import (
	"log"
	"strings"

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

	"userCenter/entity"
	"userCenter/rpc/internal/config"

	"app.yhyue.com/moapp/jybase/mysql"
)

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,
	}
	log.Println("初始化  mysql")
	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,
	}
	log.Println("初始化 base mysql")
	entity.BaseMysql.Init()

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

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

}