fix: [#840] DB cache is not reset when fresh orm (#1322)

Author: hwbrzzl

database/driver/gorm.go

@@ -17,14 +17,14 @@ import (
 )
 
 var (
-	connectionToDB     = make(map[string]*gorm.DB)
-	connectionToDBLock = sync.Mutex{}
+	connectionToDB     sync.Map
+	connectionToDBLock sync.Mutex
 	pingWarning        sync.Once
 )
 
 func BuildGorm(config config.Config, logger logger.Interface, pool database.Pool, connection string) (*gorm.DB, error) {
-	if db, ok := connectionToDB[connection]; ok {
-		return db, nil
+	if db, ok := connectionToDB.Load(connection); ok {
+		return db.(*gorm.DB), nil
 	}
 
 	if len(pool.Writers) == 0 {
@@ -34,8 +34,8 @@ func BuildGorm(config config.Config, logger logger.Interface, pool database.Pool
 	connectionToDBLock.Lock()
 	defer connectionToDBLock.Unlock()
 
-	if db, ok := connectionToDB[connection]; ok {
-		return db, nil
+	if db, ok := connectionToDB.Load(connection); ok {
+		return db.(*gorm.DB), nil
 	}
 
 	gormConfig := &gorm.Config{
@@ -82,7 +82,7 @@ func BuildGorm(config config.Config, logger logger.Interface, pool database.Pool
 		db.SetConnMaxIdleTime(connMaxIdleTime * time.Second)
 		db.SetConnMaxLifetime(connMaxLifetime * time.Second)
 
-		connectionToDB[connection] = instance
+		connectionToDB.Store(connection, instance)
 
 		return instance, nil
 	}
@@ -112,7 +112,17 @@ func BuildGorm(config config.Config, logger logger.Interface, pool database.Pool
 		return nil, err
 	}
 
-	connectionToDB[connection] = instance
+	connectionToDB.Store(connection, instance)
 
 	return instance, nil
 }
+
+func ResetConnections() {
+	connectionToDBLock.Lock()
+	defer connectionToDBLock.Unlock()
+
+	connectionToDB.Range(func(key, value any) bool {
+		connectionToDB.Delete(key)
+		return true
+	})
+}

database/orm/orm.go

@@ -12,6 +12,7 @@ import (
 	"github.com/goravel/framework/contracts/database"
 	contractsorm "github.com/goravel/framework/contracts/database/orm"
 	"github.com/goravel/framework/contracts/log"
+	"github.com/goravel/framework/database/driver"
 	"github.com/goravel/framework/database/factory"
 	"github.com/goravel/framework/database/gorm"
 )
@@ -140,8 +141,11 @@ func (r *Orm) SetQuery(query contractsorm.Query) {
 	r.query = query
 }
 
+// TODO: The fresh logic needs to be optimized, it's a bit unclear now.
+// https://github.com/goravel/goravel/issues/848
 func (r *Orm) Fresh() {
 	r.fresh(binding.Orm)
+	driver.ResetConnections()
 }
 
 func (r *Orm) Transaction(txFunc func(tx contractsorm.Query) error) (err error) {