package mainimport (
_ "crud_beego/routers" //自动注册路由
"fmt"
"github.com/astaxie/beego"
"github.com/astaxie/beego/orm"
_ "github.com/go-sql-driver/mysql")const (
DRIVER_NAME = "mysql"
DATA_SOURCE = "root:123456@tcp(127.0.0.1:3306)/test?charset=utf8&loc=Asia%2FShanghai"
MAX_IDLE_CONN = 5
MAX_OPEN_CONN = 30)
type User struct {
Id int
Name string
Email string
Age int
isActive bool
}
func (u *User) TableName() string { return "t_user"}
func registerDB() {
orm.Debug = true
orm.RegisterDataBase("default", DRIVER_NAME, DATA_SOURCE, MAX_IDLE_CONN, MAX_OPEN_CONN)
orm.RegisterModel(new(User))
}
func (this User) ToString() string { return fmt.Sprintf("Id:%d\tName:%s\tEmail:%s\tAge:%d\tisActive:%v", this.Id, this.Name, this.Email, this.Age, this.isActive)
}
func createUsers() {
users := []User{
User{Name: "adadmin1", Email: "14199@111.com", Age: 12},
User{Name: "adadmin1", Email: "14199@111.com", Age: 12},
User{Name: "adadmin1", Email: "14199@111.com", Age: 12},
User{Name: "adadmin1", Email: "14199@111.com", Age: 12},
User{Name: "adadmin1", Email: "14199@111.com", Age: 12},
User{Name: "adadmin1", Email: "14199@111.com", Age: 12},
User{Name: "adadmin1", Email: "14199@111.com", Age: 12},
}
o := orm.NewOrm() if successNums, err := o.InsertMulti(len(users), users); err != nil {
fmt.Println("insert fail.....")
} else {
fmt.Println("success inserted %d datas", successNums)
}
}//find all usersfunc listUsers() {
var users []User
orm.NewOrm().QueryTable("t_user").All(&users) for _, user := range users {
fmt.Println(user.ToString())
}
}//get user countfunc countUser() {
cnt, _ := orm.NewOrm().QueryTable("t_user").Count()
fmt.Println("All user count:", cnt)
}//get the only one userfunc getUser() {
var user User
err := orm.NewOrm().QueryTable("t_user").Filter("Id", 5).One(&user) if err == nil {
fmt.Println(user.ToString())
}
}//get the only one userfunc getUsers() {
var users []User
_, err := orm.NewOrm().QueryTable("t_user").Filter("name__contains", "awd").All(&users) if err == nil { for _, user := range users {
fmt.Println(user.ToString())
}
}
}//get limit userfunc limitUser() {
var users []User
_, err := orm.NewOrm().QueryTable("t_user").Limit(6).OrderBy("-Name").All(&users) if err == nil { for _, user := range users {
fmt.Println(user.ToString())
}
}
}//get user limit,offsetfunc limitoffsetUser() {
var users []User
_, err := orm.NewOrm().QueryTable("t_user").Limit(1, 4).OrderBy("Id").All(&users) if err == nil { for _, user := range users {
fmt.Println(user.ToString())
}
}
}//del userfunc delUser() {
num, err := orm.NewOrm().QueryTable("t_user").Filter("Id", "5").Delete()
fmt.Printf("Affected Num: %s, %s", num, err)
}//update userfunc updateUser() {
num, err := orm.NewOrm().QueryTable("t_user").Filter("name__contains", "awd").Update(orm.Params{ "name": "#########",
})
fmt.Printf("Affected Num: %s, %s", num, err)
}
func main() {
registerDB()
createUsers()
listUsers()
countUser()
getUser()
getUsers()
limitoffsetUser()
delUser()
updateUser()
beego.Run()
}
神回复
发表评论:
◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。