package mysql import ( "database/sql" _ "github.com/go-sql-driver/mysql" "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() //} 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() } // 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() //}