Lunny Xiao
bd20c37bfb
* add SetSchema for engine * fix user * fix postgres with schema * fix test * fix test * fix test * fix tablename * refactor tableName * fix schema support * improve the interface of EngineInterface
587 lines
13 KiB
Go
587 lines
13 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"
|
|
|
|
"github.com/go-xorm/core"
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
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 {
|
|
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 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(core.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(core.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)
|
|
}
|