package db import ( "database/sql" "github.com/gogf/gf/v2/util/gconv" "log" "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() // 初始化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.Printf("mysql配置异常 %v\n", err) log.Fatal(err) } err = gcfg.Instance().MustGet(initDbCtx, "bjgjdsjjys").Scan(&Bjgjdsjjys) if err != nil { log.Printf("bjgjdsjjys配置异常 %v\n", err) log.Fatal(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.Printf("初始化Mysql完成 %+v\n", mysqlConf) //初始化jymysql数据库 }