tripartite_gateway/common/db/db.go

package db

import (
	"database/sql"
	"log"

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

	"github.com/gogf/gf/v2/util/gconv"

	"app.yhyue.com/moapp/jybase/mysql"
	"github.com/gogf/gf/v2/os/gcfg"
	"github.com/gogf/gf/v2/os/gctx"
)

type Mysql struct {
	Address      string  //数据库地址:端口
	UserName     string  //用户名
	PassWord     string  //密码
	DBName       string  //数据库名
	DB           *sql.DB //数据库连接池对象
	MaxOpenConns int     //用于设置最大打开的连接数，默认值为0表示不限制。
	MaxIdleConns int     //用于设置闲置的连接数。
}

var AddressMap map[string]interface{}
var GateWatMySql *mysql.Mysql
var Bjgjdsjjys map[string]interface{}

// InitDatabases 初始化数据库
func InitDatabases() {
	initDbCtx := gctx.New()
	redis.InitRedis(gcfg.Instance().MustGet(initDbCtx, "databases.redis").String())
	// 初始化mysql数据库
	var mysqlConf Mysql
	err := gcfg.Instance().MustGet(initDbCtx, "databases.mysql").Scan(&mysqlConf)
	AddressMap = gconv.Map(gcfg.Instance().MustGet(initDbCtx, "addressMap", ""))
	if err != nil {
		log.Fatalln("mysql配置异常", err)
	}
	err = gcfg.Instance().MustGet(initDbCtx, "bjgjdsjjys").Scan(&Bjgjdsjjys)
	if err != nil {
		log.Fatalln("bjgjdsjjys配置异常", err)
	}
	GateWatMySql = &mysql.Mysql{
		Address:      mysqlConf.Address,
		UserName:     mysqlConf.UserName,
		PassWord:     mysqlConf.PassWord,
		DBName:       mysqlConf.DBName,
		MaxOpenConns: mysqlConf.MaxOpenConns,
		MaxIdleConns: mysqlConf.MaxIdleConns,
	}
	GateWatMySql.Init()
	log.Println("初始化Mysql完成")
}