main.go

package main

import (
	"fmt"

	"../dbschema"

	"github.com/admpub/null"
	_ "github.com/go-sql-driver/mysql"
	"github.com/webx-top/db"
	"github.com/webx-top/db/_tools/test/settings"
	"github.com/webx-top/db/lib/sqlbuilder"
	"github.com/webx-top/echo"
)

type GroupAndVHosts struct {
	*dbschema.NgingVhostGroup
	Vhosts []*dbschema.NgingVhost `db:"-,relation=group_id:id"` //relation=<vhost的字段>:<vhost_group的字段>
}

type GroupAndVHost struct {
	*dbschema.NgingVhostGroup
	Vhost *dbschema.NgingVhost `db:"-,relation=group_id:id"` //relation=<vhost的字段>:<vhost_group的字段>
}

type JoinData struct {
	Group *dbschema.NgingVhostGroup
	Vhost *dbschema.NgingVhost
}

type FilmWithCategory struct {
	*dbschema.OfficialFilmItem
	TypeList []*dbschema.OfficialFilmType `db:",relation=id:types|split"`
}

func testMultiOne2many2(c db.Database) {
	rows2 := []*FilmWithCategory{}
	err := c.Collection(`official_film_item`).Find().All(&rows2)
	if err != nil {
		panic(err)
	}
	echo.Dump(rows2)

}

func testJoin(c db.Database) {
	jrow := &JoinData{}
	c.Collection(`nging_vhost_group`).Find().Callback(func(sel sqlbuilder.Selector) sqlbuilder.Selector {
		return sel.From(`nging_vhost_group g`).Join(`nging_vhost v`).On(`v.group_id=g.id`)
	}).One(jrow)
	echo.Dump(jrow)
}

func testOne2one(c db.Database) {
	row := &GroupAndVHost{}
	err := c.(sqlbuilder.Database).SelectFrom(`nging_vhost_group`).Relation(`Vhost`, func(sel sqlbuilder.Selector) sqlbuilder.Selector {
		return sel.OrderBy(`-id`)
	}).One(row)
	if err != nil {
		panic(err)
	}
	echo.Dump(row)
}

func testMultiOne2one(c db.Database) {
	rows := []*GroupAndVHost{}
	//Relation 是可选的，用于增加额外条件
	err := c.(sqlbuilder.Database).SelectFrom(`nging_vhost_group`).Relation(`Vhost`, func(sel sqlbuilder.Selector) sqlbuilder.Selector {
		return sel.OrderBy(`-id`)
	}).All(&rows)
	if err != nil {
		panic(err)
	}
	echo.Dump(rows)
}

func testMultiOne2many(c db.Database) {
	rows2 := []*GroupAndVHosts{}
	err := c.Collection(`nging_vhost_group`).Find().Relation(`Vhosts`, func(sel sqlbuilder.Selector) sqlbuilder.Selector {
		return sel.OrderBy(`id`) //.ForceIndex(`group_id`)
	}).All(&rows2)
	if err != nil {
		panic(err)
	}
	echo.Dump(rows2)

}

func testMap(c db.Database) {
	row2 := null.StringMap{}
	err := c.(sqlbuilder.Database).SelectFrom(`nging_vhost_group`).One(&row2)
	if err != nil {
		panic(err)
	}
	echo.Dump(row2)

	rows3 := null.StringMapSlice{}
	err = c.(sqlbuilder.Database).SelectFrom(`nging_vhost_group`).Limit(2).All(&rows3)
	if err != nil {
		panic(err)
	}
	echo.Dump(rows3)
}

func main() {
	c := settings.Connect()

	testMultiOne2many2(c)
	//return
	testJoin(c)
	//return
	testOne2one(c)

	fmt.Println(`===========================================`)
	testMultiOne2one(c)

	fmt.Println(`===========================================`)
	testMultiOne2many(c)
	//验证map方式是否正常==============================
	testMap(c)
}