mysql.go

package mysql

import (
	_ "github.com/go-sql-driver/mysql"
	"github.com/jmoiron/sqlx"
	"system_pay/setting"
)

var (
	shopDB *sqlx.DB
	//db *sqlx.DB
	// 0 ~ h
	//userDB *sqlx.DB
	// i ~ z
	//secondDB *sqlx.DB
	// PayDB 支付
	//payDB *sqlx.DB
	err   error
)

// NewShopConn is 连接谛宝多多库
func NewShopConn() (*sqlx.DB, error) {
	if shopDB == nil {
		shopDB, err = sqlx.Connect("mysql", setting.Conf.DatabaseSetting.ShopDB)
		return shopDB, err
	}
	//shopDB.SetMaxOpenConns(setting.Conf.DatabaseSetting.MaxOpenConns)
	return shopDB, err
}

// ShopDBClose 关闭MySQL连接
func ShopDBClose() {
	_ = shopDB.Close()
}

// NewAccountConn is 连接医院用户库
//func NewAccountConn() (*sqlx.DB, error) {
//	if db == nil {
//		db, err = sqlx.Connect("mysql", setting.Conf.DatabaseSetting.AccountDB)
//		return db, err
//	}
//	//db.SetMaxOpenConns(setting.Conf.DatabaseSetting.MaxOpenConns)
//	return db, err
//}

// NewUserConn 连接用户存放数据的库
//func NewUserConn(chainCode string) (*sqlx.DB, error) {
//
//	chainCode = strings.ToLower(chainCode)
//	if len(chainCode[:1]) != 1 {
//		return nil, err
//	}
//	word := chainCode[:1]
//	if word > "h" {
//		if secondDB == nil {
//			secondDB, err = sqlx.Connect("mysql", setting.Conf.DatabaseSetting.SecondDB)
//			return secondDB, err
//		}
//		//secondDB.SetMaxOpenConns(setting.Conf.DatabaseSetting.MaxOpenConns)
//		return secondDB, err
//	}
//
//	if userDB == nil {
//		userDB, err = sqlx.Connect("mysql", setting.Conf.DatabaseSetting.UserDB)
//		return userDB, err
//	}
//	//userDB.SetMaxOpenConns(setting.Conf.DatabaseSetting.MaxOpenConns)
//	return userDB, err
//}

// NewPayConn 支付
//func NewPayConn() (*sqlx.DB, error) {
//	if payDB == nil {
//			payDB, err = sqlx.Connect("mysql", setting.Conf.DatabaseSetting.PayDB)
//		return payDB, err
//	}
//	//payDB.SetMaxOpenConns(setting.Conf.DatabaseSetting.MaxOpenConns)
//	return payDB, err
//}

// Close 关闭MySQL连接
//func Close() {
//	_ = db.Close()
//}

// PayDBClose 关闭MySQL连接
//func PayDBClose() {
//	_ = payDB.Close()
//}