forked from mirror/gorm
133 lines
4.9 KiB
Go
133 lines
4.9 KiB
Go
package tests_test
|
|
|
|
import (
|
|
"fmt"
|
|
"regexp"
|
|
"sort"
|
|
"strings"
|
|
"testing"
|
|
|
|
"gorm.io/gorm"
|
|
. "gorm.io/gorm/utils/tests"
|
|
)
|
|
|
|
func TestCount(t *testing.T) {
|
|
var (
|
|
user1 = *GetUser("count-1", Config{})
|
|
user2 = *GetUser("count-2", Config{})
|
|
user3 = *GetUser("count-3", Config{})
|
|
users []User
|
|
count, count1, count2 int64
|
|
)
|
|
|
|
DB.Save(&user1).Save(&user2).Save(&user3)
|
|
|
|
if err := DB.Where("name = ?", user1.Name).Or("name = ?", user3.Name).Find(&users).Count(&count).Error; err != nil {
|
|
t.Errorf(fmt.Sprintf("Count should work, but got err %v", err))
|
|
}
|
|
|
|
if count != int64(len(users)) {
|
|
t.Errorf("Count() method should get correct value, expect: %v, got %v", count, len(users))
|
|
}
|
|
|
|
if err := DB.Model(&User{}).Where("name = ?", user1.Name).Or("name = ?", user3.Name).Count(&count).Find(&users).Error; err != nil {
|
|
t.Errorf(fmt.Sprintf("Count should work, but got err %v", err))
|
|
}
|
|
|
|
if count != int64(len(users)) {
|
|
t.Errorf("Count() method should get correct value, expect: %v, got %v", count, len(users))
|
|
}
|
|
|
|
DB.Model(&User{}).Where("name = ?", user1.Name).Count(&count1).Or("name in ?", []string{user2.Name, user3.Name}).Count(&count2)
|
|
if count1 != 1 || count2 != 3 {
|
|
t.Errorf("multiple count in chain should works")
|
|
}
|
|
|
|
tx := DB.Model(&User{}).Where("name = ?", user1.Name).Session(&gorm.Session{})
|
|
tx.Count(&count1)
|
|
tx.Or("name in ?", []string{user2.Name, user3.Name}).Count(&count2)
|
|
if count1 != 1 || count2 != 3 {
|
|
t.Errorf("count after new session should works")
|
|
}
|
|
|
|
var count3 int64
|
|
if err := DB.Model(&User{}).Where("name in ?", []string{user2.Name, user2.Name, user3.Name}).Group("id").Count(&count3).Error; err != nil {
|
|
t.Errorf("Error happened when count with group, but got %v", err)
|
|
}
|
|
|
|
if count3 != 2 {
|
|
t.Errorf("Should get correct count for count with group, but got %v", count3)
|
|
}
|
|
|
|
dryDB := DB.Session(&gorm.Session{DryRun: true})
|
|
result := dryDB.Table("users").Select("name").Count(&count)
|
|
if !regexp.MustCompile(`SELECT COUNT\(.name.\) FROM .*users.*`).MatchString(result.Statement.SQL.String()) {
|
|
t.Fatalf("Build count with select, but got %v", result.Statement.SQL.String())
|
|
}
|
|
|
|
result = dryDB.Table("users").Distinct("name").Count(&count)
|
|
if !regexp.MustCompile(`SELECT COUNT\(DISTINCT\(.name.\)\) FROM .*users.*`).MatchString(result.Statement.SQL.String()) {
|
|
t.Fatalf("Build count with select, but got %v", result.Statement.SQL.String())
|
|
}
|
|
|
|
var count4 int64
|
|
if err := DB.Table("users").Joins("LEFT JOIN companies on companies.name = users.name").Where("users.name = ?", user1.Name).Count(&count4).Error; err != nil || count4 != 1 {
|
|
t.Errorf("count with join, got error: %v, count %v", err, count4)
|
|
}
|
|
|
|
var count5 int64
|
|
if err := DB.Table("users").Where("users.name = ?", user1.Name).Order("name").Count(&count5).Error; err != nil || count5 != 1 {
|
|
t.Errorf("count with join, got error: %v, count %v", err, count)
|
|
}
|
|
|
|
var count6 int64
|
|
if err := DB.Model(&User{}).Where("name in ?", []string{user1.Name, user2.Name, user3.Name}).Select(
|
|
"(CASE WHEN name=? THEN ? ELSE ? END) as name", "count-1", "main", "other",
|
|
).Count(&count6).Find(&users).Error; err != nil || count6 != 3 {
|
|
t.Fatalf(fmt.Sprintf("Count should work, but got err %v", err))
|
|
}
|
|
|
|
expects := []User{User{Name: "main"}, {Name: "other"}, {Name: "other"}}
|
|
sort.SliceStable(users, func(i, j int) bool {
|
|
return strings.Compare(users[i].Name, users[j].Name) < 0
|
|
})
|
|
|
|
AssertEqual(t, users, expects)
|
|
|
|
var count7 int64
|
|
if err := DB.Model(&User{}).Where("name in ?", []string{user1.Name, user2.Name, user3.Name}).Select(
|
|
"(CASE WHEN name=? THEN ? ELSE ? END) as name, age", "count-1", "main", "other",
|
|
).Count(&count7).Find(&users).Error; err != nil || count7 != 3 {
|
|
t.Fatalf(fmt.Sprintf("Count should work, but got err %v", err))
|
|
}
|
|
|
|
expects = []User{User{Name: "main", Age: 18}, {Name: "other", Age: 18}, {Name: "other", Age: 18}}
|
|
sort.SliceStable(users, func(i, j int) bool {
|
|
return strings.Compare(users[i].Name, users[j].Name) < 0
|
|
})
|
|
|
|
AssertEqual(t, users, expects)
|
|
|
|
var count8 int64
|
|
if err := DB.Model(&User{}).Where("name in ?", []string{user1.Name, user2.Name, user3.Name}).Select(
|
|
"(CASE WHEN age=18 THEN 1 ELSE 2 END) as age", "name",
|
|
).Count(&count8).Find(&users).Error; err != nil || count8 != 3 {
|
|
t.Fatalf(fmt.Sprintf("Count should work, but got err %v", err))
|
|
}
|
|
|
|
expects = []User{User{Name: "count-1", Age: 1}, {Name: "count-2", Age: 1}, {Name: "count-3", Age: 1}}
|
|
sort.SliceStable(users, func(i, j int) bool {
|
|
return strings.Compare(users[i].Name, users[j].Name) < 0
|
|
})
|
|
|
|
AssertEqual(t, users, expects)
|
|
|
|
var count9 int64
|
|
if err := DB.Debug().Scopes(func(tx *gorm.DB) *gorm.DB {
|
|
fmt.Println("kdkdkdkdk")
|
|
return tx.Table("users")
|
|
}).Where("name in ?", []string{user1.Name, user2.Name, user3.Name}).Count(&count9).Find(&users).Error; err != nil || count9 != 3 {
|
|
t.Fatalf(fmt.Sprintf("Count should work, but got err %v", err))
|
|
}
|
|
}
|