reafactor: add nil detection when sqldb return (#6373)
* reafactor: add null detection when sqldb return * refactor: Detecting nil in dbConnector.GetDBConn() * refactor: Revert partial code from c1ea73036715018a1bb55cdb8690441044e13a76 * fix: fix if statement
This commit is contained in:
parent
7a76c042e6
commit
5eaccaa624
8
gorm.go
8
gorm.go
@ -181,7 +181,7 @@ func Open(dialector Dialector, opts ...Option) (db *DB, err error) {
|
|||||||
err = config.Dialector.Initialize(db)
|
err = config.Dialector.Initialize(db)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if db, _ := db.DB(); db != nil {
|
if db, err := db.DB(); err == nil {
|
||||||
_ = db.Close()
|
_ = db.Close()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -376,10 +376,12 @@ func (db *DB) DB() (*sql.DB, error) {
|
|||||||
connPool := db.ConnPool
|
connPool := db.ConnPool
|
||||||
|
|
||||||
if dbConnector, ok := connPool.(GetDBConnector); ok && dbConnector != nil {
|
if dbConnector, ok := connPool.(GetDBConnector); ok && dbConnector != nil {
|
||||||
return dbConnector.GetDBConn()
|
if sqldb, err := dbConnector.GetDBConn(); sqldb != nil || err != nil {
|
||||||
|
return sqldb, err
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if sqldb, ok := connPool.(*sql.DB); ok {
|
if sqldb, ok := connPool.(*sql.DB); ok && sqldb != nil {
|
||||||
return sqldb, nil
|
return sqldb, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user