Lunny Xiao
cc33b2d305
Fix test Fix test Add new Quoter object to handle quote Fix join table name quote bug Move reserve words related files into dialects sub package (#1544) Move reserve words related files into dialects sub package Reviewed-on: xorm/xorm#1544 Fix mssql quote (#1535) Fix some quotes Fix mssql quote Merge core package back into the main repository and split into serval sub packages. (#1543) Fix test Improve fmt update go.mod Move core as a sub package Reviewed-on: xorm/xorm#1543 Fix int time deleted bug (#1539) Fix panic Fix test Fix test for mssql time Add sql type check on deleted cond Fix int time deleted bug Reviewed-on: xorm/xorm#1539 Add test for mysql8.0 (#1538) Fix pk order on test Add test for mysql8.0 Reviewed-on: xorm/xorm#1538 Add test for join limit (#1536) Add test for join limit Reviewed-on: xorm/xorm#1536 Improve drone (#1537) Fix drone Improve drone * use traditional positional parameters on inser... Reviewed-on: xorm/xorm#1537 Fix slice of struct not cache bug (#895) Fix failure caused by nil bean Judge both type of struct and pointer in case of out-of-range Fix issue #894 Add test for join subquery (#1528) Fix test Fix subquery with schema Add test for join subquery Add makefile (#1531) Fix drone Fix ci Add deps Improve drone Fix envs Add makefile Reviewed-on: xorm/xorm#1531 Add password for postgres drone image (#1530) Add password for postgres drone image Reviewed-on: xorm/xorm#1530 format time when sqlTypeName is core.Varchar (#1026) fix time test add test for time format sign codes according to contributing rules. format time when sqlTypeName is core.Varchar. Same with core.DateTime or core.TimeStamp Add test for second insert error (#1527) Add test for second insert error Reviewed-on: xorm/xorm#1527 Add tests for table name (#1517) add tests for table name Fix test (#1526) Fix test Reviewed-on: xorm/xorm#1526 Fix test (#1526) Fix test Reviewed-on: xorm/xorm#1526 Fix wrong warning log on autoincrement column when sync table (#1525) improve doc Fix wrong warning log on autoincrement column when sync table Reviewed-on: xorm/xorm#1525 Fixed Join strings on func Exist (#1520) fix test fixed Join strings on func Exist Co-authored-by: Tomofumi Kusana <tkusana@morisawa.co.jp> Reviewed-on: xorm/xorm#1520 For nullable columns, store nil values as NULL (#531) Merge branch 'master' into jcsalem/fix/nil_ptr_is_nullable fix bug when buffersize with iterate (#941) Merge branch 'master' into lunny/fix_buffer_iterate Exclude schema from index name (#1505) Merge branch 'master' into fix-schema-idx SetExpr support more go types (#1499) Improve tests SetExpr support more go types fix vet fix drone lint remove go1.10 test on drone Reviewed-on: xorm/xorm#1499 fix vet fix drone lint remove go1.10 test on drone Exclude schema from the index name Co-authored-by: Guillermo Prandi <guillep2k@users.noreply.github.com> Co-authored-by: Lunny Xiao <xiaolunwen@gmail.com> Reviewed-on: xorm/xorm#1505 fix test fix bug fix bug when buffersize with iterate SetExpr support more go types (#1499) Improve tests SetExpr support more go types fix vet fix drone lint remove go1.10 test on drone Reviewed-on: xorm/xorm#1499 fix vet fix drone lint remove go1.10 test on drone Fix update with Alias (#1455) Co-authored-by: Guillermo Prandi <guillep2k@noreply.gitea.io> Reviewed-on: xorm/xorm#941 fix update map with version (#1448) fix test fix update map with version SetExpr support more go types (#1499) Improve tests SetExpr support more go types fix vet fix drone lint remove go1.10 test on drone Reviewed-on: xorm/xorm#1499 fix vet fix drone lint remove go1.10 test on drone Fix update with Alias (#1455) Reviewed-on: xorm/xorm#1448 Exclude schema from index name (#1505) Merge branch 'master' into fix-schema-idx SetExpr support more go types (#1499) Improve tests SetExpr support more go types fix vet fix drone lint remove go1.10 test on drone Reviewed-on: xorm/xorm#1499 fix vet fix drone lint remove go1.10 test on drone Exclude schema from the index name Co-authored-by: Guillermo Prandi <guillep2k@users.noreply.github.com> Co-authored-by: Lunny Xiao <xiaolunwen@gmail.com> Reviewed-on: xorm/xorm#1505 SetExpr support more go types (#1499) Improve tests SetExpr support more go types fix vet fix drone lint remove go1.10 test on drone Reviewed-on: xorm/xorm#1499 For nullable columns, store nil values as NULL fix vet fix drone lint remove go1.10 test on drone Fix update with Alias (#1455) Improve c... Reviewed-on: xorm/xorm#1534
835 lines
19 KiB
Go
835 lines
19 KiB
Go
// Copyright 2017 The Xorm Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package xorm
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"xorm.io/xorm/names"
|
|
)
|
|
|
|
func TestJoinLimit(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
|
|
type Salary struct {
|
|
Id int64
|
|
Lid int64
|
|
}
|
|
|
|
type CheckList struct {
|
|
Id int64
|
|
Eid int64
|
|
}
|
|
|
|
type Empsetting struct {
|
|
Id int64
|
|
Name string
|
|
}
|
|
|
|
assert.NoError(t, testEngine.Sync2(new(Salary), new(CheckList), new(Empsetting)))
|
|
|
|
var emp Empsetting
|
|
cnt, err := testEngine.Insert(&emp)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
var checklist = CheckList{
|
|
Eid: emp.Id,
|
|
}
|
|
cnt, err = testEngine.Insert(&checklist)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
var salary = Salary{
|
|
Lid: checklist.Id,
|
|
}
|
|
cnt, err = testEngine.Insert(&salary)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
var salaries []Salary
|
|
err = testEngine.Table("salary").
|
|
Join("INNER", "check_list", "check_list.id = salary.lid").
|
|
Join("LEFT", "empsetting", "empsetting.id = check_list.eid").
|
|
Limit(10, 0).
|
|
Find(&salaries)
|
|
assert.NoError(t, err)
|
|
}
|
|
|
|
func assertSync(t *testing.T, beans ...interface{}) {
|
|
for _, bean := range beans {
|
|
t.Run(testEngine.TableName(bean, true), func(t *testing.T) {
|
|
assert.NoError(t, testEngine.DropTables(bean))
|
|
assert.NoError(t, testEngine.Sync2(bean))
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestWhere(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
|
|
assertSync(t, new(Userinfo))
|
|
|
|
users := make([]Userinfo, 0)
|
|
err := testEngine.Where("id > ?", 2).Find(&users)
|
|
if err != nil {
|
|
t.Error(err)
|
|
panic(err)
|
|
}
|
|
fmt.Println(users)
|
|
|
|
err = testEngine.Where("id > ?", 2).And("id < ?", 10).Find(&users)
|
|
if err != nil {
|
|
t.Error(err)
|
|
panic(err)
|
|
}
|
|
fmt.Println(users)
|
|
}
|
|
|
|
func TestFind(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
users := make([]Userinfo, 0)
|
|
|
|
err := testEngine.Find(&users)
|
|
assert.NoError(t, err)
|
|
for _, user := range users {
|
|
fmt.Println(user)
|
|
}
|
|
|
|
users2 := make([]Userinfo, 0)
|
|
var tbName = testEngine.Quote(testEngine.TableName(new(Userinfo), true))
|
|
err = testEngine.SQL("select * from " + tbName).Find(&users2)
|
|
assert.NoError(t, err)
|
|
}
|
|
|
|
func TestFind2(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
users := make([]*Userinfo, 0)
|
|
|
|
assertSync(t, new(Userinfo))
|
|
|
|
err := testEngine.Find(&users)
|
|
assert.NoError(t, err)
|
|
|
|
for _, user := range users {
|
|
fmt.Println(user)
|
|
}
|
|
}
|
|
|
|
type Team struct {
|
|
Id int64
|
|
}
|
|
|
|
type TeamUser struct {
|
|
OrgId int64
|
|
Uid int64
|
|
TeamId int64
|
|
}
|
|
|
|
func (TeamUser) TableName() string {
|
|
return "team_user"
|
|
}
|
|
|
|
func TestFind3(t *testing.T) {
|
|
var teamUser = new(TeamUser)
|
|
assert.NoError(t, prepareEngine())
|
|
err := testEngine.Sync2(new(Team), teamUser)
|
|
assert.NoError(t, err)
|
|
|
|
var teams []Team
|
|
err = testEngine.Cols("`team`.id").
|
|
Where("`team_user`.org_id=?", 1).
|
|
And("`team_user`.uid=?", 2).
|
|
Join("INNER", "`team_user`", "`team_user`.team_id=`team`.id").
|
|
Find(&teams)
|
|
assert.NoError(t, err)
|
|
|
|
teams = make([]Team, 0)
|
|
err = testEngine.Cols("`team`.id").
|
|
Where("`team_user`.org_id=?", 1).
|
|
And("`team_user`.uid=?", 2).
|
|
Join("INNER", teamUser, "`team_user`.team_id=`team`.id").
|
|
Find(&teams)
|
|
assert.NoError(t, err)
|
|
|
|
teams = make([]Team, 0)
|
|
err = testEngine.Cols("`team`.id").
|
|
Where("`team_user`.org_id=?", 1).
|
|
And("`team_user`.uid=?", 2).
|
|
Join("INNER", []interface{}{teamUser}, "`team_user`.team_id=`team`.id").
|
|
Find(&teams)
|
|
assert.NoError(t, err)
|
|
|
|
teams = make([]Team, 0)
|
|
err = testEngine.Cols("`team`.id").
|
|
Where("`tu`.org_id=?", 1).
|
|
And("`tu`.uid=?", 2).
|
|
Join("INNER", []string{"team_user", "tu"}, "`tu`.team_id=`team`.id").
|
|
Find(&teams)
|
|
assert.NoError(t, err)
|
|
|
|
teams = make([]Team, 0)
|
|
err = testEngine.Cols("`team`.id").
|
|
Where("`tu`.org_id=?", 1).
|
|
And("`tu`.uid=?", 2).
|
|
Join("INNER", []interface{}{"team_user", "tu"}, "`tu`.team_id=`team`.id").
|
|
Find(&teams)
|
|
assert.NoError(t, err)
|
|
|
|
teams = make([]Team, 0)
|
|
err = testEngine.Cols("`team`.id").
|
|
Where("`tu`.org_id=?", 1).
|
|
And("`tu`.uid=?", 2).
|
|
Join("INNER", []interface{}{teamUser, "tu"}, "`tu`.team_id=`team`.id").
|
|
Find(&teams)
|
|
assert.NoError(t, err)
|
|
}
|
|
|
|
func TestFindMap(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
users := make(map[int64]Userinfo)
|
|
err := testEngine.Find(&users)
|
|
if err != nil {
|
|
t.Error(err)
|
|
panic(err)
|
|
}
|
|
for _, user := range users {
|
|
fmt.Println(user)
|
|
}
|
|
}
|
|
|
|
func TestFindMap2(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
users := make(map[int64]*Userinfo)
|
|
err := testEngine.Find(&users)
|
|
if err != nil {
|
|
t.Error(err)
|
|
panic(err)
|
|
}
|
|
for id, user := range users {
|
|
fmt.Println(id, user)
|
|
}
|
|
}
|
|
|
|
func TestDistinct(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
_, err := testEngine.Insert(&Userinfo{
|
|
Username: "lunny",
|
|
})
|
|
assert.NoError(t, err)
|
|
|
|
users := make([]Userinfo, 0)
|
|
departname := testEngine.GetTableMapper().Obj2Table("Departname")
|
|
err = testEngine.Distinct(departname).Find(&users)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, len(users))
|
|
|
|
fmt.Println(users)
|
|
|
|
type Depart struct {
|
|
Departname string
|
|
}
|
|
|
|
users2 := make([]Depart, 0)
|
|
err = testEngine.Distinct(departname).Table(new(Userinfo)).Find(&users2)
|
|
assert.NoError(t, err)
|
|
if len(users2) != 1 {
|
|
fmt.Println(len(users2))
|
|
t.Error(err)
|
|
panic(errors.New("should be one record"))
|
|
}
|
|
fmt.Println(users2)
|
|
}
|
|
|
|
func TestOrder(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
users := make([]Userinfo, 0)
|
|
err := testEngine.OrderBy("id desc").Find(&users)
|
|
assert.NoError(t, err)
|
|
fmt.Println(users)
|
|
|
|
users2 := make([]Userinfo, 0)
|
|
err = testEngine.Asc("id", "username").Desc("height").Find(&users2)
|
|
assert.NoError(t, err)
|
|
fmt.Println(users2)
|
|
}
|
|
|
|
func TestGroupBy(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
users := make([]Userinfo, 0)
|
|
err := testEngine.GroupBy("id, username").Find(&users)
|
|
assert.NoError(t, err)
|
|
}
|
|
|
|
func TestHaving(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
users := make([]Userinfo, 0)
|
|
err := testEngine.GroupBy("username").Having("username='xlw'").Find(&users)
|
|
assert.NoError(t, err)
|
|
fmt.Println(users)
|
|
|
|
/*users = make([]Userinfo, 0)
|
|
err = testEngine.Cols("id, username").GroupBy("username").Having("username='xlw'").Find(&users)
|
|
if err != nil {
|
|
t.Error(err)
|
|
panic(err)
|
|
}
|
|
fmt.Println(users)*/
|
|
}
|
|
|
|
func TestOrderSameMapper(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
testEngine.UnMapType(rValue(new(Userinfo)).Type())
|
|
|
|
mapper := testEngine.GetTableMapper()
|
|
testEngine.SetMapper(names.SameMapper{})
|
|
|
|
defer func() {
|
|
testEngine.UnMapType(rValue(new(Userinfo)).Type())
|
|
testEngine.SetMapper(mapper)
|
|
}()
|
|
|
|
assertSync(t, new(Userinfo))
|
|
|
|
users := make([]Userinfo, 0)
|
|
err := testEngine.OrderBy("id desc").Find(&users)
|
|
assert.NoError(t, err)
|
|
fmt.Println(users)
|
|
|
|
users2 := make([]Userinfo, 0)
|
|
err = testEngine.Asc("id", "Username").Desc("Height").Find(&users2)
|
|
assert.NoError(t, err)
|
|
fmt.Println(users2)
|
|
}
|
|
|
|
func TestHavingSameMapper(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
testEngine.UnMapType(rValue(new(Userinfo)).Type())
|
|
|
|
mapper := testEngine.GetTableMapper()
|
|
testEngine.SetMapper(names.SameMapper{})
|
|
defer func() {
|
|
testEngine.UnMapType(rValue(new(Userinfo)).Type())
|
|
testEngine.SetMapper(mapper)
|
|
}()
|
|
assertSync(t, new(Userinfo))
|
|
|
|
users := make([]Userinfo, 0)
|
|
err := testEngine.GroupBy("`Username`").Having("`Username`='xlw'").Find(&users)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
fmt.Println(users)
|
|
}
|
|
|
|
func TestFindInts(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
userinfo := testEngine.GetTableMapper().Obj2Table("Userinfo")
|
|
var idsInt64 []int64
|
|
err := testEngine.Table(userinfo).Cols("id").Desc("id").Find(&idsInt64)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
fmt.Println(idsInt64)
|
|
|
|
var idsInt32 []int32
|
|
err = testEngine.Table(userinfo).Cols("id").Desc("id").Find(&idsInt32)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
fmt.Println(idsInt32)
|
|
|
|
var idsInt []int
|
|
err = testEngine.Table(userinfo).Cols("id").Desc("id").Find(&idsInt)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
fmt.Println(idsInt)
|
|
|
|
var idsUint []uint
|
|
err = testEngine.Table(userinfo).Cols("id").Desc("id").Find(&idsUint)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
fmt.Println(idsUint)
|
|
|
|
type MyInt int
|
|
var idsMyInt []MyInt
|
|
err = testEngine.Table(userinfo).Cols("id").Desc("id").Find(&idsMyInt)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
fmt.Println(idsMyInt)
|
|
}
|
|
|
|
func TestFindStrings(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
userinfo := testEngine.GetTableMapper().Obj2Table("Userinfo")
|
|
username := testEngine.GetColumnMapper().Obj2Table("Username")
|
|
var idsString []string
|
|
err := testEngine.Table(userinfo).Cols(username).Desc("id").Find(&idsString)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
fmt.Println(idsString)
|
|
}
|
|
|
|
func TestFindMyString(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
userinfo := testEngine.GetTableMapper().Obj2Table("Userinfo")
|
|
username := testEngine.GetColumnMapper().Obj2Table("Username")
|
|
|
|
var idsMyString []MyString
|
|
err := testEngine.Table(userinfo).Cols(username).Desc("id").Find(&idsMyString)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
fmt.Println(idsMyString)
|
|
}
|
|
|
|
func TestFindInterface(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
userinfo := testEngine.GetTableMapper().Obj2Table("Userinfo")
|
|
username := testEngine.GetColumnMapper().Obj2Table("Username")
|
|
var idsInterface []interface{}
|
|
err := testEngine.Table(userinfo).Cols(username).Desc("id").Find(&idsInterface)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
fmt.Println(idsInterface)
|
|
}
|
|
|
|
func TestFindSliceBytes(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
userinfo := testEngine.GetTableMapper().Obj2Table("Userinfo")
|
|
var ids [][][]byte
|
|
err := testEngine.Table(userinfo).Desc("id").Find(&ids)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
for _, record := range ids {
|
|
fmt.Println(record)
|
|
}
|
|
}
|
|
|
|
func TestFindSlicePtrString(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
userinfo := testEngine.GetTableMapper().Obj2Table("Userinfo")
|
|
var ids [][]*string
|
|
err := testEngine.Table(userinfo).Desc("id").Find(&ids)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
for _, record := range ids {
|
|
fmt.Println(record)
|
|
}
|
|
}
|
|
|
|
func TestFindMapBytes(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
userinfo := testEngine.GetTableMapper().Obj2Table("Userinfo")
|
|
var ids []map[string][]byte
|
|
err := testEngine.Table(userinfo).Desc("id").Find(&ids)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
for _, record := range ids {
|
|
fmt.Println(record)
|
|
}
|
|
}
|
|
|
|
func TestFindMapPtrString(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Userinfo))
|
|
|
|
userinfo := testEngine.GetTableMapper().Obj2Table("Userinfo")
|
|
var ids []map[string]*string
|
|
err := testEngine.Table(userinfo).Desc("id").Find(&ids)
|
|
assert.NoError(t, err)
|
|
for _, record := range ids {
|
|
fmt.Println(record)
|
|
}
|
|
}
|
|
|
|
func TestFindBit(t *testing.T) {
|
|
type FindBitStruct struct {
|
|
Id int64
|
|
Msg bool `xorm:"bit"`
|
|
}
|
|
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(FindBitStruct))
|
|
|
|
cnt, err := testEngine.Insert([]FindBitStruct{
|
|
{
|
|
Msg: false,
|
|
},
|
|
{
|
|
Msg: true,
|
|
},
|
|
})
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 2, cnt)
|
|
|
|
var results = make([]FindBitStruct, 0, 2)
|
|
err = testEngine.Find(&results)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 2, len(results))
|
|
}
|
|
|
|
func TestFindMark(t *testing.T) {
|
|
|
|
type Mark struct {
|
|
Mark1 string `xorm:"VARCHAR(1)"`
|
|
Mark2 string `xorm:"VARCHAR(1)"`
|
|
MarkA string `xorm:"VARCHAR(1)"`
|
|
}
|
|
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(Mark))
|
|
|
|
cnt, err := testEngine.Insert([]Mark{
|
|
{
|
|
Mark1: "1",
|
|
Mark2: "2",
|
|
MarkA: "A",
|
|
},
|
|
{
|
|
Mark1: "1",
|
|
Mark2: "2",
|
|
MarkA: "A",
|
|
},
|
|
})
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 2, cnt)
|
|
|
|
var results = make([]Mark, 0, 2)
|
|
err = testEngine.Find(&results)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 2, len(results))
|
|
}
|
|
|
|
func TestFindAndCountOneFunc(t *testing.T) {
|
|
type FindAndCountStruct struct {
|
|
Id int64
|
|
Content string
|
|
Msg bool `xorm:"bit"`
|
|
}
|
|
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(FindAndCountStruct))
|
|
|
|
cnt, err := testEngine.Insert([]FindAndCountStruct{
|
|
{
|
|
Content: "111",
|
|
Msg: false,
|
|
},
|
|
{
|
|
Content: "222",
|
|
Msg: true,
|
|
},
|
|
})
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 2, cnt)
|
|
|
|
var results = make([]FindAndCountStruct, 0, 2)
|
|
cnt, err = testEngine.FindAndCount(&results)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 2, len(results))
|
|
assert.EqualValues(t, 2, cnt)
|
|
|
|
results = make([]FindAndCountStruct, 0, 1)
|
|
cnt, err = testEngine.Where("msg = ?", true).FindAndCount(&results)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, len(results))
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
results = make([]FindAndCountStruct, 0, 1)
|
|
cnt, err = testEngine.Where("msg = ?", true).Limit(1).FindAndCount(&results)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, len(results))
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
results = make([]FindAndCountStruct, 0, 1)
|
|
cnt, err = testEngine.Where("msg = ?", true).Select("id, content, msg").
|
|
Limit(1).FindAndCount(&results)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, len(results))
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
results = make([]FindAndCountStruct, 0, 1)
|
|
cnt, err = testEngine.Where("msg = ?", true).Desc("id").
|
|
Limit(1).FindAndCount(&results)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, len(results))
|
|
assert.EqualValues(t, 1, cnt)
|
|
}
|
|
|
|
type FindMapDevice struct {
|
|
Deviceid string `xorm:"pk"`
|
|
Status int
|
|
}
|
|
|
|
func (device *FindMapDevice) TableName() string {
|
|
return "devices"
|
|
}
|
|
|
|
func TestFindMapStringId(t *testing.T) {
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(FindMapDevice))
|
|
|
|
cnt, err := testEngine.Insert(&FindMapDevice{
|
|
Deviceid: "1",
|
|
Status: 1,
|
|
})
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
deviceIDs := []string{"1"}
|
|
|
|
deviceMaps := make(map[string]*FindMapDevice, len(deviceIDs))
|
|
err = testEngine.
|
|
Where("status = ?", 1).
|
|
In("deviceid", deviceIDs).
|
|
Find(&deviceMaps)
|
|
assert.NoError(t, err)
|
|
|
|
deviceMaps2 := make(map[string]FindMapDevice, len(deviceIDs))
|
|
err = testEngine.
|
|
Where("status = ?", 1).
|
|
In("deviceid", deviceIDs).
|
|
Find(&deviceMaps2)
|
|
assert.NoError(t, err)
|
|
|
|
devices := make([]*FindMapDevice, 0, len(deviceIDs))
|
|
err = testEngine.Find(&devices)
|
|
assert.NoError(t, err)
|
|
|
|
devices2 := make([]FindMapDevice, 0, len(deviceIDs))
|
|
err = testEngine.Find(&devices2)
|
|
assert.NoError(t, err)
|
|
|
|
var device FindMapDevice
|
|
has, err := testEngine.Get(&device)
|
|
assert.NoError(t, err)
|
|
assert.True(t, has)
|
|
|
|
has, err = testEngine.Exist(&FindMapDevice{})
|
|
assert.NoError(t, err)
|
|
assert.True(t, has)
|
|
|
|
cnt, err = testEngine.Count(new(FindMapDevice))
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
cnt, err = testEngine.ID("1").Update(&FindMapDevice{
|
|
Status: 2,
|
|
})
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
sum, err := testEngine.SumInt(new(FindMapDevice), "status")
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 2, sum)
|
|
|
|
cnt, err = testEngine.ID("1").Delete(new(FindMapDevice))
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
}
|
|
|
|
func TestFindExtends(t *testing.T) {
|
|
type FindExtendsB struct {
|
|
ID int64
|
|
}
|
|
|
|
type FindExtendsA struct {
|
|
FindExtendsB `xorm:"extends"`
|
|
}
|
|
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(FindExtendsA))
|
|
|
|
cnt, err := testEngine.Insert(&FindExtendsA{
|
|
FindExtendsB: FindExtendsB{},
|
|
})
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
cnt, err = testEngine.Insert(&FindExtendsA{
|
|
FindExtendsB: FindExtendsB{},
|
|
})
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
var results []FindExtendsA
|
|
err = testEngine.Find(&results)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 2, len(results))
|
|
}
|
|
|
|
func TestFindExtends3(t *testing.T) {
|
|
type FindExtendsCC struct {
|
|
ID int64
|
|
Name string
|
|
}
|
|
|
|
type FindExtendsBB struct {
|
|
FindExtendsCC `xorm:"extends"`
|
|
}
|
|
|
|
type FindExtendsAA struct {
|
|
FindExtendsBB `xorm:"extends"`
|
|
}
|
|
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(FindExtendsAA))
|
|
|
|
cnt, err := testEngine.Insert(&FindExtendsAA{
|
|
FindExtendsBB: FindExtendsBB{
|
|
FindExtendsCC: FindExtendsCC{
|
|
Name: "cc1",
|
|
},
|
|
},
|
|
})
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
cnt, err = testEngine.Insert(&FindExtendsAA{
|
|
FindExtendsBB: FindExtendsBB{
|
|
FindExtendsCC: FindExtendsCC{
|
|
Name: "cc2",
|
|
},
|
|
},
|
|
})
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
var results []FindExtendsAA
|
|
err = testEngine.Find(&results)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 2, len(results))
|
|
}
|
|
|
|
func TestFindCacheLimit(t *testing.T) {
|
|
type InviteCode struct {
|
|
ID int64 `xorm:"pk autoincr 'id'"`
|
|
Code string `xorm:"unique"`
|
|
Created time.Time `xorm:"created"`
|
|
}
|
|
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(InviteCode))
|
|
|
|
cnt, err := testEngine.Insert(&InviteCode{
|
|
Code: "123456",
|
|
})
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
cnt, err = testEngine.Insert(&InviteCode{
|
|
Code: "234567",
|
|
})
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, cnt)
|
|
|
|
for i := 0; i < 8; i++ {
|
|
var beans []InviteCode
|
|
err = testEngine.Limit(1, 0).Find(&beans)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, len(beans))
|
|
}
|
|
|
|
for i := 0; i < 8; i++ {
|
|
var beans2 []*InviteCode
|
|
err = testEngine.Limit(1, 0).Find(&beans2)
|
|
assert.NoError(t, err)
|
|
assert.EqualValues(t, 1, len(beans2))
|
|
}
|
|
}
|
|
|
|
func TestFindJoin(t *testing.T) {
|
|
type SceneItem struct {
|
|
Type int
|
|
DeviceId int64
|
|
}
|
|
|
|
type DeviceUserPrivrels struct {
|
|
UserId int64
|
|
DeviceId int64
|
|
}
|
|
|
|
type Order struct {
|
|
Id int64
|
|
}
|
|
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(SceneItem), new(DeviceUserPrivrels), new(Order))
|
|
|
|
var scenes []SceneItem
|
|
err := testEngine.Join("LEFT OUTER", "device_user_privrels", "device_user_privrels.device_id=scene_item.device_id").
|
|
Where("scene_item.type=?", 3).Or("device_user_privrels.user_id=?", 339).Find(&scenes)
|
|
assert.NoError(t, err)
|
|
|
|
scenes = make([]SceneItem, 0)
|
|
err = testEngine.Join("LEFT OUTER", new(DeviceUserPrivrels), "device_user_privrels.device_id=scene_item.device_id").
|
|
Where("scene_item.type=?", 3).Or("device_user_privrels.user_id=?", 339).Find(&scenes)
|
|
assert.NoError(t, err)
|
|
|
|
scenes = make([]SceneItem, 0)
|
|
err = testEngine.Join("INNER", "order", "`scene_item`.device_id=`order`.id").Find(&scenes)
|
|
assert.NoError(t, err)
|
|
}
|
|
|
|
func TestJoinFindLimit(t *testing.T) {
|
|
type JoinFindLimit1 struct {
|
|
Id int64
|
|
Name string
|
|
}
|
|
|
|
type JoinFindLimit2 struct {
|
|
Id int64
|
|
Eid int64 `xorm:"index"`
|
|
Name string
|
|
}
|
|
|
|
assert.NoError(t, prepareEngine())
|
|
assertSync(t, new(JoinFindLimit1), new(JoinFindLimit2))
|
|
|
|
var finds []JoinFindLimit1
|
|
err := testEngine.Join("INNER", new(JoinFindLimit2), "join_find_limit2.eid=join_find_limit1.id").
|
|
Limit(10, 10).Find(&finds)
|
|
assert.NoError(t, err)
|
|
}
|