base-gin/helpers/mysql.go

package helpers

import (
	"base-gin/conf"
	"base-gin/utils/base"
	"base-gin/pkg/gorm"
	"time"
)

var MysqlClient *gorm.DB

func InitMysql() {
	var err error
	MysqlClient, err = base.InitMysqlClient(base.MysqlConf{
		User:            conf.Conf.Mysql.User,
		Password:        conf.Conf.Mysql.PassWord,
		Addr:            conf.Conf.Mysql.Addr,
		DataBase:        conf.Conf.Mysql.DataBase,
		MaxIdleConns:    conf.Conf.Mysql.MaxIdleConns,
		MaxOpenConns:    conf.Conf.Mysql.MaxOpenConns,
		ConnMaxLifeTime: 3600 * time.Second,
		LogMode:         true,
	})
	if err != nil {
		base.PanicfLogger(nil, "mysql connect error: %v", err)
	}
}

// Data source operator
var (
	WarebusinessDataSource *gorm.DB
	AcsDataSource          *gorm.DB
)

// InitReportDataSource Data source operator
func InitReportDataSource() {
	var err error
	WarebusinessDataSource, err = base.InitMysqlClient(base.MysqlConf{
		User:            conf.Conf.Mysql.User,
		Password:        conf.Conf.Mysql.PassWord,
		Addr:            conf.Conf.Mysql.Addr,
		DataBase:        "warebusiness",
		MaxIdleConns:    conf.Conf.Mysql.MaxIdleConns,
		MaxOpenConns:    conf.Conf.Mysql.MaxOpenConns,
		ConnMaxLifeTime: 3600 * time.Second,
		LogMode:         true,
	})
	if err != nil {
		base.PanicfLogger(nil, "WarebusinessDataSource connect error: %v", err)
	}
	AcsDataSource, err = base.InitMysqlClient(base.MysqlConf{
		User:            conf.Conf.Mysql.User,
		Password:        conf.Conf.Mysql.PassWord,
		Addr:            conf.Conf.Mysql.Addr,
		DataBase:        "acs",
		MaxIdleConns:    conf.Conf.Mysql.MaxIdleConns,
		MaxOpenConns:    conf.Conf.Mysql.MaxOpenConns,
		ConnMaxLifeTime: 3600 * time.Second,
		LogMode:         true,
	})
	if err != nil {
		base.PanicfLogger(nil, "AcsDataSource connect error: %v", err)
	}
}