|
@@ -83,7 +83,7 @@ func connect() (dbx *sqlx.DB, err error) {
|
|
|
db.DB.SetMaxOpenConns(config.MaxOpenConns)
|
|
|
db.DB.SetMaxIdleConns(config.MaxIdle)
|
|
|
db.DB.SetConnMaxLifetime(config.MaxLifetime)
|
|
|
- db.Ping()
|
|
|
+ err = db.Ping()
|
|
|
}
|
|
|
})
|
|
|
dbx = db
|
|
@@ -113,6 +113,16 @@ func (d *DB) Close() {
|
|
|
//d.conn.Close()
|
|
|
}
|
|
|
|
|
|
+// Ping Ping connect
|
|
|
+func (d *DB) Ping() (err error) {
|
|
|
+ d.conn, err = connect()
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ return d.conn.Ping()
|
|
|
+}
|
|
|
+
|
|
|
// BeginTrans begin trans
|
|
|
func (d *DB) BeginTrans() (err error) {
|
|
|
d.conn, err = connect()
|
|
@@ -335,6 +345,17 @@ func (d *DB) Limit(page, pagesize int) string {
|
|
|
return fmt.Sprintf(" limit %d offset %d", pagesize, (page-1)*pagesize)
|
|
|
}
|
|
|
|
|
|
+// Ping ping connect
|
|
|
+func Ping() (err error) {
|
|
|
+ defaultDB.conn, err = connect()
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ err = defaultDB.Ping()
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
// Select select
|
|
|
func Select(dest interface{}, query string, args ...interface{}) (err error) {
|
|
|
defaultDB.conn, err = connect()
|