package main
import (
"fmt"
"github.com/astaxie/beego/orm"
_ "github.com/go-sql-driver/mysql"
)
type User struct {
Id int `orm:"auto"`
Name string
Profile_id int
}
func init() {
orm.RegisterModel(new(User))
orm.RegisterDataBase("default", "mysql", "ta3:ta3@/ta3?charset=utf8")
orm.RunSyncdb("default", false, true)
}
func main() {
var (
sSql string
err error
)
var users []User
orm.Debug = true //打开查询日志
o := orm.NewOrm()
o.Using("default") // 默认使用 default，你可以指定为其他数据库
//查询 以于大数据量不知道性能怎样？
sSql = "SELECT Id, Name FROM User "
num, err := o.Raw(sSql).QueryRows(&users)
if err == nil && num > 0 {
for i, _ := range users {
fmt.Println(users[i].Name)
}
}
//执行更新
sSql = "update User set name='aaa' where Id= 1"
_, err = o.Raw(sSql).Exec()
if err != nil {
fmt.Println("更新出错")
}
//事务
err = o.Begin()
sSql = " insert into User (Id, Name, Profile_id) values(3, 'bbbb',9) "
_, err = o.Raw(sSql).Exec()
if err != nil {
o.Rollback()
} else {
o.Commit()
}
//以下这种用法可以适应全部的SQL写法
sSql = fmt.Sprintf("insert into User (Id, Name, Profile_id) values(4, 'bbbb',%d)", 10)
_, err = o.Raw(sSql).Exec()
if err != nil {
fmt.Println("插入出错")
}
}