fix(database/gdb): Fixed the bug that the forced cache policy was invalidated

contrib/drivers/mariadb/mariadb_unit_model_test.go

@@ -421,7 +421,7 @@ func Test_Model_All(t *testing.T) {
 	})
 	gtest.C(t, func(t *gtest.T) {
 		result, err := db.Model(table).Where("id<0").All()
-		t.Assert(result, nil)
+		t.Assert(len(result), 0)
 		t.AssertNil(err)
 	})
 }

contrib/drivers/mssql/mssql_z_unit_model_test.go

@@ -457,7 +457,7 @@ func Test_Model_All(t *testing.T) {
 	})
 	gtest.C(t, func(t *gtest.T) {
 		result, err := db.Model(table).Where("id<0").All()
-		t.Assert(result, nil)
+		t.Assert(len(result), 0)
 		t.AssertNil(err)
 	})
 }

contrib/drivers/mysql/mysql_z_unit_model_test.go

@@ -575,7 +575,7 @@ func Test_Model_All(t *testing.T) {
 	})
 	gtest.C(t, func(t *gtest.T) {
 		result, err := db.Model(table).Where("id<0").All()
-		t.Assert(result, nil)
+		t.Assert(len(result), 0)
 		t.AssertNil(err)
 	})
 }

contrib/drivers/oracle/oracle_z_unit_model_test.go

@@ -420,7 +420,7 @@ func Test_Model_All(t *testing.T) {
 	})
 	gtest.C(t, func(t *gtest.T) {
 		result, err := db.Model(table).Where("id<0").All()
-		t.Assert(result, nil)
+		t.Assert(len(result), 0)
 		t.AssertNil(err)
 	})
 }

contrib/drivers/sqlite/sqlite_z_unit_model_test.go

@@ -612,7 +612,7 @@ func Test_Model_All(t *testing.T) {
 	})
 	gtest.C(t, func(t *gtest.T) {
 		result, err := db.Model(table).Where("id<0").All()
-		t.Assert(result, nil)
+		t.Assert(len(result), 0)
 		t.AssertNil(err)
 	})
 }

contrib/drivers/sqlitecgo/sqlitecgo_z_unit_model_test.go

@@ -572,7 +572,7 @@ func Test_Model_All(t *testing.T) {
 	})
 	gtest.C(t, func(t *gtest.T) {
 		result, err := db.Model(table).Where("id<0").All()
-		t.Assert(result, nil)
+		t.Assert(len(result), 0)
 		t.AssertNil(err)
 	})
 }

database/gdb/gdb_model_cache.go

@@ -109,22 +109,31 @@ func (m *Model) saveSelectResultToCache(
 	if len(result) > 0 {
 		var core = m.db.GetCore()
 		switch selectType {
-		case SelectTypeValue, SelectTypeArray, SelectTypeCount:
+		case SelectTypeValue, SelectTypeArray:
 			if internalData := core.getInternalColumnFromCtx(ctx); internalData != nil {
 				if result[0][internalData.FirstResultColumn].IsEmpty() {
 					result = nil
 				}
 			}
+		case SelectTypeCount:
+			if internalData := core.getInternalColumnFromCtx(ctx); internalData != nil {
+				if !m.cacheOption.Force && result[0][internalData.FirstResultColumn].IsEmpty() {
+					result = nil
+				}
+			}
 		default:
 		}
 	}
-
+	if result == nil && !m.cacheOption.Force {
+		return
+	}
 	// In case of Cache Penetration.
 	if result != nil && result.IsEmpty() {
 		if m.cacheOption.Force {
 			result = Result{}
 		} else {
 			result = nil
+			return
 		}
 	}
 	var (

database/gdb/gdb_model_select.go

@@ -692,7 +692,9 @@ func (m *Model) doGetAllBySql(
 	if result, err = in.Next(ctx); err != nil {
 		return
 	}
-
+	if result == nil {
+		result = Result{}
+	}
 	err = m.saveSelectResultToCache(ctx, selectType, result, sql, args...)
 	return
 }