cicv_data_closed_loop/common/config/c_db/c_sqlx_config.go

package c_db

import (
	"cicv-data-closedloop/common/config/c_log"
	_ "github.com/go-sql-driver/mysql"
	"github.com/jmoiron/sqlx"
	"os"
)

var MysqlDb *sqlx.DB

// InitSqlxMysql 初始化mysql连接
// - charset 字符集 utf8、utf8mb4
func InitSqlxMysql(username string, password string, ip string, port string, dbname string, charset string) {
	var err error
	// 连接数据库
	// - parseTime 是否将数据库中的时间类型字段解析为 Go 中的 time.Time 类型。
	// - loc 时间解析时使用的本地位置信息。通常设置为 "Local"。
	MysqlDb, err = sqlx.Open("mysql", username+":"+password+"@tcp("+ip+":"+port+")/"+dbname+"?charset="+charset+"&parseTime=True&loc=Local")
	if err != nil {
		c_log.GlobalLogger.Error("程序退出。mysql连接失败：", err)
		os.Exit(-1)
	}

	// 配置连接池
	MysqlDb.SetMaxOpenConns(10)   // 设置最大打开连接数为 10
	MysqlDb.SetMaxIdleConns(5)    // 设置最大空闲连接数为 5
	MysqlDb.SetConnMaxLifetime(0) // 设置连接的最大生存时间为 0（不限制）
	c_log.GlobalLogger.Info("mysql连接成功。")
}