bileiqi/05.code/backend/db/db_iss.go

package db

import (
	"os"
	"rtzh_elec_temperature/conf"
	"rtzh_elec_temperature/logger"

	"git.rtzhtech.cn/iss/public-lib/config"
	"git.rtzhtech.cn/iss/public-lib/svc"
)

type IssDB struct {
}

func (t *IssDB) Conn(cnf DbConfig) {
	debug := false
	if conf.GlobalConfig["loglevel"] == "5" {
		debug = true
	}
	c := config.Config{
		Debug: config.Debug{Mysql: debug},
		Mysql: config.Mysql{
			Username: cnf.User,
			Password: cnf.Pwd,
			Network:  "tcp",
			Server:   cnf.Host,
			Port:     cnf.Port,
			Database: cnf.Db,
		},
	}
	_, err := svc.NewServiceContext(&c)
	if err != nil {
		logger.Logger.Error("=====连接中台数据库失败=====" + err.Error())
		os.Exit(1)
	} else {
		logger.Logger.Println("=====连接中台数据库成功=====")
	}
}