mysql.go

package mysql

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

var (
	systemdb  *sql.DB
	err error
)

// NewPayConn is 连接支付库
func NewPayConn() (*sql.DB, error) {
	if systemdb == nil {
		//systemdb, err = sql.Open("mysql", beego.AppConfig.String("PayURL"))
		systemdb, err = sql.Open("mysql", setting.Conf.DatabaseSetting.SystemDB)
		//systemdb, err = sqlx.Connect("mysql", setting.Conf.DatabaseSetting.SystemDB)
		return systemdb, err
	}
	return systemdb, nil
}

// CloseTx is 有错误则关闭事务、没错则提交事务
func CloseTx(tx *sql.Tx, err error) {
	if err != nil {
		tx.Rollback()
	}
	tx.Commit()
}