beego框架orm操做exper的操做

1、基本使用

• 一、初始化一个项目

• 二、安装依赖包

  // orm框架
  go get github.com/astaxie/beego/orm 
  // 使用什么数据库
  go get github.com/go-sql-driver/mysql

• 三、在main.go中使用init函数进行链接

  import (
  	...
  	_ "github.com/go-sql-driver/mysql" // 必须加上
  )
  
  func init()  {
  	orm.RegisterDriver("mysql", orm.DRMySQL)
    // default必需要有,表示链接的数据库别名,多是多个
  	orm.RegisterDataBase("default", "mysql", "用户名:密码@tcp(localhost:3306)/数据库名?charset=utf8mb4&parseTime=True&loc=Local")
  }

• 四、建立一个models的文件夹专门存放数据模型(与数据库表一一对应的)

  package models
  
  import "github.com/astaxie/beego/orm"
  
  type User struct {
  	Id int
  	Name string
  	Age int
  	Address string
  }
  
  //自定义表名,能够不写的会默认如下划线来分割驼峰命名的
  func (self *User) TableName () string  {
  	return "user"
  }
  
  func init() {
    // 使用exper表达式必需要注入模型,所以咱们强制本身无论什么都要在模型中使用init函数来注入模型
  	orm.RegisterModel(new(User))
  }

2、使用exper查询建立句柄的两种方式

• 一、直接使用表名的方式来建立句柄

  type UserExper1Controller struct {
  	beego.Controller
  }
  
  func (ctx *UserExper1Controller) Get() {
  	o := orm.NewOrm()
    // 使用表名的方式来建立一个exper查询句柄
  	qs :=o.QueryTable("user")
    // 查询后的数据须要放到user这个结构体中
  	user := models.User{}
    // 使用expre表达式查询【name__exact】表示name彻底匹配,One表示查询一条数据
  	qs.Filter("name__exact", "孙悟空").One(&user)
  	fmt.Println(user)
  	ctx.TplName="orm.html"
  }

• 二、使用数据模型的方式【建议使用数据模型】

  type UserExper1Controller struct {
  	beego.Controller
  }
  
  func (ctx *UserExper1Controller) Get() {
  	o := orm.NewOrm()
    // 使用数据模型
  	userModel := new(models.User)
  	qs :=o.QueryTable(userModel)
  	user := models.User{}
  	qs.Filter("name__exact", "孙悟空").One(&user)
  	fmt.Println(user)
  	ctx.TplName="orm.html"
  }

3、常见的exper表达式的操做符号

No	名称	举例	对比原生sql
1	exact/iexact	name__exact(name字段等于后面的)	where name = "xx"
2	contains/icontains	name__contains(包含)	where name like "%xx%"
3	gt/gte	age__gt(大于/大于等于)	where age > 19
4	lt/lte	age__lt(小于/小于等于)	where age < 19
5	startswith/istartswith	name__startswith(以什么开头)	where name like "x%"
6	endswith/iendswith	name__endswith(以什么结尾)	where name like "%x"
7	in	age__in(在什么范围里面)	where age in (1,2,3)
8	isnull	qs.Filter("gender__isnull",true).One(&user)

4、在beego中开启打印orm对应的sql语句的方法

• 一、全局开启，在main.go中(推荐使用)

  func main() {
  	orm.Debug = true
  	beego.Run()
  }

• 二、在对应的控制器中局部开发

  func (ctx *UserExper1Controller) Get() {
  	// 开始打印对应的sql
  	orm.Debug = true
  	...
  	ctx.TplName="orm.html"
  }

5、Filter的使用

• 一、查询想要的字段

  o := orm.NewOrm()
  // 使用数据模型
  userModel := new(models.User)
  qs := o.QueryTable(userModel)
  user := models.User{}
  // 须要查询出什么字段就在后面加
  qs.Filter("name__exact", "孙悟空").One(&user, "Name","Age")
  fmt.Println(user)
  ctx.Data["json"] = user
  ctx.ServeJSON()

• 二、多条件查询

  o := orm.NewOrm()
  userModel := new(models.User)
  qs := o.QueryTable(userModel)
  user := models.User{}
  // 多条件的时候就多使用Filter
  qs.Filter("name__exact","孙悟空").Filter("age__gte", 2000).One(&user, "Name","Age")
  // 匹配的sql
  // select name, age from user where name = "孙悟空" and age >= 2000;
  ctx.Data["json"] = user
  ctx.ServeJSON()

• 三、使用all查询多条语句

  o := orm.NewOrm()
  userModel := new(models.User)
  qs := o.QueryTable(userModel)
  //返回多条语句要用切片
  user := []models.User{}
  //不加条件的查询
  qs.All(&user, "Name", "Age", "Address")
  // select name, age, address from user;
  ctx.Data["json"] = user
  ctx.ServeJSON()

• 四、使用Exclude排除字段返回

  o := orm.NewOrm()
  userModel := new(models.User)
  qs := o.QueryTable(userModel)
  user := []models.User{}
  qs.Exclude("name__exact", "孙悟空").All(&user)
  // select * from user where not name = "孙悟空";
  ctx.Data["json"] = user
  ctx.ServeJSON()

• 五、分页查询语句

  o := orm.NewOrm()
  userModel := new(models.User)
  qs := o.QueryTable(userModel)
  user := []models.User{}
  //查询3条,从第一条开始查询
  qs.Limit(3).Offset(1).All(&user)
  // select * from user limit 1,3;
  ctx.Data["json"] = user
  ctx.ServeJSON()

• 六、根据字段排序

  o :=orm.NewOrm()
  userModel := new(models.User)
  qs := o.QueryTable(userModel)
  user := []models.User{}
  // 默认是升序,若是要降序的话就直接OrderBy("-age")
  qs.OrderBy("age").All(&user)
  ctx.Data["json"] = user
  ctx.ServeJSON()

• 七、判断是否存在

  exist := qs.Filter("name__exact","猪八戒").Exist()
  // 返回true或者false
  fmt.Println(exist)

• 八、使用Update更新操做

  o := orm.NewOrm()
  userModel := new(models.User)
  num, err := o.QueryTable(userModel).Filter("name__exact", "孙悟空").Update(orm.Params{
    "Age": 2000,
  })
  fmt.Println(num) // 受影响的行数
  fmt.Println(err) // 错误
  ctx.Data["json"] = map[string]string{
    "code":    "0",
    "message": "成功",
  }
  ctx.ServeJSON()

• 九、删除语句

  o := orm.NewOrm()
  userModel := new(models.User)
  num, err := o.QueryTable(userModel).Filter("name__exact","孙悟空").Delete()
  fmt.Println(num)
  fmt.Println(err)

• 十、PrepareInsert同时插入多条语句

  注意最后要关闭

  o := orm.NewOrm()
  users := []models.User{
    {Name: "孙悟空",Age: 1000,Address: "花果山"},
    {Name: "猪八戒",Age: 800,Address: "高老庄"},
    {Name: "沙增",Age: 500,Address: "流沙河"},
  }
  inserter, _ := o.QueryTable(new(models.User)).PrepareInsert()
  // 循环切片的数据
  for _, val := range users {
    id, err := inserter.Insert(&val)
    fmt.Println(id)
    fmt.Println(err)
  }
  //注意要记得关闭
  inserter.Close()
  
  // 可是插入多条数据建议使用InsertMulti
  o := orm.NewOrm()
  users := []models.User{
    {Name: "郭靖", Age: 30, Address: "襄阳"},
    {Name: "黄蓉", Age: 23, Address: "襄阳"},
  }
  num, err := o.InsertMulti(100, &users)
  fmt.Println(num, err)

• 十一、values的使用(真正的json返回想要的字段)

  var maps []orm.Params
  o := orm.NewOrm()
  num, err := o.QueryTable(new(models.User)).Filter("age__gte", 100).Values(&maps, "Name", "Id", "Address", "Age")
  fmt.Println(num, err)
  ctx.Data["json"] = maps
  ctx.ServeJSON()

• 十二、ValuesList默认返回是1000条数据

  var lists []orm.ParamsList
  o := orm.NewOrm()
  // 返回数组,里面嵌套根据字段嵌套
  num, err := o.QueryTable(new(models.User)).ValuesList(&lists, "Name")
  fmt.Println(num, err)
  ctx.Data["json"] = lists
  ctx.ServeJSON()
  
  // 返回的数据结构
  [
    [
      "唐三藏"
    ],
    [
      "孙悟空"
    ]
  ]

• 1三、ValuesFlat扁平化返回一个数组

  var lists orm.ParamsList
  o := orm.NewOrm()
  // 返回数组,里面嵌套根据字段嵌套
  num, err := o.QueryTable(new(models.User)).ValuesFlat(&lists, "Name")
  fmt.Println(num, err)
  ctx.Data["json"] = lists
  ctx.ServeJSON()
  
  // 返回数据
  [
    "唐三藏",
    "孙悟空",
  ]

• 1四、Update根据现有字段添加值

  o := orm.NewOrm()
  num, err := o.QueryTable(new(models.User)).Filter("name__exact", "孙悟空").Update(orm.Params{
    "Age": orm.ColValue(orm.ColAdd, 100),
  })
  // 对应的原生sql
  // update user set age=age+100 where name = "孙悟空";
  fmt.Println(num, err)

  对应别的方法有

  • ColAdd添加

  • ColMinus减小

  • ColMultiply乘法

  • ColExcept除法