This commit is contained in:
george 2022-04-10 02:07:25 +08:00
parent 0729261b62
commit d6c15a2353

21
gorm.go
View File

@ -209,6 +209,27 @@ func Open(dialector Dialector, opts ...Option) (db *DB, err error) {
return return
} }
func (db *DB) Close() error {
sdb, isSdb := db.ConnPool.(*sql.DB)
stmt, isStmt := db.ConnPool.(*PreparedStmtDB)
switch {
case isSdb:
return sdb.Close()
case isStmt:
db.cacheStore.Delete(preparedStmtDBKey)
for _, v := range stmt.Stmts {
v.Close()
}
sdb, err := stmt.GetDBConn()
if err != nil {
return err
}
return sdb.Close()
}
return nil
}
// Session create new db session // Session create new db session
func (db *DB) Session(config *Session) *DB { func (db *DB) Session(config *Session) *DB {
var ( var (